cluster

type Balancer interface {
	Pick(sess Session) (NodeEntry, error)
}

type BalancerFactory func(serviceCode int32, nodes []NodeEntry) Balancer

type GRPCEntry struct {
	// 监听地址 host:port
	Endpoint string `json:"endpoint"`

	// grpc服务列表
	Services []GRPCServiceDesc `json:"services"`
}

type GRPCServiceDesc struct {
	// 服务代码枚举值，每个服务的代码值必须唯一
	//
	// 网关会根据客户端请求消息内的service_code字段，将请求转发到对应的服务
	Code int32 `json:"code"`

	// 服务路径，网关在构造grpc请求时，用于方法地址构造
	//
	// example: /helloworld.Greeter
	Path string `json:"path"`

	// 是否允许客户端访问
	Public bool `json:"public,omitempty"`

	// 负载均衡策略
	Balancer string `json:"balancer"`

	// Weight 节点权重，用于负载均衡
	Weight int `json:"weight,omitempty"`

	// Stateful 是否有状态服务
	Stateful bool `json:"stateful,omitempty"`

	// Allocation 有状态节点分配方式
	Allocation string `json:"allocation,omitempty"`

	// Pipeline 声明管道名称的服务，请求会严格按照时序性顺序处理，没有声明管道的请求会被并发处理
	//
	// 多个服务可以声明同一个管道名称，这样请求会被分配到同一个管道中
	Pipeline string `json:"pipeline,omitempty"`
}

type NodeEntry struct {
	// 节点ID，集群内唯一
	ID ulid.ULID `json:"id"`

	// 节点名称，仅用于显示
	Name string `json:"name"`

	// 节点状态
	State NodeState `json:"state"`

	// 网关入口URL
	//
	// Example:
	//	 - tcp://0.0.0.0:8222
	//	 - ws://0.0.0.0:8222/grpc
	Entrance string `json:"entrance,omitempty"`

	// grpc服务信息
	GRPC GRPCEntry `json:"grpc"`

	// git版本
	GitVersion string `json:"git_version,omitempty"`
}

type NodeState string

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

type Session interface {
	ID() string
	RemoteAddr() string
}