kinesisPool

type Client struct {
	sync.Mutex

	ID int64
	// contains filtered or unexported fields
}

type Config struct {
	// Internal clients details
	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 Kinesis record
	MaxRecords    int  // To send in batch to Kinesis
	Compress      bool // Compress records with snappy

	// Authentication and enpoints
	StreamName string // Kinesis/Kinesis stream name
	Region     string // AWS region
	Profile    string // AWS Profile name
}

type Server struct {
	sync.Mutex

	C chan interface{}
	// contains filtered or unexported fields
}