cnt2

type ClientConfig struct {
	Endpoints     []string
	DialTimeout   time.Duration
	LocalFilePath string //指定本地缓存的存储地址，便于在配置中心不可用时，可以使用之前的配置
	App           string
	Profile       string
	EnableCommon  bool
}

type Cnt2Service struct {
	*ClientConfig
	// contains filtered or unexported fields
}

type Config struct {
	App         string            `json:"app"`
	Profile     string            `json:"profile"`
	Key         string            `json:"key"`
	Version     int64             `json:"version"`
	PublishInfo ConfigPublishInfo `json:"publishInfo"`
	Value       string            `json:"value"`
}

type ConfigCenterServiceClient interface {
	// 根据appId，profile 查询
	QueryAll(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	// 根据appId，profile，key，keyVersion查询，keyVersion=0时，返回最新数据，否则返回指定版本数据
	QueryKey(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*ResponseMessage, error)
	//  发布处理结果通知（灰度才会有这个回调通知）
	ValueChangeResultNotify(ctx context.Context, in *ValueChangeResultRequest, opts ...grpc.CallOption) (*ValueChangeResultResponse, error)
	// 启动的时候注册服务:获取服务id
	RegisterClient(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
}

type ConfigCenterServiceServer interface {
	// 根据appId，profile 查询
	QueryAll(context.Context, *QueryRequest) (*QueryResponse, error)
	// 根据appId，profile，key，keyVersion查询，keyVersion=0时，返回最新数据，否则返回指定版本数据
	QueryKey(context.Context, *QueryRequest) (*ResponseMessage, error)
	//  发布处理结果通知（灰度才会有这个回调通知）
	ValueChangeResultNotify(context.Context, *ValueChangeResultRequest) (*ValueChangeResultResponse, error)
	// 启动的时候注册服务:获取服务id
	RegisterClient(context.Context, *RegisterRequest) (*RegisterResponse, error)
}

type ConfigPublishInfo struct {
	PublishId    int64       `json:"publishId"`
	Key          string      `json:"key"`
	Version      int64       `json:"version"`
	PublishNodes StringArray `json:"publishNodes"`
}

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

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

type GrpcServerInfo struct {
	ServerIP map[int]string `json:"serverIP"`
	Port     int            `json:"port"`
	GroupId  int            `json:"groupId"`
}

type HostIP struct {
	Type NetType
	Ip   string
}

type HostInfo struct {
	Ips     []HostIP
	GroupId int
}

type LocalStore struct {
	Db *bolt.DB
	// contains filtered or unexported fields
}

type NetType struct {
	Name string
	Val  int
}

type Node struct {
	NodeId       string `json:"nodeId"`
	App          string `json:"app"`
	Profile      string `json:"profile"`
	Sip          string `json:"sip"`
	Pid          int    `json:"pid"`
	RegisterTime int64  `json:"registerTime"`
}

type QueryRequest struct {
	App        string `protobuf:"bytes,1,opt,name=app" json:"app,omitempty"`
	Profile    string `protobuf:"bytes,2,opt,name=profile" json:"profile,omitempty"`
	Key        string `protobuf:"bytes,3,opt,name=key" json:"key,omitempty"`
	KeyVersion int64  `protobuf:"varint,4,opt,name=key_version,json=keyVersion" json:"key_version,omitempty"`
}

type QueryResponse struct {
	Result []*ResponseMessage `protobuf:"bytes,1,rep,name=result" json:"result,omitempty"`
}

type RegisterRequest struct {
	App      string `protobuf:"bytes,1,opt,name=app" json:"app,omitempty"`
	Profile  string `protobuf:"bytes,2,opt,name=profile" json:"profile,omitempty"`
	ServerIp string `protobuf:"bytes,3,opt,name=server_ip,json=serverIp" json:"server_ip,omitempty"`
	Pid      string `protobuf:"bytes,4,opt,name=pid" json:"pid,omitempty"`
}

type RegisterResponse struct {
	Result int32  `protobuf:"varint,1,opt,name=result" json:"result,omitempty"`
	NodeId string `protobuf:"bytes,2,opt,name=node_id,json=nodeId" json:"node_id,omitempty"`
}

type ResponseMessage struct {
	Key     string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Profile string `protobuf:"bytes,2,opt,name=profile" json:"profile,omitempty"`
	Path    string `protobuf:"bytes,3,opt,name=path" json:"path,omitempty"`
	Value   string `protobuf:"bytes,4,opt,name=value" json:"value,omitempty"`
	Version int64  `protobuf:"varint,5,opt,name=version" json:"version,omitempty"`
}

type StringArray []string

type ValueChangeResultRequest struct {
	NodeId   string                                     `protobuf:"bytes,1,opt,name=node_id,json=nodeId" json:"node_id,omitempty"`
	App      string                                     `protobuf:"bytes,2,opt,name=app" json:"app,omitempty"`
	Profile  string                                     `protobuf:"bytes,3,opt,name=profile" json:"profile,omitempty"`
	Key      string                                     `protobuf:"bytes,4,opt,name=key" json:"key,omitempty"`
	DeployId string                                     `protobuf:"bytes,5,opt,name=deploy_id,json=deployId" json:"deploy_id,omitempty"`
	Result   ValueChangeResultRequest_ValueChangeResult `protobuf:"varint,6,opt,name=result,enum=pb.ValueChangeResultRequest_ValueChangeResult" json:"result,omitempty"`
	Msg      string                                     `protobuf:"bytes,7,opt,name=msg" json:"msg,omitempty"`
	Version  int64                                      `protobuf:"varint,8,opt,name=version" json:"version,omitempty"`
}

type ValueChangeResultRequest_ValueChangeResult int32

type ValueChangeResultResponse struct {
	Status int32  `protobuf:"varint,1,opt,name=status" json:"status,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg" json:"msg,omitempty"`
}