gossip

type GossipConfig struct {
	// GossipProbeInterval define the probe interval used by the gossip
	// service in tests.
	// GossipProbeInterval time.Duration `json:"gossipProbeInterval"`
	// BindAddress is the address for the gossip service to bind to and listen on.
	// Both UDP and TCP ports are used by the gossip service. The local gossip
	// service should be able to receive gossip service related messages by
	// binding to and listening on this address. BindAddress is usually in the
	// format of IP:Port, Hostname:Port or DNS Name:Port.
	BindAddress string `json:"-"`
	BindPort    uint16 `json:"bindPort"`

	// AdvertiseAddress is the address to advertise to other NodeHost instances
	// used for NAT traversal. Gossip services running on remote NodeHost
	// instances will use AdvertiseAddress to exchange gossip service related
	// messages. AdvertiseAddress is in the format of IP:Port.
	// AdvertiseAddress string
	// Seed is a list of AdvertiseAddress of remote NodeHost instances. Local
	// NodeHost instance will try to contact all of them to bootstrap the gossip
	// service. At least one reachable NodeHost instance is required to
	// successfully bootstrap the gossip service. Each seed address is in the
	// format of IP:Port, Hostname:Port or DNS Name:Port.
	//
	// It is ok to include seed addresses that are temporarily unreachable, e.g.
	// when launching the first NodeHost instance in your deployment, you can
	// include AdvertiseAddresses from other NodeHost instances that you plan to
	// launch shortly afterwards.
	Seeds []string `json:"seeds"`
	// contains filtered or unexported fields
}

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

type GossipOptions struct {
	// gossip name
	Name string

	// shard moveTo grpc addr
	MoveToGrpcAddr string

	// server grpc addr
	ServerGrpcAddr string

	GossipNodes        int
	LogDir             string
	LogLevel           zapcore.Level
	DisableCoordinates bool
}

type MemberInfo struct {
	ShardId        uint64
	ConfigChangeId uint64
	Replicas       map[uint64]string
	Observers      map[uint64]string
	LeaderId       uint64
	LeaderValid    bool
}

type Meta struct {
	MoveToGrpcAddr string
	ServerGrpcAddr string
}

type PushPullMessage struct {
	Shard      *RaftShardMessage
	Membership *RaftMembershipMessage
}

type RaftMembershipMessage struct {
	// key: shardId
	MemberInfos map[uint64]*MemberInfo
}

type RaftShardMessage struct {
	Revision int64 `json:"revision"`

	// 机器ID对应的MoveTo的GRPC地址
	// key: 当raft以nodehostid=true的方式起的时候是机器ID，以固定地址方式起是raftAddr
	Targets map[string]TargetShardId `json:"targets"`

	// 每个raft shard对应的机器ID|raftAddr
	Shards map[uint64][]string `json:"shards"`

	// 每个raft shard的initial members
	// key: shardId, key: replicaId, val: raftAddr或nodeHostID
	InitialMembers map[uint64]map[uint64]string `json:"initial_members"`
	Join           map[uint64]map[uint64]bool   `json:"join"`
}

type ShardCallback func(shard *RaftShardMessage) error

type TargetShardId struct {
	GrpcAddr string   `json:"grpcAddr"`
	ShardIds []uint64 `json:"shardIds"`
}