streammanager

package

v0.0.0-...-0ade494 Latest Latest Go to latest Published: Aug 26, 2022 License: AGPL-3.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/serviceexchange/server

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)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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

Types ¶

This section is empty.

Source Files ¶

View all Source files

streammanager.go

Directories ¶

Path	Synopsis
bqstream
common
eventbridge
firehose
googlepubsub
googlesheets
kafka
client
client/testutil
kinesis
lambda
personalize

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL