common

Documentation

Index

• func NewEndpointResolver(urlStr string) (sqs.EndpointResolverV2, error)
• func NewSQSClient(ctx context.Context, httpClient *http.Client, cfg Config) (*sqs.Client, error)
• type Config
• type EndpointResolver
  • func (e *EndpointResolver) ResolveEndpoint(_ context.Context, _ sqs.EndpointParameters) (transport.Endpoint, error)
• type Position
  • func ParsePosition(sdkPosition opencdc.Position) (Position, error)
  • func (p Position) ToSdkPosition() opencdc.Position

Functions

func NewEndpointResolver

func NewEndpointResolver(urlStr string) (sqs.EndpointResolverV2, error)

func NewSQSClient

func NewSQSClient(ctx context.Context, httpClient *http.Client, cfg Config) (*sqs.Client, error)

Types

type Config

type Config struct {
	// AWSAccessKeyID is the amazon access key id
	AWSAccessKeyID string `json:"aws.accessKeyId" validate:"required"`
	// AWSSecretAccessKey is the amazon secret access key
	AWSSecretAccessKey string `json:"aws.secretAccessKey" validate:"required"`
	// AWSRegion is the amazon sqs region
	AWSRegion string `json:"aws.region" validate:"required"`
	// AWSURL is the URL for AWS (internal use only).
	AWSURL string `json:"aws.url"`
}

type EndpointResolver

type EndpointResolver struct {
	// contains filtered or unexported fields
}

EndpointResolver sets a custom endpoint for the sqs client. It satisfies the sqs.EndpointResolverV2 interface.

func (*EndpointResolver) ResolveEndpoint

func (e *EndpointResolver) ResolveEndpoint(
	_ context.Context,
	_ sqs.EndpointParameters,
) (transport.Endpoint, error)

type Position

type Position struct {
	ReceiptHandle string `json:"receipt_handle"`
	QueueName     string `json:"queue_name"`
}

func ParsePosition

func ParsePosition(sdkPosition opencdc.Position) (Position, error)

func (Position) ToSdkPosition

func (p Position) ToSdkPosition() opencdc.Position