awsclient

type AWS interface {
	GetBucketTags(ctx context.Context, bucketName string) (commons.Tags, error)
	ListBuckets(ctx context.Context) ([]*Bucket, error)
	GetFunction(ctx context.Context, functionName string) (*Function, error)
	ListFunctions(ctx context.Context) ([]*Function, error)
	Listen(ctx context.Context, handler ListenerFunc) error
	Close() error
}

type AWSMock struct {
	ListenError  error
	ListenAssert func(ctx context.Context, handler ListenerFunc)

	GetBucketTagsResult commons.Tags
	GetBucketTagsError  error

	ListBucketsResult []*Bucket
	ListBucketsError  error

	GetFunctionResult *Function
	GetFunctionError  error

	ListFunctionsResult []*Function
	ListFunctionsError  error

	CloseError error
	// contains filtered or unexported fields
}

type Bucket struct {
	Name      string
	AccountID string
	Region    string
}

type Config struct {
	QueueURL        string
	Region          string
	AccessKeyID     string
	SecretAccessKey string
	SessionToken    string
}

type Function struct {
	Name      string
	AccountID string
	Region    string
	ARN       string
	Tags      commons.Tags
}

type ListenerFunc func(ctx context.Context, data []byte) error