nacos_grpc_service

type BaseRequest interface {
	GetHeaders() map[string]string
	GetRequestType() string
	GetBody(request BaseRequest) string
	PutAllHeaders(headers map[string]string)
	GetRequestId() string
	GetStringToSign() string
}

type BaseResponse interface {
	GetResponseType() string
	SetRequestId(requestId string)
	GetRequestId() string
	GetBody() string
	GetErrorCode() int
	IsSuccess() bool
	GetResultCode() int
	GetMessage() string
}

type BatchInstanceRequest struct {
	*NamingRequest
	Type      string            `json:"type"`
	Instances []*model.Instance `json:"instances"`
}

type BatchInstanceResponse struct {
	*Response
	Type string `json:"type"`
}

type BiRequestStreamClient interface {
	// Sends a commonRequest
	RequestBiStream(ctx context.Context, opts ...grpc.CallOption) (BiRequestStream_RequestBiStreamClient, error)
}

type BiRequestStreamServer interface {
	// Sends a commonRequest
	RequestBiStream(BiRequestStream_RequestBiStreamServer) error
}

type BiRequestStream_RequestBiStreamClient interface {
	Send(*Payload) error
	Recv() (*Payload, error)
	grpc.ClientStream
}

type BiRequestStream_RequestBiStreamServer interface {
	Send(*Payload) error
	Recv() (*Payload, error)
	grpc.ServerStream
}

type ClientAbilities struct {
	// RemoteAbility .
	RemoteAbility ClientRemoteAbility `json:"remoteAbility"`
	// ConfigAbility .
	ConfigAbility ClientConfigAbility `json:"configAbility"`
	// NamingAbility .
	NamingAbility ClientNamingAbility `json:"namingAbility"`
}

type ClientConfigAbility struct {
	// SupportRemoteMetrics .
	SupportRemoteMetrics bool `json:"supportRemoteMetrics"`
}

type ClientDetectionRequest struct {
	*InternalRequest
}

type ClientDetectionResponse struct {
	*Response
}

type ClientNamingAbility struct {
	// SupportDeltaPush 支持增量推送
	SupportDeltaPush bool `json:"supportDeltaPush"`
	// SupportRemoteMetric .
	SupportRemoteMetric bool `json:"supportRemoteMetric"`
}

type ClientRemoteAbility struct {
	// SupportRemoteConnection .
	SupportRemoteConnection bool `json:"supportRemoteConnection"`
}

type ConfigBatchListenRequest struct {
	*ConfigRequest
	Listen               bool                  `json:"listen"`
	ConfigListenContexts []ConfigListenContext `json:"configListenContexts"`
}

type ConfigChangeBatchListenResponse struct {
	*Response
	ChangedConfigs []ConfigContext `json:"changedConfigs"`
}

type ConfigChangeNotifyRequest struct {
	*ConfigRequest
}

type ConfigChangeNotifyResponse struct {
	*Response
}

type ConfigContext struct {
	Group  string `json:"group"`
	DataId string `json:"dataId"`
	Tenant string `json:"tenant"`
}

type ConfigListenContext struct {
	Group  string `json:"group"`
	Md5    string `json:"md5"`
	DataId string `json:"dataId"`
	Tenant string `json:"tenant"`
}

type ConfigPublishRequest struct {
	*ConfigRequest
	Content     string            `json:"content"`
	CasMd5      string            `json:"casMd5"`
	AdditionMap map[string]string `json:"additionMap"`
}

type ConfigPublishResponse struct {
	*Response
}

type ConfigQueryRequest struct {
	*ConfigRequest
	Tag string `json:"tag"`
}

type ConfigQueryResponse struct {
	*Response
	Content          string `json:"content"`
	EncryptedDataKey string `json:"encryptedDataKey"`
	ContentType      string `json:"contentType"`
	Md5              string `json:"md5"`
	LastModified     int64  `json:"lastModified"`
	IsBeta           bool   `json:"isBeta"`
	Tag              bool   `json:"tag"`
}

type ConfigRemoveRequest struct {
	*ConfigRequest
}

type ConfigRemoveResponse struct {
	*Response
}

type ConfigRequest struct {
	*Request
	Group  string `json:"group"`
	DataId string `json:"dataId"`
	Tenant string `json:"tenant"`
	Module string `json:"module"`
}

type ConnectResetRequest struct {
	*InternalRequest
	ServerIp   string
	ServerPort string
}

type ConnectResetResponse struct {
	*Response
}

type ConnectionSetupRequest struct {
	*InternalRequest
	ClientVersion   string            `json:"clientVersion"`
	Tenant          string            `json:"tenant"`
	Labels          map[string]string `json:"labels"`
	ClientAbilities ClientAbilities   `json:"clientAbilities"`
}

type CustomerPayload interface{}

type ErrorResponse struct {
	*Response
}

type HealthCheckRequest struct {
	*InternalRequest
}

type HealthCheckResponse struct {
	*Response
}

type InstanceRequest struct {
	*NamingRequest
	Type     string         `json:"type"`
	Instance model.Instance `json:"instance"`
}

type InstanceResponse struct {
	*Response
	Type string `json:"type"`
}

type InternalRequest struct {
	*Request
	Module string `json:"module"`
}

type MetaRequestInfo interface {
	RequestMeta() interface{}
}

type Metadata struct {
	Type                 string            `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	ClientIp             string            `protobuf:"bytes,8,opt,name=clientIp,proto3" json:"clientIp,omitempty"`
	Headers              map[string]string `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

type NamingRequest struct {
	*Request
	Namespace   string `json:"namespace"`
	ServiceName string `json:"serviceName"`
	GroupName   string `json:"groupName"`
	Module      string `json:"module"`
}

type NotifySubscriberRequest struct {
	*NamingRequest
	ServiceInfo *model.ServiceInfo `json:"serviceInfo"`
}

type NotifySubscriberResponse struct {
	*Response
}

type Payload struct {
	Metadata             *Metadata  `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Body                 *anypb.Any `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

type PersistentInstanceRequest struct {
	*NamingRequest
	Type     string         `json:"type"`
	Instance model.Instance `json:"instance"`
}

type QueryServiceResponse struct {
	*Response
	ServiceInfo model.Service `json:"serviceInfo"`
}

type Request struct {
	Headers   map[string]string `json:"-"`
	RequestId string            `json:"requestId"`
}

type RequestClient interface {
	// Sends a commonRequest
	Request(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*Payload, error)
}

type RequestMeta struct {
	ConnectionID  string
	ClientIP      string
	ClientVersion string
	Labels        map[string]string
}

type RequestServer interface {
	// Sends a commonRequest
	Request(context.Context, *Payload) (*Payload, error)
}

type Response struct {
	ResultCode int    `json:"resultCode"`
	ErrorCode  int    `json:"errorCode"`
	Success    bool   `json:"success"`
	Message    string `json:"message"`
	RequestId  string `json:"requestId"`
}

type ServerCheckRequest struct {
	*InternalRequest
}

type ServerCheckResponse struct {
	*Response
	ConnectionId string `json:"connectionId"`
}

type ServiceListRequest struct {
	*NamingRequest
	PageNo   int    `json:"pageNo"`
	PageSize int    `json:"pageSize"`
	Selector string `json:"selector"`
}

type ServiceListResponse struct {
	*Response
	Count        int      `json:"count"`
	ServiceNames []string `json:"serviceNames"`
}

type ServiceQueryRequest struct {
	*NamingRequest
	Cluster     string `json:"cluster"`
	HealthyOnly bool   `json:"healthyOnly"`
	UdpPort     int    `json:"udpPort"`
}

type SubscribeServiceRequest struct {
	*NamingRequest
	Subscribe bool   `json:"subscribe"`
	Clusters  string `json:"clusters"`
}

type SubscribeServiceResponse struct {
	*Response
	ServiceInfo model.ServiceInfo `json:"serviceInfo"`
}