workers

package

v1.0.0 Latest Latest Go to latest Published: Nov 12, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

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

TaskConsumer exposing methods every consmumer should implement

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

NewTaskConsumer returns a new consumer

type TaskProducer interface {
	Start() error
}

TaskProducer exposes methods for producing tasks

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

NewTaskProducer is to return a new object