s3

Documentation

Index

• type Config
• type S3Producer
  • func (p *S3Producer) Close() error
  • func (p *S3Producer) Initialize(configFile string)
  • func (p *S3Producer) Produce(k []byte, v []byte, o any)

Types

type Config

type Config struct {
	AWSRegion string `json:"aws_region"`
	Bucket    string `json:"bucket"`
}

type S3Producer

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

func (*S3Producer) Close

func (p *S3Producer) Close() error

func (*S3Producer) Initialize

func (p *S3Producer) Initialize(configFile string)

func (*S3Producer) Produce

func (p *S3Producer) Produce(k []byte, v []byte, o any)