sink

Apr 19, 2023

Changes in this version

+ func NewFileExtension(format config.Config, compression config.Config) (ext string)

+ func NewFileWrapper(f *os.File, format config.Config, compression config.Config) (*fw, error)

Jan 4, 2023

Changes in this version

type Sink

+ func New(cfg config.Config) (Sink, error)

Nov 30, 2022

Changes in this version

+ type Grpc struct

+ Certificate string

+ Server string

+ Timeout int

+ func (sink *Grpc) Send(ctx context.Context, ch *config.Channel) error

Sep 1, 2022

Changes in this version

+ const FirehoseDataExceededSizeLimit

+ const SQSDataExceededSizeLimit

+ type Firehose struct

+ Stream string

+ func (sink *Firehose) Send(ctx context.Context, ch chan config.Capsule, kill chan struct{}) error

+ type SQS struct

+ Queue string

+ func (sink *SQS) Send(ctx context.Context, ch chan config.Capsule, kill chan struct{}) error

Jun 17, 2022

Changes in this version

+ const DynamoDBSinkInvalidJSON

+ const SumoLogicSinkInvalidJSON

type DynamoDB

+ ItemsKey string

+ Table string

type HTTP

+ HeadersKey string

type Kinesis

+ Partition string

+ ShardRedistribution bool

type S3

+ PrefixKey string

type SumoLogic

+ Category string

+ CategoryKey string

Apr 19, 2022

Changes in this version

+ const SinkInvalidFactoryConfig

+ type Config struct

+ Settings map[string]interface{}

+ Type string

+ type DynamoDB struct

+ ErrorOnFailure bool

+ Items []struct{ ... }

+ func (sink *DynamoDB) Send(ctx context.Context, ch chan []byte, kill chan struct{}) error

+ type HTTP struct

+ Headers []struct{ ... }

+ URL string

+ func (sink *HTTP) Send(ctx context.Context, ch chan []byte, kill chan struct{}) error

+ type Kinesis struct

+ PartitionKey string

+ Stream string

+ func (sink *Kinesis) Send(ctx context.Context, ch chan []byte, kill chan struct{}) error

+ type S3 struct

+ Bucket string

+ Prefix string

+ func (sink *S3) Send(ctx context.Context, ch chan []byte, kill chan struct{}) error

+ type Sink interface

+ Send func(context.Context, chan []byte, chan struct{}) error

+ func Factory(cfg Config) (Sink, error)

+ type Stdout struct

+ func (sink *Stdout) Send(ctx context.Context, ch chan []byte, kill chan struct{}) error

+ type SumoLogic struct

+ Categories []struct{ ... }

+ ErrorOnFailure bool

+ URL string

+ func (sink *SumoLogic) Send(ctx context.Context, ch chan []byte, kill chan struct{}) error