rpc

package
v0.12.27 Latest Latest
Warning

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

 Go to latest Published: Aug 3, 2021 License: BSD-3-Clause Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const C_InfoRequest int64 = 1180205313
View Source 
const C_InfoResponse int64 = 699497142
View Source 
const C_SampleInfoWithClientRedirect int64 = 1298563006
View Source 
const C_SampleInfoWithServerRedirect int64 = 1831149695

Variables

View Source 
var File_sample_proto protoreflect.FileDescriptor
View Source 
var PoolInfoRequest = poolInfoRequest{}
View Source 
var PoolInfoResponse = poolInfoResponse{}

Functions

func RegisterSample 

func RegisterSample(h ISample, e *edge.Server, preHandlers ...edge.Handler)

func RegisterSampleWithFunc 

func RegisterSampleWithFunc(h ISample, e *edge.Server, handlerFunc func(c int64) []edge.Handler)

func TunnelRequestInfoWithClientRedirect added in v0.12.30 

func TunnelRequestInfoWithClientRedirect(ctx *edge.RequestCtx, replicaSet uint64, req *InfoRequest, res *InfoResponse, kvs ...*rony.KeyValue) error

func TunnelRequestInfoWithServerRedirect added in v0.12.30 

func TunnelRequestInfoWithServerRedirect(ctx *edge.RequestCtx, replicaSet uint64, req *InfoRequest, res *InfoResponse, kvs ...*rony.KeyValue) error

Types

type ISample 

type ISample interface {
	InfoWithClientRedirect(ctx *edge.RequestCtx, req *InfoRequest, res *InfoResponse)
	InfoWithServerRedirect(ctx *edge.RequestCtx, req *InfoRequest, res *InfoResponse)
}

type InfoRequest 

type InfoRequest struct {
	ReplicaSet uint64 `protobuf:"varint,1,opt,name=ReplicaSet,proto3" json:"ReplicaSet,omitempty"`
	RandomText string `protobuf:"bytes,2,opt,name=RandomText,proto3" json:"RandomText,omitempty"`
	// contains filtered or unexported fields
}

InfoRequest

func (*InfoRequest) Clone 

func (x *InfoRequest) Clone() *InfoRequest

func (*InfoRequest) DeepCopy 

func (x *InfoRequest) DeepCopy(z *InfoRequest)

func (*InfoRequest) Descriptor deprecated 

func (*InfoRequest) Descriptor() ([]byte, []int)

Deprecated: Use InfoRequest.ProtoReflect.Descriptor instead.

func (*InfoRequest) GetRandomText 

func (x *InfoRequest) GetRandomText() string

func (*InfoRequest) GetReplicaSet 

func (x *InfoRequest) GetReplicaSet() uint64

func (*InfoRequest) Marshal 

func (x *InfoRequest) Marshal() ([]byte, error)

func (*InfoRequest) MarshalJSON 

func (x *InfoRequest) MarshalJSON() ([]byte, error)

func (*InfoRequest) ProtoMessage 

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) ProtoReflect 

func (x *InfoRequest) ProtoReflect() protoreflect.Message

func (*InfoRequest) PushToContext 

func (x *InfoRequest) PushToContext(ctx *edge.RequestCtx)

func (*InfoRequest) Reset 

func (x *InfoRequest) Reset()

func (*InfoRequest) String 

func (x *InfoRequest) String() string

func (*InfoRequest) Unmarshal 

func (x *InfoRequest) Unmarshal(b []byte) error

func (*InfoRequest) UnmarshalJSON 

func (x *InfoRequest) UnmarshalJSON(b []byte) error

type InfoResponse 

type InfoResponse struct {
	ServerID   string `protobuf:"bytes,1,opt,name=ServerID,proto3" json:"ServerID,omitempty"`
	RandomText string `protobuf:"bytes,2,opt,name=RandomText,proto3" json:"RandomText,omitempty"`
	// contains filtered or unexported fields
}

InfoResponse

func (*InfoResponse) Clone 

func (x *InfoResponse) Clone() *InfoResponse

func (*InfoResponse) DeepCopy 

func (x *InfoResponse) DeepCopy(z *InfoResponse)

func (*InfoResponse) Descriptor deprecated 

func (*InfoResponse) Descriptor() ([]byte, []int)

Deprecated: Use InfoResponse.ProtoReflect.Descriptor instead.

func (*InfoResponse) GetRandomText 

func (x *InfoResponse) GetRandomText() string

func (*InfoResponse) GetServerID 

func (x *InfoResponse) GetServerID() string

func (*InfoResponse) Marshal 

func (x *InfoResponse) Marshal() ([]byte, error)

func (*InfoResponse) MarshalJSON 

func (x *InfoResponse) MarshalJSON() ([]byte, error)

func (*InfoResponse) ProtoMessage 

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) ProtoReflect 

func (x *InfoResponse) ProtoReflect() protoreflect.Message

func (*InfoResponse) PushToContext 

func (x *InfoResponse) PushToContext(ctx *edge.RequestCtx)

func (*InfoResponse) Reset 

func (x *InfoResponse) Reset()

func (*InfoResponse) String 

func (x *InfoResponse) String() string

func (*InfoResponse) Unmarshal 

func (x *InfoResponse) Unmarshal(b []byte) error

func (*InfoResponse) UnmarshalJSON 

func (x *InfoResponse) UnmarshalJSON(b []byte) error

type Sample 

type Sample struct{}

Sample implements auto-generated service.ISample interface

func (*Sample) InfoWithClientRedirect 

func (s *Sample) InfoWithClientRedirect(ctx *edge.RequestCtx, req *InfoRequest, res *InfoResponse)

func (*Sample) InfoWithServerRedirect 

func (s *Sample) InfoWithServerRedirect(ctx *edge.RequestCtx, req *InfoRequest, res *InfoResponse)

type SampleClient 

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

func NewSampleClient 

func NewSampleClient(ec edgec.Client) *SampleClient

func (*SampleClient) InfoWithClientRedirect 

func (c *SampleClient) InfoWithClientRedirect(req *InfoRequest, kvs ...*rony.KeyValue) (*InfoResponse, error)

func (*SampleClient) InfoWithServerRedirect 

func (c *SampleClient) InfoWithServerRedirect(req *InfoRequest, kvs ...*rony.KeyValue) (*InfoResponse, error)

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.