Versions in this module Expand all Collapse all v4 v4.22.0 Oct 23, 2023 Changes in this version + func AsyncReaderWithConnBackOff(boff backoff.BackOff) func(a *AsyncReader) + type Async interface + Close func(ctx context.Context) error + Connect func(ctx context.Context) error + ReadBatch func(ctx context.Context) (message.Batch, AsyncAckFn, error) + type AsyncAckFn func(context.Context, error) error + type AsyncCutOff struct + func NewAsyncCutOff(r Async) *AsyncCutOff + func (c *AsyncCutOff) Close(ctx context.Context) error + func (c *AsyncCutOff) Connect(ctx context.Context) error + func (c *AsyncCutOff) ReadBatch(ctx context.Context) (message.Batch, AsyncAckFn, error) + type AsyncPreserver struct + func NewAsyncPreserver(r Async) *AsyncPreserver + func (p *AsyncPreserver) Close(ctx context.Context) error + func (p *AsyncPreserver) Connect(ctx context.Context) error + func (p *AsyncPreserver) ReadBatch(ctx context.Context) (message.Batch, AsyncAckFn, error) + type AsyncReader struct + func (r *AsyncReader) Connected() bool + func (r *AsyncReader) TransactionChan() <-chan message.Transaction + func (r *AsyncReader) TriggerCloseNow() + func (r *AsyncReader) TriggerStopConsuming() + func (r *AsyncReader) WaitForClose(ctx context.Context) error + type BrokerConfig struct + Batching batchconfig.Config + Copies int + Inputs []Config + func NewBrokerConfig() BrokerConfig + type Config struct + Broker BrokerConfig + Dynamic DynamicConfig + Generate GenerateConfig + Inproc InprocConfig + Label string + MQTT MQTTConfig + NSQ NSQConfig + Nanomsg NanomsgConfig + Plugin any + Processors []processor.Config + ReadUntil ReadUntilConfig + Resource string + SFTP SFTPConfig + STDIN STDINConfig + Sequence SequenceConfig + Socket SocketConfig + SocketServer SocketServerConfig + Subprocess SubprocessConfig + Type string + func NewConfig() Config + func (conf *Config) UnmarshalYAML(value *yaml.Node) error + type DynamicConfig struct + Inputs map[string]Config + Prefix string + func NewDynamicConfig() DynamicConfig + type GenerateConfig struct + BatchSize int + Count int + Interval string + Mapping string + func NewGenerateConfig() GenerateConfig + type InprocConfig string + func NewInprocConfig() InprocConfig + type MQTTConfig struct + CleanSession bool + ClientID string + ConnectTimeout string + DynamicClientIDSuffix string + KeepAlive int64 + Password string + QoS uint8 + TLS tls.Config + Topics []string + URLs []string + User string + Will mqttconf.Will + func NewMQTTConfig() MQTTConfig + type NSQConfig struct + Addresses []string + Channel string + LookupAddresses []string + MaxAttempts uint16 + MaxInFlight int + TLS btls.Config + Topic string + UserAgent string + func NewNSQConfig() NSQConfig + type NanomsgConfig struct + Bind bool + PollTimeout string + SocketType string + SubFilters []string + URLs []string + func NewNanomsgConfig() NanomsgConfig + type ReadUntilConfig struct + Check string + Input *Config + Restart bool + func NewReadUntilConfig() ReadUntilConfig + func (r ReadUntilConfig) MarshalJSON() ([]byte, error) + func (r ReadUntilConfig) MarshalYAML() (any, error) + type SFTPConfig struct + Address string + Codec string + Credentials sftpSetup.Credentials + DeleteOnFinish bool + MaxBuffer int + Paths []string + Watcher watcherConfig + func NewSFTPConfig() SFTPConfig + type STDINConfig struct + Codec string + MaxBuffer int + func NewSTDINConfig() STDINConfig + type SequenceConfig struct + Inputs []Config + ShardedJoin SequenceShardedJoinConfig + func NewSequenceConfig() SequenceConfig + type SequenceShardedJoinConfig struct + IDPath string + Iterations int + MergeStrategy string + Type string + func NewSequenceShardedJoinConfig() SequenceShardedJoinConfig + type SocketConfig struct + Address string + Codec string + MaxBuffer int + Network string + func NewSocketConfig() SocketConfig + type SocketServerConfig struct + Address string + Codec string + MaxBuffer int + Network string + TLS SocketServerTLSConfig + func NewSocketServerConfig() SocketServerConfig + type SocketServerTLSConfig struct + CertFile string + KeyFile string + SelfSigned bool + type Streamed interface + Connected func() bool + TransactionChan func() <-chan message.Transaction + TriggerCloseNow func() + TriggerStopConsuming func() + WaitForClose func(ctx context.Context) error + func NewAsyncReader(typeStr string, r Async, mgr component.Observability, ...) (Streamed, error) + func WrapWithPipelines(in Streamed, pipeConstructors ...iprocessor.PipelineConstructorFunc) (Streamed, error) + type SubprocessConfig struct + Args []string + Codec string + MaxBuffer int + Name string + RestartOnExit bool + func NewSubprocessConfig() SubprocessConfig + type WithPipeline struct + func WrapWithPipeline(in Streamed, pipeConstructor iprocessor.PipelineConstructorFunc) (*WithPipeline, error) + func (i *WithPipeline) Connected() bool + func (i *WithPipeline) TransactionChan() <-chan message.Transaction + func (i *WithPipeline) TriggerCloseNow() + func (i *WithPipeline) TriggerStopConsuming() + func (i *WithPipeline) WaitForClose(ctx context.Context) error
Go to main page