functions

Documentation

Index

• Constants
• type CDCPayload
• type Data
• type EventSource
• type Executor
  • func NewExecutor(cfg *model.DataTransformOptions, baseURL string, source EventSource, ...) (*Executor, error)
  • func (e *Executor) Do(data []abstract.ChangeItem) ([]abstract.ChangeItem, error)
• type ProcessResult
• type Record
• type YDSPayload

Constants

const (
	YDS = EventSource("YDS")
	CDC = EventSource("CDC")

	OK               = ProcessResult("Ok")
	Split            = ProcessResult("Split")
	Dropped          = ProcessResult("Dropped")
	ProcessingFailed = ProcessResult("ProcessingFailed")
)

Types

type CDCPayload

type CDCPayload struct {
	// TODO: Fill with generic CDC event?
	abstract.ChangeItem
}

type Data

type Data struct {
	Records []Record `json:"Records"`
}

type EventSource

type EventSource string

type Executor

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

func NewExecutor

func NewExecutor(cfg *model.DataTransformOptions, baseURL string, source EventSource, lgr log.Logger, registry metrics.Registry) (*Executor, error)

func (*Executor) Do

func (e *Executor) Do(data []abstract.ChangeItem) ([]abstract.ChangeItem, error)

type ProcessResult

type ProcessResult string

type Record

type Record struct {
	CDC               *CDCPayload   `json:"cdc"`
	CDCSplit          []CDCPayload  `json:"cdc_split"`
	YDS               *YDSPayload   `json:"kinesis"` // maybe YDS?
	Result            ProcessResult `json:"result"`
	EventSource       EventSource   `json:"eventSource"`
	EventID           string        `json:"eventID"`
	InvokeIdentityArn string        `json:"invokeIdentityArn"`
	EventVersion      string        `json:"eventVersion"`
	EventName         string        `json:"eventName"`
	EventSourceARN    string        `json:"eventSourceARN"`
	AwsRegion         string        `json:"awsRegion"`
}

type YDSPayload

type YDSPayload struct {
	PartitionKey string  `json:"partitionKey"`
	Data         string  `json:"data"`
	SeqNo        uint64  `json:"sequenceNumber"`
	WriteTime    float64 `json:"approximateArrivalTimestamp"`
}