pb

package
v0.0.14 Latest Latest
Warning

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

 Go to latest Published: Dec 10, 2020 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_Ask int64 = 1349233664
View Source 
const C_AskRequest int64 = 4187105886
View Source 
const C_AskResponse int64 = 3537566840
View Source 
const C_Echo int64 = 3073810188
View Source 
const C_EchoRequest int64 = 3196215161
View Source 
const C_EchoResponse int64 = 2006407526
View Source 
const C_Func1 int64 = 272094254
View Source 
const C_Func2 int64 = 2302576020
View Source 
const C_Req1 int64 = 36419086
View Source 
const C_Req2 int64 = 2602756020
View Source 
const C_Res1 int64 = 807261324
View Source 
const C_Res2 int64 = 2836694326

Variables

View Source 
var (
	ConstructorNames = map[int64]string{}
)
View Source 
var File_service_proto protoreflect.FileDescriptor
View Source 
var PoolAskRequest = poolAskRequest{}
View Source 
var PoolAskResponse = poolAskResponse{}
View Source 
var PoolEchoRequest = poolEchoRequest{}
View Source 
var PoolEchoResponse = poolEchoResponse{}
View Source 
var PoolReq1 = poolReq1{}
View Source 
var PoolReq2 = poolReq2{}
View Source 
var PoolRes1 = poolRes1{}
View Source 
var PoolRes2 = poolRes2{}

Functions

func RegisterSample 

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

Types

type AskRequest 

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

func (*AskRequest) DeepCopy 

func (x *AskRequest) DeepCopy(z *AskRequest)

func (*AskRequest) Descriptor deprecated 

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

Deprecated: Use AskRequest.ProtoReflect.Descriptor instead.

func (*AskRequest) GetServerID 

func (x *AskRequest) GetServerID() string

func (*AskRequest) MarshalTo 

func (x *AskRequest) MarshalTo(b []byte) ([]byte, error)

func (*AskRequest) ProtoMessage 

func (*AskRequest) ProtoMessage()

func (*AskRequest) ProtoReflect 

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

func (*AskRequest) PushToContext 

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

func (*AskRequest) Reset 

func (x *AskRequest) Reset()

func (*AskRequest) String 

func (x *AskRequest) String() string

func (*AskRequest) Unmarshal 

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

type AskResponse 

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

func (*AskResponse) DeepCopy 

func (x *AskResponse) DeepCopy(z *AskResponse)

func (*AskResponse) Descriptor deprecated 

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

Deprecated: Use AskResponse.ProtoReflect.Descriptor instead.

func (*AskResponse) GetCoordinator 

func (x *AskResponse) GetCoordinator() string

func (*AskResponse) GetResponder 

func (x *AskResponse) GetResponder() string

func (*AskResponse) MarshalTo 

func (x *AskResponse) MarshalTo(b []byte) ([]byte, error)

func (*AskResponse) ProtoMessage 

func (*AskResponse) ProtoMessage()

func (*AskResponse) ProtoReflect 

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

func (*AskResponse) PushToContext 

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

func (*AskResponse) Reset 

func (x *AskResponse) Reset()

func (*AskResponse) String 

func (x *AskResponse) String() string

func (*AskResponse) Unmarshal 

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

type EchoRequest 

type EchoRequest struct {
	Int       int64 `protobuf:"varint,1,opt,name=Int,proto3" json:"Int,omitempty"`
	Bool      bool  `protobuf:"varint,2,opt,name=Bool,proto3" json:"Bool,omitempty"`
	Timestamp int64 `protobuf:"varint,3,opt,name=Timestamp,proto3" json:"Timestamp,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) GetBool 

func (x *EchoRequest) GetBool() bool

func (*EchoRequest) GetInt 

func (x *EchoRequest) GetInt() int64

func (*EchoRequest) GetTimestamp 

func (x *EchoRequest) GetTimestamp() int64

func (*EchoRequest) MarshalTo 

func (x *EchoRequest) MarshalTo(b []byte) ([]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"`
	Bool      bool   `protobuf:"varint,2,opt,name=Bool,proto3" json:"Bool,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) GetBool 

func (x *EchoResponse) GetBool() bool

func (*EchoResponse) GetDelay 

func (x *EchoResponse) GetDelay() int64

func (*EchoResponse) GetInt 

func (x *EchoResponse) GetInt() int64

func (*EchoResponse) GetServerID 

func (x *EchoResponse) GetServerID() string

func (*EchoResponse) GetTimestamp 

func (x *EchoResponse) GetTimestamp() int64

func (*EchoResponse) MarshalTo 

func (x *EchoResponse) MarshalTo(b []byte) ([]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 {
	Func1(ctx *edge.RequestCtx, req *Req1, res *Res1)
	Func2(ctx *edge.RequestCtx, req *Req2, res *Res2)
	Echo(ctx *edge.RequestCtx, req *EchoRequest, res *EchoResponse)
	Ask(ctx *edge.RequestCtx, req *AskRequest, res *AskResponse)
}

type Req1 

type Req1 struct {
	Item1 int64 `protobuf:"varint,1,opt,name=Item1,proto3" json:"Item1,omitempty"`
	// contains filtered or unexported fields
}

func (*Req1) DeepCopy 

func (x *Req1) DeepCopy(z *Req1)

func (*Req1) Descriptor deprecated 

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

Deprecated: Use Req1.ProtoReflect.Descriptor instead.

func (*Req1) GetItem1 

func (x *Req1) GetItem1() int64

func (*Req1) MarshalTo 

func (x *Req1) MarshalTo(b []byte) ([]byte, error)

func (*Req1) ProtoMessage 

func (*Req1) ProtoMessage()

func (*Req1) ProtoReflect 

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

func (*Req1) PushToContext 

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

func (*Req1) Reset 

func (x *Req1) Reset()

func (*Req1) String 

func (x *Req1) String() string

func (*Req1) Unmarshal 

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

type Req2 

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

func (*Req2) DeepCopy 

func (x *Req2) DeepCopy(z *Req2)

func (*Req2) Descriptor deprecated 

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

Deprecated: Use Req2.ProtoReflect.Descriptor instead.

func (*Req2) GetItem1 

func (x *Req2) GetItem1() string

func (*Req2) MarshalTo 

func (x *Req2) MarshalTo(b []byte) ([]byte, error)

func (*Req2) ProtoMessage 

func (*Req2) ProtoMessage()

func (*Req2) ProtoReflect 

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

func (*Req2) PushToContext 

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

func (*Req2) Reset 

func (x *Req2) Reset()

func (*Req2) String 

func (x *Req2) String() string

func (*Req2) Unmarshal 

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

type Res1 

type Res1 struct {
	Item1 int64 `protobuf:"varint,1,opt,name=Item1,proto3" json:"Item1,omitempty"`
	// contains filtered or unexported fields
}

func (*Res1) DeepCopy 

func (x *Res1) DeepCopy(z *Res1)

func (*Res1) Descriptor deprecated 

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

Deprecated: Use Res1.ProtoReflect.Descriptor instead.

func (*Res1) GetItem1 

func (x *Res1) GetItem1() int64

func (*Res1) MarshalTo 

func (x *Res1) MarshalTo(b []byte) ([]byte, error)

func (*Res1) ProtoMessage 

func (*Res1) ProtoMessage()

func (*Res1) ProtoReflect 

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

func (*Res1) PushToContext 

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

func (*Res1) Reset 

func (x *Res1) Reset()

func (*Res1) String 

func (x *Res1) String() string

func (*Res1) Unmarshal 

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

type Res2 

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

func (*Res2) DeepCopy 

func (x *Res2) DeepCopy(z *Res2)

func (*Res2) Descriptor deprecated 

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

Deprecated: Use Res2.ProtoReflect.Descriptor instead.

func (*Res2) GetItem1 

func (x *Res2) GetItem1() string

func (*Res2) MarshalTo 

func (x *Res2) MarshalTo(b []byte) ([]byte, error)

func (*Res2) ProtoMessage 

func (*Res2) ProtoMessage()

func (*Res2) ProtoReflect 

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

func (*Res2) PushToContext 

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

func (*Res2) Reset 

func (x *Res2) Reset()

func (*Res2) String 

func (x *Res2) String() string

func (*Res2) Unmarshal 

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

type SampleClient 

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

func NewSampleClient 

func NewSampleClient(ec edgec.Client) *SampleClient

func (*SampleClient) Ask 

func (c *SampleClient) Ask(req *AskRequest, kvs ...*rony.KeyValue) (*AskResponse, error)

func (*SampleClient) Echo 

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

func (*SampleClient) Func1 

func (c *SampleClient) Func1(req *Req1, kvs ...*rony.KeyValue) (*Res1, error)

func (*SampleClient) Func2 

func (c *SampleClient) Func2(req *Req2, kvs ...*rony.KeyValue) (*Res2, error)

type SampleWrapper 

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

func (*SampleWrapper) AskWrapper 

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

func (*SampleWrapper) EchoWrapper 

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

func (*SampleWrapper) Func1Wrapper 

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

func (*SampleWrapper) Func2Wrapper 

func (sw *SampleWrapper) Func2Wrapper(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.