sinks

Documentation

Index

• Constants
• Variables
• type DataWithIdentifier
• type Sink

Constants

const (
	Mongo = "mongo"

	// Fake is a fake writer used for testing purposes
	Fake = "fake"
)

Variables

var (
	ErrEmptyID = errors.New("id is empty")
)

Types

type DataWithIdentifier

type DataWithIdentifier interface {
	GetID() string
	Operation() entities.Operation
}

type Sink

type Sink[Data DataWithIdentifier] interface {
	// WriteData will save the Data to the destination configured in the Writer.
	// Data will have the operation to perform (write, delete) and the data to save,
	// which can be used based on the sink type.
	WriteData(ctx context.Context, data Data) error
}

Sink interface abstract the implementation of an integration pipeline target. The concrete implementation has to know how to write and delete a Data.