stan_output

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)

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) Close

func (s *StanOutput) Close() error

Close //

func (*StanOutput) Init

func (s *StanOutput) Init(ctx context.Context, cfg map[string]interface{}, logger *log.Logger) error

Init //

func (*StanOutput) Metrics

func (s *StanOutput) Metrics() []prometheus.Collector

Metrics //

func (*StanOutput) String

func (s *StanOutput) String() string

func (*StanOutput) Write

func (s *StanOutput) Write(_ context.Context, rsp protoreflect.ProtoMessage, meta outputs.Meta)

Write //