rpc_request

package
v0.0.0-...-c202456 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 19, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchInstanceRequest 

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

func NewBatchInstanceRequest 

func NewBatchInstanceRequest(namespace, serviceName, groupName, Type string, instances []model.Instance) *BatchInstanceRequest

func (*BatchInstanceRequest) GetRequestType 

func (r *BatchInstanceRequest) GetRequestType() string

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
}

func NewConfigChangeNotifyRequest 

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

func (*ConfigChangeNotifyRequest) GetRequestType 

func (r *ConfigChangeNotifyRequest) GetRequestType() string

type ConfigPublishRequest 

type ConfigPublishRequest struct {
	*ConfigRequest
	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
	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
}

func NewConfigRemoveRequest 

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

func (*ConfigRemoveRequest) GetRequestType 

func (r *ConfigRemoveRequest) GetRequestType() string

type ConfigRequest 

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

func NewConfigRequest 

func NewConfigRequest(group, dataId, tenant string) *ConfigRequest

func (*ConfigRequest) GetDataId 

func (r *ConfigRequest) GetDataId() string

func (*ConfigRequest) GetGroup 

func (r *ConfigRequest) GetGroup() string

func (*ConfigRequest) GetTenant 

func (r *ConfigRequest) GetTenant() string

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 IConfigRequest 

type IConfigRequest interface {
	GetDataId() string
	GetGroup() string
	GetTenant() string
}

type IRequest 

type IRequest interface {
	GetHeaders() map[string]string
	GetRequestType() string
	GetBody(request IRequest) string
	PutAllHeaders(headers map[string]string)
	GetRequestId() string
	GetStringToSign() 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

func (*NamingRequest) GetStringToSign 

func (r *NamingRequest) GetStringToSign() string

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) GetStringToSign 

func (r *Request) GetStringToSign() 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
	Cluster     string `json:"cluster"`
	HealthyOnly bool   `json:"healthyOnly"`
	UdpPort     int    `json:"udpPort"`
}

func NewServiceQueryRequest 

func NewServiceQueryRequest(namespace, serviceName, groupName, cluster 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.