pb

package
v0.1.9 Latest Latest
Warning

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

 Go to latest Published: Jan 9, 2021 License: BSD-3-Clause Imports: 11 Imported by: 0

README

1st Time Use Instruction

If this is the first time you are going to build protos of this package, please make sure you already install protoc form [https://github.com/google/protobuf] then run the following commands:

go install ./protoc-gen-gorony

Documentation

Index

Constants

View Source 
const C_Echo int64 = 3073810188
View Source 
const C_EchoDelay int64 = 3639218737
View Source 
const C_EchoLeaderOnly int64 = 27569121
View Source 
const C_EchoRequest int64 = 1904100324
View Source 
const C_EchoResponse int64 = 4192619139
View Source 
const C_EchoTunnel int64 = 3809767204

Variables

View Source 
var File_service_proto protoreflect.FileDescriptor
View Source 
var PoolEchoRequest = poolEchoRequest{}
View Source 
var PoolEchoResponse = poolEchoResponse{}

Functions

func RegisterSample 

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

Types

type EchoRequest 

type EchoRequest struct {
	Int        int64  `protobuf:"varint,1,opt,name=Int,proto3" json:"Int,omitempty"`
	Timestamp  int64  `protobuf:"varint,3,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	ReplicaSet uint64 `protobuf:"varint,4,opt,name=ReplicaSet,proto3" json:"ReplicaSet,omitempty"`
	// contains filtered or unexported fields
}

func (*EchoRequest) DeepCopy 

func (x *EchoRequest) DeepCopy(z *EchoRequest)

func (*EchoRequest) Descriptor deprecated 

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

Deprecated: Use EchoRequest.ProtoReflect.Descriptor instead.

func (*EchoRequest) GetInt 

func (x *EchoRequest) GetInt() int64

func (*EchoRequest) GetReplicaSet added in v0.1.9 

func (x *EchoRequest) GetReplicaSet() uint64

func (*EchoRequest) GetTimestamp 

func (x *EchoRequest) GetTimestamp() int64

func (*EchoRequest) Marshal added in v0.0.17 

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

func (*EchoRequest) ProtoMessage 

func (*EchoRequest) ProtoMessage()

func (*EchoRequest) ProtoReflect 

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

func (*EchoRequest) PushToContext 

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

func (*EchoRequest) Reset 

func (x *EchoRequest) Reset()

func (*EchoRequest) String 

func (x *EchoRequest) String() string

func (*EchoRequest) Unmarshal 

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

type EchoResponse 

type EchoResponse struct {
	Int       int64  `protobuf:"varint,1,opt,name=Int,proto3" json:"Int,omitempty"`
	Responder string `protobuf:"bytes,2,opt,name=Responder,proto3" json:"Responder,omitempty"`
	Timestamp int64  `protobuf:"varint,4,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Delay     int64  `protobuf:"varint,5,opt,name=Delay,proto3" json:"Delay,omitempty"`
	ServerID  string `protobuf:"bytes,6,opt,name=ServerID,proto3" json:"ServerID,omitempty"`
	// contains filtered or unexported fields
}

func (*EchoResponse) DeepCopy 

func (x *EchoResponse) DeepCopy(z *EchoResponse)

func (*EchoResponse) Descriptor deprecated 

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

Deprecated: Use EchoResponse.ProtoReflect.Descriptor instead.

func (*EchoResponse) GetDelay 

func (x *EchoResponse) GetDelay() int64

func (*EchoResponse) GetInt 

func (x *EchoResponse) GetInt() int64

func (*EchoResponse) GetResponder added in v0.1.5 

func (x *EchoResponse) GetResponder() string

func (*EchoResponse) GetServerID 

func (x *EchoResponse) GetServerID() string

func (*EchoResponse) GetTimestamp 

func (x *EchoResponse) GetTimestamp() int64

func (*EchoResponse) Marshal added in v0.0.17 

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

func (*EchoResponse) ProtoMessage 

func (*EchoResponse) ProtoMessage()

func (*EchoResponse) ProtoReflect 

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

func (*EchoResponse) PushToContext 

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

func (*EchoResponse) Reset 

func (x *EchoResponse) Reset()

func (*EchoResponse) String 

func (x *EchoResponse) String() string

func (*EchoResponse) Unmarshal 

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

type ISample 

type ISample interface {
	Echo(ctx *edge.RequestCtx, req *EchoRequest, res *EchoResponse)
	EchoLeaderOnly(ctx *edge.RequestCtx, req *EchoRequest, res *EchoResponse)
	EchoTunnel(ctx *edge.RequestCtx, req *EchoRequest, res *EchoResponse)
	EchoDelay(ctx *edge.RequestCtx, req *EchoRequest, res *EchoResponse)
}

type SampleClient 

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

func NewSampleClient 

func NewSampleClient(ec edgec.Client) *SampleClient

func (*SampleClient) Echo 

func (c *SampleClient) Echo(req *EchoRequest, kvs ...*rony.KeyValue) (*EchoResponse, error)

func (*SampleClient) EchoDelay added in v0.1.9 

func (c *SampleClient) EchoDelay(req *EchoRequest, kvs ...*rony.KeyValue) (*EchoResponse, error)

func (*SampleClient) EchoLeaderOnly added in v0.1.5 

func (c *SampleClient) EchoLeaderOnly(req *EchoRequest, kvs ...*rony.KeyValue) (*EchoResponse, error)

func (*SampleClient) EchoTunnel added in v0.1.5 

func (c *SampleClient) EchoTunnel(req *EchoRequest, kvs ...*rony.KeyValue) (*EchoResponse, error)

type SampleWrapper 

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

func (*SampleWrapper) EchoDelayWrapper added in v0.1.9 

func (sw *SampleWrapper) EchoDelayWrapper(ctx *edge.RequestCtx, in *rony.MessageEnvelope)

func (*SampleWrapper) EchoLeaderOnlyWrapper added in v0.1.5 

func (sw *SampleWrapper) EchoLeaderOnlyWrapper(ctx *edge.RequestCtx, in *rony.MessageEnvelope)

func (*SampleWrapper) EchoTunnelWrapper added in v0.1.5 

func (sw *SampleWrapper) EchoTunnelWrapper(ctx *edge.RequestCtx, in *rony.MessageEnvelope)

func (*SampleWrapper) EchoWrapper 

func (sw *SampleWrapper) EchoWrapper(ctx *edge.RequestCtx, in *rony.MessageEnvelope)

func (*SampleWrapper) Register 

func (sw *SampleWrapper) Register(e *edge.Server)

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.