events

type Encoder interface {
	// Encodes an event into some kind of binary representation.
	Encode(event Event) ([]byte, error)

	// Close the encoder.
	Close() error
}

type Event interface {
	// Returns the avro schema of this event
	Schema() string

	// Writes the event (in avro format) to the given writer.
	Serialize(io.Writer) error
}

type EventSender interface {
	// Send the given event. This method should be non blocking and
	// must never fail. You might want to use a channel for buffering
	// events internally
	Send(event Event)

	// Close the event sender and flush all pending events.
	Close() error
}

type EventTopics struct {
	EventTypes map[reflect.Type]kafka.Topic

	// This is the fallback topic if a type can not be matched to one of the event types.
	// It will be created automatically.
	Fallback string
}

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

type KafkaSenderConfig struct {
	// Set to true to block Send() if the buffers are full.
	AllowBlocking bool

	// Topics configuration
	TopicsConfig EventTopics

	// The event encoder to use
	Encoder Encoder
}

type LogrusEventSender struct {
	logrus.FieldLogger
}

type NoopEventSender struct{}

type TopicsFunc func(replicationFactor int16) EventTopics

type WriterEventSender struct {
	io.WriteCloser
}