jetstream_input

package
v0.42.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 19, 2025 License: Apache-2.0 Imports: 19 Imported by: 0

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

func (n *JetstreamInput) Close() error

Close //

func (*JetstreamInput) Dial

func (n *JetstreamInput) Dial(network, address string) (net.Conn, error)

Dial //

func (*JetstreamInput) SetEventProcessors

func (n *JetstreamInput) SetEventProcessors(ps map[string]map[string]any, logger *log.Logger, tcs map[string]*types.TargetConfig, acts map[string]map[string]any) error

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 //

func (*JetstreamInput) Start

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

Init //

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL