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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL