Versions in this module Expand all Collapse all v0 v0.0.2 Apr 3, 2019 Changes in this version + const DeregisterNodeRequestType + const DeregisterPartitionRequestType + const DeregisterTopicRequestType + const HealthAny + const HealthCritical + const HealthMaint + const HealthPassing + const HealthWarning + const RegisterGroupRequestType + const RegisterNodeRequestType + const RegisterPartitionRequestType + const RegisterTopicRequestType + const SerfCheckAliveOutput + const SerfCheckFailedOutput + const SerfCheckID + const SerfCheckName + func Decode(buf []byte, out interface{}) error + func Encode(t MessageType, msg interface{}) ([]byte, error) + 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 + Coordinator int32 + GenerationID int32 + Group string + ID string + LeaderID string + Members map[string]Member + State GroupState + type GroupState int32 + const GroupStateCompletingRebalance + const GroupStateDead + const GroupStateEmpty + const GroupStatePreparingRebalance + const GroupStateStable + type HealthCheck struct + CheckID CheckID + Name string + Node string + Output string + Status string + type Member struct + Assignment []byte + ID string + Metadata []byte + type MessageType uint8 + type Node struct + Address string + Check *HealthCheck + ID int32 + Meta map[string]string + Node int32 + type NodeService struct + Address string + ID string + Port int + Service string + Tags []string + type Partition struct + AR []int32 + ControllerEpoch int32 + ID int32 + ISR []int32 + Leader int32 + LeaderEpoch int32 + Partition int32 + Topic string + 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 + Config TopicConfig + ID string + Internal bool + Partitions map[int32][]int32 + Topic string + type TopicConfig map[string]TopicConfigEntry + func NewTopicConfig() TopicConfig + func (c TopicConfig) Get(name string) TopicConfigEntry + func (c TopicConfig) GetValue(name string) interface{} + func (c TopicConfig) Set(e TopicConfigEntry) + func (c TopicConfig) SetValue(name string, value interface{}) TopicConfig + type TopicConfigEntry struct + ServerDefault string