Versions in this module Expand all Collapse all v0 v0.2.0 Feb 9, 2024 v0.1.0 Jan 31, 2023 Changes in this version + func ContextWithDataSource(ctx context.Context, dc *raptorApi.DataSource) context.Context + func DataSourceFromContext(ctx context.Context) *raptorApi.DataSource + func Register(name string, b Broker) + type Broker interface + Metadata func(context.Context, *pubsub.Message) Metadata + Subscribe func(context.Context, raptorApi.ParsedConfig) (context.Context, *pubsub.Subscription, error) + func Get(name string) Broker + type Metadata struct + ID string + Timestamp time.Time + Topic string + type MetadataExtractor func(ctx context.Context, msg *pubsub.Message) Metadata + type Unmarshaler func(any) error
Go to main page