brokers

Documentation

Index

• 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
  • func Get(name string) Broker
• type Metadata
• type MetadataExtractor
• type Unmarshaler

Functions

func ContextWithDataSource

func ContextWithDataSource(ctx context.Context, dc *raptorApi.DataSource) context.Context

func DataSourceFromContext

func DataSourceFromContext(ctx context.Context) *raptorApi.DataSource

func Register

func Register(name string, b Broker)

Register registers a broker

Types

type Broker

type Broker interface {
	Metadata(context.Context, *pubsub.Message) Metadata
	Subscribe(context.Context, raptorApi.ParsedConfig) (context.Context, *pubsub.Subscription, error)
}

func Get

func Get(name string) Broker

Get retrieves a broker

type Metadata

type Metadata struct {
	Topic     string
	Timestamp time.Time
	ID        string
}

type MetadataExtractor

type MetadataExtractor func(ctx context.Context, msg *pubsub.Message) Metadata

type Unmarshaler

type Unmarshaler func(any) error