natss

Documentation

Index

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

Functions

func NewMessageSink

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

func NewMessageSource

func NewMessageSource(conf MessageSourceConfig) (pubsub.MessageSource, error)

Types

type MessageSinkConfig

type MessageSinkConfig struct {
	NatsURL   string
	ClusterID string
	Topic     string
	ClientID  string
}

type MessageSourceConfig

type MessageSourceConfig struct {
	NatsURL    string
	ClusterID  string
	Topic      string
	ConsumerID string
}