rpc

package
v0.16.25 Latest Latest
Warning

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

 Go to latest Published: Aug 7, 2023 License: BSD-3-Clause Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const C_InfoRequest uint64 = 393641345359739852
View Source 
const C_InfoResponse uint64 = 10205569623592301307
View Source 
const C_SampleInfoWithClientRedirect uint64 = 11847639677132253675
View Source 
const C_SampleInfoWithServerRedirect uint64 = 11816518540128942571

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 uint64) []edge.Handler)

func TunnelRequestSampleInfoWithClientRedirect 

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

func TunnelRequestSampleInfoWithServerRedirect 

func TunnelRequestSampleInfoWithServerRedirect(
	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) *rony.Error
	InfoWithServerRedirect(ctx *edge.RequestCtx, req *InfoRequest, res *InfoResponse) *rony.Error
}

type ISampleClient added in v0.15.2 

type ISampleClient interface {
	InfoWithClientRedirect(ctx context.Context, req *InfoRequest, kvs ...*rony.KeyValue) (*InfoResponse, error)
	InfoWithServerRedirect(ctx context.Context, req *InfoRequest, kvs ...*rony.KeyValue) (*InfoResponse, error)
}

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) *rony.Error

func (*Sample) InfoWithServerRedirect 

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

type SampleClient 

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

func NewSampleClient 

func NewSampleClient(name string, ec edgec.Client) *SampleClient

func (*SampleClient) InfoWithClientRedirect 

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

func (*SampleClient) InfoWithServerRedirect 

func (c *SampleClient) InfoWithServerRedirect(
	ctx context.Context, 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.