handlers

Documentation

Index

• type Producer
  • func NewProducer(queue chan lambda.LambdaEvent, runtimeDoneChannels []chan struct{}) *Producer
  • func (p *Producer) Shutdown(timeout time.Duration)
  • func (p *Producer) Start()

Types

type Producer

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

Producer is used to listen to the Logs API using HTTP

func NewProducer

func NewProducer(queue chan lambda.LambdaEvent, runtimeDoneChannels []chan struct{}) *Producer

func (*Producer) Shutdown

func (p *Producer) Shutdown(timeout time.Duration)

Terminates the HTTP server listening for logs

func (*Producer) Start

func (p *Producer) Start()

Start initiates the server where the logs will be sent