selector

type Builder interface {
	Build() Selector
}

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

type DoneFunc func(ctx context.Context, di DoneInfo)

type DoneInfo struct {
	// Response Error
	Err error
	// Response Metadata
	ReplyMD ReplyMD

	// BytesSent indicates if any bytes have been sent to the server.
	BytesSent bool
	// BytesReceived indicates if any byte has been received from the server.
	BytesReceived bool
}

type Node interface {

	// Address is the unique address under the same service
	Address() string

	// ServiceName is service name
	ServiceName() string

	// InitialWeight is the initial value of scheduling weight
	// if not set return nil
	InitialWeight() int64

	// Version is service node version
	Version() string

	// Metadata is the kv pair metadata associated with the service instance.
	// version,namespace,region,protocol etc..
	Metadata() map[string]string
}

type Peer struct {
	// node is the peer node.
	Node Node
}

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

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

type ReplyMD interface {
	Get(key string) string
}

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

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

type Selector interface {
	Add(nodes ...Node) error
	Next(ctx context.Context) (selected Node, err error)
}

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

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

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

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