Documentation
¶
Index ¶
- type Config
- type StanOutput
- func (s *StanOutput) Close() error
- func (s *StanOutput) Init(ctx context.Context, cfg map[string]interface{}, logger *log.Logger) error
- func (s *StanOutput) Metrics() []prometheus.Collector
- func (s *StanOutput) String() string
- func (s *StanOutput) Write(_ context.Context, rsp protoreflect.ProtoMessage, meta outputs.Meta)
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"`
PingInterval int `mapstructure:"ping-interval,omitempty"`
PingRetry int `mapstructure:"ping-retry,omitempty"`
Format string `mapstructure:"format,omitempty"`
RecoveryWaitTime time.Duration `mapstructure:"recovery-wait-time,omitempty"`
}
Config //
type StanOutput ¶
type StanOutput struct {
Cfg *Config
// contains filtered or unexported fields
}
StanOutput //
func (*StanOutput) Init ¶
func (s *StanOutput) Init(ctx context.Context, cfg map[string]interface{}, logger *log.Logger) error
Init //
func (*StanOutput) String ¶
func (s *StanOutput) String() string
func (*StanOutput) Write ¶
func (s *StanOutput) Write(_ context.Context, rsp protoreflect.ProtoMessage, meta outputs.Meta)
Write //
Click to show internal directories.
Click to hide internal directories.