jetstream_input

Sep 19, 2025

Changes in this version

+ type Config struct

+ Address string

+ BufferSize int

+ ConnectTimeWait time.Duration

+ Debug bool

+ DeliverPolicy deliverPolicy

+ EventProcessors []string

+ FetchBatchSize int

+ Format string

+ Name string

+ NumWorkers int

+ Outputs []string

+ Password string

+ Stream string

+ SubjectFormat subjectFormat

+ Subjects []string

+ TLS *types.TLSConfig

+ Username string

+ type JetstreamInput struct

+ Cfg *Config

+ 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