Documentation
¶
Index ¶
- type Config
- type JetstreamInput
- func (n *JetstreamInput) Close() error
- func (n *JetstreamInput) Dial(network, address string) (net.Conn, error)
- func (n *JetstreamInput) SetEventProcessors(ps map[string]map[string]any, logger *log.Logger, ...) error
- func (n *JetstreamInput) SetLogger(logger *log.Logger)
- func (n *JetstreamInput) SetName(name string)
- func (n *JetstreamInput) SetOutputs(outs map[string]outputs.Output)
- func (n *JetstreamInput) Start(ctx context.Context, name string, cfg map[string]interface{}, ...) error
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"`
Stream string `mapstructure:"stream,omitempty"`
Subjects []string `mapstructure:"subjects,omitempty"`
SubjectFormat subjectFormat `mapstructure:"subject-format,omitempty" json:"subject-format,omitempty"`
DeliverPolicy deliverPolicy `mapstructure:"deliver-policy,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"`
Format string `mapstructure:"format,omitempty"`
Debug bool `mapstructure:"debug,omitempty"`
NumWorkers int `mapstructure:"num-workers,omitempty"`
BufferSize int `mapstructure:"buffer-size,omitempty"`
FetchBatchSize int `mapstructure:"fetch-batch-size,omitempty"`
Outputs []string `mapstructure:"outputs,omitempty"`
EventProcessors []string `mapstructure:"event-processors,omitempty"`
}
Config //
type JetstreamInput ¶
type JetstreamInput struct {
Cfg *Config
// contains filtered or unexported fields
}
JetstreamInput //
func (*JetstreamInput) Dial ¶
func (n *JetstreamInput) Dial(network, address string) (net.Conn, error)
Dial //
func (*JetstreamInput) SetEventProcessors ¶
func (*JetstreamInput) SetLogger ¶
func (n *JetstreamInput) SetLogger(logger *log.Logger)
SetLogger //
func (*JetstreamInput) SetName ¶
func (n *JetstreamInput) SetName(name string)
func (*JetstreamInput) SetOutputs ¶
func (n *JetstreamInput) SetOutputs(outs map[string]outputs.Output)
SetOutputs //
Click to show internal directories.
Click to hide internal directories.