io

type EgressIdentifier struct {
	EgressNamespace string
	EgressType      string
}

type KafkaRecord struct {
	// The topic to which the message
	// should be written.
	Topic string

	// An optional key to be written with
	// the message into the topic.
	Key string

	// The message to be written
	// to the topic.
	Value proto.Message
}

type KinesisRecord struct {
	// Target AWS Kinesis stream to write to.
	Stream string

	// Partition key to use when writing
	// the record to AWS Kinesis.
	PartitionKey string

	// Optional explicit hash key to use
	// when writing the record to
	// the stream.
	ExplicitHashKey string

	// The message to write out to
	// the target stream.
	Value proto.Message
}