adaptor

Documentation

Index

• type Decoder
  • func NewMsgpackDecoder(r io.ReadCloser) Decoder
• type DecoderFactory
• type Encoder
  • func NewMsgpackEncoder(w io.Writer) Encoder
• type EncoderFactory
• type S3Client
  • func NewS3Client(region string) S3Client
• type S3ClientFactory
• type SQSClient
  • func NewSQSClient(region string) SQSClient
• type SQSClientFactory

Types

type Decoder

type Decoder interface {
	Decode(v interface{}) error
}

func NewMsgpackDecoder

func NewMsgpackDecoder(r io.ReadCloser) Decoder

type DecoderFactory

type DecoderFactory func(w io.ReadCloser) Decoder

type Encoder

type Encoder interface {
	Encode(v interface{}) error
	Close() error
	Size() int64
	Ext() string
	ContentEncoding() string
}

func NewMsgpackEncoder

func NewMsgpackEncoder(w io.Writer) Encoder

type EncoderFactory

type EncoderFactory func(w io.Writer) Encoder

type S3Client

type S3Client interface {
	GetObject(input *s3.GetObjectInput) (*s3.GetObjectOutput, error)
	PutObject(input *s3.PutObjectInput) (*s3.PutObjectOutput, error)
	DeleteObjects(input *s3.DeleteObjectsInput) (*s3.DeleteObjectsOutput, error)
	HeadObject(input *s3.HeadObjectInput) (*s3.HeadObjectOutput, error)
	Upload(bucket, key string, body io.Reader, encoding string) error
}

S3Client is interface of AWS S3 SDK

func NewS3Client

func NewS3Client(region string) S3Client

NewS3Client creates actual AWS S3 SDK client

type S3ClientFactory

type S3ClientFactory func(region string) S3Client

S3ClientFactory is interface S3Client constructor

type SQSClient

type SQSClient interface {
	SendMessage(*sqs.SendMessageInput) (*sqs.SendMessageOutput, error)
	ReceiveMessage(input *sqs.ReceiveMessageInput) (*sqs.ReceiveMessageOutput, error)
	DeleteMessage(input *sqs.DeleteMessageInput) (*sqs.DeleteMessageOutput, error)
}

SQSClient is interface of AWS SDK SQS

func NewSQSClient

func NewSQSClient(region string) SQSClient

NewSQSClient creates actual AWS SQS SDK client

type SQSClientFactory

type SQSClientFactory func(region string) SQSClient

SQSClientFactory is interface SQSClient constructor