sinks

Aug 24, 2023

Changes in this version

+ const EventBridgeSizeLimit

+ type DocumentDetail struct

+ ContentTypes []string

+ ContentURIs []string

+ ContentUUIDs []string

+ LinkTypes []string

+ Links map[string][]DocumentLink

+ Meta map[string][]DocumentMeta

+ MetaTypes []string

+ Title string

+ Type string

+ URI string

+ UUID string

+ func DetailFromDocument(d newsdoc.Document) *DocumentDetail

+ type DocumentLink struct

+ Role string

+ Type string

+ URI string

+ UUID string

+ Value string

+ type DocumentMeta struct

+ Data newsdoc.DataMap

+ Role string

+ Value string

+ type EventBridge struct

+ func NewEventBridge(client EventBridgeEventPutter, opts EventBridgeOptions) *EventBridge

+ func (*EventBridge) SinkName() string

+ func (eb *EventBridge) SendEvents(ctx context.Context, evts []EventDetail, skipMetric IncrementSkipMetricFunc) (int, error)

+ type EventBridgeEventPutter interface

+ PutEvents func(ctx context.Context, params *eventbridge.PutEventsInput, ...) (*eventbridge.PutEventsOutput, error)

+ type EventBridgeOptions struct

+ EventBusName string

+ Logger *slog.Logger

+ type EventDetail struct

+ Document *DocumentDetail

+ Event repository.Event

+ type EventForwarder struct

+ func NewEventForwarder(opts EventForwarderOptions) (*EventForwarder, error)

+ func (r *EventForwarder) Run(ctx context.Context)

+ func (r *EventForwarder) Stop()

+ type EventForwarderOptions struct

+ DB *pgxpool.Pool

+ Documents repository.Documents

+ Logger *slog.Logger

+ MetricsRegisterer prometheus.Registerer

+ Sink EventSink

+ StateStore SinkStateStore

+ type EventSink interface

+ SendEvents func(ctx context.Context, evts []EventDetail, skipMetric IncrementSkipMetricFunc) (int, error)

+ SinkName func() string

+ type IncrementSkipMetricFunc func(eventType string, reason string)

+ type SinkStateStore interface

+ GetSinkPosition func(ctx context.Context, name string) (int64, error)

+ SetSinkPosition func(ctx context.Context, name string, pos int64) error