uploader

README

uploader

test

DEBUG_LEVEL=error STORAGE_EMULATOR_HOST=localhost:8000  go test -race -v . -bench=.

Documentation

Index

• Constants
• func Module(scope string) fx.Option
• type Params
• type Uploader

Constants

const (
	DefaultDomain         = "onglai-msg"
	DefaultSubject        = "%s.archive.bucket.job.%s"
	DefaultBucketName     = "example.com"
	DefaultBucketCategory = "msg-store"
)

Functions

func Module

func Module(scope string) fx.Option

Types

type Params

type Params struct {
	fx.In
	NATSConnector   *nats_connector.NATSConnector
	BucketConnector *bucket_connector.BucketConnector
	Lifecycle       fx.Lifecycle
	Logger          *zap.Logger
}

type Uploader

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