workers

Documentation

Index

• type SubEventType
• type TaskConsumer
  • func NewTaskConsumer(consumerQueue chan []byte, config *cfg.LambdaExtensionConfig, ...) TaskConsumer
• type TaskProducer
  • func NewTaskProducer(consumerQueue chan []byte, logger *logrus.Entry) TaskProducer

Types

type SubEventType

type SubEventType string

const (
	// RuntimeDone event is sent when lambda function is finished it's execution
	RuntimeDone SubEventType = "platform.runtimeDone"
)

type TaskConsumer

type TaskConsumer interface {
	FlushDataQueue(context.Context)
	DrainQueue(context.Context) int
}

TaskConsumer exposing methods every consmumer should implement

func NewTaskConsumer

func NewTaskConsumer(consumerQueue chan []byte, config *cfg.LambdaExtensionConfig, logger *logrus.Entry) TaskConsumer

NewTaskConsumer returns a new consumer

type TaskProducer

type TaskProducer interface {
	Start() error
}

TaskProducer exposes methods for producing tasks

func NewTaskProducer

func NewTaskProducer(consumerQueue chan []byte, logger *logrus.Entry) TaskProducer

NewTaskProducer is to return a new object