kdb

package

v0.0.0-...-91d2721 Latest Latest Go to latest Published: May 26, 2022 License: GPL-3.0 Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

func MakeTopicName(topicType string) string

MakeTopicName creates a topic name - adds the prefix if needed

func NewKafkaWriter(ctx context.Context, topic string) (writer *kafka.Writer, err error)

type AllWriters struct {
	// contains filtered or unexported fields
}

var W AllWriters

W aka Writers is a globally shared set of topic:Writer instances

func (w *AllWriters) Close() error

func (w *AllWriters) Get(ctx context.Context, topic string) (*kafka.Writer, error)

Get or create the requested writer for the given topic - ctx is only used for new connections!