proximo

Documentation

Index

• func NewMessageSink(config MessageSinkConfig) (pubsub.MessageSink, error)
• func NewMessageSource(config MessageSourceConfig) pubsub.MessageSource
• type MessageSinkConfig
• type MessageSourceConfig

Functions

func NewMessageSink

func NewMessageSink(config MessageSinkConfig) (pubsub.MessageSink, error)

func NewMessageSource

func NewMessageSource(config MessageSourceConfig) pubsub.MessageSource

Types

type MessageSinkConfig

type MessageSinkConfig struct {
	Topic  string
	Broker string
}

type MessageSourceConfig

type MessageSourceConfig struct {
	ConsumerGroup string
	Topic         string
	Broker        string
}