kafka

type Assignment map[int32]int64

type BOF struct {
	Topic     string
	Partition int32
	Offset    int64
	Hwm       int64
}

type Consumer interface {
	Events() <-chan Event

	// group consume assumes co-partioned topics
	Subscribe(topics map[string]int64) error
	AddGroupPartition(partition int32)
	Commit(topic string, partition int32, offset int64) error

	// consume individual topic/partitions
	AddPartition(topic string, partition int32, initialOffset int64)
	RemovePartition(topic string, partition int32)

	// Close stops closes the events channel
	Close() error
}

type EOF struct {
	Topic     string
	Partition int32
	Hwm       int64
}

type Error struct {
	Err error
}

type Event interface {
	// contains filtered or unexported methods
}

type Message struct {
	Topic     string
	Partition int32
	Offset    int64

	Key   string
	Value []byte
}

type NOP struct {
	Topic     string
	Partition int32
}

type Producer interface {
	// Emit sends a message to topic.
	// TODO (franz): this method should return a promise, instead of getting one.
	// Otherwise a callback is sufficient
	Emit(topic string, key string, value []byte) *Promise
	Close() error
}

type Promise struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type TopicManager interface {
	// EnsureTableExists checks that a table (log-compacted topic) exists, or create one if possible
	EnsureTableExists(topic string, npar int) error
	// EnsureStreamExists checks that a stream topic exists, or create one if possible
	EnsureStreamExists(topic string, npar int) error

	// Partitions returns the number of partitions of a topic, that are assigned to the running
	// instance, i.e. it doesn't represent all partitions of a topic.
	Partitions(topic string) ([]int32, error)

	// Close closes the topic manager
	Close() error
}

type TopicManagerConfig struct {
	Table struct {
		Replication int
	}
	Stream struct {
		Replication int
		Retention   time.Duration
	}
}