s3

Documentation

Index

• Constants
• type MultipartUpload
• type Plugin
  • func NewPlugin(ctx context.Context, config *config.Config) (*Plugin, error)
  • func (p *Plugin) Start(ctx context.Context) chan<- string

Constants

const (
	MaxParts = 10_000
)

Types

type MultipartUpload

type MultipartUpload struct {
	Upload        *s3.CreateMultipartUploadOutput
	Parts         []types.CompletedPart
	Buffer        []byte
	TotalDataSent int
}

type Plugin

type Plugin struct {
	S3Client        *s3.Client
	Region          string
	Bucket          string
	InputPacketLen  int
	TotalFileSize   uint64
	UploadChunkSize uint64
	UploadTimeout   time.Duration
	CannedACL       string
}

func NewPlugin

func NewPlugin(ctx context.Context, config *config.Config) (*Plugin, error)

func (*Plugin) Start

func (p *Plugin) Start(ctx context.Context) chan<- string

Start returns a write-only channel to which packet chunks should be written should they wish to be streamed to S3. It is the responsibility of the caller to close the returned channel.