pushers

Documentation

Index

• Constants
• type Processor
  • 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 NewPusher(conf *cfg.Config, inC chan []byte, runtimeDoneC chan struct{}) *Pusher
  • func (p *Pusher) Invoke(ctx context.Context, doneC chan struct{})
  • func (p *Pusher) Start()
  • func (p *Pusher) Stop(timeout time.Duration)

Constants

const (
	StartStep = "START"
	EndStep   = "END"
)

Types

type Processor

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

func NewProcessor

func NewProcessor(conf *cfg.Config, outC chan []byte, inC chan []*lambda.LambdaEvent, runtimeDoneC chan struct{}) *Processor

NewProcessor initializes the log processor.

func (*Processor) Invoke

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

func (*Processor) Start

func (p *Processor) Start()

func (*Processor) Stop

func (p *Processor) Stop()

type Pusher

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

func NewPusher

func NewPusher(conf *cfg.Config, inC chan []byte, runtimeDoneC chan struct{}) *Pusher

NewPusher initializes Pusher

func (*Pusher) Invoke

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

func (*Pusher) Start

func (p *Pusher) Start()

func (*Pusher) Stop

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