blobdestination

May 15, 2021

Changes in this version

+ func New(env *Options) destination.Destination

+ type Blob struct

+ func (d *Blob) Actions() map[string]destination.Action

+ func (d *Blob) Init(tk *destination.Toolkit) error

+ func (d *Blob) Options() *destination.Options

+ func (d *Blob) Shutdown(tk *destination.Toolkit) error

+ func (d *Blob) String() string

+ type Driver string

+ var DriverAWSS3 Driver = "aws/s3"

+ var DriverAzureBlob Driver = "azure/blob"

+ var DriverGoogleStorage Driver = "google/storage"

+ type Options struct

+ Connection string

+ Driver Driver

+ Interval string

+ MaxRetries uint16

+ Name string

+ Params url.Values

+ Realtime bool

+ type Write struct

+ Content []byte

+ Filename string

+ func (a Write) Load(tk *destination.Toolkit, queue *store.Queue, then chan<- destination.Then)

+ func (a Write) Marshal(tk *destination.Toolkit) (*destination.Job, error)

+ func (a Write) Schedule() *destination.Schedule

+ func (a Write) String() string