weighter_notify

Documentation

Index

• type WeighterNotifyI
  • func New(ctx context.Context, t WeighterType) WeighterNotifyI
• type WeighterType

Types

type WeighterNotifyI

type WeighterNotifyI interface {
	GrpcUnaryClientInterceptor(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error
	NotifyWeighterChange() <-chan []*common.KV
	Close() error
}

func New

func New(ctx context.Context, t WeighterType) WeighterNotifyI

type WeighterType

type WeighterType int

const (
	DefaultWeighter WeighterType = iota
	RespTimeWeighter
)