Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
Client is the thread that connect to the remote redis server
type Config ¶
type Config struct { // Internal clients details MinWorkers int MaxWorkers int ThresholdWarmUp float64 Interval time.Duration CoolDownPeriod time.Duration Critical bool // Handle this stream as critical Serializer func(i interface{}) ([]byte, error) // Limits Buffer int ConcatRecords bool // Contact many rows in one firehose record MaxRecords int // To send in batch to Kinesis Compress bool // Compress records with snappy // Authentication and enpoints StreamName string // Kinesis/Firehose stream name Region string // AWS region Profile string // AWS Profile name Endpoint string // AWS endpoint OnFHError func(e error) }
Config is the general configuration for the server
Click to show internal directories.
Click to hide internal directories.