cluster-autoscaler/cloudprovider/aws/aws-sdk-go/service/entityresolution/api.go (3,756 lines of code) (raw):

// Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT. package entityresolution import ( "fmt" "time" "k8s.io/autoscaler/cluster-autoscaler/cloudprovider/aws/aws-sdk-go/aws" "k8s.io/autoscaler/cluster-autoscaler/cloudprovider/aws/aws-sdk-go/aws/awsutil" "k8s.io/autoscaler/cluster-autoscaler/cloudprovider/aws/aws-sdk-go/aws/request" "k8s.io/autoscaler/cluster-autoscaler/cloudprovider/aws/aws-sdk-go/private/protocol" "k8s.io/autoscaler/cluster-autoscaler/cloudprovider/aws/aws-sdk-go/private/protocol/restjson" ) const opCreateIdMappingWorkflow = "CreateIdMappingWorkflow" // CreateIdMappingWorkflowRequest generates a "aws/request.Request" representing the // client's request for the CreateIdMappingWorkflow operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See CreateIdMappingWorkflow for more information on using the CreateIdMappingWorkflow // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the CreateIdMappingWorkflowRequest method. // req, resp := client.CreateIdMappingWorkflowRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/CreateIdMappingWorkflow func (c *EntityResolution) CreateIdMappingWorkflowRequest(input *CreateIdMappingWorkflowInput) (req *request.Request, output *CreateIdMappingWorkflowOutput) { op := &request.Operation{ Name: opCreateIdMappingWorkflow, HTTPMethod: "POST", HTTPPath: "/idmappingworkflows", } if input == nil { input = &CreateIdMappingWorkflowInput{} } output = &CreateIdMappingWorkflowOutput{} req = c.newRequest(op, input, output) return } // CreateIdMappingWorkflow API operation for AWS EntityResolution. // // Creates an IdMappingWorkflow object which stores the configuration of the // data processing job to be run. Each IdMappingWorkflow must have a unique // workflow name. To modify an existing workflow, use the UpdateIdMappingWorkflow // API. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation CreateIdMappingWorkflow for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ExceedsLimitException // The request was rejected because it attempted to create resources beyond // the current Entity Resolution account limits. The error message describes // the limit exceeded. HTTP Status Code: 402 // // - ConflictException // The request could not be processed because of conflict in the current state // of the resource. Example: Workflow already exists, Schema already exists, // Workflow is currently running, etc. HTTP Status Code: 400 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/CreateIdMappingWorkflow func (c *EntityResolution) CreateIdMappingWorkflow(input *CreateIdMappingWorkflowInput) (*CreateIdMappingWorkflowOutput, error) { req, out := c.CreateIdMappingWorkflowRequest(input) return out, req.Send() } // CreateIdMappingWorkflowWithContext is the same as CreateIdMappingWorkflow with the addition of // the ability to pass a context and additional request options. // // See CreateIdMappingWorkflow for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) CreateIdMappingWorkflowWithContext(ctx aws.Context, input *CreateIdMappingWorkflowInput, opts ...request.Option) (*CreateIdMappingWorkflowOutput, error) { req, out := c.CreateIdMappingWorkflowRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opCreateMatchingWorkflow = "CreateMatchingWorkflow" // CreateMatchingWorkflowRequest generates a "aws/request.Request" representing the // client's request for the CreateMatchingWorkflow operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See CreateMatchingWorkflow for more information on using the CreateMatchingWorkflow // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the CreateMatchingWorkflowRequest method. // req, resp := client.CreateMatchingWorkflowRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/CreateMatchingWorkflow func (c *EntityResolution) CreateMatchingWorkflowRequest(input *CreateMatchingWorkflowInput) (req *request.Request, output *CreateMatchingWorkflowOutput) { op := &request.Operation{ Name: opCreateMatchingWorkflow, HTTPMethod: "POST", HTTPPath: "/matchingworkflows", } if input == nil { input = &CreateMatchingWorkflowInput{} } output = &CreateMatchingWorkflowOutput{} req = c.newRequest(op, input, output) return } // CreateMatchingWorkflow API operation for AWS EntityResolution. // // Creates a MatchingWorkflow object which stores the configuration of the data // processing job to be run. It is important to note that there should not be // a pre-existing MatchingWorkflow with the same name. To modify an existing // workflow, utilize the UpdateMatchingWorkflow API. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation CreateMatchingWorkflow for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ExceedsLimitException // The request was rejected because it attempted to create resources beyond // the current Entity Resolution account limits. The error message describes // the limit exceeded. HTTP Status Code: 402 // // - ConflictException // The request could not be processed because of conflict in the current state // of the resource. Example: Workflow already exists, Schema already exists, // Workflow is currently running, etc. HTTP Status Code: 400 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/CreateMatchingWorkflow func (c *EntityResolution) CreateMatchingWorkflow(input *CreateMatchingWorkflowInput) (*CreateMatchingWorkflowOutput, error) { req, out := c.CreateMatchingWorkflowRequest(input) return out, req.Send() } // CreateMatchingWorkflowWithContext is the same as CreateMatchingWorkflow with the addition of // the ability to pass a context and additional request options. // // See CreateMatchingWorkflow for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) CreateMatchingWorkflowWithContext(ctx aws.Context, input *CreateMatchingWorkflowInput, opts ...request.Option) (*CreateMatchingWorkflowOutput, error) { req, out := c.CreateMatchingWorkflowRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opCreateSchemaMapping = "CreateSchemaMapping" // CreateSchemaMappingRequest generates a "aws/request.Request" representing the // client's request for the CreateSchemaMapping operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See CreateSchemaMapping for more information on using the CreateSchemaMapping // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the CreateSchemaMappingRequest method. // req, resp := client.CreateSchemaMappingRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/CreateSchemaMapping func (c *EntityResolution) CreateSchemaMappingRequest(input *CreateSchemaMappingInput) (req *request.Request, output *CreateSchemaMappingOutput) { op := &request.Operation{ Name: opCreateSchemaMapping, HTTPMethod: "POST", HTTPPath: "/schemas", } if input == nil { input = &CreateSchemaMappingInput{} } output = &CreateSchemaMappingOutput{} req = c.newRequest(op, input, output) return } // CreateSchemaMapping API operation for AWS EntityResolution. // // Creates a schema mapping, which defines the schema of the input customer // records table. The SchemaMapping also provides Entity Resolution with some // metadata about the table, such as the attribute types of the columns and // which columns to match on. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation CreateSchemaMapping for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ExceedsLimitException // The request was rejected because it attempted to create resources beyond // the current Entity Resolution account limits. The error message describes // the limit exceeded. HTTP Status Code: 402 // // - ConflictException // The request could not be processed because of conflict in the current state // of the resource. Example: Workflow already exists, Schema already exists, // Workflow is currently running, etc. HTTP Status Code: 400 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/CreateSchemaMapping func (c *EntityResolution) CreateSchemaMapping(input *CreateSchemaMappingInput) (*CreateSchemaMappingOutput, error) { req, out := c.CreateSchemaMappingRequest(input) return out, req.Send() } // CreateSchemaMappingWithContext is the same as CreateSchemaMapping with the addition of // the ability to pass a context and additional request options. // // See CreateSchemaMapping for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) CreateSchemaMappingWithContext(ctx aws.Context, input *CreateSchemaMappingInput, opts ...request.Option) (*CreateSchemaMappingOutput, error) { req, out := c.CreateSchemaMappingRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opDeleteIdMappingWorkflow = "DeleteIdMappingWorkflow" // DeleteIdMappingWorkflowRequest generates a "aws/request.Request" representing the // client's request for the DeleteIdMappingWorkflow operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See DeleteIdMappingWorkflow for more information on using the DeleteIdMappingWorkflow // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the DeleteIdMappingWorkflowRequest method. // req, resp := client.DeleteIdMappingWorkflowRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/DeleteIdMappingWorkflow func (c *EntityResolution) DeleteIdMappingWorkflowRequest(input *DeleteIdMappingWorkflowInput) (req *request.Request, output *DeleteIdMappingWorkflowOutput) { op := &request.Operation{ Name: opDeleteIdMappingWorkflow, HTTPMethod: "DELETE", HTTPPath: "/idmappingworkflows/{workflowName}", } if input == nil { input = &DeleteIdMappingWorkflowInput{} } output = &DeleteIdMappingWorkflowOutput{} req = c.newRequest(op, input, output) return } // DeleteIdMappingWorkflow API operation for AWS EntityResolution. // // Deletes the IdMappingWorkflow with a given name. This operation will succeed // even if a workflow with the given name does not exist. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation DeleteIdMappingWorkflow for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/DeleteIdMappingWorkflow func (c *EntityResolution) DeleteIdMappingWorkflow(input *DeleteIdMappingWorkflowInput) (*DeleteIdMappingWorkflowOutput, error) { req, out := c.DeleteIdMappingWorkflowRequest(input) return out, req.Send() } // DeleteIdMappingWorkflowWithContext is the same as DeleteIdMappingWorkflow with the addition of // the ability to pass a context and additional request options. // // See DeleteIdMappingWorkflow for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) DeleteIdMappingWorkflowWithContext(ctx aws.Context, input *DeleteIdMappingWorkflowInput, opts ...request.Option) (*DeleteIdMappingWorkflowOutput, error) { req, out := c.DeleteIdMappingWorkflowRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opDeleteMatchingWorkflow = "DeleteMatchingWorkflow" // DeleteMatchingWorkflowRequest generates a "aws/request.Request" representing the // client's request for the DeleteMatchingWorkflow operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See DeleteMatchingWorkflow for more information on using the DeleteMatchingWorkflow // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the DeleteMatchingWorkflowRequest method. // req, resp := client.DeleteMatchingWorkflowRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/DeleteMatchingWorkflow func (c *EntityResolution) DeleteMatchingWorkflowRequest(input *DeleteMatchingWorkflowInput) (req *request.Request, output *DeleteMatchingWorkflowOutput) { op := &request.Operation{ Name: opDeleteMatchingWorkflow, HTTPMethod: "DELETE", HTTPPath: "/matchingworkflows/{workflowName}", } if input == nil { input = &DeleteMatchingWorkflowInput{} } output = &DeleteMatchingWorkflowOutput{} req = c.newRequest(op, input, output) return } // DeleteMatchingWorkflow API operation for AWS EntityResolution. // // Deletes the MatchingWorkflow with a given name. This operation will succeed // even if a workflow with the given name does not exist. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation DeleteMatchingWorkflow for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/DeleteMatchingWorkflow func (c *EntityResolution) DeleteMatchingWorkflow(input *DeleteMatchingWorkflowInput) (*DeleteMatchingWorkflowOutput, error) { req, out := c.DeleteMatchingWorkflowRequest(input) return out, req.Send() } // DeleteMatchingWorkflowWithContext is the same as DeleteMatchingWorkflow with the addition of // the ability to pass a context and additional request options. // // See DeleteMatchingWorkflow for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) DeleteMatchingWorkflowWithContext(ctx aws.Context, input *DeleteMatchingWorkflowInput, opts ...request.Option) (*DeleteMatchingWorkflowOutput, error) { req, out := c.DeleteMatchingWorkflowRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opDeleteSchemaMapping = "DeleteSchemaMapping" // DeleteSchemaMappingRequest generates a "aws/request.Request" representing the // client's request for the DeleteSchemaMapping operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See DeleteSchemaMapping for more information on using the DeleteSchemaMapping // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the DeleteSchemaMappingRequest method. // req, resp := client.DeleteSchemaMappingRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/DeleteSchemaMapping func (c *EntityResolution) DeleteSchemaMappingRequest(input *DeleteSchemaMappingInput) (req *request.Request, output *DeleteSchemaMappingOutput) { op := &request.Operation{ Name: opDeleteSchemaMapping, HTTPMethod: "DELETE", HTTPPath: "/schemas/{schemaName}", } if input == nil { input = &DeleteSchemaMappingInput{} } output = &DeleteSchemaMappingOutput{} req = c.newRequest(op, input, output) return } // DeleteSchemaMapping API operation for AWS EntityResolution. // // Deletes the SchemaMapping with a given name. This operation will succeed // even if a schema with the given name does not exist. This operation will // fail if there is a MatchingWorkflow object that references the SchemaMapping // in the workflow's InputSourceConfig. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation DeleteSchemaMapping for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ConflictException // The request could not be processed because of conflict in the current state // of the resource. Example: Workflow already exists, Schema already exists, // Workflow is currently running, etc. HTTP Status Code: 400 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/DeleteSchemaMapping func (c *EntityResolution) DeleteSchemaMapping(input *DeleteSchemaMappingInput) (*DeleteSchemaMappingOutput, error) { req, out := c.DeleteSchemaMappingRequest(input) return out, req.Send() } // DeleteSchemaMappingWithContext is the same as DeleteSchemaMapping with the addition of // the ability to pass a context and additional request options. // // See DeleteSchemaMapping for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) DeleteSchemaMappingWithContext(ctx aws.Context, input *DeleteSchemaMappingInput, opts ...request.Option) (*DeleteSchemaMappingOutput, error) { req, out := c.DeleteSchemaMappingRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opGetIdMappingJob = "GetIdMappingJob" // GetIdMappingJobRequest generates a "aws/request.Request" representing the // client's request for the GetIdMappingJob operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See GetIdMappingJob for more information on using the GetIdMappingJob // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the GetIdMappingJobRequest method. // req, resp := client.GetIdMappingJobRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/GetIdMappingJob func (c *EntityResolution) GetIdMappingJobRequest(input *GetIdMappingJobInput) (req *request.Request, output *GetIdMappingJobOutput) { op := &request.Operation{ Name: opGetIdMappingJob, HTTPMethod: "GET", HTTPPath: "/idmappingworkflows/{workflowName}/jobs/{jobId}", } if input == nil { input = &GetIdMappingJobInput{} } output = &GetIdMappingJobOutput{} req = c.newRequest(op, input, output) return } // GetIdMappingJob API operation for AWS EntityResolution. // // Gets the status, metrics, and errors (if there are any) that are associated // with a job. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation GetIdMappingJob for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - ResourceNotFoundException // The resource could not be found. HTTP Status Code: 404 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/GetIdMappingJob func (c *EntityResolution) GetIdMappingJob(input *GetIdMappingJobInput) (*GetIdMappingJobOutput, error) { req, out := c.GetIdMappingJobRequest(input) return out, req.Send() } // GetIdMappingJobWithContext is the same as GetIdMappingJob with the addition of // the ability to pass a context and additional request options. // // See GetIdMappingJob for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) GetIdMappingJobWithContext(ctx aws.Context, input *GetIdMappingJobInput, opts ...request.Option) (*GetIdMappingJobOutput, error) { req, out := c.GetIdMappingJobRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opGetIdMappingWorkflow = "GetIdMappingWorkflow" // GetIdMappingWorkflowRequest generates a "aws/request.Request" representing the // client's request for the GetIdMappingWorkflow operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See GetIdMappingWorkflow for more information on using the GetIdMappingWorkflow // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the GetIdMappingWorkflowRequest method. // req, resp := client.GetIdMappingWorkflowRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/GetIdMappingWorkflow func (c *EntityResolution) GetIdMappingWorkflowRequest(input *GetIdMappingWorkflowInput) (req *request.Request, output *GetIdMappingWorkflowOutput) { op := &request.Operation{ Name: opGetIdMappingWorkflow, HTTPMethod: "GET", HTTPPath: "/idmappingworkflows/{workflowName}", } if input == nil { input = &GetIdMappingWorkflowInput{} } output = &GetIdMappingWorkflowOutput{} req = c.newRequest(op, input, output) return } // GetIdMappingWorkflow API operation for AWS EntityResolution. // // Returns the IdMappingWorkflow with a given name, if it exists. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation GetIdMappingWorkflow for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - ResourceNotFoundException // The resource could not be found. HTTP Status Code: 404 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/GetIdMappingWorkflow func (c *EntityResolution) GetIdMappingWorkflow(input *GetIdMappingWorkflowInput) (*GetIdMappingWorkflowOutput, error) { req, out := c.GetIdMappingWorkflowRequest(input) return out, req.Send() } // GetIdMappingWorkflowWithContext is the same as GetIdMappingWorkflow with the addition of // the ability to pass a context and additional request options. // // See GetIdMappingWorkflow for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) GetIdMappingWorkflowWithContext(ctx aws.Context, input *GetIdMappingWorkflowInput, opts ...request.Option) (*GetIdMappingWorkflowOutput, error) { req, out := c.GetIdMappingWorkflowRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opGetMatchId = "GetMatchId" // GetMatchIdRequest generates a "aws/request.Request" representing the // client's request for the GetMatchId operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See GetMatchId for more information on using the GetMatchId // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the GetMatchIdRequest method. // req, resp := client.GetMatchIdRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/GetMatchId func (c *EntityResolution) GetMatchIdRequest(input *GetMatchIdInput) (req *request.Request, output *GetMatchIdOutput) { op := &request.Operation{ Name: opGetMatchId, HTTPMethod: "POST", HTTPPath: "/matchingworkflows/{workflowName}/matches", } if input == nil { input = &GetMatchIdInput{} } output = &GetMatchIdOutput{} req = c.newRequest(op, input, output) return } // GetMatchId API operation for AWS EntityResolution. // // Returns the corresponding Match ID of a customer record if the record has // been processed. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation GetMatchId for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - ResourceNotFoundException // The resource could not be found. HTTP Status Code: 404 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/GetMatchId func (c *EntityResolution) GetMatchId(input *GetMatchIdInput) (*GetMatchIdOutput, error) { req, out := c.GetMatchIdRequest(input) return out, req.Send() } // GetMatchIdWithContext is the same as GetMatchId with the addition of // the ability to pass a context and additional request options. // // See GetMatchId for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) GetMatchIdWithContext(ctx aws.Context, input *GetMatchIdInput, opts ...request.Option) (*GetMatchIdOutput, error) { req, out := c.GetMatchIdRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opGetMatchingJob = "GetMatchingJob" // GetMatchingJobRequest generates a "aws/request.Request" representing the // client's request for the GetMatchingJob operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See GetMatchingJob for more information on using the GetMatchingJob // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the GetMatchingJobRequest method. // req, resp := client.GetMatchingJobRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/GetMatchingJob func (c *EntityResolution) GetMatchingJobRequest(input *GetMatchingJobInput) (req *request.Request, output *GetMatchingJobOutput) { op := &request.Operation{ Name: opGetMatchingJob, HTTPMethod: "GET", HTTPPath: "/matchingworkflows/{workflowName}/jobs/{jobId}", } if input == nil { input = &GetMatchingJobInput{} } output = &GetMatchingJobOutput{} req = c.newRequest(op, input, output) return } // GetMatchingJob API operation for AWS EntityResolution. // // Gets the status, metrics, and errors (if there are any) that are associated // with a job. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation GetMatchingJob for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - ResourceNotFoundException // The resource could not be found. HTTP Status Code: 404 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/GetMatchingJob func (c *EntityResolution) GetMatchingJob(input *GetMatchingJobInput) (*GetMatchingJobOutput, error) { req, out := c.GetMatchingJobRequest(input) return out, req.Send() } // GetMatchingJobWithContext is the same as GetMatchingJob with the addition of // the ability to pass a context and additional request options. // // See GetMatchingJob for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) GetMatchingJobWithContext(ctx aws.Context, input *GetMatchingJobInput, opts ...request.Option) (*GetMatchingJobOutput, error) { req, out := c.GetMatchingJobRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opGetMatchingWorkflow = "GetMatchingWorkflow" // GetMatchingWorkflowRequest generates a "aws/request.Request" representing the // client's request for the GetMatchingWorkflow operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See GetMatchingWorkflow for more information on using the GetMatchingWorkflow // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the GetMatchingWorkflowRequest method. // req, resp := client.GetMatchingWorkflowRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/GetMatchingWorkflow func (c *EntityResolution) GetMatchingWorkflowRequest(input *GetMatchingWorkflowInput) (req *request.Request, output *GetMatchingWorkflowOutput) { op := &request.Operation{ Name: opGetMatchingWorkflow, HTTPMethod: "GET", HTTPPath: "/matchingworkflows/{workflowName}", } if input == nil { input = &GetMatchingWorkflowInput{} } output = &GetMatchingWorkflowOutput{} req = c.newRequest(op, input, output) return } // GetMatchingWorkflow API operation for AWS EntityResolution. // // Returns the MatchingWorkflow with a given name, if it exists. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation GetMatchingWorkflow for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - ResourceNotFoundException // The resource could not be found. HTTP Status Code: 404 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/GetMatchingWorkflow func (c *EntityResolution) GetMatchingWorkflow(input *GetMatchingWorkflowInput) (*GetMatchingWorkflowOutput, error) { req, out := c.GetMatchingWorkflowRequest(input) return out, req.Send() } // GetMatchingWorkflowWithContext is the same as GetMatchingWorkflow with the addition of // the ability to pass a context and additional request options. // // See GetMatchingWorkflow for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) GetMatchingWorkflowWithContext(ctx aws.Context, input *GetMatchingWorkflowInput, opts ...request.Option) (*GetMatchingWorkflowOutput, error) { req, out := c.GetMatchingWorkflowRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opGetSchemaMapping = "GetSchemaMapping" // GetSchemaMappingRequest generates a "aws/request.Request" representing the // client's request for the GetSchemaMapping operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See GetSchemaMapping for more information on using the GetSchemaMapping // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the GetSchemaMappingRequest method. // req, resp := client.GetSchemaMappingRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/GetSchemaMapping func (c *EntityResolution) GetSchemaMappingRequest(input *GetSchemaMappingInput) (req *request.Request, output *GetSchemaMappingOutput) { op := &request.Operation{ Name: opGetSchemaMapping, HTTPMethod: "GET", HTTPPath: "/schemas/{schemaName}", } if input == nil { input = &GetSchemaMappingInput{} } output = &GetSchemaMappingOutput{} req = c.newRequest(op, input, output) return } // GetSchemaMapping API operation for AWS EntityResolution. // // Returns the SchemaMapping of a given name. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation GetSchemaMapping for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - ResourceNotFoundException // The resource could not be found. HTTP Status Code: 404 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/GetSchemaMapping func (c *EntityResolution) GetSchemaMapping(input *GetSchemaMappingInput) (*GetSchemaMappingOutput, error) { req, out := c.GetSchemaMappingRequest(input) return out, req.Send() } // GetSchemaMappingWithContext is the same as GetSchemaMapping with the addition of // the ability to pass a context and additional request options. // // See GetSchemaMapping for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) GetSchemaMappingWithContext(ctx aws.Context, input *GetSchemaMappingInput, opts ...request.Option) (*GetSchemaMappingOutput, error) { req, out := c.GetSchemaMappingRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opListIdMappingJobs = "ListIdMappingJobs" // ListIdMappingJobsRequest generates a "aws/request.Request" representing the // client's request for the ListIdMappingJobs operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See ListIdMappingJobs for more information on using the ListIdMappingJobs // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the ListIdMappingJobsRequest method. // req, resp := client.ListIdMappingJobsRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/ListIdMappingJobs func (c *EntityResolution) ListIdMappingJobsRequest(input *ListIdMappingJobsInput) (req *request.Request, output *ListIdMappingJobsOutput) { op := &request.Operation{ Name: opListIdMappingJobs, HTTPMethod: "GET", HTTPPath: "/idmappingworkflows/{workflowName}/jobs", Paginator: &request.Paginator{ InputTokens: []string{"nextToken"}, OutputTokens: []string{"nextToken"}, LimitToken: "maxResults", TruncationToken: "", }, } if input == nil { input = &ListIdMappingJobsInput{} } output = &ListIdMappingJobsOutput{} req = c.newRequest(op, input, output) return } // ListIdMappingJobs API operation for AWS EntityResolution. // // Lists all ID mapping jobs for a given workflow. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation ListIdMappingJobs for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - ResourceNotFoundException // The resource could not be found. HTTP Status Code: 404 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/ListIdMappingJobs func (c *EntityResolution) ListIdMappingJobs(input *ListIdMappingJobsInput) (*ListIdMappingJobsOutput, error) { req, out := c.ListIdMappingJobsRequest(input) return out, req.Send() } // ListIdMappingJobsWithContext is the same as ListIdMappingJobs with the addition of // the ability to pass a context and additional request options. // // See ListIdMappingJobs for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) ListIdMappingJobsWithContext(ctx aws.Context, input *ListIdMappingJobsInput, opts ...request.Option) (*ListIdMappingJobsOutput, error) { req, out := c.ListIdMappingJobsRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } // ListIdMappingJobsPages iterates over the pages of a ListIdMappingJobs operation, // calling the "fn" function with the response data for each page. To stop // iterating, return false from the fn function. // // See ListIdMappingJobs method for more information on how to use this operation. // // Note: This operation can generate multiple requests to a service. // // // Example iterating over at most 3 pages of a ListIdMappingJobs operation. // pageNum := 0 // err := client.ListIdMappingJobsPages(params, // func(page *entityresolution.ListIdMappingJobsOutput, lastPage bool) bool { // pageNum++ // fmt.Println(page) // return pageNum <= 3 // }) func (c *EntityResolution) ListIdMappingJobsPages(input *ListIdMappingJobsInput, fn func(*ListIdMappingJobsOutput, bool) bool) error { return c.ListIdMappingJobsPagesWithContext(aws.BackgroundContext(), input, fn) } // ListIdMappingJobsPagesWithContext same as ListIdMappingJobsPages except // it takes a Context and allows setting request options on the pages. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) ListIdMappingJobsPagesWithContext(ctx aws.Context, input *ListIdMappingJobsInput, fn func(*ListIdMappingJobsOutput, bool) bool, opts ...request.Option) error { p := request.Pagination{ NewRequest: func() (*request.Request, error) { var inCpy *ListIdMappingJobsInput if input != nil { tmp := *input inCpy = &tmp } req, _ := c.ListIdMappingJobsRequest(inCpy) req.SetContext(ctx) req.ApplyOptions(opts...) return req, nil }, } for p.Next() { if !fn(p.Page().(*ListIdMappingJobsOutput), !p.HasNextPage()) { break } } return p.Err() } const opListIdMappingWorkflows = "ListIdMappingWorkflows" // ListIdMappingWorkflowsRequest generates a "aws/request.Request" representing the // client's request for the ListIdMappingWorkflows operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See ListIdMappingWorkflows for more information on using the ListIdMappingWorkflows // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the ListIdMappingWorkflowsRequest method. // req, resp := client.ListIdMappingWorkflowsRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/ListIdMappingWorkflows func (c *EntityResolution) ListIdMappingWorkflowsRequest(input *ListIdMappingWorkflowsInput) (req *request.Request, output *ListIdMappingWorkflowsOutput) { op := &request.Operation{ Name: opListIdMappingWorkflows, HTTPMethod: "GET", HTTPPath: "/idmappingworkflows", Paginator: &request.Paginator{ InputTokens: []string{"nextToken"}, OutputTokens: []string{"nextToken"}, LimitToken: "maxResults", TruncationToken: "", }, } if input == nil { input = &ListIdMappingWorkflowsInput{} } output = &ListIdMappingWorkflowsOutput{} req = c.newRequest(op, input, output) return } // ListIdMappingWorkflows API operation for AWS EntityResolution. // // Returns a list of all the IdMappingWorkflows that have been created for an // Amazon Web Services account. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation ListIdMappingWorkflows for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/ListIdMappingWorkflows func (c *EntityResolution) ListIdMappingWorkflows(input *ListIdMappingWorkflowsInput) (*ListIdMappingWorkflowsOutput, error) { req, out := c.ListIdMappingWorkflowsRequest(input) return out, req.Send() } // ListIdMappingWorkflowsWithContext is the same as ListIdMappingWorkflows with the addition of // the ability to pass a context and additional request options. // // See ListIdMappingWorkflows for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) ListIdMappingWorkflowsWithContext(ctx aws.Context, input *ListIdMappingWorkflowsInput, opts ...request.Option) (*ListIdMappingWorkflowsOutput, error) { req, out := c.ListIdMappingWorkflowsRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } // ListIdMappingWorkflowsPages iterates over the pages of a ListIdMappingWorkflows operation, // calling the "fn" function with the response data for each page. To stop // iterating, return false from the fn function. // // See ListIdMappingWorkflows method for more information on how to use this operation. // // Note: This operation can generate multiple requests to a service. // // // Example iterating over at most 3 pages of a ListIdMappingWorkflows operation. // pageNum := 0 // err := client.ListIdMappingWorkflowsPages(params, // func(page *entityresolution.ListIdMappingWorkflowsOutput, lastPage bool) bool { // pageNum++ // fmt.Println(page) // return pageNum <= 3 // }) func (c *EntityResolution) ListIdMappingWorkflowsPages(input *ListIdMappingWorkflowsInput, fn func(*ListIdMappingWorkflowsOutput, bool) bool) error { return c.ListIdMappingWorkflowsPagesWithContext(aws.BackgroundContext(), input, fn) } // ListIdMappingWorkflowsPagesWithContext same as ListIdMappingWorkflowsPages except // it takes a Context and allows setting request options on the pages. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) ListIdMappingWorkflowsPagesWithContext(ctx aws.Context, input *ListIdMappingWorkflowsInput, fn func(*ListIdMappingWorkflowsOutput, bool) bool, opts ...request.Option) error { p := request.Pagination{ NewRequest: func() (*request.Request, error) { var inCpy *ListIdMappingWorkflowsInput if input != nil { tmp := *input inCpy = &tmp } req, _ := c.ListIdMappingWorkflowsRequest(inCpy) req.SetContext(ctx) req.ApplyOptions(opts...) return req, nil }, } for p.Next() { if !fn(p.Page().(*ListIdMappingWorkflowsOutput), !p.HasNextPage()) { break } } return p.Err() } const opListMatchingJobs = "ListMatchingJobs" // ListMatchingJobsRequest generates a "aws/request.Request" representing the // client's request for the ListMatchingJobs operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See ListMatchingJobs for more information on using the ListMatchingJobs // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the ListMatchingJobsRequest method. // req, resp := client.ListMatchingJobsRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/ListMatchingJobs func (c *EntityResolution) ListMatchingJobsRequest(input *ListMatchingJobsInput) (req *request.Request, output *ListMatchingJobsOutput) { op := &request.Operation{ Name: opListMatchingJobs, HTTPMethod: "GET", HTTPPath: "/matchingworkflows/{workflowName}/jobs", Paginator: &request.Paginator{ InputTokens: []string{"nextToken"}, OutputTokens: []string{"nextToken"}, LimitToken: "maxResults", TruncationToken: "", }, } if input == nil { input = &ListMatchingJobsInput{} } output = &ListMatchingJobsOutput{} req = c.newRequest(op, input, output) return } // ListMatchingJobs API operation for AWS EntityResolution. // // Lists all jobs for a given workflow. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation ListMatchingJobs for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - ResourceNotFoundException // The resource could not be found. HTTP Status Code: 404 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/ListMatchingJobs func (c *EntityResolution) ListMatchingJobs(input *ListMatchingJobsInput) (*ListMatchingJobsOutput, error) { req, out := c.ListMatchingJobsRequest(input) return out, req.Send() } // ListMatchingJobsWithContext is the same as ListMatchingJobs with the addition of // the ability to pass a context and additional request options. // // See ListMatchingJobs for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) ListMatchingJobsWithContext(ctx aws.Context, input *ListMatchingJobsInput, opts ...request.Option) (*ListMatchingJobsOutput, error) { req, out := c.ListMatchingJobsRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } // ListMatchingJobsPages iterates over the pages of a ListMatchingJobs operation, // calling the "fn" function with the response data for each page. To stop // iterating, return false from the fn function. // // See ListMatchingJobs method for more information on how to use this operation. // // Note: This operation can generate multiple requests to a service. // // // Example iterating over at most 3 pages of a ListMatchingJobs operation. // pageNum := 0 // err := client.ListMatchingJobsPages(params, // func(page *entityresolution.ListMatchingJobsOutput, lastPage bool) bool { // pageNum++ // fmt.Println(page) // return pageNum <= 3 // }) func (c *EntityResolution) ListMatchingJobsPages(input *ListMatchingJobsInput, fn func(*ListMatchingJobsOutput, bool) bool) error { return c.ListMatchingJobsPagesWithContext(aws.BackgroundContext(), input, fn) } // ListMatchingJobsPagesWithContext same as ListMatchingJobsPages except // it takes a Context and allows setting request options on the pages. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) ListMatchingJobsPagesWithContext(ctx aws.Context, input *ListMatchingJobsInput, fn func(*ListMatchingJobsOutput, bool) bool, opts ...request.Option) error { p := request.Pagination{ NewRequest: func() (*request.Request, error) { var inCpy *ListMatchingJobsInput if input != nil { tmp := *input inCpy = &tmp } req, _ := c.ListMatchingJobsRequest(inCpy) req.SetContext(ctx) req.ApplyOptions(opts...) return req, nil }, } for p.Next() { if !fn(p.Page().(*ListMatchingJobsOutput), !p.HasNextPage()) { break } } return p.Err() } const opListMatchingWorkflows = "ListMatchingWorkflows" // ListMatchingWorkflowsRequest generates a "aws/request.Request" representing the // client's request for the ListMatchingWorkflows operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See ListMatchingWorkflows for more information on using the ListMatchingWorkflows // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the ListMatchingWorkflowsRequest method. // req, resp := client.ListMatchingWorkflowsRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/ListMatchingWorkflows func (c *EntityResolution) ListMatchingWorkflowsRequest(input *ListMatchingWorkflowsInput) (req *request.Request, output *ListMatchingWorkflowsOutput) { op := &request.Operation{ Name: opListMatchingWorkflows, HTTPMethod: "GET", HTTPPath: "/matchingworkflows", Paginator: &request.Paginator{ InputTokens: []string{"nextToken"}, OutputTokens: []string{"nextToken"}, LimitToken: "maxResults", TruncationToken: "", }, } if input == nil { input = &ListMatchingWorkflowsInput{} } output = &ListMatchingWorkflowsOutput{} req = c.newRequest(op, input, output) return } // ListMatchingWorkflows API operation for AWS EntityResolution. // // Returns a list of all the MatchingWorkflows that have been created for an // Amazon Web Services account. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation ListMatchingWorkflows for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/ListMatchingWorkflows func (c *EntityResolution) ListMatchingWorkflows(input *ListMatchingWorkflowsInput) (*ListMatchingWorkflowsOutput, error) { req, out := c.ListMatchingWorkflowsRequest(input) return out, req.Send() } // ListMatchingWorkflowsWithContext is the same as ListMatchingWorkflows with the addition of // the ability to pass a context and additional request options. // // See ListMatchingWorkflows for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) ListMatchingWorkflowsWithContext(ctx aws.Context, input *ListMatchingWorkflowsInput, opts ...request.Option) (*ListMatchingWorkflowsOutput, error) { req, out := c.ListMatchingWorkflowsRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } // ListMatchingWorkflowsPages iterates over the pages of a ListMatchingWorkflows operation, // calling the "fn" function with the response data for each page. To stop // iterating, return false from the fn function. // // See ListMatchingWorkflows method for more information on how to use this operation. // // Note: This operation can generate multiple requests to a service. // // // Example iterating over at most 3 pages of a ListMatchingWorkflows operation. // pageNum := 0 // err := client.ListMatchingWorkflowsPages(params, // func(page *entityresolution.ListMatchingWorkflowsOutput, lastPage bool) bool { // pageNum++ // fmt.Println(page) // return pageNum <= 3 // }) func (c *EntityResolution) ListMatchingWorkflowsPages(input *ListMatchingWorkflowsInput, fn func(*ListMatchingWorkflowsOutput, bool) bool) error { return c.ListMatchingWorkflowsPagesWithContext(aws.BackgroundContext(), input, fn) } // ListMatchingWorkflowsPagesWithContext same as ListMatchingWorkflowsPages except // it takes a Context and allows setting request options on the pages. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) ListMatchingWorkflowsPagesWithContext(ctx aws.Context, input *ListMatchingWorkflowsInput, fn func(*ListMatchingWorkflowsOutput, bool) bool, opts ...request.Option) error { p := request.Pagination{ NewRequest: func() (*request.Request, error) { var inCpy *ListMatchingWorkflowsInput if input != nil { tmp := *input inCpy = &tmp } req, _ := c.ListMatchingWorkflowsRequest(inCpy) req.SetContext(ctx) req.ApplyOptions(opts...) return req, nil }, } for p.Next() { if !fn(p.Page().(*ListMatchingWorkflowsOutput), !p.HasNextPage()) { break } } return p.Err() } const opListProviderServices = "ListProviderServices" // ListProviderServicesRequest generates a "aws/request.Request" representing the // client's request for the ListProviderServices operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See ListProviderServices for more information on using the ListProviderServices // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the ListProviderServicesRequest method. // req, resp := client.ListProviderServicesRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/ListProviderServices func (c *EntityResolution) ListProviderServicesRequest(input *ListProviderServicesInput) (req *request.Request, output *ListProviderServicesOutput) { op := &request.Operation{ Name: opListProviderServices, HTTPMethod: "GET", HTTPPath: "/providerservices", Paginator: &request.Paginator{ InputTokens: []string{"nextToken"}, OutputTokens: []string{"nextToken"}, LimitToken: "maxResults", TruncationToken: "", }, } if input == nil { input = &ListProviderServicesInput{} } output = &ListProviderServicesOutput{} req = c.newRequest(op, input, output) return } // ListProviderServices API operation for AWS EntityResolution. // // Returns a list of all the ProviderServices that are available in this Amazon // Web Services Region. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation ListProviderServices for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/ListProviderServices func (c *EntityResolution) ListProviderServices(input *ListProviderServicesInput) (*ListProviderServicesOutput, error) { req, out := c.ListProviderServicesRequest(input) return out, req.Send() } // ListProviderServicesWithContext is the same as ListProviderServices with the addition of // the ability to pass a context and additional request options. // // See ListProviderServices for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) ListProviderServicesWithContext(ctx aws.Context, input *ListProviderServicesInput, opts ...request.Option) (*ListProviderServicesOutput, error) { req, out := c.ListProviderServicesRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } // ListProviderServicesPages iterates over the pages of a ListProviderServices operation, // calling the "fn" function with the response data for each page. To stop // iterating, return false from the fn function. // // See ListProviderServices method for more information on how to use this operation. // // Note: This operation can generate multiple requests to a service. // // // Example iterating over at most 3 pages of a ListProviderServices operation. // pageNum := 0 // err := client.ListProviderServicesPages(params, // func(page *entityresolution.ListProviderServicesOutput, lastPage bool) bool { // pageNum++ // fmt.Println(page) // return pageNum <= 3 // }) func (c *EntityResolution) ListProviderServicesPages(input *ListProviderServicesInput, fn func(*ListProviderServicesOutput, bool) bool) error { return c.ListProviderServicesPagesWithContext(aws.BackgroundContext(), input, fn) } // ListProviderServicesPagesWithContext same as ListProviderServicesPages except // it takes a Context and allows setting request options on the pages. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) ListProviderServicesPagesWithContext(ctx aws.Context, input *ListProviderServicesInput, fn func(*ListProviderServicesOutput, bool) bool, opts ...request.Option) error { p := request.Pagination{ NewRequest: func() (*request.Request, error) { var inCpy *ListProviderServicesInput if input != nil { tmp := *input inCpy = &tmp } req, _ := c.ListProviderServicesRequest(inCpy) req.SetContext(ctx) req.ApplyOptions(opts...) return req, nil }, } for p.Next() { if !fn(p.Page().(*ListProviderServicesOutput), !p.HasNextPage()) { break } } return p.Err() } const opListSchemaMappings = "ListSchemaMappings" // ListSchemaMappingsRequest generates a "aws/request.Request" representing the // client's request for the ListSchemaMappings operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See ListSchemaMappings for more information on using the ListSchemaMappings // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the ListSchemaMappingsRequest method. // req, resp := client.ListSchemaMappingsRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/ListSchemaMappings func (c *EntityResolution) ListSchemaMappingsRequest(input *ListSchemaMappingsInput) (req *request.Request, output *ListSchemaMappingsOutput) { op := &request.Operation{ Name: opListSchemaMappings, HTTPMethod: "GET", HTTPPath: "/schemas", Paginator: &request.Paginator{ InputTokens: []string{"nextToken"}, OutputTokens: []string{"nextToken"}, LimitToken: "maxResults", TruncationToken: "", }, } if input == nil { input = &ListSchemaMappingsInput{} } output = &ListSchemaMappingsOutput{} req = c.newRequest(op, input, output) return } // ListSchemaMappings API operation for AWS EntityResolution. // // Returns a list of all the SchemaMappings that have been created for an Amazon // Web Services account. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation ListSchemaMappings for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/ListSchemaMappings func (c *EntityResolution) ListSchemaMappings(input *ListSchemaMappingsInput) (*ListSchemaMappingsOutput, error) { req, out := c.ListSchemaMappingsRequest(input) return out, req.Send() } // ListSchemaMappingsWithContext is the same as ListSchemaMappings with the addition of // the ability to pass a context and additional request options. // // See ListSchemaMappings for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) ListSchemaMappingsWithContext(ctx aws.Context, input *ListSchemaMappingsInput, opts ...request.Option) (*ListSchemaMappingsOutput, error) { req, out := c.ListSchemaMappingsRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } // ListSchemaMappingsPages iterates over the pages of a ListSchemaMappings operation, // calling the "fn" function with the response data for each page. To stop // iterating, return false from the fn function. // // See ListSchemaMappings method for more information on how to use this operation. // // Note: This operation can generate multiple requests to a service. // // // Example iterating over at most 3 pages of a ListSchemaMappings operation. // pageNum := 0 // err := client.ListSchemaMappingsPages(params, // func(page *entityresolution.ListSchemaMappingsOutput, lastPage bool) bool { // pageNum++ // fmt.Println(page) // return pageNum <= 3 // }) func (c *EntityResolution) ListSchemaMappingsPages(input *ListSchemaMappingsInput, fn func(*ListSchemaMappingsOutput, bool) bool) error { return c.ListSchemaMappingsPagesWithContext(aws.BackgroundContext(), input, fn) } // ListSchemaMappingsPagesWithContext same as ListSchemaMappingsPages except // it takes a Context and allows setting request options on the pages. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) ListSchemaMappingsPagesWithContext(ctx aws.Context, input *ListSchemaMappingsInput, fn func(*ListSchemaMappingsOutput, bool) bool, opts ...request.Option) error { p := request.Pagination{ NewRequest: func() (*request.Request, error) { var inCpy *ListSchemaMappingsInput if input != nil { tmp := *input inCpy = &tmp } req, _ := c.ListSchemaMappingsRequest(inCpy) req.SetContext(ctx) req.ApplyOptions(opts...) return req, nil }, } for p.Next() { if !fn(p.Page().(*ListSchemaMappingsOutput), !p.HasNextPage()) { break } } return p.Err() } const opListTagsForResource = "ListTagsForResource" // ListTagsForResourceRequest generates a "aws/request.Request" representing the // client's request for the ListTagsForResource operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See ListTagsForResource for more information on using the ListTagsForResource // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the ListTagsForResourceRequest method. // req, resp := client.ListTagsForResourceRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/ListTagsForResource func (c *EntityResolution) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput) { op := &request.Operation{ Name: opListTagsForResource, HTTPMethod: "GET", HTTPPath: "/tags/{resourceArn}", } if input == nil { input = &ListTagsForResourceInput{} } output = &ListTagsForResourceOutput{} req = c.newRequest(op, input, output) return } // ListTagsForResource API operation for AWS EntityResolution. // // Displays the tags associated with an Entity Resolution resource. In Entity // Resolution, SchemaMapping, and MatchingWorkflow can be tagged. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation ListTagsForResource for usage and error information. // // Returned Error Types: // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - ResourceNotFoundException // The resource could not be found. HTTP Status Code: 404 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/ListTagsForResource func (c *EntityResolution) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error) { req, out := c.ListTagsForResourceRequest(input) return out, req.Send() } // ListTagsForResourceWithContext is the same as ListTagsForResource with the addition of // the ability to pass a context and additional request options. // // See ListTagsForResource for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error) { req, out := c.ListTagsForResourceRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opStartIdMappingJob = "StartIdMappingJob" // StartIdMappingJobRequest generates a "aws/request.Request" representing the // client's request for the StartIdMappingJob operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See StartIdMappingJob for more information on using the StartIdMappingJob // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the StartIdMappingJobRequest method. // req, resp := client.StartIdMappingJobRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/StartIdMappingJob func (c *EntityResolution) StartIdMappingJobRequest(input *StartIdMappingJobInput) (req *request.Request, output *StartIdMappingJobOutput) { op := &request.Operation{ Name: opStartIdMappingJob, HTTPMethod: "POST", HTTPPath: "/idmappingworkflows/{workflowName}/jobs", } if input == nil { input = &StartIdMappingJobInput{} } output = &StartIdMappingJobOutput{} req = c.newRequest(op, input, output) return } // StartIdMappingJob API operation for AWS EntityResolution. // // Starts the IdMappingJob of a workflow. The workflow must have previously // been created using the CreateIdMappingWorkflow endpoint. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation StartIdMappingJob for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - ResourceNotFoundException // The resource could not be found. HTTP Status Code: 404 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ExceedsLimitException // The request was rejected because it attempted to create resources beyond // the current Entity Resolution account limits. The error message describes // the limit exceeded. HTTP Status Code: 402 // // - ConflictException // The request could not be processed because of conflict in the current state // of the resource. Example: Workflow already exists, Schema already exists, // Workflow is currently running, etc. HTTP Status Code: 400 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/StartIdMappingJob func (c *EntityResolution) StartIdMappingJob(input *StartIdMappingJobInput) (*StartIdMappingJobOutput, error) { req, out := c.StartIdMappingJobRequest(input) return out, req.Send() } // StartIdMappingJobWithContext is the same as StartIdMappingJob with the addition of // the ability to pass a context and additional request options. // // See StartIdMappingJob for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) StartIdMappingJobWithContext(ctx aws.Context, input *StartIdMappingJobInput, opts ...request.Option) (*StartIdMappingJobOutput, error) { req, out := c.StartIdMappingJobRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opStartMatchingJob = "StartMatchingJob" // StartMatchingJobRequest generates a "aws/request.Request" representing the // client's request for the StartMatchingJob operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See StartMatchingJob for more information on using the StartMatchingJob // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the StartMatchingJobRequest method. // req, resp := client.StartMatchingJobRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/StartMatchingJob func (c *EntityResolution) StartMatchingJobRequest(input *StartMatchingJobInput) (req *request.Request, output *StartMatchingJobOutput) { op := &request.Operation{ Name: opStartMatchingJob, HTTPMethod: "POST", HTTPPath: "/matchingworkflows/{workflowName}/jobs", } if input == nil { input = &StartMatchingJobInput{} } output = &StartMatchingJobOutput{} req = c.newRequest(op, input, output) return } // StartMatchingJob API operation for AWS EntityResolution. // // Starts the MatchingJob of a workflow. The workflow must have previously been // created using the CreateMatchingWorkflow endpoint. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation StartMatchingJob for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - ResourceNotFoundException // The resource could not be found. HTTP Status Code: 404 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ExceedsLimitException // The request was rejected because it attempted to create resources beyond // the current Entity Resolution account limits. The error message describes // the limit exceeded. HTTP Status Code: 402 // // - ConflictException // The request could not be processed because of conflict in the current state // of the resource. Example: Workflow already exists, Schema already exists, // Workflow is currently running, etc. HTTP Status Code: 400 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/StartMatchingJob func (c *EntityResolution) StartMatchingJob(input *StartMatchingJobInput) (*StartMatchingJobOutput, error) { req, out := c.StartMatchingJobRequest(input) return out, req.Send() } // StartMatchingJobWithContext is the same as StartMatchingJob with the addition of // the ability to pass a context and additional request options. // // See StartMatchingJob for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) StartMatchingJobWithContext(ctx aws.Context, input *StartMatchingJobInput, opts ...request.Option) (*StartMatchingJobOutput, error) { req, out := c.StartMatchingJobRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opTagResource = "TagResource" // TagResourceRequest generates a "aws/request.Request" representing the // client's request for the TagResource operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See TagResource for more information on using the TagResource // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the TagResourceRequest method. // req, resp := client.TagResourceRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/TagResource func (c *EntityResolution) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput) { op := &request.Operation{ Name: opTagResource, HTTPMethod: "POST", HTTPPath: "/tags/{resourceArn}", } if input == nil { input = &TagResourceInput{} } output = &TagResourceOutput{} req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Swap(restjson.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler) return } // TagResource API operation for AWS EntityResolution. // // Assigns one or more tags (key-value pairs) to the specified Entity Resolution // resource. Tags can help you organize and categorize your resources. You can // also use them to scope user permissions by granting a user permission to // access or change only resources with certain tag values. In Entity Resolution, // SchemaMapping and MatchingWorkflow can be tagged. Tags don't have any semantic // meaning to Amazon Web Services and are interpreted strictly as strings of // characters. You can use the TagResource action with a resource that already // has tags. If you specify a new tag key, this tag is appended to the list // of tags associated with the resource. If you specify a tag key that is already // associated with the resource, the new tag value that you specify replaces // the previous value for that tag. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation TagResource for usage and error information. // // Returned Error Types: // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - ResourceNotFoundException // The resource could not be found. HTTP Status Code: 404 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/TagResource func (c *EntityResolution) TagResource(input *TagResourceInput) (*TagResourceOutput, error) { req, out := c.TagResourceRequest(input) return out, req.Send() } // TagResourceWithContext is the same as TagResource with the addition of // the ability to pass a context and additional request options. // // See TagResource for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error) { req, out := c.TagResourceRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opUntagResource = "UntagResource" // UntagResourceRequest generates a "aws/request.Request" representing the // client's request for the UntagResource operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See UntagResource for more information on using the UntagResource // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the UntagResourceRequest method. // req, resp := client.UntagResourceRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/UntagResource func (c *EntityResolution) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput) { op := &request.Operation{ Name: opUntagResource, HTTPMethod: "DELETE", HTTPPath: "/tags/{resourceArn}", } if input == nil { input = &UntagResourceInput{} } output = &UntagResourceOutput{} req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Swap(restjson.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler) return } // UntagResource API operation for AWS EntityResolution. // // Removes one or more tags from the specified Entity Resolution resource. In // Entity Resolution, SchemaMapping, and MatchingWorkflow can be tagged. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation UntagResource for usage and error information. // // Returned Error Types: // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - ResourceNotFoundException // The resource could not be found. HTTP Status Code: 404 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/UntagResource func (c *EntityResolution) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error) { req, out := c.UntagResourceRequest(input) return out, req.Send() } // UntagResourceWithContext is the same as UntagResource with the addition of // the ability to pass a context and additional request options. // // See UntagResource for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error) { req, out := c.UntagResourceRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opUpdateIdMappingWorkflow = "UpdateIdMappingWorkflow" // UpdateIdMappingWorkflowRequest generates a "aws/request.Request" representing the // client's request for the UpdateIdMappingWorkflow operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See UpdateIdMappingWorkflow for more information on using the UpdateIdMappingWorkflow // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the UpdateIdMappingWorkflowRequest method. // req, resp := client.UpdateIdMappingWorkflowRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/UpdateIdMappingWorkflow func (c *EntityResolution) UpdateIdMappingWorkflowRequest(input *UpdateIdMappingWorkflowInput) (req *request.Request, output *UpdateIdMappingWorkflowOutput) { op := &request.Operation{ Name: opUpdateIdMappingWorkflow, HTTPMethod: "PUT", HTTPPath: "/idmappingworkflows/{workflowName}", } if input == nil { input = &UpdateIdMappingWorkflowInput{} } output = &UpdateIdMappingWorkflowOutput{} req = c.newRequest(op, input, output) return } // UpdateIdMappingWorkflow API operation for AWS EntityResolution. // // Updates an existing IdMappingWorkflow. This method is identical to CreateIdMappingWorkflow, // except it uses an HTTP PUT request instead of a POST request, and the IdMappingWorkflow // must already exist for the method to succeed. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation UpdateIdMappingWorkflow for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - ResourceNotFoundException // The resource could not be found. HTTP Status Code: 404 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/UpdateIdMappingWorkflow func (c *EntityResolution) UpdateIdMappingWorkflow(input *UpdateIdMappingWorkflowInput) (*UpdateIdMappingWorkflowOutput, error) { req, out := c.UpdateIdMappingWorkflowRequest(input) return out, req.Send() } // UpdateIdMappingWorkflowWithContext is the same as UpdateIdMappingWorkflow with the addition of // the ability to pass a context and additional request options. // // See UpdateIdMappingWorkflow for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) UpdateIdMappingWorkflowWithContext(ctx aws.Context, input *UpdateIdMappingWorkflowInput, opts ...request.Option) (*UpdateIdMappingWorkflowOutput, error) { req, out := c.UpdateIdMappingWorkflowRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opUpdateMatchingWorkflow = "UpdateMatchingWorkflow" // UpdateMatchingWorkflowRequest generates a "aws/request.Request" representing the // client's request for the UpdateMatchingWorkflow operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See UpdateMatchingWorkflow for more information on using the UpdateMatchingWorkflow // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the UpdateMatchingWorkflowRequest method. // req, resp := client.UpdateMatchingWorkflowRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/UpdateMatchingWorkflow func (c *EntityResolution) UpdateMatchingWorkflowRequest(input *UpdateMatchingWorkflowInput) (req *request.Request, output *UpdateMatchingWorkflowOutput) { op := &request.Operation{ Name: opUpdateMatchingWorkflow, HTTPMethod: "PUT", HTTPPath: "/matchingworkflows/{workflowName}", } if input == nil { input = &UpdateMatchingWorkflowInput{} } output = &UpdateMatchingWorkflowOutput{} req = c.newRequest(op, input, output) return } // UpdateMatchingWorkflow API operation for AWS EntityResolution. // // Updates an existing MatchingWorkflow. This method is identical to CreateMatchingWorkflow, // except it uses an HTTP PUT request instead of a POST request, and the MatchingWorkflow // must already exist for the method to succeed. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation UpdateMatchingWorkflow for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - ResourceNotFoundException // The resource could not be found. HTTP Status Code: 404 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/UpdateMatchingWorkflow func (c *EntityResolution) UpdateMatchingWorkflow(input *UpdateMatchingWorkflowInput) (*UpdateMatchingWorkflowOutput, error) { req, out := c.UpdateMatchingWorkflowRequest(input) return out, req.Send() } // UpdateMatchingWorkflowWithContext is the same as UpdateMatchingWorkflow with the addition of // the ability to pass a context and additional request options. // // See UpdateMatchingWorkflow for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) UpdateMatchingWorkflowWithContext(ctx aws.Context, input *UpdateMatchingWorkflowInput, opts ...request.Option) (*UpdateMatchingWorkflowOutput, error) { req, out := c.UpdateMatchingWorkflowRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opUpdateSchemaMapping = "UpdateSchemaMapping" // UpdateSchemaMappingRequest generates a "aws/request.Request" representing the // client's request for the UpdateSchemaMapping operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See UpdateSchemaMapping for more information on using the UpdateSchemaMapping // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the UpdateSchemaMappingRequest method. // req, resp := client.UpdateSchemaMappingRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/UpdateSchemaMapping func (c *EntityResolution) UpdateSchemaMappingRequest(input *UpdateSchemaMappingInput) (req *request.Request, output *UpdateSchemaMappingOutput) { op := &request.Operation{ Name: opUpdateSchemaMapping, HTTPMethod: "PUT", HTTPPath: "/schemas/{schemaName}", } if input == nil { input = &UpdateSchemaMappingInput{} } output = &UpdateSchemaMappingOutput{} req = c.newRequest(op, input, output) return } // UpdateSchemaMapping API operation for AWS EntityResolution. // // Updates a schema mapping. // // A schema is immutable if it is being used by a workflow. Therefore, you can't // update a schema mapping if it's associated with a workflow. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS EntityResolution's // API operation UpdateSchemaMapping for usage and error information. // // Returned Error Types: // // - ThrottlingException // The request was denied due to request throttling. HTTP Status Code: 429 // // - InternalServerException // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 // // - ResourceNotFoundException // The resource could not be found. HTTP Status Code: 404 // // - AccessDeniedException // You do not have sufficient access to perform this action. HTTP Status Code: // 403 // // - ConflictException // The request could not be processed because of conflict in the current state // of the resource. Example: Workflow already exists, Schema already exists, // Workflow is currently running, etc. HTTP Status Code: 400 // // - ValidationException // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 // // See also, https://docs.aws.amazon.com/goto/WebAPI/entityresolution-2018-05-10/UpdateSchemaMapping func (c *EntityResolution) UpdateSchemaMapping(input *UpdateSchemaMappingInput) (*UpdateSchemaMappingOutput, error) { req, out := c.UpdateSchemaMappingRequest(input) return out, req.Send() } // UpdateSchemaMappingWithContext is the same as UpdateSchemaMapping with the addition of // the ability to pass a context and additional request options. // // See UpdateSchemaMapping for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *EntityResolution) UpdateSchemaMappingWithContext(ctx aws.Context, input *UpdateSchemaMappingInput, opts ...request.Option) (*UpdateSchemaMappingOutput, error) { req, out := c.UpdateSchemaMappingRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } // You do not have sufficient access to perform this action. HTTP Status Code: // 403 type AccessDeniedException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ *string `locationName:"message" min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s AccessDeniedException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s AccessDeniedException) GoString() string { return s.String() } func newErrorAccessDeniedException(v protocol.ResponseMetadata) error { return &AccessDeniedException{ RespMetadata: v, } } // Code returns the exception type name. func (s *AccessDeniedException) Code() string { return "AccessDeniedException" } // Message returns the exception's message. func (s *AccessDeniedException) Message() string { if s.Message_ != nil { return *s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s *AccessDeniedException) OrigErr() error { return nil } func (s *AccessDeniedException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s *AccessDeniedException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s *AccessDeniedException) RequestID() string { return s.RespMetadata.RequestID } // The request could not be processed because of conflict in the current state // of the resource. Example: Workflow already exists, Schema already exists, // Workflow is currently running, etc. HTTP Status Code: 400 type ConflictException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ *string `locationName:"message" min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ConflictException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ConflictException) GoString() string { return s.String() } func newErrorConflictException(v protocol.ResponseMetadata) error { return &ConflictException{ RespMetadata: v, } } // Code returns the exception type name. func (s *ConflictException) Code() string { return "ConflictException" } // Message returns the exception's message. func (s *ConflictException) Message() string { if s.Message_ != nil { return *s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s *ConflictException) OrigErr() error { return nil } func (s *ConflictException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s *ConflictException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s *ConflictException) RequestID() string { return s.RespMetadata.RequestID } type CreateIdMappingWorkflowInput struct { _ struct{} `type:"structure"` // A description of the workflow. Description *string `locationName:"description" type:"string"` // An object which defines the idMappingType and the providerProperties. // // IdMappingTechniques is a required field IdMappingTechniques *IdMappingTechniques `locationName:"idMappingTechniques" type:"structure" required:"true"` // A list of InputSource objects, which have the fields InputSourceARN and SchemaName. // // InputSourceConfig is a required field InputSourceConfig []*IdMappingWorkflowInputSource `locationName:"inputSourceConfig" min:"1" type:"list" required:"true"` // A list of IdMappingWorkflowOutputSource objects, each of which contains fields // OutputS3Path and Output. // // OutputSourceConfig is a required field OutputSourceConfig []*IdMappingWorkflowOutputSource `locationName:"outputSourceConfig" min:"1" type:"list" required:"true"` // The Amazon Resource Name (ARN) of the IAM role. Entity Resolution assumes // this role to create resources on your behalf as part of workflow execution. // // RoleArn is a required field RoleArn *string `locationName:"roleArn" type:"string" required:"true"` // The tags used to organize, track, or control access for this resource. Tags map[string]*string `locationName:"tags" type:"map"` // The name of the workflow. There can't be multiple IdMappingWorkflows with // the same name. // // WorkflowName is a required field WorkflowName *string `locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CreateIdMappingWorkflowInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CreateIdMappingWorkflowInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *CreateIdMappingWorkflowInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "CreateIdMappingWorkflowInput"} if s.IdMappingTechniques == nil { invalidParams.Add(request.NewErrParamRequired("IdMappingTechniques")) } if s.InputSourceConfig == nil { invalidParams.Add(request.NewErrParamRequired("InputSourceConfig")) } if s.InputSourceConfig != nil && len(s.InputSourceConfig) < 1 { invalidParams.Add(request.NewErrParamMinLen("InputSourceConfig", 1)) } if s.OutputSourceConfig == nil { invalidParams.Add(request.NewErrParamRequired("OutputSourceConfig")) } if s.OutputSourceConfig != nil && len(s.OutputSourceConfig) < 1 { invalidParams.Add(request.NewErrParamMinLen("OutputSourceConfig", 1)) } if s.RoleArn == nil { invalidParams.Add(request.NewErrParamRequired("RoleArn")) } if s.WorkflowName == nil { invalidParams.Add(request.NewErrParamRequired("WorkflowName")) } if s.WorkflowName != nil && len(*s.WorkflowName) < 1 { invalidParams.Add(request.NewErrParamMinLen("WorkflowName", 1)) } if s.IdMappingTechniques != nil { if err := s.IdMappingTechniques.Validate(); err != nil { invalidParams.AddNested("IdMappingTechniques", err.(request.ErrInvalidParams)) } } if s.InputSourceConfig != nil { for i, v := range s.InputSourceConfig { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "InputSourceConfig", i), err.(request.ErrInvalidParams)) } } } if s.OutputSourceConfig != nil { for i, v := range s.OutputSourceConfig { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "OutputSourceConfig", i), err.(request.ErrInvalidParams)) } } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetDescription sets the Description field's value. func (s *CreateIdMappingWorkflowInput) SetDescription(v string) *CreateIdMappingWorkflowInput { s.Description = &v return s } // SetIdMappingTechniques sets the IdMappingTechniques field's value. func (s *CreateIdMappingWorkflowInput) SetIdMappingTechniques(v *IdMappingTechniques) *CreateIdMappingWorkflowInput { s.IdMappingTechniques = v return s } // SetInputSourceConfig sets the InputSourceConfig field's value. func (s *CreateIdMappingWorkflowInput) SetInputSourceConfig(v []*IdMappingWorkflowInputSource) *CreateIdMappingWorkflowInput { s.InputSourceConfig = v return s } // SetOutputSourceConfig sets the OutputSourceConfig field's value. func (s *CreateIdMappingWorkflowInput) SetOutputSourceConfig(v []*IdMappingWorkflowOutputSource) *CreateIdMappingWorkflowInput { s.OutputSourceConfig = v return s } // SetRoleArn sets the RoleArn field's value. func (s *CreateIdMappingWorkflowInput) SetRoleArn(v string) *CreateIdMappingWorkflowInput { s.RoleArn = &v return s } // SetTags sets the Tags field's value. func (s *CreateIdMappingWorkflowInput) SetTags(v map[string]*string) *CreateIdMappingWorkflowInput { s.Tags = v return s } // SetWorkflowName sets the WorkflowName field's value. func (s *CreateIdMappingWorkflowInput) SetWorkflowName(v string) *CreateIdMappingWorkflowInput { s.WorkflowName = &v return s } type CreateIdMappingWorkflowOutput struct { _ struct{} `type:"structure"` // A description of the workflow. Description *string `locationName:"description" type:"string"` // An object which defines the idMappingType and the providerProperties. // // IdMappingTechniques is a required field IdMappingTechniques *IdMappingTechniques `locationName:"idMappingTechniques" type:"structure" required:"true"` // A list of InputSource objects, which have the fields InputSourceARN and SchemaName. // // InputSourceConfig is a required field InputSourceConfig []*IdMappingWorkflowInputSource `locationName:"inputSourceConfig" min:"1" type:"list" required:"true"` // A list of IdMappingWorkflowOutputSource objects, each of which contains fields // OutputS3Path and Output. // // OutputSourceConfig is a required field OutputSourceConfig []*IdMappingWorkflowOutputSource `locationName:"outputSourceConfig" min:"1" type:"list" required:"true"` // The Amazon Resource Name (ARN) of the IAM role. Entity Resolution assumes // this role to create resources on your behalf as part of workflow execution. // // RoleArn is a required field RoleArn *string `locationName:"roleArn" type:"string" required:"true"` // The ARN (Amazon Resource Name) that Entity Resolution generated for the IDMappingWorkflow. // // WorkflowArn is a required field WorkflowArn *string `locationName:"workflowArn" type:"string" required:"true"` // The name of the workflow. // // WorkflowName is a required field WorkflowName *string `locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CreateIdMappingWorkflowOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CreateIdMappingWorkflowOutput) GoString() string { return s.String() } // SetDescription sets the Description field's value. func (s *CreateIdMappingWorkflowOutput) SetDescription(v string) *CreateIdMappingWorkflowOutput { s.Description = &v return s } // SetIdMappingTechniques sets the IdMappingTechniques field's value. func (s *CreateIdMappingWorkflowOutput) SetIdMappingTechniques(v *IdMappingTechniques) *CreateIdMappingWorkflowOutput { s.IdMappingTechniques = v return s } // SetInputSourceConfig sets the InputSourceConfig field's value. func (s *CreateIdMappingWorkflowOutput) SetInputSourceConfig(v []*IdMappingWorkflowInputSource) *CreateIdMappingWorkflowOutput { s.InputSourceConfig = v return s } // SetOutputSourceConfig sets the OutputSourceConfig field's value. func (s *CreateIdMappingWorkflowOutput) SetOutputSourceConfig(v []*IdMappingWorkflowOutputSource) *CreateIdMappingWorkflowOutput { s.OutputSourceConfig = v return s } // SetRoleArn sets the RoleArn field's value. func (s *CreateIdMappingWorkflowOutput) SetRoleArn(v string) *CreateIdMappingWorkflowOutput { s.RoleArn = &v return s } // SetWorkflowArn sets the WorkflowArn field's value. func (s *CreateIdMappingWorkflowOutput) SetWorkflowArn(v string) *CreateIdMappingWorkflowOutput { s.WorkflowArn = &v return s } // SetWorkflowName sets the WorkflowName field's value. func (s *CreateIdMappingWorkflowOutput) SetWorkflowName(v string) *CreateIdMappingWorkflowOutput { s.WorkflowName = &v return s } type CreateMatchingWorkflowInput struct { _ struct{} `type:"structure"` // A description of the workflow. Description *string `locationName:"description" type:"string"` // An object which defines an incremental run type and has only incrementalRunType // as a field. IncrementalRunConfig *IncrementalRunConfig `locationName:"incrementalRunConfig" type:"structure"` // A list of InputSource objects, which have the fields InputSourceARN and SchemaName. // // InputSourceConfig is a required field InputSourceConfig []*InputSource `locationName:"inputSourceConfig" min:"1" type:"list" required:"true"` // A list of OutputSource objects, each of which contains fields OutputS3Path, // ApplyNormalization, and Output. // // OutputSourceConfig is a required field OutputSourceConfig []*OutputSource `locationName:"outputSourceConfig" min:"1" type:"list" required:"true"` // An object which defines the resolutionType and the ruleBasedProperties. // // ResolutionTechniques is a required field ResolutionTechniques *ResolutionTechniques `locationName:"resolutionTechniques" type:"structure" required:"true"` // The Amazon Resource Name (ARN) of the IAM role. Entity Resolution assumes // this role to create resources on your behalf as part of workflow execution. // // RoleArn is a required field RoleArn *string `locationName:"roleArn" type:"string" required:"true"` // The tags used to organize, track, or control access for this resource. Tags map[string]*string `locationName:"tags" type:"map"` // The name of the workflow. There can't be multiple MatchingWorkflows with // the same name. // // WorkflowName is a required field WorkflowName *string `locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CreateMatchingWorkflowInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CreateMatchingWorkflowInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *CreateMatchingWorkflowInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "CreateMatchingWorkflowInput"} if s.InputSourceConfig == nil { invalidParams.Add(request.NewErrParamRequired("InputSourceConfig")) } if s.InputSourceConfig != nil && len(s.InputSourceConfig) < 1 { invalidParams.Add(request.NewErrParamMinLen("InputSourceConfig", 1)) } if s.OutputSourceConfig == nil { invalidParams.Add(request.NewErrParamRequired("OutputSourceConfig")) } if s.OutputSourceConfig != nil && len(s.OutputSourceConfig) < 1 { invalidParams.Add(request.NewErrParamMinLen("OutputSourceConfig", 1)) } if s.ResolutionTechniques == nil { invalidParams.Add(request.NewErrParamRequired("ResolutionTechniques")) } if s.RoleArn == nil { invalidParams.Add(request.NewErrParamRequired("RoleArn")) } if s.WorkflowName == nil { invalidParams.Add(request.NewErrParamRequired("WorkflowName")) } if s.WorkflowName != nil && len(*s.WorkflowName) < 1 { invalidParams.Add(request.NewErrParamMinLen("WorkflowName", 1)) } if s.InputSourceConfig != nil { for i, v := range s.InputSourceConfig { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "InputSourceConfig", i), err.(request.ErrInvalidParams)) } } } if s.OutputSourceConfig != nil { for i, v := range s.OutputSourceConfig { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "OutputSourceConfig", i), err.(request.ErrInvalidParams)) } } } if s.ResolutionTechniques != nil { if err := s.ResolutionTechniques.Validate(); err != nil { invalidParams.AddNested("ResolutionTechniques", err.(request.ErrInvalidParams)) } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetDescription sets the Description field's value. func (s *CreateMatchingWorkflowInput) SetDescription(v string) *CreateMatchingWorkflowInput { s.Description = &v return s } // SetIncrementalRunConfig sets the IncrementalRunConfig field's value. func (s *CreateMatchingWorkflowInput) SetIncrementalRunConfig(v *IncrementalRunConfig) *CreateMatchingWorkflowInput { s.IncrementalRunConfig = v return s } // SetInputSourceConfig sets the InputSourceConfig field's value. func (s *CreateMatchingWorkflowInput) SetInputSourceConfig(v []*InputSource) *CreateMatchingWorkflowInput { s.InputSourceConfig = v return s } // SetOutputSourceConfig sets the OutputSourceConfig field's value. func (s *CreateMatchingWorkflowInput) SetOutputSourceConfig(v []*OutputSource) *CreateMatchingWorkflowInput { s.OutputSourceConfig = v return s } // SetResolutionTechniques sets the ResolutionTechniques field's value. func (s *CreateMatchingWorkflowInput) SetResolutionTechniques(v *ResolutionTechniques) *CreateMatchingWorkflowInput { s.ResolutionTechniques = v return s } // SetRoleArn sets the RoleArn field's value. func (s *CreateMatchingWorkflowInput) SetRoleArn(v string) *CreateMatchingWorkflowInput { s.RoleArn = &v return s } // SetTags sets the Tags field's value. func (s *CreateMatchingWorkflowInput) SetTags(v map[string]*string) *CreateMatchingWorkflowInput { s.Tags = v return s } // SetWorkflowName sets the WorkflowName field's value. func (s *CreateMatchingWorkflowInput) SetWorkflowName(v string) *CreateMatchingWorkflowInput { s.WorkflowName = &v return s } type CreateMatchingWorkflowOutput struct { _ struct{} `type:"structure"` // A description of the workflow. Description *string `locationName:"description" type:"string"` // An object which defines an incremental run type and has only incrementalRunType // as a field. IncrementalRunConfig *IncrementalRunConfig `locationName:"incrementalRunConfig" type:"structure"` // A list of InputSource objects, which have the fields InputSourceARN and SchemaName. // // InputSourceConfig is a required field InputSourceConfig []*InputSource `locationName:"inputSourceConfig" min:"1" type:"list" required:"true"` // A list of OutputSource objects, each of which contains fields OutputS3Path, // ApplyNormalization, and Output. // // OutputSourceConfig is a required field OutputSourceConfig []*OutputSource `locationName:"outputSourceConfig" min:"1" type:"list" required:"true"` // An object which defines the resolutionType and the ruleBasedProperties. // // ResolutionTechniques is a required field ResolutionTechniques *ResolutionTechniques `locationName:"resolutionTechniques" type:"structure" required:"true"` // The Amazon Resource Name (ARN) of the IAM role. Entity Resolution assumes // this role to create resources on your behalf as part of workflow execution. // // RoleArn is a required field RoleArn *string `locationName:"roleArn" type:"string" required:"true"` // The ARN (Amazon Resource Name) that Entity Resolution generated for the MatchingWorkflow. // // WorkflowArn is a required field WorkflowArn *string `locationName:"workflowArn" type:"string" required:"true"` // The name of the workflow. // // WorkflowName is a required field WorkflowName *string `locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CreateMatchingWorkflowOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CreateMatchingWorkflowOutput) GoString() string { return s.String() } // SetDescription sets the Description field's value. func (s *CreateMatchingWorkflowOutput) SetDescription(v string) *CreateMatchingWorkflowOutput { s.Description = &v return s } // SetIncrementalRunConfig sets the IncrementalRunConfig field's value. func (s *CreateMatchingWorkflowOutput) SetIncrementalRunConfig(v *IncrementalRunConfig) *CreateMatchingWorkflowOutput { s.IncrementalRunConfig = v return s } // SetInputSourceConfig sets the InputSourceConfig field's value. func (s *CreateMatchingWorkflowOutput) SetInputSourceConfig(v []*InputSource) *CreateMatchingWorkflowOutput { s.InputSourceConfig = v return s } // SetOutputSourceConfig sets the OutputSourceConfig field's value. func (s *CreateMatchingWorkflowOutput) SetOutputSourceConfig(v []*OutputSource) *CreateMatchingWorkflowOutput { s.OutputSourceConfig = v return s } // SetResolutionTechniques sets the ResolutionTechniques field's value. func (s *CreateMatchingWorkflowOutput) SetResolutionTechniques(v *ResolutionTechniques) *CreateMatchingWorkflowOutput { s.ResolutionTechniques = v return s } // SetRoleArn sets the RoleArn field's value. func (s *CreateMatchingWorkflowOutput) SetRoleArn(v string) *CreateMatchingWorkflowOutput { s.RoleArn = &v return s } // SetWorkflowArn sets the WorkflowArn field's value. func (s *CreateMatchingWorkflowOutput) SetWorkflowArn(v string) *CreateMatchingWorkflowOutput { s.WorkflowArn = &v return s } // SetWorkflowName sets the WorkflowName field's value. func (s *CreateMatchingWorkflowOutput) SetWorkflowName(v string) *CreateMatchingWorkflowOutput { s.WorkflowName = &v return s } type CreateSchemaMappingInput struct { _ struct{} `type:"structure"` // A description of the schema. Description *string `locationName:"description" type:"string"` // A list of MappedInputFields. Each MappedInputField corresponds to a column // the source data table, and contains column name plus additional information // that Entity Resolution uses for matching. // // MappedInputFields is a required field MappedInputFields []*SchemaInputAttribute `locationName:"mappedInputFields" min:"2" type:"list" required:"true"` // The name of the schema. There can't be multiple SchemaMappings with the same // name. // // SchemaName is a required field SchemaName *string `locationName:"schemaName" min:"1" type:"string" required:"true"` // The tags used to organize, track, or control access for this resource. Tags map[string]*string `locationName:"tags" type:"map"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CreateSchemaMappingInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CreateSchemaMappingInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *CreateSchemaMappingInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "CreateSchemaMappingInput"} if s.MappedInputFields == nil { invalidParams.Add(request.NewErrParamRequired("MappedInputFields")) } if s.MappedInputFields != nil && len(s.MappedInputFields) < 2 { invalidParams.Add(request.NewErrParamMinLen("MappedInputFields", 2)) } if s.SchemaName == nil { invalidParams.Add(request.NewErrParamRequired("SchemaName")) } if s.SchemaName != nil && len(*s.SchemaName) < 1 { invalidParams.Add(request.NewErrParamMinLen("SchemaName", 1)) } if s.MappedInputFields != nil { for i, v := range s.MappedInputFields { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "MappedInputFields", i), err.(request.ErrInvalidParams)) } } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetDescription sets the Description field's value. func (s *CreateSchemaMappingInput) SetDescription(v string) *CreateSchemaMappingInput { s.Description = &v return s } // SetMappedInputFields sets the MappedInputFields field's value. func (s *CreateSchemaMappingInput) SetMappedInputFields(v []*SchemaInputAttribute) *CreateSchemaMappingInput { s.MappedInputFields = v return s } // SetSchemaName sets the SchemaName field's value. func (s *CreateSchemaMappingInput) SetSchemaName(v string) *CreateSchemaMappingInput { s.SchemaName = &v return s } // SetTags sets the Tags field's value. func (s *CreateSchemaMappingInput) SetTags(v map[string]*string) *CreateSchemaMappingInput { s.Tags = v return s } type CreateSchemaMappingOutput struct { _ struct{} `type:"structure"` // A description of the schema. // // Description is a required field Description *string `locationName:"description" type:"string" required:"true"` // A list of MappedInputFields. Each MappedInputField corresponds to a column // the source data table, and contains column name plus additional information // that Entity Resolution uses for matching. // // MappedInputFields is a required field MappedInputFields []*SchemaInputAttribute `locationName:"mappedInputFields" min:"2" type:"list" required:"true"` // The ARN (Amazon Resource Name) that Entity Resolution generated for the SchemaMapping. // // SchemaArn is a required field SchemaArn *string `locationName:"schemaArn" type:"string" required:"true"` // The name of the schema. // // SchemaName is a required field SchemaName *string `locationName:"schemaName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CreateSchemaMappingOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CreateSchemaMappingOutput) GoString() string { return s.String() } // SetDescription sets the Description field's value. func (s *CreateSchemaMappingOutput) SetDescription(v string) *CreateSchemaMappingOutput { s.Description = &v return s } // SetMappedInputFields sets the MappedInputFields field's value. func (s *CreateSchemaMappingOutput) SetMappedInputFields(v []*SchemaInputAttribute) *CreateSchemaMappingOutput { s.MappedInputFields = v return s } // SetSchemaArn sets the SchemaArn field's value. func (s *CreateSchemaMappingOutput) SetSchemaArn(v string) *CreateSchemaMappingOutput { s.SchemaArn = &v return s } // SetSchemaName sets the SchemaName field's value. func (s *CreateSchemaMappingOutput) SetSchemaName(v string) *CreateSchemaMappingOutput { s.SchemaName = &v return s } type DeleteIdMappingWorkflowInput struct { _ struct{} `type:"structure" nopayload:"true"` // The name of the workflow to be deleted. // // WorkflowName is a required field WorkflowName *string `location:"uri" locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteIdMappingWorkflowInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteIdMappingWorkflowInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DeleteIdMappingWorkflowInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DeleteIdMappingWorkflowInput"} if s.WorkflowName == nil { invalidParams.Add(request.NewErrParamRequired("WorkflowName")) } if s.WorkflowName != nil && len(*s.WorkflowName) < 1 { invalidParams.Add(request.NewErrParamMinLen("WorkflowName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetWorkflowName sets the WorkflowName field's value. func (s *DeleteIdMappingWorkflowInput) SetWorkflowName(v string) *DeleteIdMappingWorkflowInput { s.WorkflowName = &v return s } type DeleteIdMappingWorkflowOutput struct { _ struct{} `type:"structure"` // A successful operation message. // // Message is a required field Message *string `locationName:"message" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteIdMappingWorkflowOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteIdMappingWorkflowOutput) GoString() string { return s.String() } // SetMessage sets the Message field's value. func (s *DeleteIdMappingWorkflowOutput) SetMessage(v string) *DeleteIdMappingWorkflowOutput { s.Message = &v return s } type DeleteMatchingWorkflowInput struct { _ struct{} `type:"structure" nopayload:"true"` // The name of the workflow to be retrieved. // // WorkflowName is a required field WorkflowName *string `location:"uri" locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteMatchingWorkflowInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteMatchingWorkflowInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DeleteMatchingWorkflowInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DeleteMatchingWorkflowInput"} if s.WorkflowName == nil { invalidParams.Add(request.NewErrParamRequired("WorkflowName")) } if s.WorkflowName != nil && len(*s.WorkflowName) < 1 { invalidParams.Add(request.NewErrParamMinLen("WorkflowName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetWorkflowName sets the WorkflowName field's value. func (s *DeleteMatchingWorkflowInput) SetWorkflowName(v string) *DeleteMatchingWorkflowInput { s.WorkflowName = &v return s } type DeleteMatchingWorkflowOutput struct { _ struct{} `type:"structure"` // A successful operation message. // // Message is a required field Message *string `locationName:"message" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteMatchingWorkflowOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteMatchingWorkflowOutput) GoString() string { return s.String() } // SetMessage sets the Message field's value. func (s *DeleteMatchingWorkflowOutput) SetMessage(v string) *DeleteMatchingWorkflowOutput { s.Message = &v return s } type DeleteSchemaMappingInput struct { _ struct{} `type:"structure" nopayload:"true"` // The name of the schema to delete. // // SchemaName is a required field SchemaName *string `location:"uri" locationName:"schemaName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteSchemaMappingInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteSchemaMappingInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DeleteSchemaMappingInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DeleteSchemaMappingInput"} if s.SchemaName == nil { invalidParams.Add(request.NewErrParamRequired("SchemaName")) } if s.SchemaName != nil && len(*s.SchemaName) < 1 { invalidParams.Add(request.NewErrParamMinLen("SchemaName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetSchemaName sets the SchemaName field's value. func (s *DeleteSchemaMappingInput) SetSchemaName(v string) *DeleteSchemaMappingInput { s.SchemaName = &v return s } type DeleteSchemaMappingOutput struct { _ struct{} `type:"structure"` // A successful operation message. // // Message is a required field Message *string `locationName:"message" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteSchemaMappingOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteSchemaMappingOutput) GoString() string { return s.String() } // SetMessage sets the Message field's value. func (s *DeleteSchemaMappingOutput) SetMessage(v string) *DeleteSchemaMappingOutput { s.Message = &v return s } // An object containing an error message, if there was an error. type ErrorDetails struct { _ struct{} `type:"structure"` // The error message from the job, if there is one. ErrorMessage *string `locationName:"errorMessage" min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ErrorDetails) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ErrorDetails) GoString() string { return s.String() } // SetErrorMessage sets the ErrorMessage field's value. func (s *ErrorDetails) SetErrorMessage(v string) *ErrorDetails { s.ErrorMessage = &v return s } // The request was rejected because it attempted to create resources beyond // the current Entity Resolution account limits. The error message describes // the limit exceeded. HTTP Status Code: 402 type ExceedsLimitException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ *string `locationName:"message" min:"1" type:"string"` // The name of the quota that has been breached. QuotaName *string `locationName:"quotaName" type:"string"` // The current quota value for the customers. QuotaValue *int64 `locationName:"quotaValue" type:"integer"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ExceedsLimitException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ExceedsLimitException) GoString() string { return s.String() } func newErrorExceedsLimitException(v protocol.ResponseMetadata) error { return &ExceedsLimitException{ RespMetadata: v, } } // Code returns the exception type name. func (s *ExceedsLimitException) Code() string { return "ExceedsLimitException" } // Message returns the exception's message. func (s *ExceedsLimitException) Message() string { if s.Message_ != nil { return *s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s *ExceedsLimitException) OrigErr() error { return nil } func (s *ExceedsLimitException) Error() string { return fmt.Sprintf("%s: %s\n%s", s.Code(), s.Message(), s.String()) } // Status code returns the HTTP status code for the request's response error. func (s *ExceedsLimitException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s *ExceedsLimitException) RequestID() string { return s.RespMetadata.RequestID } type GetIdMappingJobInput struct { _ struct{} `type:"structure" nopayload:"true"` // The ID of the job. // // JobId is a required field JobId *string `location:"uri" locationName:"jobId" type:"string" required:"true"` // The name of the workflow. // // WorkflowName is a required field WorkflowName *string `location:"uri" locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetIdMappingJobInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetIdMappingJobInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *GetIdMappingJobInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "GetIdMappingJobInput"} if s.JobId == nil { invalidParams.Add(request.NewErrParamRequired("JobId")) } if s.JobId != nil && len(*s.JobId) < 1 { invalidParams.Add(request.NewErrParamMinLen("JobId", 1)) } if s.WorkflowName == nil { invalidParams.Add(request.NewErrParamRequired("WorkflowName")) } if s.WorkflowName != nil && len(*s.WorkflowName) < 1 { invalidParams.Add(request.NewErrParamMinLen("WorkflowName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetJobId sets the JobId field's value. func (s *GetIdMappingJobInput) SetJobId(v string) *GetIdMappingJobInput { s.JobId = &v return s } // SetWorkflowName sets the WorkflowName field's value. func (s *GetIdMappingJobInput) SetWorkflowName(v string) *GetIdMappingJobInput { s.WorkflowName = &v return s } type GetIdMappingJobOutput struct { _ struct{} `type:"structure"` // The time at which the job has finished. EndTime *time.Time `locationName:"endTime" type:"timestamp"` // An object containing an error message, if there was an error. ErrorDetails *ErrorDetails `locationName:"errorDetails" type:"structure"` // The ID of the job. // // JobId is a required field JobId *string `locationName:"jobId" type:"string" required:"true"` // Metrics associated with the execution, specifically total records processed, // unique IDs generated, and records the execution skipped. Metrics *IdMappingJobMetrics `locationName:"metrics" type:"structure"` // The time at which the job was started. // // StartTime is a required field StartTime *time.Time `locationName:"startTime" type:"timestamp" required:"true"` // The current status of the job. // // Status is a required field Status *string `locationName:"status" type:"string" required:"true" enum:"JobStatus"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetIdMappingJobOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetIdMappingJobOutput) GoString() string { return s.String() } // SetEndTime sets the EndTime field's value. func (s *GetIdMappingJobOutput) SetEndTime(v time.Time) *GetIdMappingJobOutput { s.EndTime = &v return s } // SetErrorDetails sets the ErrorDetails field's value. func (s *GetIdMappingJobOutput) SetErrorDetails(v *ErrorDetails) *GetIdMappingJobOutput { s.ErrorDetails = v return s } // SetJobId sets the JobId field's value. func (s *GetIdMappingJobOutput) SetJobId(v string) *GetIdMappingJobOutput { s.JobId = &v return s } // SetMetrics sets the Metrics field's value. func (s *GetIdMappingJobOutput) SetMetrics(v *IdMappingJobMetrics) *GetIdMappingJobOutput { s.Metrics = v return s } // SetStartTime sets the StartTime field's value. func (s *GetIdMappingJobOutput) SetStartTime(v time.Time) *GetIdMappingJobOutput { s.StartTime = &v return s } // SetStatus sets the Status field's value. func (s *GetIdMappingJobOutput) SetStatus(v string) *GetIdMappingJobOutput { s.Status = &v return s } type GetIdMappingWorkflowInput struct { _ struct{} `type:"structure" nopayload:"true"` // The name of the workflow. // // WorkflowName is a required field WorkflowName *string `location:"uri" locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetIdMappingWorkflowInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetIdMappingWorkflowInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *GetIdMappingWorkflowInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "GetIdMappingWorkflowInput"} if s.WorkflowName == nil { invalidParams.Add(request.NewErrParamRequired("WorkflowName")) } if s.WorkflowName != nil && len(*s.WorkflowName) < 1 { invalidParams.Add(request.NewErrParamMinLen("WorkflowName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetWorkflowName sets the WorkflowName field's value. func (s *GetIdMappingWorkflowInput) SetWorkflowName(v string) *GetIdMappingWorkflowInput { s.WorkflowName = &v return s } type GetIdMappingWorkflowOutput struct { _ struct{} `type:"structure"` // The timestamp of when the workflow was created. // // CreatedAt is a required field CreatedAt *time.Time `locationName:"createdAt" type:"timestamp" required:"true"` // A description of the workflow. Description *string `locationName:"description" type:"string"` // An object which defines the idMappingType and the providerProperties. // // IdMappingTechniques is a required field IdMappingTechniques *IdMappingTechniques `locationName:"idMappingTechniques" type:"structure" required:"true"` // A list of InputSource objects, which have the fields InputSourceARN and SchemaName. // // InputSourceConfig is a required field InputSourceConfig []*IdMappingWorkflowInputSource `locationName:"inputSourceConfig" min:"1" type:"list" required:"true"` // A list of OutputSource objects, each of which contains fields OutputS3Path // and KMSArn. // // OutputSourceConfig is a required field OutputSourceConfig []*IdMappingWorkflowOutputSource `locationName:"outputSourceConfig" min:"1" type:"list" required:"true"` // The Amazon Resource Name (ARN) of the IAM role. Entity Resolution assumes // this role to access resources on your behalf. // // RoleArn is a required field RoleArn *string `locationName:"roleArn" type:"string" required:"true"` // The tags used to organize, track, or control access for this resource. Tags map[string]*string `locationName:"tags" type:"map"` // The timestamp of when the workflow was last updated. // // UpdatedAt is a required field UpdatedAt *time.Time `locationName:"updatedAt" type:"timestamp" required:"true"` // The ARN (Amazon Resource Name) that Entity Resolution generated for the IdMappingWorkflow . // // WorkflowArn is a required field WorkflowArn *string `locationName:"workflowArn" type:"string" required:"true"` // The name of the workflow. // // WorkflowName is a required field WorkflowName *string `locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetIdMappingWorkflowOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetIdMappingWorkflowOutput) GoString() string { return s.String() } // SetCreatedAt sets the CreatedAt field's value. func (s *GetIdMappingWorkflowOutput) SetCreatedAt(v time.Time) *GetIdMappingWorkflowOutput { s.CreatedAt = &v return s } // SetDescription sets the Description field's value. func (s *GetIdMappingWorkflowOutput) SetDescription(v string) *GetIdMappingWorkflowOutput { s.Description = &v return s } // SetIdMappingTechniques sets the IdMappingTechniques field's value. func (s *GetIdMappingWorkflowOutput) SetIdMappingTechniques(v *IdMappingTechniques) *GetIdMappingWorkflowOutput { s.IdMappingTechniques = v return s } // SetInputSourceConfig sets the InputSourceConfig field's value. func (s *GetIdMappingWorkflowOutput) SetInputSourceConfig(v []*IdMappingWorkflowInputSource) *GetIdMappingWorkflowOutput { s.InputSourceConfig = v return s } // SetOutputSourceConfig sets the OutputSourceConfig field's value. func (s *GetIdMappingWorkflowOutput) SetOutputSourceConfig(v []*IdMappingWorkflowOutputSource) *GetIdMappingWorkflowOutput { s.OutputSourceConfig = v return s } // SetRoleArn sets the RoleArn field's value. func (s *GetIdMappingWorkflowOutput) SetRoleArn(v string) *GetIdMappingWorkflowOutput { s.RoleArn = &v return s } // SetTags sets the Tags field's value. func (s *GetIdMappingWorkflowOutput) SetTags(v map[string]*string) *GetIdMappingWorkflowOutput { s.Tags = v return s } // SetUpdatedAt sets the UpdatedAt field's value. func (s *GetIdMappingWorkflowOutput) SetUpdatedAt(v time.Time) *GetIdMappingWorkflowOutput { s.UpdatedAt = &v return s } // SetWorkflowArn sets the WorkflowArn field's value. func (s *GetIdMappingWorkflowOutput) SetWorkflowArn(v string) *GetIdMappingWorkflowOutput { s.WorkflowArn = &v return s } // SetWorkflowName sets the WorkflowName field's value. func (s *GetIdMappingWorkflowOutput) SetWorkflowName(v string) *GetIdMappingWorkflowOutput { s.WorkflowName = &v return s } type GetMatchIdInput struct { _ struct{} `type:"structure"` // The record to fetch the Match ID for. // // Record is a sensitive parameter and its value will be // replaced with "sensitive" in string returned by GetMatchIdInput's // String and GoString methods. // // Record is a required field Record map[string]*string `locationName:"record" type:"map" required:"true" sensitive:"true"` // The name of the workflow. // // WorkflowName is a required field WorkflowName *string `location:"uri" locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetMatchIdInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetMatchIdInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *GetMatchIdInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "GetMatchIdInput"} if s.Record == nil { invalidParams.Add(request.NewErrParamRequired("Record")) } if s.WorkflowName == nil { invalidParams.Add(request.NewErrParamRequired("WorkflowName")) } if s.WorkflowName != nil && len(*s.WorkflowName) < 1 { invalidParams.Add(request.NewErrParamMinLen("WorkflowName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetRecord sets the Record field's value. func (s *GetMatchIdInput) SetRecord(v map[string]*string) *GetMatchIdInput { s.Record = v return s } // SetWorkflowName sets the WorkflowName field's value. func (s *GetMatchIdInput) SetWorkflowName(v string) *GetMatchIdInput { s.WorkflowName = &v return s } type GetMatchIdOutput struct { _ struct{} `type:"structure"` // The unique identifiers for this group of match records. MatchId *string `locationName:"matchId" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetMatchIdOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetMatchIdOutput) GoString() string { return s.String() } // SetMatchId sets the MatchId field's value. func (s *GetMatchIdOutput) SetMatchId(v string) *GetMatchIdOutput { s.MatchId = &v return s } type GetMatchingJobInput struct { _ struct{} `type:"structure" nopayload:"true"` // The ID of the job. // // JobId is a required field JobId *string `location:"uri" locationName:"jobId" type:"string" required:"true"` // The name of the workflow. // // WorkflowName is a required field WorkflowName *string `location:"uri" locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetMatchingJobInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetMatchingJobInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *GetMatchingJobInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "GetMatchingJobInput"} if s.JobId == nil { invalidParams.Add(request.NewErrParamRequired("JobId")) } if s.JobId != nil && len(*s.JobId) < 1 { invalidParams.Add(request.NewErrParamMinLen("JobId", 1)) } if s.WorkflowName == nil { invalidParams.Add(request.NewErrParamRequired("WorkflowName")) } if s.WorkflowName != nil && len(*s.WorkflowName) < 1 { invalidParams.Add(request.NewErrParamMinLen("WorkflowName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetJobId sets the JobId field's value. func (s *GetMatchingJobInput) SetJobId(v string) *GetMatchingJobInput { s.JobId = &v return s } // SetWorkflowName sets the WorkflowName field's value. func (s *GetMatchingJobInput) SetWorkflowName(v string) *GetMatchingJobInput { s.WorkflowName = &v return s } type GetMatchingJobOutput struct { _ struct{} `type:"structure"` // The time at which the job has finished. EndTime *time.Time `locationName:"endTime" type:"timestamp"` // An object containing an error message, if there was an error. ErrorDetails *ErrorDetails `locationName:"errorDetails" type:"structure"` // The ID of the job. // // JobId is a required field JobId *string `locationName:"jobId" type:"string" required:"true"` // Metrics associated with the execution, specifically total records processed, // unique IDs generated, and records the execution skipped. Metrics *JobMetrics `locationName:"metrics" type:"structure"` // The time at which the job was started. // // StartTime is a required field StartTime *time.Time `locationName:"startTime" type:"timestamp" required:"true"` // The current status of the job. // // Status is a required field Status *string `locationName:"status" type:"string" required:"true" enum:"JobStatus"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetMatchingJobOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetMatchingJobOutput) GoString() string { return s.String() } // SetEndTime sets the EndTime field's value. func (s *GetMatchingJobOutput) SetEndTime(v time.Time) *GetMatchingJobOutput { s.EndTime = &v return s } // SetErrorDetails sets the ErrorDetails field's value. func (s *GetMatchingJobOutput) SetErrorDetails(v *ErrorDetails) *GetMatchingJobOutput { s.ErrorDetails = v return s } // SetJobId sets the JobId field's value. func (s *GetMatchingJobOutput) SetJobId(v string) *GetMatchingJobOutput { s.JobId = &v return s } // SetMetrics sets the Metrics field's value. func (s *GetMatchingJobOutput) SetMetrics(v *JobMetrics) *GetMatchingJobOutput { s.Metrics = v return s } // SetStartTime sets the StartTime field's value. func (s *GetMatchingJobOutput) SetStartTime(v time.Time) *GetMatchingJobOutput { s.StartTime = &v return s } // SetStatus sets the Status field's value. func (s *GetMatchingJobOutput) SetStatus(v string) *GetMatchingJobOutput { s.Status = &v return s } type GetMatchingWorkflowInput struct { _ struct{} `type:"structure" nopayload:"true"` // The name of the workflow. // // WorkflowName is a required field WorkflowName *string `location:"uri" locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetMatchingWorkflowInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetMatchingWorkflowInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *GetMatchingWorkflowInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "GetMatchingWorkflowInput"} if s.WorkflowName == nil { invalidParams.Add(request.NewErrParamRequired("WorkflowName")) } if s.WorkflowName != nil && len(*s.WorkflowName) < 1 { invalidParams.Add(request.NewErrParamMinLen("WorkflowName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetWorkflowName sets the WorkflowName field's value. func (s *GetMatchingWorkflowInput) SetWorkflowName(v string) *GetMatchingWorkflowInput { s.WorkflowName = &v return s } type GetMatchingWorkflowOutput struct { _ struct{} `type:"structure"` // The timestamp of when the workflow was created. // // CreatedAt is a required field CreatedAt *time.Time `locationName:"createdAt" type:"timestamp" required:"true"` // A description of the workflow. Description *string `locationName:"description" type:"string"` // An object which defines an incremental run type and has only incrementalRunType // as a field. IncrementalRunConfig *IncrementalRunConfig `locationName:"incrementalRunConfig" type:"structure"` // A list of InputSource objects, which have the fields InputSourceARN and SchemaName. // // InputSourceConfig is a required field InputSourceConfig []*InputSource `locationName:"inputSourceConfig" min:"1" type:"list" required:"true"` // A list of OutputSource objects, each of which contains fields OutputS3Path, // ApplyNormalization, and Output. // // OutputSourceConfig is a required field OutputSourceConfig []*OutputSource `locationName:"outputSourceConfig" min:"1" type:"list" required:"true"` // An object which defines the resolutionType and the ruleBasedProperties. // // ResolutionTechniques is a required field ResolutionTechniques *ResolutionTechniques `locationName:"resolutionTechniques" type:"structure" required:"true"` // The Amazon Resource Name (ARN) of the IAM role. Entity Resolution assumes // this role to access resources on your behalf. // // RoleArn is a required field RoleArn *string `locationName:"roleArn" type:"string" required:"true"` // The tags used to organize, track, or control access for this resource. Tags map[string]*string `locationName:"tags" type:"map"` // The timestamp of when the workflow was last updated. // // UpdatedAt is a required field UpdatedAt *time.Time `locationName:"updatedAt" type:"timestamp" required:"true"` // The ARN (Amazon Resource Name) that Entity Resolution generated for the MatchingWorkflow. // // WorkflowArn is a required field WorkflowArn *string `locationName:"workflowArn" type:"string" required:"true"` // The name of the workflow. // // WorkflowName is a required field WorkflowName *string `locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetMatchingWorkflowOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetMatchingWorkflowOutput) GoString() string { return s.String() } // SetCreatedAt sets the CreatedAt field's value. func (s *GetMatchingWorkflowOutput) SetCreatedAt(v time.Time) *GetMatchingWorkflowOutput { s.CreatedAt = &v return s } // SetDescription sets the Description field's value. func (s *GetMatchingWorkflowOutput) SetDescription(v string) *GetMatchingWorkflowOutput { s.Description = &v return s } // SetIncrementalRunConfig sets the IncrementalRunConfig field's value. func (s *GetMatchingWorkflowOutput) SetIncrementalRunConfig(v *IncrementalRunConfig) *GetMatchingWorkflowOutput { s.IncrementalRunConfig = v return s } // SetInputSourceConfig sets the InputSourceConfig field's value. func (s *GetMatchingWorkflowOutput) SetInputSourceConfig(v []*InputSource) *GetMatchingWorkflowOutput { s.InputSourceConfig = v return s } // SetOutputSourceConfig sets the OutputSourceConfig field's value. func (s *GetMatchingWorkflowOutput) SetOutputSourceConfig(v []*OutputSource) *GetMatchingWorkflowOutput { s.OutputSourceConfig = v return s } // SetResolutionTechniques sets the ResolutionTechniques field's value. func (s *GetMatchingWorkflowOutput) SetResolutionTechniques(v *ResolutionTechniques) *GetMatchingWorkflowOutput { s.ResolutionTechniques = v return s } // SetRoleArn sets the RoleArn field's value. func (s *GetMatchingWorkflowOutput) SetRoleArn(v string) *GetMatchingWorkflowOutput { s.RoleArn = &v return s } // SetTags sets the Tags field's value. func (s *GetMatchingWorkflowOutput) SetTags(v map[string]*string) *GetMatchingWorkflowOutput { s.Tags = v return s } // SetUpdatedAt sets the UpdatedAt field's value. func (s *GetMatchingWorkflowOutput) SetUpdatedAt(v time.Time) *GetMatchingWorkflowOutput { s.UpdatedAt = &v return s } // SetWorkflowArn sets the WorkflowArn field's value. func (s *GetMatchingWorkflowOutput) SetWorkflowArn(v string) *GetMatchingWorkflowOutput { s.WorkflowArn = &v return s } // SetWorkflowName sets the WorkflowName field's value. func (s *GetMatchingWorkflowOutput) SetWorkflowName(v string) *GetMatchingWorkflowOutput { s.WorkflowName = &v return s } type GetSchemaMappingInput struct { _ struct{} `type:"structure" nopayload:"true"` // The name of the schema to be retrieved. // // SchemaName is a required field SchemaName *string `location:"uri" locationName:"schemaName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetSchemaMappingInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetSchemaMappingInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *GetSchemaMappingInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "GetSchemaMappingInput"} if s.SchemaName == nil { invalidParams.Add(request.NewErrParamRequired("SchemaName")) } if s.SchemaName != nil && len(*s.SchemaName) < 1 { invalidParams.Add(request.NewErrParamMinLen("SchemaName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetSchemaName sets the SchemaName field's value. func (s *GetSchemaMappingInput) SetSchemaName(v string) *GetSchemaMappingInput { s.SchemaName = &v return s } type GetSchemaMappingOutput struct { _ struct{} `type:"structure"` // The timestamp of when the SchemaMapping was created. // // CreatedAt is a required field CreatedAt *time.Time `locationName:"createdAt" type:"timestamp" required:"true"` // A description of the schema. Description *string `locationName:"description" type:"string"` // Specifies whether the schema mapping has been applied to a workflow. // // HasWorkflows is a required field HasWorkflows *bool `locationName:"hasWorkflows" type:"boolean" required:"true"` // A list of MappedInputFields. Each MappedInputField corresponds to a column // the source data table, and contains column name plus additional information // Venice uses for matching. // // MappedInputFields is a required field MappedInputFields []*SchemaInputAttribute `locationName:"mappedInputFields" min:"2" type:"list" required:"true"` // The ARN (Amazon Resource Name) that Entity Resolution generated for the SchemaMapping. // // SchemaArn is a required field SchemaArn *string `locationName:"schemaArn" type:"string" required:"true"` // The name of the schema. // // SchemaName is a required field SchemaName *string `locationName:"schemaName" min:"1" type:"string" required:"true"` // The tags used to organize, track, or control access for this resource. Tags map[string]*string `locationName:"tags" type:"map"` // The timestamp of when the SchemaMapping was last updated. // // UpdatedAt is a required field UpdatedAt *time.Time `locationName:"updatedAt" type:"timestamp" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetSchemaMappingOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetSchemaMappingOutput) GoString() string { return s.String() } // SetCreatedAt sets the CreatedAt field's value. func (s *GetSchemaMappingOutput) SetCreatedAt(v time.Time) *GetSchemaMappingOutput { s.CreatedAt = &v return s } // SetDescription sets the Description field's value. func (s *GetSchemaMappingOutput) SetDescription(v string) *GetSchemaMappingOutput { s.Description = &v return s } // SetHasWorkflows sets the HasWorkflows field's value. func (s *GetSchemaMappingOutput) SetHasWorkflows(v bool) *GetSchemaMappingOutput { s.HasWorkflows = &v return s } // SetMappedInputFields sets the MappedInputFields field's value. func (s *GetSchemaMappingOutput) SetMappedInputFields(v []*SchemaInputAttribute) *GetSchemaMappingOutput { s.MappedInputFields = v return s } // SetSchemaArn sets the SchemaArn field's value. func (s *GetSchemaMappingOutput) SetSchemaArn(v string) *GetSchemaMappingOutput { s.SchemaArn = &v return s } // SetSchemaName sets the SchemaName field's value. func (s *GetSchemaMappingOutput) SetSchemaName(v string) *GetSchemaMappingOutput { s.SchemaName = &v return s } // SetTags sets the Tags field's value. func (s *GetSchemaMappingOutput) SetTags(v map[string]*string) *GetSchemaMappingOutput { s.Tags = v return s } // SetUpdatedAt sets the UpdatedAt field's value. func (s *GetSchemaMappingOutput) SetUpdatedAt(v time.Time) *GetSchemaMappingOutput { s.UpdatedAt = &v return s } // An object containing InputRecords, TotalRecordsProcessed, MatchIDs, and RecordsNotProcessed. type IdMappingJobMetrics struct { _ struct{} `type:"structure"` // The total number of input records. InputRecords *int64 `locationName:"inputRecords" type:"integer"` // The total number of records that did not get processed. RecordsNotProcessed *int64 `locationName:"recordsNotProcessed" type:"integer"` // The total number of records processed. TotalRecordsProcessed *int64 `locationName:"totalRecordsProcessed" type:"integer"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s IdMappingJobMetrics) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s IdMappingJobMetrics) GoString() string { return s.String() } // SetInputRecords sets the InputRecords field's value. func (s *IdMappingJobMetrics) SetInputRecords(v int64) *IdMappingJobMetrics { s.InputRecords = &v return s } // SetRecordsNotProcessed sets the RecordsNotProcessed field's value. func (s *IdMappingJobMetrics) SetRecordsNotProcessed(v int64) *IdMappingJobMetrics { s.RecordsNotProcessed = &v return s } // SetTotalRecordsProcessed sets the TotalRecordsProcessed field's value. func (s *IdMappingJobMetrics) SetTotalRecordsProcessed(v int64) *IdMappingJobMetrics { s.TotalRecordsProcessed = &v return s } // An object which defines the ID mapping techniques and provider configurations. type IdMappingTechniques struct { _ struct{} `type:"structure"` // The type of ID mapping. // // IdMappingType is a required field IdMappingType *string `locationName:"idMappingType" type:"string" required:"true" enum:"IdMappingType"` // An object which defines any additional configurations required by the provider // service. // // ProviderProperties is a required field ProviderProperties *ProviderProperties `locationName:"providerProperties" type:"structure" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s IdMappingTechniques) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s IdMappingTechniques) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *IdMappingTechniques) Validate() error { invalidParams := request.ErrInvalidParams{Context: "IdMappingTechniques"} if s.IdMappingType == nil { invalidParams.Add(request.NewErrParamRequired("IdMappingType")) } if s.ProviderProperties == nil { invalidParams.Add(request.NewErrParamRequired("ProviderProperties")) } if s.ProviderProperties != nil { if err := s.ProviderProperties.Validate(); err != nil { invalidParams.AddNested("ProviderProperties", err.(request.ErrInvalidParams)) } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetIdMappingType sets the IdMappingType field's value. func (s *IdMappingTechniques) SetIdMappingType(v string) *IdMappingTechniques { s.IdMappingType = &v return s } // SetProviderProperties sets the ProviderProperties field's value. func (s *IdMappingTechniques) SetProviderProperties(v *ProviderProperties) *IdMappingTechniques { s.ProviderProperties = v return s } // An object containing InputSourceARN and SchemaName. type IdMappingWorkflowInputSource struct { _ struct{} `type:"structure"` // An Gluetable ARN for the input source table. // // InputSourceARN is a required field InputSourceARN *string `locationName:"inputSourceARN" type:"string" required:"true"` // The name of the schema to be retrieved. // // SchemaName is a required field SchemaName *string `locationName:"schemaName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s IdMappingWorkflowInputSource) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s IdMappingWorkflowInputSource) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *IdMappingWorkflowInputSource) Validate() error { invalidParams := request.ErrInvalidParams{Context: "IdMappingWorkflowInputSource"} if s.InputSourceARN == nil { invalidParams.Add(request.NewErrParamRequired("InputSourceARN")) } if s.SchemaName == nil { invalidParams.Add(request.NewErrParamRequired("SchemaName")) } if s.SchemaName != nil && len(*s.SchemaName) < 1 { invalidParams.Add(request.NewErrParamMinLen("SchemaName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetInputSourceARN sets the InputSourceARN field's value. func (s *IdMappingWorkflowInputSource) SetInputSourceARN(v string) *IdMappingWorkflowInputSource { s.InputSourceARN = &v return s } // SetSchemaName sets the SchemaName field's value. func (s *IdMappingWorkflowInputSource) SetSchemaName(v string) *IdMappingWorkflowInputSource { s.SchemaName = &v return s } // The output source for the ID mapping workflow. type IdMappingWorkflowOutputSource struct { _ struct{} `type:"structure"` // Customer KMS ARN for encryption at rest. If not provided, system will use // an Entity Resolution managed KMS key. KMSArn *string `type:"string"` // The S3 path to which Entity Resolution will write the output table. // // OutputS3Path is a required field OutputS3Path *string `locationName:"outputS3Path" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s IdMappingWorkflowOutputSource) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s IdMappingWorkflowOutputSource) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *IdMappingWorkflowOutputSource) Validate() error { invalidParams := request.ErrInvalidParams{Context: "IdMappingWorkflowOutputSource"} if s.OutputS3Path == nil { invalidParams.Add(request.NewErrParamRequired("OutputS3Path")) } if s.OutputS3Path != nil && len(*s.OutputS3Path) < 1 { invalidParams.Add(request.NewErrParamMinLen("OutputS3Path", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetKMSArn sets the KMSArn field's value. func (s *IdMappingWorkflowOutputSource) SetKMSArn(v string) *IdMappingWorkflowOutputSource { s.KMSArn = &v return s } // SetOutputS3Path sets the OutputS3Path field's value. func (s *IdMappingWorkflowOutputSource) SetOutputS3Path(v string) *IdMappingWorkflowOutputSource { s.OutputS3Path = &v return s } // A list of IdMappingWorkflowSummary objects, each of which contain the fields // WorkflowName, WorkflowArn, CreatedAt, and UpdatedAt. type IdMappingWorkflowSummary struct { _ struct{} `type:"structure"` // The timestamp of when the workflow was created. // // CreatedAt is a required field CreatedAt *time.Time `locationName:"createdAt" type:"timestamp" required:"true"` // The timestamp of when the workflow was last updated. // // UpdatedAt is a required field UpdatedAt *time.Time `locationName:"updatedAt" type:"timestamp" required:"true"` // The ARN (Amazon Resource Name) that Entity Resolution generated for the IdMappingWorkflow. // // WorkflowArn is a required field WorkflowArn *string `locationName:"workflowArn" type:"string" required:"true"` // The name of the workflow. // // WorkflowName is a required field WorkflowName *string `locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s IdMappingWorkflowSummary) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s IdMappingWorkflowSummary) GoString() string { return s.String() } // SetCreatedAt sets the CreatedAt field's value. func (s *IdMappingWorkflowSummary) SetCreatedAt(v time.Time) *IdMappingWorkflowSummary { s.CreatedAt = &v return s } // SetUpdatedAt sets the UpdatedAt field's value. func (s *IdMappingWorkflowSummary) SetUpdatedAt(v time.Time) *IdMappingWorkflowSummary { s.UpdatedAt = &v return s } // SetWorkflowArn sets the WorkflowArn field's value. func (s *IdMappingWorkflowSummary) SetWorkflowArn(v string) *IdMappingWorkflowSummary { s.WorkflowArn = &v return s } // SetWorkflowName sets the WorkflowName field's value. func (s *IdMappingWorkflowSummary) SetWorkflowName(v string) *IdMappingWorkflowSummary { s.WorkflowName = &v return s } // An object which defines an incremental run type and has only incrementalRunType // as a field. type IncrementalRunConfig struct { _ struct{} `type:"structure"` // The type of incremental run. It takes only one value: IMMEDIATE. IncrementalRunType *string `locationName:"incrementalRunType" type:"string" enum:"IncrementalRunType"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s IncrementalRunConfig) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s IncrementalRunConfig) GoString() string { return s.String() } // SetIncrementalRunType sets the IncrementalRunType field's value. func (s *IncrementalRunConfig) SetIncrementalRunType(v string) *IncrementalRunConfig { s.IncrementalRunType = &v return s } // An object containing InputSourceARN, SchemaName, and ApplyNormalization. type InputSource struct { _ struct{} `type:"structure"` // Normalizes the attributes defined in the schema in the input data. For example, // if an attribute has an AttributeType of PHONE_NUMBER, and the data in the // input table is in a format of 1234567890, Entity Resolution will normalize // this field in the output to (123)-456-7890. ApplyNormalization *bool `locationName:"applyNormalization" type:"boolean"` // An Glue table ARN for the input source table. // // InputSourceARN is a required field InputSourceARN *string `locationName:"inputSourceARN" type:"string" required:"true"` // The name of the schema to be retrieved. // // SchemaName is a required field SchemaName *string `locationName:"schemaName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InputSource) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InputSource) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *InputSource) Validate() error { invalidParams := request.ErrInvalidParams{Context: "InputSource"} if s.InputSourceARN == nil { invalidParams.Add(request.NewErrParamRequired("InputSourceARN")) } if s.SchemaName == nil { invalidParams.Add(request.NewErrParamRequired("SchemaName")) } if s.SchemaName != nil && len(*s.SchemaName) < 1 { invalidParams.Add(request.NewErrParamMinLen("SchemaName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetApplyNormalization sets the ApplyNormalization field's value. func (s *InputSource) SetApplyNormalization(v bool) *InputSource { s.ApplyNormalization = &v return s } // SetInputSourceARN sets the InputSourceARN field's value. func (s *InputSource) SetInputSourceARN(v string) *InputSource { s.InputSourceARN = &v return s } // SetSchemaName sets the SchemaName field's value. func (s *InputSource) SetSchemaName(v string) *InputSource { s.SchemaName = &v return s } // The Amazon S3 location that temporarily stores your data while it processes. // Your information won't be saved permanently. type IntermediateSourceConfiguration struct { _ struct{} `type:"structure"` // The Amazon S3 location (bucket and prefix). For example: s3://provider_bucket/DOC-EXAMPLE-BUCKET // // IntermediateS3Path is a required field IntermediateS3Path *string `locationName:"intermediateS3Path" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s IntermediateSourceConfiguration) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s IntermediateSourceConfiguration) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *IntermediateSourceConfiguration) Validate() error { invalidParams := request.ErrInvalidParams{Context: "IntermediateSourceConfiguration"} if s.IntermediateS3Path == nil { invalidParams.Add(request.NewErrParamRequired("IntermediateS3Path")) } if s.IntermediateS3Path != nil && len(*s.IntermediateS3Path) < 1 { invalidParams.Add(request.NewErrParamMinLen("IntermediateS3Path", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetIntermediateS3Path sets the IntermediateS3Path field's value. func (s *IntermediateSourceConfiguration) SetIntermediateS3Path(v string) *IntermediateSourceConfiguration { s.IntermediateS3Path = &v return s } // This exception occurs when there is an internal failure in the Entity Resolution // service. HTTP Status Code: 500 type InternalServerException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ *string `locationName:"message" min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InternalServerException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InternalServerException) GoString() string { return s.String() } func newErrorInternalServerException(v protocol.ResponseMetadata) error { return &InternalServerException{ RespMetadata: v, } } // Code returns the exception type name. func (s *InternalServerException) Code() string { return "InternalServerException" } // Message returns the exception's message. func (s *InternalServerException) Message() string { if s.Message_ != nil { return *s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s *InternalServerException) OrigErr() error { return nil } func (s *InternalServerException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s *InternalServerException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s *InternalServerException) RequestID() string { return s.RespMetadata.RequestID } // An object containing InputRecords, TotalRecordsProcessed, MatchIDs, and RecordsNotProcessed. type JobMetrics struct { _ struct{} `type:"structure"` // The total number of input records. InputRecords *int64 `locationName:"inputRecords" type:"integer"` // The total number of matchIDs generated. MatchIDs *int64 `locationName:"matchIDs" type:"integer"` // The total number of records that did not get processed. RecordsNotProcessed *int64 `locationName:"recordsNotProcessed" type:"integer"` // The total number of records processed. TotalRecordsProcessed *int64 `locationName:"totalRecordsProcessed" type:"integer"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s JobMetrics) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s JobMetrics) GoString() string { return s.String() } // SetInputRecords sets the InputRecords field's value. func (s *JobMetrics) SetInputRecords(v int64) *JobMetrics { s.InputRecords = &v return s } // SetMatchIDs sets the MatchIDs field's value. func (s *JobMetrics) SetMatchIDs(v int64) *JobMetrics { s.MatchIDs = &v return s } // SetRecordsNotProcessed sets the RecordsNotProcessed field's value. func (s *JobMetrics) SetRecordsNotProcessed(v int64) *JobMetrics { s.RecordsNotProcessed = &v return s } // SetTotalRecordsProcessed sets the TotalRecordsProcessed field's value. func (s *JobMetrics) SetTotalRecordsProcessed(v int64) *JobMetrics { s.TotalRecordsProcessed = &v return s } // An object containing the JobId, Status, StartTime, and EndTime of a job. type JobSummary struct { _ struct{} `type:"structure"` // The time at which the job has finished. EndTime *time.Time `locationName:"endTime" type:"timestamp"` // The ID of the job. // // JobId is a required field JobId *string `locationName:"jobId" type:"string" required:"true"` // The time at which the job was started. // // StartTime is a required field StartTime *time.Time `locationName:"startTime" type:"timestamp" required:"true"` // The current status of the job. // // Status is a required field Status *string `locationName:"status" type:"string" required:"true" enum:"JobStatus"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s JobSummary) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s JobSummary) GoString() string { return s.String() } // SetEndTime sets the EndTime field's value. func (s *JobSummary) SetEndTime(v time.Time) *JobSummary { s.EndTime = &v return s } // SetJobId sets the JobId field's value. func (s *JobSummary) SetJobId(v string) *JobSummary { s.JobId = &v return s } // SetStartTime sets the StartTime field's value. func (s *JobSummary) SetStartTime(v time.Time) *JobSummary { s.StartTime = &v return s } // SetStatus sets the Status field's value. func (s *JobSummary) SetStatus(v string) *JobSummary { s.Status = &v return s } type ListIdMappingJobsInput struct { _ struct{} `type:"structure" nopayload:"true"` // The maximum number of objects returned per page. MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` // The pagination token from the previous API call. NextToken *string `location:"querystring" locationName:"nextToken" min:"1" type:"string"` // The name of the workflow to be retrieved. // // WorkflowName is a required field WorkflowName *string `location:"uri" locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListIdMappingJobsInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListIdMappingJobsInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListIdMappingJobsInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListIdMappingJobsInput"} if s.MaxResults != nil && *s.MaxResults < 1 { invalidParams.Add(request.NewErrParamMinValue("MaxResults", 1)) } if s.NextToken != nil && len(*s.NextToken) < 1 { invalidParams.Add(request.NewErrParamMinLen("NextToken", 1)) } if s.WorkflowName == nil { invalidParams.Add(request.NewErrParamRequired("WorkflowName")) } if s.WorkflowName != nil && len(*s.WorkflowName) < 1 { invalidParams.Add(request.NewErrParamMinLen("WorkflowName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetMaxResults sets the MaxResults field's value. func (s *ListIdMappingJobsInput) SetMaxResults(v int64) *ListIdMappingJobsInput { s.MaxResults = &v return s } // SetNextToken sets the NextToken field's value. func (s *ListIdMappingJobsInput) SetNextToken(v string) *ListIdMappingJobsInput { s.NextToken = &v return s } // SetWorkflowName sets the WorkflowName field's value. func (s *ListIdMappingJobsInput) SetWorkflowName(v string) *ListIdMappingJobsInput { s.WorkflowName = &v return s } type ListIdMappingJobsOutput struct { _ struct{} `type:"structure"` // A list of JobSummary objects. Jobs []*JobSummary `locationName:"jobs" type:"list"` // The pagination token from the previous API call. NextToken *string `locationName:"nextToken" min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListIdMappingJobsOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListIdMappingJobsOutput) GoString() string { return s.String() } // SetJobs sets the Jobs field's value. func (s *ListIdMappingJobsOutput) SetJobs(v []*JobSummary) *ListIdMappingJobsOutput { s.Jobs = v return s } // SetNextToken sets the NextToken field's value. func (s *ListIdMappingJobsOutput) SetNextToken(v string) *ListIdMappingJobsOutput { s.NextToken = &v return s } type ListIdMappingWorkflowsInput struct { _ struct{} `type:"structure" nopayload:"true"` // The maximum number of objects returned per page. MaxResults *int64 `location:"querystring" locationName:"maxResults" type:"integer"` // The pagination token from the previous API call. NextToken *string `location:"querystring" locationName:"nextToken" min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListIdMappingWorkflowsInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListIdMappingWorkflowsInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListIdMappingWorkflowsInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListIdMappingWorkflowsInput"} if s.NextToken != nil && len(*s.NextToken) < 1 { invalidParams.Add(request.NewErrParamMinLen("NextToken", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetMaxResults sets the MaxResults field's value. func (s *ListIdMappingWorkflowsInput) SetMaxResults(v int64) *ListIdMappingWorkflowsInput { s.MaxResults = &v return s } // SetNextToken sets the NextToken field's value. func (s *ListIdMappingWorkflowsInput) SetNextToken(v string) *ListIdMappingWorkflowsInput { s.NextToken = &v return s } type ListIdMappingWorkflowsOutput struct { _ struct{} `type:"structure"` // The pagination token from the previous API call. NextToken *string `locationName:"nextToken" min:"1" type:"string"` // A list of IdMappingWorkflowSummary objects. WorkflowSummaries []*IdMappingWorkflowSummary `locationName:"workflowSummaries" type:"list"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListIdMappingWorkflowsOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListIdMappingWorkflowsOutput) GoString() string { return s.String() } // SetNextToken sets the NextToken field's value. func (s *ListIdMappingWorkflowsOutput) SetNextToken(v string) *ListIdMappingWorkflowsOutput { s.NextToken = &v return s } // SetWorkflowSummaries sets the WorkflowSummaries field's value. func (s *ListIdMappingWorkflowsOutput) SetWorkflowSummaries(v []*IdMappingWorkflowSummary) *ListIdMappingWorkflowsOutput { s.WorkflowSummaries = v return s } type ListMatchingJobsInput struct { _ struct{} `type:"structure" nopayload:"true"` // The maximum number of objects returned per page. MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` // The pagination token from the previous API call. NextToken *string `location:"querystring" locationName:"nextToken" min:"1" type:"string"` // The name of the workflow to be retrieved. // // WorkflowName is a required field WorkflowName *string `location:"uri" locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListMatchingJobsInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListMatchingJobsInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListMatchingJobsInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListMatchingJobsInput"} if s.MaxResults != nil && *s.MaxResults < 1 { invalidParams.Add(request.NewErrParamMinValue("MaxResults", 1)) } if s.NextToken != nil && len(*s.NextToken) < 1 { invalidParams.Add(request.NewErrParamMinLen("NextToken", 1)) } if s.WorkflowName == nil { invalidParams.Add(request.NewErrParamRequired("WorkflowName")) } if s.WorkflowName != nil && len(*s.WorkflowName) < 1 { invalidParams.Add(request.NewErrParamMinLen("WorkflowName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetMaxResults sets the MaxResults field's value. func (s *ListMatchingJobsInput) SetMaxResults(v int64) *ListMatchingJobsInput { s.MaxResults = &v return s } // SetNextToken sets the NextToken field's value. func (s *ListMatchingJobsInput) SetNextToken(v string) *ListMatchingJobsInput { s.NextToken = &v return s } // SetWorkflowName sets the WorkflowName field's value. func (s *ListMatchingJobsInput) SetWorkflowName(v string) *ListMatchingJobsInput { s.WorkflowName = &v return s } type ListMatchingJobsOutput struct { _ struct{} `type:"structure"` // A list of JobSummary objects, each of which contain the ID, status, start // time, and end time of a job. Jobs []*JobSummary `locationName:"jobs" type:"list"` // The pagination token from the previous API call. NextToken *string `locationName:"nextToken" min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListMatchingJobsOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListMatchingJobsOutput) GoString() string { return s.String() } // SetJobs sets the Jobs field's value. func (s *ListMatchingJobsOutput) SetJobs(v []*JobSummary) *ListMatchingJobsOutput { s.Jobs = v return s } // SetNextToken sets the NextToken field's value. func (s *ListMatchingJobsOutput) SetNextToken(v string) *ListMatchingJobsOutput { s.NextToken = &v return s } type ListMatchingWorkflowsInput struct { _ struct{} `type:"structure" nopayload:"true"` // The maximum number of objects returned per page. MaxResults *int64 `location:"querystring" locationName:"maxResults" type:"integer"` // The pagination token from the previous API call. NextToken *string `location:"querystring" locationName:"nextToken" min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListMatchingWorkflowsInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListMatchingWorkflowsInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListMatchingWorkflowsInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListMatchingWorkflowsInput"} if s.NextToken != nil && len(*s.NextToken) < 1 { invalidParams.Add(request.NewErrParamMinLen("NextToken", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetMaxResults sets the MaxResults field's value. func (s *ListMatchingWorkflowsInput) SetMaxResults(v int64) *ListMatchingWorkflowsInput { s.MaxResults = &v return s } // SetNextToken sets the NextToken field's value. func (s *ListMatchingWorkflowsInput) SetNextToken(v string) *ListMatchingWorkflowsInput { s.NextToken = &v return s } type ListMatchingWorkflowsOutput struct { _ struct{} `type:"structure"` // The pagination token from the previous API call. NextToken *string `locationName:"nextToken" min:"1" type:"string"` // A list of MatchingWorkflowSummary objects, each of which contain the fields // WorkflowName, WorkflowArn, CreatedAt, and UpdatedAt. WorkflowSummaries []*MatchingWorkflowSummary `locationName:"workflowSummaries" type:"list"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListMatchingWorkflowsOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListMatchingWorkflowsOutput) GoString() string { return s.String() } // SetNextToken sets the NextToken field's value. func (s *ListMatchingWorkflowsOutput) SetNextToken(v string) *ListMatchingWorkflowsOutput { s.NextToken = &v return s } // SetWorkflowSummaries sets the WorkflowSummaries field's value. func (s *ListMatchingWorkflowsOutput) SetWorkflowSummaries(v []*MatchingWorkflowSummary) *ListMatchingWorkflowsOutput { s.WorkflowSummaries = v return s } type ListProviderServicesInput struct { _ struct{} `type:"structure" nopayload:"true"` // The maximum number of objects returned per page. MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"15" type:"integer"` // The pagination token from the previous API call. NextToken *string `location:"querystring" locationName:"nextToken" min:"1" type:"string"` // The name of the provider. This name is typically the company name. ProviderName *string `location:"querystring" locationName:"providerName" min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListProviderServicesInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListProviderServicesInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListProviderServicesInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListProviderServicesInput"} if s.MaxResults != nil && *s.MaxResults < 15 { invalidParams.Add(request.NewErrParamMinValue("MaxResults", 15)) } if s.NextToken != nil && len(*s.NextToken) < 1 { invalidParams.Add(request.NewErrParamMinLen("NextToken", 1)) } if s.ProviderName != nil && len(*s.ProviderName) < 1 { invalidParams.Add(request.NewErrParamMinLen("ProviderName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetMaxResults sets the MaxResults field's value. func (s *ListProviderServicesInput) SetMaxResults(v int64) *ListProviderServicesInput { s.MaxResults = &v return s } // SetNextToken sets the NextToken field's value. func (s *ListProviderServicesInput) SetNextToken(v string) *ListProviderServicesInput { s.NextToken = &v return s } // SetProviderName sets the ProviderName field's value. func (s *ListProviderServicesInput) SetProviderName(v string) *ListProviderServicesInput { s.ProviderName = &v return s } type ListProviderServicesOutput struct { _ struct{} `type:"structure"` // The pagination token from the previous API call. NextToken *string `locationName:"nextToken" min:"1" type:"string"` // A list of ProviderServices objects. ProviderServiceSummaries []*ProviderServiceSummary `locationName:"providerServiceSummaries" type:"list"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListProviderServicesOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListProviderServicesOutput) GoString() string { return s.String() } // SetNextToken sets the NextToken field's value. func (s *ListProviderServicesOutput) SetNextToken(v string) *ListProviderServicesOutput { s.NextToken = &v return s } // SetProviderServiceSummaries sets the ProviderServiceSummaries field's value. func (s *ListProviderServicesOutput) SetProviderServiceSummaries(v []*ProviderServiceSummary) *ListProviderServicesOutput { s.ProviderServiceSummaries = v return s } type ListSchemaMappingsInput struct { _ struct{} `type:"structure" nopayload:"true"` // The maximum number of objects returned per page. MaxResults *int64 `location:"querystring" locationName:"maxResults" type:"integer"` // The pagination token from the previous API call. NextToken *string `location:"querystring" locationName:"nextToken" min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListSchemaMappingsInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListSchemaMappingsInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListSchemaMappingsInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListSchemaMappingsInput"} if s.NextToken != nil && len(*s.NextToken) < 1 { invalidParams.Add(request.NewErrParamMinLen("NextToken", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetMaxResults sets the MaxResults field's value. func (s *ListSchemaMappingsInput) SetMaxResults(v int64) *ListSchemaMappingsInput { s.MaxResults = &v return s } // SetNextToken sets the NextToken field's value. func (s *ListSchemaMappingsInput) SetNextToken(v string) *ListSchemaMappingsInput { s.NextToken = &v return s } type ListSchemaMappingsOutput struct { _ struct{} `type:"structure"` // The pagination token from the previous API call. NextToken *string `locationName:"nextToken" min:"1" type:"string"` // A list of SchemaMappingSummary objects, each of which contain the fields // SchemaName, SchemaArn, CreatedAt, UpdatedAt. SchemaList []*SchemaMappingSummary `locationName:"schemaList" type:"list"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListSchemaMappingsOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListSchemaMappingsOutput) GoString() string { return s.String() } // SetNextToken sets the NextToken field's value. func (s *ListSchemaMappingsOutput) SetNextToken(v string) *ListSchemaMappingsOutput { s.NextToken = &v return s } // SetSchemaList sets the SchemaList field's value. func (s *ListSchemaMappingsOutput) SetSchemaList(v []*SchemaMappingSummary) *ListSchemaMappingsOutput { s.SchemaList = v return s } type ListTagsForResourceInput struct { _ struct{} `type:"structure" nopayload:"true"` // The ARN of the resource for which you want to view tags. // // ResourceArn is a required field ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListTagsForResourceInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListTagsForResourceInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListTagsForResourceInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListTagsForResourceInput"} if s.ResourceArn == nil { invalidParams.Add(request.NewErrParamRequired("ResourceArn")) } if s.ResourceArn != nil && len(*s.ResourceArn) < 1 { invalidParams.Add(request.NewErrParamMinLen("ResourceArn", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetResourceArn sets the ResourceArn field's value. func (s *ListTagsForResourceInput) SetResourceArn(v string) *ListTagsForResourceInput { s.ResourceArn = &v return s } type ListTagsForResourceOutput struct { _ struct{} `type:"structure"` // The tags used to organize, track, or control access for this resource. // // Tags is a required field Tags map[string]*string `locationName:"tags" type:"map" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListTagsForResourceOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListTagsForResourceOutput) GoString() string { return s.String() } // SetTags sets the Tags field's value. func (s *ListTagsForResourceOutput) SetTags(v map[string]*string) *ListTagsForResourceOutput { s.Tags = v return s } // A list of MatchingWorkflowSummary objects, each of which contain the fields // WorkflowName, WorkflowArn, CreatedAt, UpdatedAt. type MatchingWorkflowSummary struct { _ struct{} `type:"structure"` // The timestamp of when the workflow was created. // // CreatedAt is a required field CreatedAt *time.Time `locationName:"createdAt" type:"timestamp" required:"true"` // The method that has been specified for data matching, either using matching // provided by Entity Resolution or through a provider service. // // ResolutionType is a required field ResolutionType *string `locationName:"resolutionType" type:"string" required:"true" enum:"ResolutionType"` // The timestamp of when the workflow was last updated. // // UpdatedAt is a required field UpdatedAt *time.Time `locationName:"updatedAt" type:"timestamp" required:"true"` // The ARN (Amazon Resource Name) that Entity Resolution generated for the MatchingWorkflow. // // WorkflowArn is a required field WorkflowArn *string `locationName:"workflowArn" type:"string" required:"true"` // The name of the workflow. // // WorkflowName is a required field WorkflowName *string `locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s MatchingWorkflowSummary) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s MatchingWorkflowSummary) GoString() string { return s.String() } // SetCreatedAt sets the CreatedAt field's value. func (s *MatchingWorkflowSummary) SetCreatedAt(v time.Time) *MatchingWorkflowSummary { s.CreatedAt = &v return s } // SetResolutionType sets the ResolutionType field's value. func (s *MatchingWorkflowSummary) SetResolutionType(v string) *MatchingWorkflowSummary { s.ResolutionType = &v return s } // SetUpdatedAt sets the UpdatedAt field's value. func (s *MatchingWorkflowSummary) SetUpdatedAt(v time.Time) *MatchingWorkflowSummary { s.UpdatedAt = &v return s } // SetWorkflowArn sets the WorkflowArn field's value. func (s *MatchingWorkflowSummary) SetWorkflowArn(v string) *MatchingWorkflowSummary { s.WorkflowArn = &v return s } // SetWorkflowName sets the WorkflowName field's value. func (s *MatchingWorkflowSummary) SetWorkflowName(v string) *MatchingWorkflowSummary { s.WorkflowName = &v return s } // A list of OutputAttribute objects, each of which have the fields Name and // Hashed. Each of these objects selects a column to be included in the output // table, and whether the values of the column should be hashed. type OutputAttribute struct { _ struct{} `type:"structure"` // Enables the ability to hash the column values in the output. Hashed *bool `locationName:"hashed" type:"boolean"` // A name of a column to be written to the output. This must be an InputField // name in the schema mapping. // // Name is a required field Name *string `locationName:"name" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s OutputAttribute) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s OutputAttribute) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *OutputAttribute) Validate() error { invalidParams := request.ErrInvalidParams{Context: "OutputAttribute"} if s.Name == nil { invalidParams.Add(request.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetHashed sets the Hashed field's value. func (s *OutputAttribute) SetHashed(v bool) *OutputAttribute { s.Hashed = &v return s } // SetName sets the Name field's value. func (s *OutputAttribute) SetName(v string) *OutputAttribute { s.Name = &v return s } // A list of OutputAttribute objects, each of which have the fields Name and // Hashed. Each of these objects selects a column to be included in the output // table, and whether the values of the column should be hashed. type OutputSource struct { _ struct{} `type:"structure"` // Normalizes the attributes defined in the schema in the input data. For example, // if an attribute has an AttributeType of PHONE_NUMBER, and the data in the // input table is in a format of 1234567890, Entity Resolution will normalize // this field in the output to (123)-456-7890. ApplyNormalization *bool `locationName:"applyNormalization" type:"boolean"` // Customer KMS ARN for encryption at rest. If not provided, system will use // an Entity Resolution managed KMS key. KMSArn *string `type:"string"` // A list of OutputAttribute objects, each of which have the fields Name and // Hashed. Each of these objects selects a column to be included in the output // table, and whether the values of the column should be hashed. // // Output is a required field Output []*OutputAttribute `locationName:"output" type:"list" required:"true"` // The S3 path to which Entity Resolution will write the output table. // // OutputS3Path is a required field OutputS3Path *string `locationName:"outputS3Path" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s OutputSource) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s OutputSource) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *OutputSource) Validate() error { invalidParams := request.ErrInvalidParams{Context: "OutputSource"} if s.Output == nil { invalidParams.Add(request.NewErrParamRequired("Output")) } if s.OutputS3Path == nil { invalidParams.Add(request.NewErrParamRequired("OutputS3Path")) } if s.OutputS3Path != nil && len(*s.OutputS3Path) < 1 { invalidParams.Add(request.NewErrParamMinLen("OutputS3Path", 1)) } if s.Output != nil { for i, v := range s.Output { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "Output", i), err.(request.ErrInvalidParams)) } } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetApplyNormalization sets the ApplyNormalization field's value. func (s *OutputSource) SetApplyNormalization(v bool) *OutputSource { s.ApplyNormalization = &v return s } // SetKMSArn sets the KMSArn field's value. func (s *OutputSource) SetKMSArn(v string) *OutputSource { s.KMSArn = &v return s } // SetOutput sets the Output field's value. func (s *OutputSource) SetOutput(v []*OutputAttribute) *OutputSource { s.Output = v return s } // SetOutputS3Path sets the OutputS3Path field's value. func (s *OutputSource) SetOutputS3Path(v string) *OutputSource { s.OutputS3Path = &v return s } // An object containing the providerServiceARN, intermediateSourceConfiguration, // and providerConfiguration. type ProviderProperties struct { _ struct{} `type:"structure"` // The Amazon S3 location that temporarily stores your data while it processes. // Your information won't be saved permanently. IntermediateSourceConfiguration *IntermediateSourceConfiguration `locationName:"intermediateSourceConfiguration" type:"structure"` // The ARN of the provider service. // // ProviderServiceArn is a required field ProviderServiceArn *string `locationName:"providerServiceArn" min:"20" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ProviderProperties) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ProviderProperties) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ProviderProperties) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ProviderProperties"} if s.ProviderServiceArn == nil { invalidParams.Add(request.NewErrParamRequired("ProviderServiceArn")) } if s.ProviderServiceArn != nil && len(*s.ProviderServiceArn) < 20 { invalidParams.Add(request.NewErrParamMinLen("ProviderServiceArn", 20)) } if s.IntermediateSourceConfiguration != nil { if err := s.IntermediateSourceConfiguration.Validate(); err != nil { invalidParams.AddNested("IntermediateSourceConfiguration", err.(request.ErrInvalidParams)) } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetIntermediateSourceConfiguration sets the IntermediateSourceConfiguration field's value. func (s *ProviderProperties) SetIntermediateSourceConfiguration(v *IntermediateSourceConfiguration) *ProviderProperties { s.IntermediateSourceConfiguration = v return s } // SetProviderServiceArn sets the ProviderServiceArn field's value. func (s *ProviderProperties) SetProviderServiceArn(v string) *ProviderProperties { s.ProviderServiceArn = &v return s } // A list of ProviderService objects, each of which contain the fields providerName, // providerServiceArn, providerServiceName, and providerServiceType. type ProviderServiceSummary struct { _ struct{} `type:"structure"` // The name of the provider. This name is typically the company name. // // ProviderName is a required field ProviderName *string `locationName:"providerName" min:"1" type:"string" required:"true"` // The ARN (Amazon Resource Name) that Entity Resolution generated for the providerService. // // ProviderServiceArn is a required field ProviderServiceArn *string `locationName:"providerServiceArn" min:"20" type:"string" required:"true"` // The display name of the provider service. // // ProviderServiceDisplayName is a required field ProviderServiceDisplayName *string `locationName:"providerServiceDisplayName" type:"string" required:"true"` // The name of the product that the provider service provides. // // ProviderServiceName is a required field ProviderServiceName *string `locationName:"providerServiceName" min:"1" type:"string" required:"true"` // The type of provider service. // // ProviderServiceType is a required field ProviderServiceType *string `locationName:"providerServiceType" type:"string" required:"true" enum:"ServiceType"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ProviderServiceSummary) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ProviderServiceSummary) GoString() string { return s.String() } // SetProviderName sets the ProviderName field's value. func (s *ProviderServiceSummary) SetProviderName(v string) *ProviderServiceSummary { s.ProviderName = &v return s } // SetProviderServiceArn sets the ProviderServiceArn field's value. func (s *ProviderServiceSummary) SetProviderServiceArn(v string) *ProviderServiceSummary { s.ProviderServiceArn = &v return s } // SetProviderServiceDisplayName sets the ProviderServiceDisplayName field's value. func (s *ProviderServiceSummary) SetProviderServiceDisplayName(v string) *ProviderServiceSummary { s.ProviderServiceDisplayName = &v return s } // SetProviderServiceName sets the ProviderServiceName field's value. func (s *ProviderServiceSummary) SetProviderServiceName(v string) *ProviderServiceSummary { s.ProviderServiceName = &v return s } // SetProviderServiceType sets the ProviderServiceType field's value. func (s *ProviderServiceSummary) SetProviderServiceType(v string) *ProviderServiceSummary { s.ProviderServiceType = &v return s } // An object which defines the resolutionType and the ruleBasedProperties. type ResolutionTechniques struct { _ struct{} `type:"structure"` // The properties of the provider service. ProviderProperties *ProviderProperties `locationName:"providerProperties" type:"structure"` // The type of matching. There are two types of matching: RULE_MATCHING and // ML_MATCHING. // // ResolutionType is a required field ResolutionType *string `locationName:"resolutionType" type:"string" required:"true" enum:"ResolutionType"` // An object which defines the list of matching rules to run and has a field // Rules, which is a list of rule objects. RuleBasedProperties *RuleBasedProperties `locationName:"ruleBasedProperties" type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ResolutionTechniques) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ResolutionTechniques) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ResolutionTechniques) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ResolutionTechniques"} if s.ResolutionType == nil { invalidParams.Add(request.NewErrParamRequired("ResolutionType")) } if s.ProviderProperties != nil { if err := s.ProviderProperties.Validate(); err != nil { invalidParams.AddNested("ProviderProperties", err.(request.ErrInvalidParams)) } } if s.RuleBasedProperties != nil { if err := s.RuleBasedProperties.Validate(); err != nil { invalidParams.AddNested("RuleBasedProperties", err.(request.ErrInvalidParams)) } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetProviderProperties sets the ProviderProperties field's value. func (s *ResolutionTechniques) SetProviderProperties(v *ProviderProperties) *ResolutionTechniques { s.ProviderProperties = v return s } // SetResolutionType sets the ResolutionType field's value. func (s *ResolutionTechniques) SetResolutionType(v string) *ResolutionTechniques { s.ResolutionType = &v return s } // SetRuleBasedProperties sets the RuleBasedProperties field's value. func (s *ResolutionTechniques) SetRuleBasedProperties(v *RuleBasedProperties) *ResolutionTechniques { s.RuleBasedProperties = v return s } // The resource could not be found. HTTP Status Code: 404 type ResourceNotFoundException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ *string `locationName:"message" min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ResourceNotFoundException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ResourceNotFoundException) GoString() string { return s.String() } func newErrorResourceNotFoundException(v protocol.ResponseMetadata) error { return &ResourceNotFoundException{ RespMetadata: v, } } // Code returns the exception type name. func (s *ResourceNotFoundException) Code() string { return "ResourceNotFoundException" } // Message returns the exception's message. func (s *ResourceNotFoundException) Message() string { if s.Message_ != nil { return *s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s *ResourceNotFoundException) OrigErr() error { return nil } func (s *ResourceNotFoundException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s *ResourceNotFoundException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s *ResourceNotFoundException) RequestID() string { return s.RespMetadata.RequestID } // An object containing RuleName, and MatchingKeys. type Rule struct { _ struct{} `type:"structure"` // A list of MatchingKeys. The MatchingKeys must have been defined in the SchemaMapping. // Two records are considered to match according to this rule if all of the // MatchingKeys match. // // MatchingKeys is a required field MatchingKeys []*string `locationName:"matchingKeys" min:"1" type:"list" required:"true"` // A name for the matching rule. // // RuleName is a required field RuleName *string `locationName:"ruleName" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s Rule) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s Rule) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *Rule) Validate() error { invalidParams := request.ErrInvalidParams{Context: "Rule"} if s.MatchingKeys == nil { invalidParams.Add(request.NewErrParamRequired("MatchingKeys")) } if s.MatchingKeys != nil && len(s.MatchingKeys) < 1 { invalidParams.Add(request.NewErrParamMinLen("MatchingKeys", 1)) } if s.RuleName == nil { invalidParams.Add(request.NewErrParamRequired("RuleName")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetMatchingKeys sets the MatchingKeys field's value. func (s *Rule) SetMatchingKeys(v []*string) *Rule { s.MatchingKeys = v return s } // SetRuleName sets the RuleName field's value. func (s *Rule) SetRuleName(v string) *Rule { s.RuleName = &v return s } // An object which defines the list of matching rules to run and has a field // Rules, which is a list of rule objects. type RuleBasedProperties struct { _ struct{} `type:"structure"` // The comparison type. You can either choose ONE_TO_ONE or MANY_TO_MANY as // the AttributeMatchingModel. When choosing MANY_TO_MANY, the system can match // attributes across the sub-types of an attribute type. For example, if the // value of the Email field of Profile A and the value of BusinessEmail field // of Profile B matches, the two profiles are matched on the Email type. When // choosing ONE_TO_ONE ,the system can only match if the sub-types are exact // matches. For example, only when the value of the Email field of Profile A // and the value of the Email field of Profile B matches, the two profiles are // matched on the Email type. // // AttributeMatchingModel is a required field AttributeMatchingModel *string `locationName:"attributeMatchingModel" type:"string" required:"true" enum:"AttributeMatchingModel"` // A list of Rule objects, each of which have fields RuleName and MatchingKeys. // // Rules is a required field Rules []*Rule `locationName:"rules" min:"1" type:"list" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s RuleBasedProperties) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s RuleBasedProperties) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *RuleBasedProperties) Validate() error { invalidParams := request.ErrInvalidParams{Context: "RuleBasedProperties"} if s.AttributeMatchingModel == nil { invalidParams.Add(request.NewErrParamRequired("AttributeMatchingModel")) } if s.Rules == nil { invalidParams.Add(request.NewErrParamRequired("Rules")) } if s.Rules != nil && len(s.Rules) < 1 { invalidParams.Add(request.NewErrParamMinLen("Rules", 1)) } if s.Rules != nil { for i, v := range s.Rules { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "Rules", i), err.(request.ErrInvalidParams)) } } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetAttributeMatchingModel sets the AttributeMatchingModel field's value. func (s *RuleBasedProperties) SetAttributeMatchingModel(v string) *RuleBasedProperties { s.AttributeMatchingModel = &v return s } // SetRules sets the Rules field's value. func (s *RuleBasedProperties) SetRules(v []*Rule) *RuleBasedProperties { s.Rules = v return s } // An object containing FieldName, Type, GroupName, and MatchKey. type SchemaInputAttribute struct { _ struct{} `type:"structure"` // A string containing the field name. // // FieldName is a required field FieldName *string `locationName:"fieldName" type:"string" required:"true"` // Instruct Entity Resolution to combine several columns into a unified column // with the identical attribute type. For example, when working with columns // such as first_name, middle_name, and last_name, assigning them a common GroupName // will prompt Entity Resolution to concatenate them into a single value. GroupName *string `locationName:"groupName" type:"string"` // A key that allows grouping of multiple input attributes into a unified matching // group. For example, let's consider a scenario where the source table contains // various addresses, such as business_address and shipping_address. By assigning // the MatchKey Address to both attributes, Entity Resolution will match records // across these fields to create a consolidated matching group. If no MatchKey // is specified for a column, it won't be utilized for matching purposes but // will still be included in the output table. MatchKey *string `locationName:"matchKey" type:"string"` // The subtype of the attribute, selected from a list of values. SubType *string `locationName:"subType" type:"string"` // The type of the attribute, selected from a list of values. // // Type is a required field Type *string `locationName:"type" type:"string" required:"true" enum:"SchemaAttributeType"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SchemaInputAttribute) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SchemaInputAttribute) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *SchemaInputAttribute) Validate() error { invalidParams := request.ErrInvalidParams{Context: "SchemaInputAttribute"} if s.FieldName == nil { invalidParams.Add(request.NewErrParamRequired("FieldName")) } if s.Type == nil { invalidParams.Add(request.NewErrParamRequired("Type")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetFieldName sets the FieldName field's value. func (s *SchemaInputAttribute) SetFieldName(v string) *SchemaInputAttribute { s.FieldName = &v return s } // SetGroupName sets the GroupName field's value. func (s *SchemaInputAttribute) SetGroupName(v string) *SchemaInputAttribute { s.GroupName = &v return s } // SetMatchKey sets the MatchKey field's value. func (s *SchemaInputAttribute) SetMatchKey(v string) *SchemaInputAttribute { s.MatchKey = &v return s } // SetSubType sets the SubType field's value. func (s *SchemaInputAttribute) SetSubType(v string) *SchemaInputAttribute { s.SubType = &v return s } // SetType sets the Type field's value. func (s *SchemaInputAttribute) SetType(v string) *SchemaInputAttribute { s.Type = &v return s } // An object containing SchemaName, SchemaArn, CreatedAt, andUpdatedAt. type SchemaMappingSummary struct { _ struct{} `type:"structure"` // The timestamp of when the SchemaMapping was created. // // CreatedAt is a required field CreatedAt *time.Time `locationName:"createdAt" type:"timestamp" required:"true"` // Specifies whether the schema mapping has been applied to a workflow. // // HasWorkflows is a required field HasWorkflows *bool `locationName:"hasWorkflows" type:"boolean" required:"true"` // The ARN (Amazon Resource Name) that Entity Resolution generated for the SchemaMapping. // // SchemaArn is a required field SchemaArn *string `locationName:"schemaArn" type:"string" required:"true"` // The name of the schema. // // SchemaName is a required field SchemaName *string `locationName:"schemaName" min:"1" type:"string" required:"true"` // The timestamp of when the SchemaMapping was last updated. // // UpdatedAt is a required field UpdatedAt *time.Time `locationName:"updatedAt" type:"timestamp" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SchemaMappingSummary) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SchemaMappingSummary) GoString() string { return s.String() } // SetCreatedAt sets the CreatedAt field's value. func (s *SchemaMappingSummary) SetCreatedAt(v time.Time) *SchemaMappingSummary { s.CreatedAt = &v return s } // SetHasWorkflows sets the HasWorkflows field's value. func (s *SchemaMappingSummary) SetHasWorkflows(v bool) *SchemaMappingSummary { s.HasWorkflows = &v return s } // SetSchemaArn sets the SchemaArn field's value. func (s *SchemaMappingSummary) SetSchemaArn(v string) *SchemaMappingSummary { s.SchemaArn = &v return s } // SetSchemaName sets the SchemaName field's value. func (s *SchemaMappingSummary) SetSchemaName(v string) *SchemaMappingSummary { s.SchemaName = &v return s } // SetUpdatedAt sets the UpdatedAt field's value. func (s *SchemaMappingSummary) SetUpdatedAt(v time.Time) *SchemaMappingSummary { s.UpdatedAt = &v return s } type StartIdMappingJobInput struct { _ struct{} `type:"structure" nopayload:"true"` // The name of the ID mapping job to be retrieved. // // WorkflowName is a required field WorkflowName *string `location:"uri" locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartIdMappingJobInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartIdMappingJobInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *StartIdMappingJobInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "StartIdMappingJobInput"} if s.WorkflowName == nil { invalidParams.Add(request.NewErrParamRequired("WorkflowName")) } if s.WorkflowName != nil && len(*s.WorkflowName) < 1 { invalidParams.Add(request.NewErrParamMinLen("WorkflowName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetWorkflowName sets the WorkflowName field's value. func (s *StartIdMappingJobInput) SetWorkflowName(v string) *StartIdMappingJobInput { s.WorkflowName = &v return s } type StartIdMappingJobOutput struct { _ struct{} `type:"structure"` // The ID of the job. // // JobId is a required field JobId *string `locationName:"jobId" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartIdMappingJobOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartIdMappingJobOutput) GoString() string { return s.String() } // SetJobId sets the JobId field's value. func (s *StartIdMappingJobOutput) SetJobId(v string) *StartIdMappingJobOutput { s.JobId = &v return s } type StartMatchingJobInput struct { _ struct{} `type:"structure" nopayload:"true"` // The name of the matching job to be retrieved. // // WorkflowName is a required field WorkflowName *string `location:"uri" locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartMatchingJobInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartMatchingJobInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *StartMatchingJobInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "StartMatchingJobInput"} if s.WorkflowName == nil { invalidParams.Add(request.NewErrParamRequired("WorkflowName")) } if s.WorkflowName != nil && len(*s.WorkflowName) < 1 { invalidParams.Add(request.NewErrParamMinLen("WorkflowName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetWorkflowName sets the WorkflowName field's value. func (s *StartMatchingJobInput) SetWorkflowName(v string) *StartMatchingJobInput { s.WorkflowName = &v return s } type StartMatchingJobOutput struct { _ struct{} `type:"structure"` // The ID of the job. // // JobId is a required field JobId *string `locationName:"jobId" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartMatchingJobOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartMatchingJobOutput) GoString() string { return s.String() } // SetJobId sets the JobId field's value. func (s *StartMatchingJobOutput) SetJobId(v string) *StartMatchingJobOutput { s.JobId = &v return s } type TagResourceInput struct { _ struct{} `type:"structure"` // The ARN of the resource for which you want to view tags. // // ResourceArn is a required field ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"` // The tags used to organize, track, or control access for this resource. // // Tags is a required field Tags map[string]*string `locationName:"tags" type:"map" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s TagResourceInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s TagResourceInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *TagResourceInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "TagResourceInput"} if s.ResourceArn == nil { invalidParams.Add(request.NewErrParamRequired("ResourceArn")) } if s.ResourceArn != nil && len(*s.ResourceArn) < 1 { invalidParams.Add(request.NewErrParamMinLen("ResourceArn", 1)) } if s.Tags == nil { invalidParams.Add(request.NewErrParamRequired("Tags")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetResourceArn sets the ResourceArn field's value. func (s *TagResourceInput) SetResourceArn(v string) *TagResourceInput { s.ResourceArn = &v return s } // SetTags sets the Tags field's value. func (s *TagResourceInput) SetTags(v map[string]*string) *TagResourceInput { s.Tags = v return s } type TagResourceOutput struct { _ struct{} `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s TagResourceOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s TagResourceOutput) GoString() string { return s.String() } // The request was denied due to request throttling. HTTP Status Code: 429 type ThrottlingException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ *string `locationName:"message" min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ThrottlingException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ThrottlingException) GoString() string { return s.String() } func newErrorThrottlingException(v protocol.ResponseMetadata) error { return &ThrottlingException{ RespMetadata: v, } } // Code returns the exception type name. func (s *ThrottlingException) Code() string { return "ThrottlingException" } // Message returns the exception's message. func (s *ThrottlingException) Message() string { if s.Message_ != nil { return *s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s *ThrottlingException) OrigErr() error { return nil } func (s *ThrottlingException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s *ThrottlingException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s *ThrottlingException) RequestID() string { return s.RespMetadata.RequestID } type UntagResourceInput struct { _ struct{} `type:"structure" nopayload:"true"` // The ARN of the resource for which you want to untag. // // ResourceArn is a required field ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"` // The list of tag keys to remove from the resource. // // TagKeys is a required field TagKeys []*string `location:"querystring" locationName:"tagKeys" type:"list" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UntagResourceInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UntagResourceInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *UntagResourceInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "UntagResourceInput"} if s.ResourceArn == nil { invalidParams.Add(request.NewErrParamRequired("ResourceArn")) } if s.ResourceArn != nil && len(*s.ResourceArn) < 1 { invalidParams.Add(request.NewErrParamMinLen("ResourceArn", 1)) } if s.TagKeys == nil { invalidParams.Add(request.NewErrParamRequired("TagKeys")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetResourceArn sets the ResourceArn field's value. func (s *UntagResourceInput) SetResourceArn(v string) *UntagResourceInput { s.ResourceArn = &v return s } // SetTagKeys sets the TagKeys field's value. func (s *UntagResourceInput) SetTagKeys(v []*string) *UntagResourceInput { s.TagKeys = v return s } type UntagResourceOutput struct { _ struct{} `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UntagResourceOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UntagResourceOutput) GoString() string { return s.String() } type UpdateIdMappingWorkflowInput struct { _ struct{} `type:"structure"` // A description of the workflow. Description *string `locationName:"description" type:"string"` // An object which defines the idMappingType and the providerProperties. // // IdMappingTechniques is a required field IdMappingTechniques *IdMappingTechniques `locationName:"idMappingTechniques" type:"structure" required:"true"` // A list of InputSource objects, which have the fields InputSourceARN and SchemaName. // // InputSourceConfig is a required field InputSourceConfig []*IdMappingWorkflowInputSource `locationName:"inputSourceConfig" min:"1" type:"list" required:"true"` // A list of OutputSource objects, each of which contains fields OutputS3Path // and KMSArn. // // OutputSourceConfig is a required field OutputSourceConfig []*IdMappingWorkflowOutputSource `locationName:"outputSourceConfig" min:"1" type:"list" required:"true"` // The Amazon Resource Name (ARN) of the IAM role. Entity Resolution assumes // this role to access resources on your behalf. // // RoleArn is a required field RoleArn *string `locationName:"roleArn" type:"string" required:"true"` // The name of the workflow. // // WorkflowName is a required field WorkflowName *string `location:"uri" locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UpdateIdMappingWorkflowInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UpdateIdMappingWorkflowInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *UpdateIdMappingWorkflowInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "UpdateIdMappingWorkflowInput"} if s.IdMappingTechniques == nil { invalidParams.Add(request.NewErrParamRequired("IdMappingTechniques")) } if s.InputSourceConfig == nil { invalidParams.Add(request.NewErrParamRequired("InputSourceConfig")) } if s.InputSourceConfig != nil && len(s.InputSourceConfig) < 1 { invalidParams.Add(request.NewErrParamMinLen("InputSourceConfig", 1)) } if s.OutputSourceConfig == nil { invalidParams.Add(request.NewErrParamRequired("OutputSourceConfig")) } if s.OutputSourceConfig != nil && len(s.OutputSourceConfig) < 1 { invalidParams.Add(request.NewErrParamMinLen("OutputSourceConfig", 1)) } if s.RoleArn == nil { invalidParams.Add(request.NewErrParamRequired("RoleArn")) } if s.WorkflowName == nil { invalidParams.Add(request.NewErrParamRequired("WorkflowName")) } if s.WorkflowName != nil && len(*s.WorkflowName) < 1 { invalidParams.Add(request.NewErrParamMinLen("WorkflowName", 1)) } if s.IdMappingTechniques != nil { if err := s.IdMappingTechniques.Validate(); err != nil { invalidParams.AddNested("IdMappingTechniques", err.(request.ErrInvalidParams)) } } if s.InputSourceConfig != nil { for i, v := range s.InputSourceConfig { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "InputSourceConfig", i), err.(request.ErrInvalidParams)) } } } if s.OutputSourceConfig != nil { for i, v := range s.OutputSourceConfig { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "OutputSourceConfig", i), err.(request.ErrInvalidParams)) } } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetDescription sets the Description field's value. func (s *UpdateIdMappingWorkflowInput) SetDescription(v string) *UpdateIdMappingWorkflowInput { s.Description = &v return s } // SetIdMappingTechniques sets the IdMappingTechniques field's value. func (s *UpdateIdMappingWorkflowInput) SetIdMappingTechniques(v *IdMappingTechniques) *UpdateIdMappingWorkflowInput { s.IdMappingTechniques = v return s } // SetInputSourceConfig sets the InputSourceConfig field's value. func (s *UpdateIdMappingWorkflowInput) SetInputSourceConfig(v []*IdMappingWorkflowInputSource) *UpdateIdMappingWorkflowInput { s.InputSourceConfig = v return s } // SetOutputSourceConfig sets the OutputSourceConfig field's value. func (s *UpdateIdMappingWorkflowInput) SetOutputSourceConfig(v []*IdMappingWorkflowOutputSource) *UpdateIdMappingWorkflowInput { s.OutputSourceConfig = v return s } // SetRoleArn sets the RoleArn field's value. func (s *UpdateIdMappingWorkflowInput) SetRoleArn(v string) *UpdateIdMappingWorkflowInput { s.RoleArn = &v return s } // SetWorkflowName sets the WorkflowName field's value. func (s *UpdateIdMappingWorkflowInput) SetWorkflowName(v string) *UpdateIdMappingWorkflowInput { s.WorkflowName = &v return s } type UpdateIdMappingWorkflowOutput struct { _ struct{} `type:"structure"` // A description of the workflow. Description *string `locationName:"description" type:"string"` // An object which defines the idMappingType and the providerProperties. // // IdMappingTechniques is a required field IdMappingTechniques *IdMappingTechniques `locationName:"idMappingTechniques" type:"structure" required:"true"` // A list of InputSource objects, which have the fields InputSourceARN and SchemaName. // // InputSourceConfig is a required field InputSourceConfig []*IdMappingWorkflowInputSource `locationName:"inputSourceConfig" min:"1" type:"list" required:"true"` // A list of OutputSource objects, each of which contains fields OutputS3Path // and KMSArn. // // OutputSourceConfig is a required field OutputSourceConfig []*IdMappingWorkflowOutputSource `locationName:"outputSourceConfig" min:"1" type:"list" required:"true"` // The Amazon Resource Name (ARN) of the IAM role. Entity Resolution assumes // this role to access resources on your behalf. // // RoleArn is a required field RoleArn *string `locationName:"roleArn" type:"string" required:"true"` // The Amazon Resource Name (ARN) of the workflow role. Entity Resolution assumes // this role to access resources on your behalf. // // WorkflowArn is a required field WorkflowArn *string `locationName:"workflowArn" type:"string" required:"true"` // The name of the workflow. // // WorkflowName is a required field WorkflowName *string `locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UpdateIdMappingWorkflowOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UpdateIdMappingWorkflowOutput) GoString() string { return s.String() } // SetDescription sets the Description field's value. func (s *UpdateIdMappingWorkflowOutput) SetDescription(v string) *UpdateIdMappingWorkflowOutput { s.Description = &v return s } // SetIdMappingTechniques sets the IdMappingTechniques field's value. func (s *UpdateIdMappingWorkflowOutput) SetIdMappingTechniques(v *IdMappingTechniques) *UpdateIdMappingWorkflowOutput { s.IdMappingTechniques = v return s } // SetInputSourceConfig sets the InputSourceConfig field's value. func (s *UpdateIdMappingWorkflowOutput) SetInputSourceConfig(v []*IdMappingWorkflowInputSource) *UpdateIdMappingWorkflowOutput { s.InputSourceConfig = v return s } // SetOutputSourceConfig sets the OutputSourceConfig field's value. func (s *UpdateIdMappingWorkflowOutput) SetOutputSourceConfig(v []*IdMappingWorkflowOutputSource) *UpdateIdMappingWorkflowOutput { s.OutputSourceConfig = v return s } // SetRoleArn sets the RoleArn field's value. func (s *UpdateIdMappingWorkflowOutput) SetRoleArn(v string) *UpdateIdMappingWorkflowOutput { s.RoleArn = &v return s } // SetWorkflowArn sets the WorkflowArn field's value. func (s *UpdateIdMappingWorkflowOutput) SetWorkflowArn(v string) *UpdateIdMappingWorkflowOutput { s.WorkflowArn = &v return s } // SetWorkflowName sets the WorkflowName field's value. func (s *UpdateIdMappingWorkflowOutput) SetWorkflowName(v string) *UpdateIdMappingWorkflowOutput { s.WorkflowName = &v return s } type UpdateMatchingWorkflowInput struct { _ struct{} `type:"structure"` // A description of the workflow. Description *string `locationName:"description" type:"string"` // An object which defines an incremental run type and has only incrementalRunType // as a field. IncrementalRunConfig *IncrementalRunConfig `locationName:"incrementalRunConfig" type:"structure"` // A list of InputSource objects, which have the fields InputSourceARN and SchemaName. // // InputSourceConfig is a required field InputSourceConfig []*InputSource `locationName:"inputSourceConfig" min:"1" type:"list" required:"true"` // A list of OutputSource objects, each of which contains fields OutputS3Path, // ApplyNormalization, and Output. // // OutputSourceConfig is a required field OutputSourceConfig []*OutputSource `locationName:"outputSourceConfig" min:"1" type:"list" required:"true"` // An object which defines the resolutionType and the ruleBasedProperties. // // ResolutionTechniques is a required field ResolutionTechniques *ResolutionTechniques `locationName:"resolutionTechniques" type:"structure" required:"true"` // The Amazon Resource Name (ARN) of the IAM role. Entity Resolution assumes // this role to create resources on your behalf as part of workflow execution. // // RoleArn is a required field RoleArn *string `locationName:"roleArn" type:"string" required:"true"` // The name of the workflow to be retrieved. // // WorkflowName is a required field WorkflowName *string `location:"uri" locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UpdateMatchingWorkflowInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UpdateMatchingWorkflowInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *UpdateMatchingWorkflowInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "UpdateMatchingWorkflowInput"} if s.InputSourceConfig == nil { invalidParams.Add(request.NewErrParamRequired("InputSourceConfig")) } if s.InputSourceConfig != nil && len(s.InputSourceConfig) < 1 { invalidParams.Add(request.NewErrParamMinLen("InputSourceConfig", 1)) } if s.OutputSourceConfig == nil { invalidParams.Add(request.NewErrParamRequired("OutputSourceConfig")) } if s.OutputSourceConfig != nil && len(s.OutputSourceConfig) < 1 { invalidParams.Add(request.NewErrParamMinLen("OutputSourceConfig", 1)) } if s.ResolutionTechniques == nil { invalidParams.Add(request.NewErrParamRequired("ResolutionTechniques")) } if s.RoleArn == nil { invalidParams.Add(request.NewErrParamRequired("RoleArn")) } if s.WorkflowName == nil { invalidParams.Add(request.NewErrParamRequired("WorkflowName")) } if s.WorkflowName != nil && len(*s.WorkflowName) < 1 { invalidParams.Add(request.NewErrParamMinLen("WorkflowName", 1)) } if s.InputSourceConfig != nil { for i, v := range s.InputSourceConfig { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "InputSourceConfig", i), err.(request.ErrInvalidParams)) } } } if s.OutputSourceConfig != nil { for i, v := range s.OutputSourceConfig { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "OutputSourceConfig", i), err.(request.ErrInvalidParams)) } } } if s.ResolutionTechniques != nil { if err := s.ResolutionTechniques.Validate(); err != nil { invalidParams.AddNested("ResolutionTechniques", err.(request.ErrInvalidParams)) } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetDescription sets the Description field's value. func (s *UpdateMatchingWorkflowInput) SetDescription(v string) *UpdateMatchingWorkflowInput { s.Description = &v return s } // SetIncrementalRunConfig sets the IncrementalRunConfig field's value. func (s *UpdateMatchingWorkflowInput) SetIncrementalRunConfig(v *IncrementalRunConfig) *UpdateMatchingWorkflowInput { s.IncrementalRunConfig = v return s } // SetInputSourceConfig sets the InputSourceConfig field's value. func (s *UpdateMatchingWorkflowInput) SetInputSourceConfig(v []*InputSource) *UpdateMatchingWorkflowInput { s.InputSourceConfig = v return s } // SetOutputSourceConfig sets the OutputSourceConfig field's value. func (s *UpdateMatchingWorkflowInput) SetOutputSourceConfig(v []*OutputSource) *UpdateMatchingWorkflowInput { s.OutputSourceConfig = v return s } // SetResolutionTechniques sets the ResolutionTechniques field's value. func (s *UpdateMatchingWorkflowInput) SetResolutionTechniques(v *ResolutionTechniques) *UpdateMatchingWorkflowInput { s.ResolutionTechniques = v return s } // SetRoleArn sets the RoleArn field's value. func (s *UpdateMatchingWorkflowInput) SetRoleArn(v string) *UpdateMatchingWorkflowInput { s.RoleArn = &v return s } // SetWorkflowName sets the WorkflowName field's value. func (s *UpdateMatchingWorkflowInput) SetWorkflowName(v string) *UpdateMatchingWorkflowInput { s.WorkflowName = &v return s } type UpdateMatchingWorkflowOutput struct { _ struct{} `type:"structure"` // A description of the workflow. Description *string `locationName:"description" type:"string"` // An object which defines an incremental run type and has only incrementalRunType // as a field. IncrementalRunConfig *IncrementalRunConfig `locationName:"incrementalRunConfig" type:"structure"` // A list of InputSource objects, which have the fields InputSourceARN and SchemaName. // // InputSourceConfig is a required field InputSourceConfig []*InputSource `locationName:"inputSourceConfig" min:"1" type:"list" required:"true"` // A list of OutputSource objects, each of which contains fields OutputS3Path, // ApplyNormalization, and Output. // // OutputSourceConfig is a required field OutputSourceConfig []*OutputSource `locationName:"outputSourceConfig" min:"1" type:"list" required:"true"` // An object which defines the resolutionType and the ruleBasedProperties // // ResolutionTechniques is a required field ResolutionTechniques *ResolutionTechniques `locationName:"resolutionTechniques" type:"structure" required:"true"` // The Amazon Resource Name (ARN) of the IAM role. Entity Resolution assumes // this role to create resources on your behalf as part of workflow execution. // // RoleArn is a required field RoleArn *string `locationName:"roleArn" type:"string" required:"true"` // The name of the workflow. // // WorkflowName is a required field WorkflowName *string `locationName:"workflowName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UpdateMatchingWorkflowOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UpdateMatchingWorkflowOutput) GoString() string { return s.String() } // SetDescription sets the Description field's value. func (s *UpdateMatchingWorkflowOutput) SetDescription(v string) *UpdateMatchingWorkflowOutput { s.Description = &v return s } // SetIncrementalRunConfig sets the IncrementalRunConfig field's value. func (s *UpdateMatchingWorkflowOutput) SetIncrementalRunConfig(v *IncrementalRunConfig) *UpdateMatchingWorkflowOutput { s.IncrementalRunConfig = v return s } // SetInputSourceConfig sets the InputSourceConfig field's value. func (s *UpdateMatchingWorkflowOutput) SetInputSourceConfig(v []*InputSource) *UpdateMatchingWorkflowOutput { s.InputSourceConfig = v return s } // SetOutputSourceConfig sets the OutputSourceConfig field's value. func (s *UpdateMatchingWorkflowOutput) SetOutputSourceConfig(v []*OutputSource) *UpdateMatchingWorkflowOutput { s.OutputSourceConfig = v return s } // SetResolutionTechniques sets the ResolutionTechniques field's value. func (s *UpdateMatchingWorkflowOutput) SetResolutionTechniques(v *ResolutionTechniques) *UpdateMatchingWorkflowOutput { s.ResolutionTechniques = v return s } // SetRoleArn sets the RoleArn field's value. func (s *UpdateMatchingWorkflowOutput) SetRoleArn(v string) *UpdateMatchingWorkflowOutput { s.RoleArn = &v return s } // SetWorkflowName sets the WorkflowName field's value. func (s *UpdateMatchingWorkflowOutput) SetWorkflowName(v string) *UpdateMatchingWorkflowOutput { s.WorkflowName = &v return s } type UpdateSchemaMappingInput struct { _ struct{} `type:"structure"` // A description of the schema. Description *string `locationName:"description" type:"string"` // A list of MappedInputFields. Each MappedInputField corresponds to a column // the source data table, and contains column name plus additional information // that Entity Resolution uses for matching. // // MappedInputFields is a required field MappedInputFields []*SchemaInputAttribute `locationName:"mappedInputFields" min:"2" type:"list" required:"true"` // The name of the schema. There can't be multiple SchemaMappings with the same // name. // // SchemaName is a required field SchemaName *string `location:"uri" locationName:"schemaName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UpdateSchemaMappingInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UpdateSchemaMappingInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *UpdateSchemaMappingInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "UpdateSchemaMappingInput"} if s.MappedInputFields == nil { invalidParams.Add(request.NewErrParamRequired("MappedInputFields")) } if s.MappedInputFields != nil && len(s.MappedInputFields) < 2 { invalidParams.Add(request.NewErrParamMinLen("MappedInputFields", 2)) } if s.SchemaName == nil { invalidParams.Add(request.NewErrParamRequired("SchemaName")) } if s.SchemaName != nil && len(*s.SchemaName) < 1 { invalidParams.Add(request.NewErrParamMinLen("SchemaName", 1)) } if s.MappedInputFields != nil { for i, v := range s.MappedInputFields { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "MappedInputFields", i), err.(request.ErrInvalidParams)) } } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetDescription sets the Description field's value. func (s *UpdateSchemaMappingInput) SetDescription(v string) *UpdateSchemaMappingInput { s.Description = &v return s } // SetMappedInputFields sets the MappedInputFields field's value. func (s *UpdateSchemaMappingInput) SetMappedInputFields(v []*SchemaInputAttribute) *UpdateSchemaMappingInput { s.MappedInputFields = v return s } // SetSchemaName sets the SchemaName field's value. func (s *UpdateSchemaMappingInput) SetSchemaName(v string) *UpdateSchemaMappingInput { s.SchemaName = &v return s } type UpdateSchemaMappingOutput struct { _ struct{} `type:"structure"` // A description of the schema. Description *string `locationName:"description" type:"string"` // A list of MappedInputFields. Each MappedInputField corresponds to a column // the source data table, and contains column name plus additional information // that Entity Resolution uses for matching. // // MappedInputFields is a required field MappedInputFields []*SchemaInputAttribute `locationName:"mappedInputFields" min:"2" type:"list" required:"true"` // The ARN (Amazon Resource Name) that Entity Resolution generated for the SchemaMapping. // // SchemaArn is a required field SchemaArn *string `locationName:"schemaArn" type:"string" required:"true"` // The name of the schema. // // SchemaName is a required field SchemaName *string `locationName:"schemaName" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UpdateSchemaMappingOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UpdateSchemaMappingOutput) GoString() string { return s.String() } // SetDescription sets the Description field's value. func (s *UpdateSchemaMappingOutput) SetDescription(v string) *UpdateSchemaMappingOutput { s.Description = &v return s } // SetMappedInputFields sets the MappedInputFields field's value. func (s *UpdateSchemaMappingOutput) SetMappedInputFields(v []*SchemaInputAttribute) *UpdateSchemaMappingOutput { s.MappedInputFields = v return s } // SetSchemaArn sets the SchemaArn field's value. func (s *UpdateSchemaMappingOutput) SetSchemaArn(v string) *UpdateSchemaMappingOutput { s.SchemaArn = &v return s } // SetSchemaName sets the SchemaName field's value. func (s *UpdateSchemaMappingOutput) SetSchemaName(v string) *UpdateSchemaMappingOutput { s.SchemaName = &v return s } // The input fails to satisfy the constraints specified by Entity Resolution. // HTTP Status Code: 400 type ValidationException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ *string `locationName:"message" min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ValidationException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ValidationException) GoString() string { return s.String() } func newErrorValidationException(v protocol.ResponseMetadata) error { return &ValidationException{ RespMetadata: v, } } // Code returns the exception type name. func (s *ValidationException) Code() string { return "ValidationException" } // Message returns the exception's message. func (s *ValidationException) Message() string { if s.Message_ != nil { return *s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s *ValidationException) OrigErr() error { return nil } func (s *ValidationException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s *ValidationException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s *ValidationException) RequestID() string { return s.RespMetadata.RequestID } const ( // AttributeMatchingModelOneToOne is a AttributeMatchingModel enum value AttributeMatchingModelOneToOne = "ONE_TO_ONE" // AttributeMatchingModelManyToMany is a AttributeMatchingModel enum value AttributeMatchingModelManyToMany = "MANY_TO_MANY" ) // AttributeMatchingModel_Values returns all elements of the AttributeMatchingModel enum func AttributeMatchingModel_Values() []string { return []string{ AttributeMatchingModelOneToOne, AttributeMatchingModelManyToMany, } } const ( // IdMappingTypeProvider is a IdMappingType enum value IdMappingTypeProvider = "PROVIDER" ) // IdMappingType_Values returns all elements of the IdMappingType enum func IdMappingType_Values() []string { return []string{ IdMappingTypeProvider, } } const ( // IncrementalRunTypeImmediate is a IncrementalRunType enum value IncrementalRunTypeImmediate = "IMMEDIATE" ) // IncrementalRunType_Values returns all elements of the IncrementalRunType enum func IncrementalRunType_Values() []string { return []string{ IncrementalRunTypeImmediate, } } const ( // JobStatusRunning is a JobStatus enum value JobStatusRunning = "RUNNING" // JobStatusSucceeded is a JobStatus enum value JobStatusSucceeded = "SUCCEEDED" // JobStatusFailed is a JobStatus enum value JobStatusFailed = "FAILED" // JobStatusQueued is a JobStatus enum value JobStatusQueued = "QUEUED" ) // JobStatus_Values returns all elements of the JobStatus enum func JobStatus_Values() []string { return []string{ JobStatusRunning, JobStatusSucceeded, JobStatusFailed, JobStatusQueued, } } const ( // ResolutionTypeRuleMatching is a ResolutionType enum value ResolutionTypeRuleMatching = "RULE_MATCHING" // ResolutionTypeMlMatching is a ResolutionType enum value ResolutionTypeMlMatching = "ML_MATCHING" // ResolutionTypeProvider is a ResolutionType enum value ResolutionTypeProvider = "PROVIDER" ) // ResolutionType_Values returns all elements of the ResolutionType enum func ResolutionType_Values() []string { return []string{ ResolutionTypeRuleMatching, ResolutionTypeMlMatching, ResolutionTypeProvider, } } const ( // SchemaAttributeTypeName is a SchemaAttributeType enum value SchemaAttributeTypeName = "NAME" // SchemaAttributeTypeNameFirst is a SchemaAttributeType enum value SchemaAttributeTypeNameFirst = "NAME_FIRST" // SchemaAttributeTypeNameMiddle is a SchemaAttributeType enum value SchemaAttributeTypeNameMiddle = "NAME_MIDDLE" // SchemaAttributeTypeNameLast is a SchemaAttributeType enum value SchemaAttributeTypeNameLast = "NAME_LAST" // SchemaAttributeTypeAddress is a SchemaAttributeType enum value SchemaAttributeTypeAddress = "ADDRESS" // SchemaAttributeTypeAddressStreet1 is a SchemaAttributeType enum value SchemaAttributeTypeAddressStreet1 = "ADDRESS_STREET1" // SchemaAttributeTypeAddressStreet2 is a SchemaAttributeType enum value SchemaAttributeTypeAddressStreet2 = "ADDRESS_STREET2" // SchemaAttributeTypeAddressStreet3 is a SchemaAttributeType enum value SchemaAttributeTypeAddressStreet3 = "ADDRESS_STREET3" // SchemaAttributeTypeAddressCity is a SchemaAttributeType enum value SchemaAttributeTypeAddressCity = "ADDRESS_CITY" // SchemaAttributeTypeAddressState is a SchemaAttributeType enum value SchemaAttributeTypeAddressState = "ADDRESS_STATE" // SchemaAttributeTypeAddressCountry is a SchemaAttributeType enum value SchemaAttributeTypeAddressCountry = "ADDRESS_COUNTRY" // SchemaAttributeTypeAddressPostalcode is a SchemaAttributeType enum value SchemaAttributeTypeAddressPostalcode = "ADDRESS_POSTALCODE" // SchemaAttributeTypePhone is a SchemaAttributeType enum value SchemaAttributeTypePhone = "PHONE" // SchemaAttributeTypePhoneNumber is a SchemaAttributeType enum value SchemaAttributeTypePhoneNumber = "PHONE_NUMBER" // SchemaAttributeTypePhoneCountrycode is a SchemaAttributeType enum value SchemaAttributeTypePhoneCountrycode = "PHONE_COUNTRYCODE" // SchemaAttributeTypeEmailAddress is a SchemaAttributeType enum value SchemaAttributeTypeEmailAddress = "EMAIL_ADDRESS" // SchemaAttributeTypeUniqueId is a SchemaAttributeType enum value SchemaAttributeTypeUniqueId = "UNIQUE_ID" // SchemaAttributeTypeDate is a SchemaAttributeType enum value SchemaAttributeTypeDate = "DATE" // SchemaAttributeTypeString is a SchemaAttributeType enum value SchemaAttributeTypeString = "STRING" // SchemaAttributeTypeProviderId is a SchemaAttributeType enum value SchemaAttributeTypeProviderId = "PROVIDER_ID" ) // SchemaAttributeType_Values returns all elements of the SchemaAttributeType enum func SchemaAttributeType_Values() []string { return []string{ SchemaAttributeTypeName, SchemaAttributeTypeNameFirst, SchemaAttributeTypeNameMiddle, SchemaAttributeTypeNameLast, SchemaAttributeTypeAddress, SchemaAttributeTypeAddressStreet1, SchemaAttributeTypeAddressStreet2, SchemaAttributeTypeAddressStreet3, SchemaAttributeTypeAddressCity, SchemaAttributeTypeAddressState, SchemaAttributeTypeAddressCountry, SchemaAttributeTypeAddressPostalcode, SchemaAttributeTypePhone, SchemaAttributeTypePhoneNumber, SchemaAttributeTypePhoneCountrycode, SchemaAttributeTypeEmailAddress, SchemaAttributeTypeUniqueId, SchemaAttributeTypeDate, SchemaAttributeTypeString, SchemaAttributeTypeProviderId, } } const ( // ServiceTypeAssignment is a ServiceType enum value ServiceTypeAssignment = "ASSIGNMENT" // ServiceTypeIdMapping is a ServiceType enum value ServiceTypeIdMapping = "ID_MAPPING" ) // ServiceType_Values returns all elements of the ServiceType enum func ServiceType_Values() []string { return []string{ ServiceTypeAssignment, ServiceTypeIdMapping, } }