structs

type CheckID string

type ConfigEntry struct {
	Default     interface{}
	Name        string
	ValidValues []interface{}
	Value       interface{}
}

type DeregisterNodeRequest struct {
	Node Node
}

type DeregisterPartitionRequest struct {
	Partition Partition
}

type DeregisterTopicRequest struct {
	Topic Topic
}

type Group struct {
	ID           string
	Group        string
	Coordinator  int32
	LeaderID     string
	Members      map[string]Member
	State        GroupState
	GenerationID int32

	RaftIndex
}

type GroupState int32

type HealthCheck struct {
	Node    string
	CheckID CheckID // unique check id
	Name    string  // check name
	Status  string  // current check stauts
	Output  string  // output of script runs
	RaftIndex
}

type Member struct {
	ID         string
	Metadata   []byte
	Assignment []byte
}

type MessageType uint8

type Node struct {
	ID      int32
	Node    int32
	Address string
	Check   *HealthCheck
	Meta    map[string]string
	RaftIndex
}

type NodeService struct {
	ID      string
	Service string
	Tags    []string
	Address string
	Port    int
	RaftIndex
}

type Partition struct {
	// ID identifies the partition. Is here cause memdb wants the indexed field separate.
	ID        int32
	Partition int32
	// Topic is the topic this partition belongs to.
	Topic string
	// ISR is a slice of replica IDs in ISR
	ISR []int32
	// All assigned replicas
	AR []int32
	// Leader is the ID of the leader replica
	Leader int32
	// ControllerEpoch is the epoch of the controller that last updated
	// the leader and ISR info. TODO: this will probably have to change to fit better.
	ControllerEpoch int32
	LeaderEpoch     int32

	RaftIndex
}

type RaftIndex struct {
	CreateIndex uint64
	ModifyIndex uint64
}

type RegisterGroupRequest struct {
	Group Group
}

type RegisterNodeRequest struct {
	Node Node
}

type RegisterPartitionRequest struct {
	Partition Partition
}

type RegisterTopicRequest struct {
	Topic Topic
}

type Topic struct {
	// ID is ID or name of the topic
	ID string
	// Topic is the name of the topic
	Topic string
	// Partitions is a map of partition IDs to slice of replicas IDs.
	Partitions map[int32][]int32
	// Config
	Config TopicConfig
	// Internal, e.g. group metadata topic
	Internal bool

	RaftIndex
}

type TopicConfig map[string]TopicConfigEntry

type TopicConfigEntry struct {
	ConfigEntry
	ServerDefault string
}