Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Setup ¶
func Setup(bs json.RawMessage) (types.InputPlugin, error)
Types ¶
type Nats ¶
type Nats struct {
plugin.PluginCommon
// Nats message format
input.FormatMeta
sync.Mutex
// Hosts is the URL of the nats servers. Must not be empty.
Hosts []string
// Nats subject. Must not be empty.
Subject string
// Nats queue name.
QueueName string
// QueueLen is nats subscriber queue length.
QueueLen int
// Nats user, If a token is given, it is not used.
User string
// Nats password, If a token is given, it is not used.
Password string
// Nats token
Token string
// contains filtered or unexported fields
}
The nats plugin retrieves messages from the nats server.
Click to show internal directories.
Click to hide internal directories.