cluster

type Caller interface {
	OnStartedLeading()
	OnStoppedLeading()
	OnReleaseMaster()
	OnNewLeader(leaderName string)
	MasterCall()
	SlaverCall(leaderName string)
}

type Cluster struct {
	Redis redisv1.RedisClient `autowired:"" conditional_on_property:"default.cluster.mode=redis"` // redis
	// contains filtered or unexported fields
}

type Config struct {
	Mode    string `yaml:"mode" default:"cluster" json:"mode"`
	Timeout int    `yaml:"timeout" default:"10" json:"timeout"`
	Enable  string `yaml:"enable" default:"false" json:"enable"`
	Nodes   []*struct {
		Name  string
		Ip    string
		Port  int
		Local bool //true表示当前进程与当前node匹配。适用本机测试等情况。线上为了配置文件一致性尽量不要使用。
	} `yaml:"nodes" json:"nodes"`
	RedisDiscovery    RedisDiscovery    `yaml:"redisDiscovery" json:"redisDiscovery"`
	ReplicasDiscovery ReplicasDiscovery `yaml:"replicasDiscovery" json:"replicasDiscovery"`
}

type DefaultCaller struct {
}

type DefaultJobTracker struct {
	Interval int
	// contains filtered or unexported fields
}

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

type ICluster interface {
	Name() string                                                                 // 名称
	Start() error                                                                 // 启动
	Close()                                                                       // 关闭
	IsFighting() bool                                                             // 集群是否正在选举
	IsClose() bool                                                                // 集群是否关闭
	IsReady() bool                                                                // 集群是否就绪
	IsLeader() bool                                                               // 当前节点是否是领导人
	IsCandidate() bool                                                            // 当前节点是否是候选人
	IsFollower() bool                                                             // 当前节点是否是群众
	GetLeaderNode() *Node                                                         // 获取当前的主节点
	GetLeaderName() string                                                        // 获取leader名称
	GetMyNode() *Node                                                             // 获取当前本节点
	GetNodeByName(name string) *Node                                              // 根据名称获取节点
	GetMyAddress() string                                                         // 获取当前节点通信地址
	GetMyName() string                                                            // 获得当前本节点名称
	GetMyTerm() int                                                               // 获取当前本节点任期
	GetAllNodeNames() []string                                                    // 获取所有节点名称
	GetAllNodeCount() int                                                         // 获取所有节点的数量
	GetAliveNodeNames() []string                                                  // 获取所有活着的节点名称
	GetAliveNodeCount() int                                                       // 获取在线节点数量
	GetLostNodeNames() []string                                                   // 获取所有失联节点名称
	AddJobTracker(v JobTracker) error                                             // add scheduler
	RemoveJobTracker(v JobTracker)                                                // remove scheduler
	RegisterFunc(funcName string, fn func(data interface{}) (interface{}, error)) // registerFunc
	CallFunc(fc *FuncSpec) (interface{}, error)                                   // callFunc
}

type JobTracker interface {
	Name() string
	// OnStartedLeading is called when a LeaderElector client starts leading
	OnStartedLeading()
	// OnStoppedLeading is called when a LeaderElector client stops leading
	OnStoppedLeading()
	// OnReleaseMaster is called when a client release master
	OnReleaseMaster()
	// OnNewLeader is called when the client observes a leader that is
	// not the previously observed leader. This includes the first observed
	// leader when the client starts.
	OnNewLeader(leaderName string)
}

type Message struct {
	NodeName       string `json:"nodeName"`
	Term           int    `json:"term"`
	LeaderNodeName string `json:"leaderNodeName,omitempty"`
	VoteNodeName   string `json:"voteNodeName,omitempty"`
	Success        bool   `json:"success"`
}

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

type RedisDiscovery struct {
	BeanName           string        `yaml:"beanName"`                         // 如果为空，则Ioc分配
	DataPath           string        `yaml:"dataPath"`                         // redis key
	ElectionInterval   time.Duration `yaml:"electionInterval" default:"15s"`   //多久进行一次选主/续约
	ElectionPeriod     time.Duration `yaml:"electionPeriod" default:"30s"`     //选主/续约后有效租期时间
	SyncLeaderInterval time.Duration `yaml:"syncLeaderInterval" default:"10s"` //多久同步一次leader
}

type ReplicasDiscovery struct {
	DomainPatten string `yaml:"domainPatten"`
	Port         int    `yaml:"port" default:"8081"`
	Replicas     int    `yaml:"replicas"`
}