streammanager

Documentation

Index

• func CloseProducer(producer interface{}, destType string) error
• func NewProducer(destinationConfig interface{}, destType string, o Opts) (interface{}, error)
• func Produce(jsonData json.RawMessage, destType string, producer, config interface{}) (int, string, string)
• type Opts
• type StreamProducer

Functions

func CloseProducer

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

CloseProducer delegates the call to the appropriate manager based on parameter destination to close a given producer

func NewProducer

func NewProducer(destinationConfig interface{}, destType string, o Opts) (interface{}, 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

Types

type Opts

type Opts struct {
	Timeout time.Duration
}

type StreamProducer

type StreamProducer interface {
	Produce(jsonData json.RawMessage, producer, destConfig interface{}) (int, string, string)
}