etcd

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

type GrpcService struct {
	PackageName *string `json:"packageName,omitempty"` // 包名
	ServiceName *string `json:"serviceName,omitempty"` // 服务名称
	Addr        *string `json:"addr,omitempty"`        // 服务地址 e.g.: 127.0.0.1:8989 [default]: ""
}

type IEtcd interface {
	Start(ctx context.Context, value string) error
	Stop() error
	GetKey() string
	PutWithLease(key string, value string) (*etcdclientv3.PutResponse, error)
	KeepAlive(ctx context.Context) error
}

type Options struct {
	AddCallback    xcontrol.ICallBack // 增加回调 [default: nil]
	UpdateCallback xcontrol.ICallBack // 更新回调 [default: nil]
	DelCallback    xcontrol.ICallBack // 删除回调 [default: nil]
	// contains filtered or unexported fields
}

type Registry struct {
	DataMap *xmap.MapMutexMgr[string, *ValueJson]
}

type ServerNet struct {
	Addr *string `json:"addr"`           // e.g.: 127.0.0.1:8989 [default]: ""
	Name *string `json:"name,omitempty"` // 链接名称 [default]: ""
	Type *string `json:"type"`           // [tcp, kcp] [default]: xnetcommon.ServerNetTypeNameTCP
}

type ServiceInfo struct {
	ServiceID   uint32
	ServiceName string
	ValueJson   *ValueJson
}

type ValueJson struct {
	ServerNet     []*ServerNet `json:"serverNet,omitempty"`     // 有:直接使用. 没有:使用 etcd.ServerNet
	Version       string       `json:"version,omitempty"`       // 有:直接使用. 没有:使用 base.version 生成
	AvailableLoad uint32       `json:"availableLoad,omitempty"` // 剩余可用负载, 可用资源数
	SecondOffset  int64        `json:"secondOffset,omitempty"`  // 服务 时间(秒)偏移量
	GrpcService   *GrpcService `json:"grpcService,omitempty"`   // gRPC 服务信息
}