lib

Documentation

Index

• func Start(ctx context.Context, config config.Config, sourcing interfaces.SourcingFactory, ...) error
• func StartDefault(ctx context.Context, config config.Config) error
• type Producer

Functions

func Start

func Start(ctx context.Context, config config.Config, sourcing interfaces.SourcingFactory, events interfaces.EventsFactory, analytics interfaces.AnalyticsFactory, devices interfaces.DevicesFactory, apiFactory func(ctx context.Context, config config.Config, ctrl interfaces.Events) error) error

func StartDefault

func StartDefault(ctx context.Context, config config.Config) error

Types

type Producer

type Producer interface {
	Produce(key string, message []byte) error
}