pushers

Oct 10, 2023

Changes in this version

+ const EndStep

+ const StartStep

Sep 9, 2023

Changes in this version

+ type Processor struct

+ func NewProcessor(conf *cfg.Config, outC chan []byte, inC chan []*lambda.LambdaEvent, ...) *Processor

+ func (p *Processor) Invoke(e *lambda.InvokeEvent)

+ func (p *Processor) Start()

+ func (p *Processor) Stop()

type Pusher

+ func (p *Pusher) Invoke(ctx context.Context, doneC chan struct{})

Sep 1, 2023

Changes in this version

+ type Pusher struct

+ func NewPusher(conf *cfg.Config, logQueue chan lambda.LambdaEvent, ...) *Pusher

+ func (p *Pusher) Start()

+ func (p *Pusher) Stop(timeout time.Duration)