streammanager

Documentation

Index

• func Close(producer interface{}, destType string) error
• func NewProducer(destinationConfig map[string]interface{}, destType string, opts common.Opts) (common.StreamProducer, error)
• func Produce(jsonData json.RawMessage, destType string, producer, config interface{}) (int, string, string)

Functions

func Close

func Close(producer interface{}, destType string) error

Close delegates the call to the appropriate manager based on parameter destination to close a given producer TODO check if it's possible to pass a context

func NewProducer

func NewProducer(destinationConfig map[string]interface{}, destType string, opts common.Opts) (common.StreamProducer, error)

NewProducer delegates the call to the appropriate based on parameter destination for creating producer

func Produce

func Produce(jsonData json.RawMessage, destType string, producer, config interface{}) (int, string, string)

Produce delegates call to appropriate manager based on parameter destination