Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Name string `mapstructure:"name,omitempty"`
Address string `mapstructure:"address,omitempty"`
SubjectPrefix string `mapstructure:"subject-prefix,omitempty"`
Subject string `mapstructure:"subject,omitempty"`
Username string `mapstructure:"username,omitempty"`
Password string `mapstructure:"password,omitempty"`
ClusterName string `mapstructure:"cluster-name,omitempty"`
Timeout int `mapstructure:"timeout,omitempty"`
PingInterval int `mapstructure:"ping-interval,omitempty"`
PingRetry int `mapstructure:"ping-retry,omitempty"`
Format string `mapstructure:"format,omitempty"`
}
Config //
type StanOutput ¶
type StanOutput struct {
Cfg *Config
// contains filtered or unexported fields
}
StanOutput //
func (*StanOutput) Init ¶
func (s *StanOutput) Init(cfg map[string]interface{}, logger *log.Logger) error
Init //
func (*StanOutput) String ¶
func (s *StanOutput) String() string
func (*StanOutput) Write ¶
func (s *StanOutput) Write(rsp protoreflect.ProtoMessage, meta outputs.Meta)
Write //
Click to show internal directories.
Click to hide internal directories.