s3

Documentation

Index

• type Option
  • func WithAccessKeyID(accessKeyID string) Option
  • func WithBatchSize(batchSize int) Option
  • func WithBucketName(bucketName string) Option
  • func WithBucketRegion(bucketRegion string) Option
  • func WithCustomEndpoint(customEndpoint string) Option
  • func WithPathPrefix(pathPrefix string) Option
  • func WithSecretAccessKey(secretAccessKey string) Option
• type S3
  • func New(opts ...Option) *S3
  • func (s *S3) Flush(ctx context.Context, msgs []kawa.Message[[]byte]) error
  • func (s *S3) Run(ctx context.Context) error
  • func (s *S3) Send(ctx context.Context, ack func(), msgs ...kawa.Message[[]byte]) error

Types

type Option

type Option func(*S3)

func WithAccessKeyID

func WithAccessKeyID(accessKeyID string) Option

func WithBatchSize

func WithBatchSize(batchSize int) Option

func WithBucketName

func WithBucketName(bucketName string) Option

func WithBucketRegion

func WithBucketRegion(bucketRegion string) Option

func WithCustomEndpoint

func WithCustomEndpoint(customEndpoint string) Option

func WithPathPrefix

func WithPathPrefix(pathPrefix string) Option

func WithSecretAccessKey

func WithSecretAccessKey(secretAccessKey string) Option

type S3

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

func New

func New(opts ...Option) *S3

func (*S3) Flush

func (s *S3) Flush(ctx context.Context, msgs []kawa.Message[[]byte]) error

Flush sends the given messages of type kawa.Message[type.Event] to an s3 bucket

func (*S3) Run

func (s *S3) Run(ctx context.Context) error

func (*S3) Send

func (s *S3) Send(ctx context.Context, ack func(), msgs ...kawa.Message[[]byte]) error