producer

type KinesisError struct {
	ErrorCode    string
	ErrorMessage string
	AWSError     error
	Message      *KinesisMessage
}

type KinesisMessage struct {
	Data         []byte
	Stream       string
	PartitionKey string
	Metadata     interface{}
}

type KinesisProducer interface {
	Close()
	Input() chan<- *KinesisMessage
	Successes() <-chan *KinesisMessage
	Errors() <-chan *KinesisError
}

type KinesisProducerConfig struct {
	// max time that should elapse before sending buffered requests to kinesis
	FlushFrequency *goprimitives.Duration `json:"flushFrequency"`
	// min num number of buffered bytes to have before sending a request to kinesis
	FlushBytes int `json:"flushBytes"`
	// min number of buffered requests before sending a request to kinesis
	FlushMessages int `json:"flushMessages"`
	// max number of buffered requests before sending a request to kinesis
	FlushMaxMessages int `json:"flushMaxMessages"`
	// max number of outstanding requests to a single kinesis stream
	MaxOpenRequests int `json:"maxOpenRequests"`
	// max size of the data blob (kinesis record) that can be sent to kinesis (no more then 50KB)
	MaxMessageBytes int `json:"maxMessageBytes"`
	// run the AWS client in debug mode
	AWSDebugMode bool `json:"awsDebugMode"`
	// max number of attempts when sending a request to kinesis
	MaxRetries int `json:"maxRetries"`
	// the size of internal buffers
	BufferSize int `json:"bufferSize"`
	// should the producer return successfully acknowledged messages from kinesis (you must read
	// from the Successes() channel if this is true
	AckSuccess bool `json:"AckSuccesses"`
}

type KinesisStreamManager struct {
	// contains filtered or unexported fields
}

type KinesisStreamProducer struct {
	// contains filtered or unexported fields
}

type KinesisStreamProducerError string