reader

Aug 26, 2018

Changes in this version

+ type RedisStreams struct

+ func NewRedisStreams(conf RedisStreamsConfig, log log.Modular, stats metrics.Type) (*RedisStreams, error)

+ func (r *RedisStreams) Acknowledge(err error) error

+ func (r *RedisStreams) CloseAsync()

+ func (r *RedisStreams) Connect() error

+ func (r *RedisStreams) Read() (types.Message, error)

+ func (r *RedisStreams) WaitForClose(timeout time.Duration) error

+ type RedisStreamsConfig struct

+ BodyKey string

+ ClientID string

+ CommitPeriodMS int

+ ConsumerGroup string

+ Limit int64

+ StartFromOldest bool

+ Streams []string

+ TimeoutMS int

+ URL string

+ func NewRedisStreamsConfig() RedisStreamsConfig

Aug 25, 2018

Changes in this version

+ type Kinesis struct

+ func NewKinesis(conf KinesisConfig, log log.Modular, stats metrics.Type) *Kinesis

+ func (k *Kinesis) Acknowledge(err error) error

+ func (k *Kinesis) CloseAsync()

+ func (k *Kinesis) Connect() error

+ func (k *Kinesis) Read() (types.Message, error)

+ func (k *Kinesis) WaitForClose(time.Duration) error

+ type KinesisConfig struct

+ ClientID string

+ CommitPeriodMS int

+ Credentials AmazonAWSCredentialsConfig

+ DynamoDBTable string

+ Limit int64

+ Region string

+ Shard string

+ StartFromOldest bool

+ Stream string

+ TimeoutMS int64

+ func NewKinesisConfig() KinesisConfig

Aug 17, 2018

Changes in this version

+ type AMQPBindingConfig struct

+ Exchange string

+ RoutingKey string

type AMQPConfig

+ BindingsDeclare []AMQPBindingConfig

+ QueueDeclare AMQPQueueDeclareConfig

+ type AMQPQueueDeclareConfig struct

+ Durable bool

+ Enabled bool

Aug 17, 2018

Changes in this version

type AMQPConfig

+ ExchangeDurable bool

+ QueueDurable bool

Aug 16, 2018

Changes in this version

type AMQPConfig

+ TLS btls.Config

Aug 9, 2018

Changes in this version

type KafkaBalancedConfig

+ CommitPeriodMS int

type KafkaConfig

+ CommitPeriodMS int

Aug 6, 2018

Changes in this version

type AmazonS3Config

+ Retries int

Jul 31, 2018

Changes in this version

type KafkaBalancedConfig

+ TLS btls.Config

type KafkaConfig

+ TLS btls.Config

Jul 17, 2018

Changes in this version

type KafkaBalancedConfig

+ SkipCertVerify bool

+ TLSEnable bool

type KafkaConfig

+ SkipCertVerify bool

+ TLSEnable bool

Jun 24, 2018

Changes in this version

type WebsocketConfig

+ OpenMsg string

Jun 8, 2018

Changes in this version

+ type Files struct

+ func (f *Files) Acknowledge(err error) error

+ func (f *Files) CloseAsync()

+ func (f *Files) Connect() (err error)

+ func (f *Files) Read() (types.Message, error)

+ func (f *Files) WaitForClose(timeout time.Duration) error

+ type FilesConfig struct

+ Path string

+ func NewFilesConfig() FilesConfig

type Type

+ func NewFiles(conf FilesConfig) (Type, error)

Jun 3, 2018

Changes in this version

+ type Websocket struct

+ func NewWebsocket(conf WebsocketConfig, log log.Modular, stats metrics.Type) (*Websocket, error)

+ func (w *Websocket) Acknowledge(err error) error

+ func (w *Websocket) CloseAsync()

+ func (w *Websocket) Connect() error

+ func (w *Websocket) Read() (types.Message, error)

+ func (w *Websocket) WaitForClose(timeout time.Duration) error

+ type WebsocketConfig struct

+ URL string

+ func NewWebsocketConfig() WebsocketConfig

May 10, 2018

Changes in this version

type NATSStreamConfig

+ StartFromOldest bool

Apr 5, 2018

Changes in this version

type KafkaConfig

+ TargetVersion string

Mar 27, 2018

Changes in this version

type AmazonAWSCredentialsConfig

+ Role string

Mar 21, 2018

Changes in this version

type AmazonS3Config

+ SQSEnvelopePath string

Mar 3, 2018

Changes in this version

type AmazonS3Config

+ SQSMaxMessages int64

Mar 1, 2018

Changes in this version

+ type CutOff struct

+ func NewCutOff(r Type) *CutOff

+ func (c *CutOff) Acknowledge(err error) error

+ func (c *CutOff) CloseAsync()

+ func (c *CutOff) Connect() error

+ func (c *CutOff) Read() (types.Message, error)

+ func (c *CutOff) WaitForClose(tout time.Duration) error

+ type ZMQ4Config struct

+ func NewZMQ4Config() *ZMQ4Config

Feb 23, 2018

Changes in this version

+ type MQTT struct

+ func NewMQTT(conf MQTTConfig, log log.Modular, stats metrics.Type) (*MQTT, error)

+ func (m *MQTT) Acknowledge(err error) error

+ func (m *MQTT) CloseAsync()

+ func (m *MQTT) Connect() error

+ func (m *MQTT) Read() (types.Message, error)

+ func (m *MQTT) WaitForClose(timeout time.Duration) error

+ type MQTTConfig struct

+ ClientID string

+ QoS uint8

+ Topics []string

+ URLs []string

+ func NewMQTTConfig() MQTTConfig

Feb 12, 2018

Changes in this version

+ func OptLinesSetDelimiter(delimiter string) func(r *Lines)

+ func OptLinesSetMaxBuffer(maxBuffer int) func(r *Lines)

+ func OptLinesSetMultipart(multipart bool) func(r *Lines)

+ type AMQP struct

+ func (a *AMQP) Acknowledge(err error) error

+ func (a *AMQP) CloseAsync()

+ func (a *AMQP) Connect() (err error)

+ func (a *AMQP) Read() (types.Message, error)

+ func (a *AMQP) WaitForClose(timeout time.Duration) error

+ type AMQPConfig struct

+ BindingKey string

+ ConsumerTag string

+ Exchange string

+ ExchangeType string

+ PrefetchCount int

+ PrefetchSize int

+ Queue string

+ URL string

+ func NewAMQPConfig() AMQPConfig

type AmazonS3Config

+ Prefix string

+ type KafkaBalanced struct

+ func NewKafkaBalanced(conf KafkaBalancedConfig, log log.Modular, stats metrics.Type) (*KafkaBalanced, error)

+ func (k *KafkaBalanced) Acknowledge(err error) error

+ func (k *KafkaBalanced) CloseAsync()

+ func (k *KafkaBalanced) Connect() error

+ func (k *KafkaBalanced) Read() (types.Message, error)

+ func (k *KafkaBalanced) WaitForClose(timeout time.Duration) error

+ type KafkaBalancedConfig struct

+ Addresses []string

+ ClientID string

+ ConsumerGroup string

+ StartFromOldest bool

+ Topics []string

+ func NewKafkaBalancedConfig() KafkaBalancedConfig

+ type Lines struct

+ func NewLines(handleCtor func() (io.Reader, error), onClose func(), ...) (*Lines, error)

+ func (r *Lines) Acknowledge(err error) error

+ func (r *Lines) CloseAsync()

+ func (r *Lines) Connect() error

+ func (r *Lines) Read() (types.Message, error)

+ func (r *Lines) WaitForClose(timeout time.Duration) error

+ type NATS struct

+ func (n *NATS) Acknowledge(err error) error

+ func (n *NATS) CloseAsync()

+ func (n *NATS) Connect() error

+ func (n *NATS) Read() (types.Message, error)

+ func (n *NATS) WaitForClose(timeout time.Duration) error

+ type NATSConfig struct

+ Subject string

+ URLs []string

+ func NewNATSConfig() NATSConfig

+ type NATSStream struct

+ func (n *NATSStream) Acknowledge(err error) error

+ func (n *NATSStream) CloseAsync()

+ func (n *NATSStream) Connect() error

+ func (n *NATSStream) Read() (types.Message, error)

+ func (n *NATSStream) WaitForClose(timeout time.Duration) error

+ type NATSStreamConfig struct

+ ClientID string

+ ClusterID string

+ DurableName string

+ QueueID string

+ Subject string

+ URLs []string

+ func NewNATSStreamConfig() NATSStreamConfig

+ type NSQ struct

+ func (n *NSQ) Acknowledge(err error) error

+ func (n *NSQ) CloseAsync()

+ func (n *NSQ) Connect() (err error)

+ func (n *NSQ) HandleMessage(message *nsq.Message) error

+ func (n *NSQ) Read() (types.Message, error)

+ func (n *NSQ) WaitForClose(timeout time.Duration) error

+ type NSQConfig struct

+ Addresses []string

+ Channel string

+ LookupAddresses []string

+ MaxInFlight int

+ Topic string

+ UserAgent string

+ func NewNSQConfig() NSQConfig

+ type RedisPubSub struct

+ func NewRedisPubSub(conf RedisPubSubConfig, log log.Modular, stats metrics.Type) (*RedisPubSub, error)

+ func (r *RedisPubSub) Acknowledge(err error) error

+ func (r *RedisPubSub) CloseAsync()

+ func (r *RedisPubSub) Connect() error

+ func (r *RedisPubSub) Read() (types.Message, error)

+ func (r *RedisPubSub) WaitForClose(timeout time.Duration) error

+ type RedisPubSubConfig struct

+ Channels []string

+ URL string

+ func NewRedisPubSubConfig() RedisPubSubConfig

+ type ScaleProto struct

+ func (s *ScaleProto) Acknowledge(err error) error

+ func (s *ScaleProto) CloseAsync()

+ func (s *ScaleProto) Connect() error

+ func (s *ScaleProto) Read() (types.Message, error)

+ func (s *ScaleProto) WaitForClose(timeout time.Duration) error

+ type ScaleProtoConfig struct

+ Bind bool

+ PollTimeoutMS int

+ RepTimeoutMS int

+ SocketType string

+ SubFilters []string

+ URLs []string

+ func NewScaleProtoConfig() ScaleProtoConfig

type Type

+ func NewAMQP(conf AMQPConfig, log log.Modular, stats metrics.Type) (Type, error)

+ func NewNATS(conf NATSConfig, log log.Modular, stats metrics.Type) (Type, error)

+ func NewNATSStream(conf NATSStreamConfig, log log.Modular, stats metrics.Type) (Type, error)

+ func NewNSQ(conf NSQConfig, log log.Modular, stats metrics.Type) (Type, error)

+ func NewScaleProto(conf ScaleProtoConfig, log log.Modular, stats metrics.Type) (Type, error)

Feb 7, 2018

Changes in this version

+ type AmazonAWSCredentialsConfig struct

+ ID string

+ Secret string

+ Token string

+ type AmazonSQS struct

+ func NewAmazonSQS(conf AmazonSQSConfig, log log.Modular, stats metrics.Type) *AmazonSQS

+ func (a *AmazonSQS) Acknowledge(err error) error

+ func (a *AmazonSQS) CloseAsync()

+ func (a *AmazonSQS) Connect() error

+ func (a *AmazonSQS) Read() (types.Message, error)

+ func (a *AmazonSQS) WaitForClose(time.Duration) error

+ type AmazonSQSConfig struct

+ Credentials AmazonAWSCredentialsConfig

+ Region string

+ TimeoutS int64

+ URL string

+ func NewAmazonSQSConfig() AmazonSQSConfig

Feb 7, 2018

Changes in this version

+ type AmazonS3 struct

+ func NewAmazonS3(conf AmazonS3Config, log log.Modular, stats metrics.Type) *AmazonS3

+ func (a *AmazonS3) Acknowledge(err error) error

+ func (a *AmazonS3) CloseAsync()

+ func (a *AmazonS3) Connect() error

+ func (a *AmazonS3) Read() (types.Message, error)

+ func (a *AmazonS3) WaitForClose(time.Duration) error

+ type AmazonS3Config struct

+ Bucket string

+ Credentials AmazonS3CredentialsConfig

+ DeleteObjects bool

+ Region string

+ SQSBodyPath string

+ SQSURL string

+ TimeoutS int64

+ func NewAmazonS3Config() AmazonS3Config

+ type AmazonS3CredentialsConfig struct

+ ID string

+ Secret string

+ Token string

+ type Kafka struct

+ func NewKafka(conf KafkaConfig, log log.Modular, stats metrics.Type) (*Kafka, error)

+ func (k *Kafka) Acknowledge(err error) error

+ func (k *Kafka) CloseAsync()

+ func (k *Kafka) Connect() error

+ func (k *Kafka) Read() (types.Message, error)

+ func (k *Kafka) WaitForClose(timeout time.Duration) error

+ type KafkaConfig struct

+ Addresses []string

+ ClientID string

+ ConsumerGroup string

+ Partition int32

+ StartFromOldest bool

+ Topic string

+ func NewKafkaConfig() KafkaConfig

+ type Preserver struct

+ func NewPreserver(r Type) *Preserver

+ func (p *Preserver) Acknowledge(err error) error

+ func (p *Preserver) CloseAsync()

+ func (p *Preserver) Connect() error

+ func (p *Preserver) Read() (types.Message, error)

+ func (p *Preserver) WaitForClose(tout time.Duration) error

+ type RedisList struct

+ func NewRedisList(conf RedisListConfig, log log.Modular, stats metrics.Type) (*RedisList, error)

+ func (r *RedisList) Acknowledge(err error) error

+ func (r *RedisList) CloseAsync()

+ func (r *RedisList) Connect() error

+ func (r *RedisList) Read() (types.Message, error)

+ func (r *RedisList) WaitForClose(timeout time.Duration) error

+ type RedisListConfig struct

+ Key string

+ TimeoutMS int

+ URL string

+ func NewRedisListConfig() RedisListConfig

+ type Type interface

+ Acknowledge func(err error) error

+ Connect func() error

+ Read func() (types.Message, error)