rpc_request

Documentation

Index

• type ClientAbilities
• type ClientDetectionRequest
  • func (r *ClientDetectionRequest) GetRequestType() string
• type ConfigBatchListenRequest
  • func NewConfigBatchListenRequest(cacheLen int) *ConfigBatchListenRequest
  • func (r *ConfigBatchListenRequest) GetRequestType() string
• type ConfigChangeNotifyRequest
  • func NewConfigChangeNotifyRequest(group, dataId, tenant string) *ConfigChangeNotifyRequest
  • func (r *ConfigChangeNotifyRequest) GetRequestType() string
• type ConfigPublishRequest
  • func NewConfigPublishRequest(group, dataId, tenant, content, casMd5 string) *ConfigPublishRequest
  • func (r *ConfigPublishRequest) GetRequestType() string
• type ConfigQueryRequest
  • func NewConfigQueryRequest(group, dataId, tenant string) *ConfigQueryRequest
  • func (r *ConfigQueryRequest) GetRequestType() string
• type ConfigRemoveRequest
  • func NewConfigRemoveRequest(group, dataId, tenant string) *ConfigRemoveRequest
  • func (r *ConfigRemoveRequest) GetRequestType() string
• type ConfigRequest
  • func NewConfigRequest() *ConfigRequest
• type ConnectResetRequest
  • func (r *ConnectResetRequest) GetRequestType() string
• type ConnectionSetupRequest
  • func NewConnectionSetupRequest() *ConnectionSetupRequest
  • func (r *ConnectionSetupRequest) GetRequestType() string
• type HealthCheckRequest
  • func NewHealthCheckRequest() *HealthCheckRequest
  • func (r *HealthCheckRequest) GetRequestType() string
• type IRequest
• type InstanceRequest
  • func NewInstanceRequest(namespace, serviceName, groupName, Type string, instance model.Instance) *InstanceRequest
  • func (r *InstanceRequest) GetRequestType() string
• type InternalRequest
  • func NewInternalRequest() *InternalRequest
• type NamingRequest
  • func NewNamingRequest(namespace, serviceName, groupName string) *NamingRequest
• type NotifySubscriberRequest
  • func (r *NotifySubscriberRequest) GetRequestType() string
• type Request
  • func (r *Request) ClearHeaders()
  • func (r *Request) GetBody(request IRequest) string
  • func (r *Request) GetHeaders() map[string]string
  • func (r *Request) GetRequestId() string
  • func (r *Request) PutAllHeaders(headers map[string]string)
• type ServerCheckRequest
  • func NewServerCheckRequest() *ServerCheckRequest
  • func (r *ServerCheckRequest) GetRequestType() string
• type ServiceListRequest
  • func NewServiceListRequest(namespace, serviceName, groupName string, pageNo, pageSize int, ...) *ServiceListRequest
  • func (r *ServiceListRequest) GetRequestType() string
• type ServiceQueryRequest
  • func NewServiceQueryRequest(namespace, serviceName, groupName, clusters string, healthyOnly bool, ...) *ServiceQueryRequest
  • func (r *ServiceQueryRequest) GetRequestType() string
• type SubscribeServiceRequest
  • func NewSubscribeServiceRequest(namespace, serviceName, groupName, clusters string, subscribe bool) *SubscribeServiceRequest
  • func (r *SubscribeServiceRequest) GetRequestType() string

Types

type ClientAbilities

type ClientAbilities struct {
}

type ClientDetectionRequest

type ClientDetectionRequest struct {
	*InternalRequest
}

func (*ClientDetectionRequest) GetRequestType

func (r *ClientDetectionRequest) GetRequestType() string

type ConfigBatchListenRequest

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

request of listening a batch of configs.

func NewConfigBatchListenRequest

func NewConfigBatchListenRequest(cacheLen int) *ConfigBatchListenRequest

func (*ConfigBatchListenRequest) GetRequestType

func (r *ConfigBatchListenRequest) GetRequestType() string

type ConfigChangeNotifyRequest

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

func NewConfigChangeNotifyRequest

func NewConfigChangeNotifyRequest(group, dataId, tenant string) *ConfigChangeNotifyRequest

func (*ConfigChangeNotifyRequest) GetRequestType

func (r *ConfigChangeNotifyRequest) GetRequestType() string

type ConfigPublishRequest

type ConfigPublishRequest struct {
	*ConfigRequest
	Group       string            `json:"group"`
	DataId      string            `json:"dataId"`
	Tenant      string            `json:"tenant"`
	Content     string            `json:"content"`
	CasMd5      string            `json:"casMd5"`
	AdditionMap map[string]string `json:"additionMap"`
}

func NewConfigPublishRequest

func NewConfigPublishRequest(group, dataId, tenant, content, casMd5 string) *ConfigPublishRequest

func (*ConfigPublishRequest) GetRequestType

func (r *ConfigPublishRequest) GetRequestType() string

type ConfigQueryRequest

type ConfigQueryRequest struct {
	*ConfigRequest
	Group  string `json:"group"`
	DataId string `json:"dataId"`
	Tenant string `json:"tenant"`
	Tag    string `json:"tag"`
}

func NewConfigQueryRequest

func NewConfigQueryRequest(group, dataId, tenant string) *ConfigQueryRequest

func (*ConfigQueryRequest) GetRequestType

func (r *ConfigQueryRequest) GetRequestType() string

type ConfigRemoveRequest

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

func NewConfigRemoveRequest

func NewConfigRemoveRequest(group, dataId, tenant string) *ConfigRemoveRequest

func (*ConfigRemoveRequest) GetRequestType

func (r *ConfigRemoveRequest) GetRequestType() string

type ConfigRequest

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

func NewConfigRequest

func NewConfigRequest() *ConfigRequest

type ConnectResetRequest

type ConnectResetRequest struct {
	*InternalRequest
	ServerIp   string
	ServerPort string
}

func (*ConnectResetRequest) GetRequestType

func (r *ConnectResetRequest) GetRequestType() string

type ConnectionSetupRequest

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

func NewConnectionSetupRequest

func NewConnectionSetupRequest() *ConnectionSetupRequest

func (*ConnectionSetupRequest) GetRequestType

func (r *ConnectionSetupRequest) GetRequestType() string

type HealthCheckRequest

type HealthCheckRequest struct {
	*InternalRequest
}

func NewHealthCheckRequest

func NewHealthCheckRequest() *HealthCheckRequest

func (*HealthCheckRequest) GetRequestType

func (r *HealthCheckRequest) GetRequestType() string

type IRequest

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

type InstanceRequest

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

func NewInstanceRequest

func NewInstanceRequest(namespace, serviceName, groupName, Type string, instance model.Instance) *InstanceRequest

func (*InstanceRequest) GetRequestType

func (r *InstanceRequest) GetRequestType() string

type InternalRequest

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

func NewInternalRequest

func NewInternalRequest() *InternalRequest

type NamingRequest

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

func NewNamingRequest

func NewNamingRequest(namespace, serviceName, groupName string) *NamingRequest

type NotifySubscriberRequest

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

func (*NotifySubscriberRequest) GetRequestType

func (r *NotifySubscriberRequest) GetRequestType() string

type Request

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

func (*Request) ClearHeaders

func (r *Request) ClearHeaders()

func (*Request) GetBody

func (r *Request) GetBody(request IRequest) string

func (*Request) GetHeaders

func (r *Request) GetHeaders() map[string]string

func (*Request) GetRequestId

func (r *Request) GetRequestId() string

func (*Request) PutAllHeaders

func (r *Request) PutAllHeaders(headers map[string]string)

type ServerCheckRequest

type ServerCheckRequest struct {
	*InternalRequest
}

func NewServerCheckRequest

func NewServerCheckRequest() *ServerCheckRequest

func (*ServerCheckRequest) GetRequestType

func (r *ServerCheckRequest) GetRequestType() string

type ServiceListRequest

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

func NewServiceListRequest

func NewServiceListRequest(namespace, serviceName, groupName string, pageNo, pageSize int, selector string) *ServiceListRequest

func (*ServiceListRequest) GetRequestType

func (r *ServiceListRequest) GetRequestType() string

type ServiceQueryRequest

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

func NewServiceQueryRequest

func NewServiceQueryRequest(namespace, serviceName, groupName, clusters string, healthyOnly bool, udpPort int) *ServiceQueryRequest

func (*ServiceQueryRequest) GetRequestType

func (r *ServiceQueryRequest) GetRequestType() string

type SubscribeServiceRequest

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

func NewSubscribeServiceRequest

func NewSubscribeServiceRequest(namespace, serviceName, groupName, clusters string, subscribe bool) *SubscribeServiceRequest

func (*SubscribeServiceRequest) GetRequestType

func (r *SubscribeServiceRequest) GetRequestType() string