stan_input

Documentation

Index

• type Config
• type StanInput
  • func (s *StanInput) Close() error
  • func (s *StanInput) SetEventProcessors(ps map[string]map[string]interface{}, logger *log.Logger, ...) error
  • func (s *StanInput) SetLogger(logger *log.Logger)
  • func (s *StanInput) SetName(name string)
  • func (s *StanInput) SetOutputs(outs map[string]outputs.Output)
  • func (s *StanInput) Start(ctx context.Context, name string, cfg map[string]interface{}, ...) error
  • func (s *StanInput) String() string

Types

type Config

type Config struct {
	Name            string           `mapstructure:"name,omitempty"`
	Address         string           `mapstructure:"address,omitempty"`
	Subject         string           `mapstructure:"subject,omitempty"`
	Queue           string           `mapstructure:"queue,omitempty"`
	Username        string           `mapstructure:"username,omitempty"`
	Password        string           `mapstructure:"password,omitempty"`
	ConnectTimeWait time.Duration    `mapstructure:"connect-time-wait,omitempty"`
	TLS             *types.TLSConfig `mapstructure:"tls,omitempty" json:"tls,omitempty"`
	ClusterName     string           `mapstructure:"cluster-name,omitempty"`
	PingInterval    int              `mapstructure:"ping-interval,omitempty"`
	PingRetry       int              `mapstructure:"ping-retry,omitempty"`
	Format          string           `mapstructure:"format,omitempty"`
	Debug           bool             `mapstructure:"debug,omitempty"`
	NumWorkers      int              `mapstructure:"num-workers,omitempty"`
	Outputs         []string         `mapstructure:"outputs,omitempty"`
	EventProcessors []string         `mapstructure:"event-processors,omitempty"`
}

Config //

type StanInput

type StanInput struct {
	Cfg *Config
	// contains filtered or unexported fields
}

StanInput //

func (*StanInput) Close

func (s *StanInput) Close() error

func (*StanInput) SetEventProcessors

func (s *StanInput) SetEventProcessors(ps map[string]map[string]interface{}, logger *log.Logger, tcs map[string]*types.TargetConfig, acts map[string]map[string]interface{}) error

func (*StanInput) SetLogger

func (s *StanInput) SetLogger(logger *log.Logger)

func (*StanInput) SetName

func (s *StanInput) SetName(name string)

func (*StanInput) SetOutputs

func (s *StanInput) SetOutputs(outs map[string]outputs.Output)

func (*StanInput) Start

func (s *StanInput) Start(ctx context.Context, name string, cfg map[string]interface{}, opts ...inputs.Option) error

func (*StanInput) String

func (s *StanInput) String() string