backendutils

Documentation

Index

• Variables
• func StartSinkWorker(input <-chan []envelope.Envelope, shutdown <-chan int, sink Sink) error
• type Sink
• type SinkMetadata

Variables

var DEFAULT_SINK_TIMEOUT_SECONDS int = 15

Functions

func StartSinkWorker

func StartSinkWorker(input <-chan []envelope.Envelope, shutdown <-chan int, sink Sink) error

Each sink runs an associated worker goroutine, which is responsible for dequeuing envelopes.

Types

type Sink

type Sink interface {
	Metadata() SinkMetadata
	Initialize(conf config.Sink) error
	StartWorker() error
	Enqueue(envelopes []envelope.Envelope) error
	Dequeue(ctx context.Context, envelopes []envelope.Envelope) error
	Shutdown() error
}

type SinkMetadata

type SinkMetadata struct {
	Id               *uuid.UUID `json:"id"`
	SinkType         string     `json:"sinkType"`
	Name             string     `json:"name"`
	DeliveryRequired bool       `json:"deliveryRequired"`
}