com_mesh_demo_protoc

package
v0.0.0-...-849f898 Latest Latest
Warning

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

 Go to latest Published: Aug 20, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var C2S_Cmds_name = map[int32]string{
	0:         "None",
	100100001: "Entry_Insert",
	100100003: "Entry_Sum",
	100100005: "Entry_Max",
	100200001: "Middle_InsertDecorator",
	100300001: "Model_Insert",
	100300003: "Model_Sum",
	100300005: "Model_Max",
	100300007: "Model_Len",
}
View Source 
var C2S_Cmds_value = map[string]int32{
	"None":                   0,
	"Entry_Insert":           100100001,
	"Entry_Sum":              100100003,
	"Entry_Max":              100100005,
	"Middle_InsertDecorator": 100200001,
	"Model_Insert":           100300001,
	"Model_Sum":              100300003,
	"Model_Max":              100300005,
	"Model_Len":              100300007,
}

Functions

func RegisterEntryServer 

func RegisterEntryServer(s *grpc.Server, srv EntryServer)

func RegisterGateServer 

func RegisterGateServer(s *grpc.Server, srv GateServer)

func RegisterMiddleServer 

func RegisterMiddleServer(s *grpc.Server, srv MiddleServer)

func RegisterModelServer 

func RegisterModelServer(s *grpc.Server, srv ModelServer)

Types

type C2S_Cmds 

type C2S_Cmds int32
const (
	C2S_Cmds_None                   C2S_Cmds = 0
	C2S_Cmds_Entry_Insert           C2S_Cmds = 100100001
	C2S_Cmds_Entry_Sum              C2S_Cmds = 100100003
	C2S_Cmds_Entry_Max              C2S_Cmds = 100100005
	C2S_Cmds_Middle_InsertDecorator C2S_Cmds = 100200001
	C2S_Cmds_Model_Insert           C2S_Cmds = 100300001
	C2S_Cmds_Model_Sum              C2S_Cmds = 100300003
	C2S_Cmds_Model_Max              C2S_Cmds = 100300005
	C2S_Cmds_Model_Len              C2S_Cmds = 100300007
)

func (C2S_Cmds) EnumDescriptor 

func (C2S_Cmds) EnumDescriptor() ([]byte, []int)

func (C2S_Cmds) String 

func (x C2S_Cmds) String() string

type EntryClient 

type EntryClient interface {
	Insert(ctx context.Context, in *InsertReq, opts ...grpc.CallOption) (*InsertResp, error)
	Sum(ctx context.Context, in *SumReq, opts ...grpc.CallOption) (*SumResp, error)
	Max(ctx context.Context, in *MaxReq, opts ...grpc.CallOption) (*MaxResp, error)
}

EntryClient is the client API for Entry service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEntryClient 

func NewEntryClient(cc *grpc.ClientConn) EntryClient

type EntryServer 

type EntryServer interface {
	Insert(context.Context, *InsertReq) (*InsertResp, error)
	Sum(context.Context, *SumReq) (*SumResp, error)
	Max(context.Context, *MaxReq) (*MaxResp, error)
}

EntryServer is the server API for Entry service.

type GateClient 

type GateClient interface {
}

GateClient is the client API for Gate service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewGateClient 

func NewGateClient(cc *grpc.ClientConn) GateClient

type GateServer 

type GateServer interface {
}

GateServer is the server API for Gate service.

type InsertReq 

type InsertReq struct {
	Val                  int32    `protobuf:"varint,1,opt,name=val,proto3" json:"val,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InsertReq) Descriptor 

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

func (*InsertReq) GetVal 

func (m *InsertReq) GetVal() int32

func (*InsertReq) ProtoMessage 

func (*InsertReq) ProtoMessage()

func (*InsertReq) Reset 

func (m *InsertReq) Reset()

func (*InsertReq) String 

func (m *InsertReq) String() string

func (*InsertReq) XXX_DiscardUnknown 

func (m *InsertReq) XXX_DiscardUnknown()

func (*InsertReq) XXX_Marshal 

func (m *InsertReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InsertReq) XXX_Merge 

func (m *InsertReq) XXX_Merge(src proto.Message)

func (*InsertReq) XXX_Size 

func (m *InsertReq) XXX_Size() int

func (*InsertReq) XXX_Unmarshal 

func (m *InsertReq) XXX_Unmarshal(b []byte) error

type InsertResp 

type InsertResp struct {
	Len                  int32    `protobuf:"varint,1,opt,name=len,proto3" json:"len,omitempty"`
	Data                 []int32  `protobuf:"varint,2,rep,packed,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InsertResp) Descriptor 

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

func (*InsertResp) GetData 

func (m *InsertResp) GetData() []int32

func (*InsertResp) GetLen 

func (m *InsertResp) GetLen() int32

func (*InsertResp) ProtoMessage 

func (*InsertResp) ProtoMessage()

func (*InsertResp) Reset 

func (m *InsertResp) Reset()

func (*InsertResp) String 

func (m *InsertResp) String() string

func (*InsertResp) XXX_DiscardUnknown 

func (m *InsertResp) XXX_DiscardUnknown()

func (*InsertResp) XXX_Marshal 

func (m *InsertResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InsertResp) XXX_Merge 

func (m *InsertResp) XXX_Merge(src proto.Message)

func (*InsertResp) XXX_Size 

func (m *InsertResp) XXX_Size() int

func (*InsertResp) XXX_Unmarshal 

func (m *InsertResp) XXX_Unmarshal(b []byte) error

type LenReq 

type LenReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LenReq) Descriptor 

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

func (*LenReq) ProtoMessage 

func (*LenReq) ProtoMessage()

func (*LenReq) Reset 

func (m *LenReq) Reset()

func (*LenReq) String 

func (m *LenReq) String() string

func (*LenReq) XXX_DiscardUnknown 

func (m *LenReq) XXX_DiscardUnknown()

func (*LenReq) XXX_Marshal 

func (m *LenReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LenReq) XXX_Merge 

func (m *LenReq) XXX_Merge(src proto.Message)

func (*LenReq) XXX_Size 

func (m *LenReq) XXX_Size() int

func (*LenReq) XXX_Unmarshal 

func (m *LenReq) XXX_Unmarshal(b []byte) error

type LenResp 

type LenResp struct {
	Len                  int32    `protobuf:"varint,1,opt,name=len,proto3" json:"len,omitempty"`
	Data                 []int32  `protobuf:"varint,2,rep,packed,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LenResp) Descriptor 

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

func (*LenResp) GetData 

func (m *LenResp) GetData() []int32

func (*LenResp) GetLen 

func (m *LenResp) GetLen() int32

func (*LenResp) ProtoMessage 

func (*LenResp) ProtoMessage()

func (*LenResp) Reset 

func (m *LenResp) Reset()

func (*LenResp) String 

func (m *LenResp) String() string

func (*LenResp) XXX_DiscardUnknown 

func (m *LenResp) XXX_DiscardUnknown()

func (*LenResp) XXX_Marshal 

func (m *LenResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LenResp) XXX_Merge 

func (m *LenResp) XXX_Merge(src proto.Message)

func (*LenResp) XXX_Size 

func (m *LenResp) XXX_Size() int

func (*LenResp) XXX_Unmarshal 

func (m *LenResp) XXX_Unmarshal(b []byte) error

type MaxReq 

type MaxReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MaxReq) Descriptor 

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

func (*MaxReq) ProtoMessage 

func (*MaxReq) ProtoMessage()

func (*MaxReq) Reset 

func (m *MaxReq) Reset()

func (*MaxReq) String 

func (m *MaxReq) String() string

func (*MaxReq) XXX_DiscardUnknown 

func (m *MaxReq) XXX_DiscardUnknown()

func (*MaxReq) XXX_Marshal 

func (m *MaxReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MaxReq) XXX_Merge 

func (m *MaxReq) XXX_Merge(src proto.Message)

func (*MaxReq) XXX_Size 

func (m *MaxReq) XXX_Size() int

func (*MaxReq) XXX_Unmarshal 

func (m *MaxReq) XXX_Unmarshal(b []byte) error

type MaxResp 

type MaxResp struct {
	Max                  int32    `protobuf:"varint,1,opt,name=max,proto3" json:"max,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MaxResp) Descriptor 

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

func (*MaxResp) GetMax 

func (m *MaxResp) GetMax() int32

func (*MaxResp) ProtoMessage 

func (*MaxResp) ProtoMessage()

func (*MaxResp) Reset 

func (m *MaxResp) Reset()

func (*MaxResp) String 

func (m *MaxResp) String() string

func (*MaxResp) XXX_DiscardUnknown 

func (m *MaxResp) XXX_DiscardUnknown()

func (*MaxResp) XXX_Marshal 

func (m *MaxResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MaxResp) XXX_Merge 

func (m *MaxResp) XXX_Merge(src proto.Message)

func (*MaxResp) XXX_Size 

func (m *MaxResp) XXX_Size() int

func (*MaxResp) XXX_Unmarshal 

func (m *MaxResp) XXX_Unmarshal(b []byte) error

type MiddleClient 

type MiddleClient interface {
	InsertDecorator(ctx context.Context, in *InsertReq, opts ...grpc.CallOption) (*InsertResp, error)
}

MiddleClient is the client API for Middle service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMiddleClient 

func NewMiddleClient(cc *grpc.ClientConn) MiddleClient

type MiddleServer 

type MiddleServer interface {
	InsertDecorator(context.Context, *InsertReq) (*InsertResp, error)
}

MiddleServer is the server API for Middle service.

type ModelClient 

type ModelClient interface {
	Insert(ctx context.Context, in *InsertReq, opts ...grpc.CallOption) (*InsertResp, error)
	Sum(ctx context.Context, in *SumReq, opts ...grpc.CallOption) (*SumResp, error)
	Max(ctx context.Context, in *MaxReq, opts ...grpc.CallOption) (*MaxResp, error)
	Len(ctx context.Context, in *LenReq, opts ...grpc.CallOption) (*LenResp, error)
}

ModelClient is the client API for Model service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewModelClient 

func NewModelClient(cc *grpc.ClientConn) ModelClient

type ModelServer 

type ModelServer interface {
	Insert(context.Context, *InsertReq) (*InsertResp, error)
	Sum(context.Context, *SumReq) (*SumResp, error)
	Max(context.Context, *MaxReq) (*MaxResp, error)
	Len(context.Context, *LenReq) (*LenResp, error)
}

ModelServer is the server API for Model service.

type SumReq 

type SumReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SumReq) Descriptor 

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

func (*SumReq) ProtoMessage 

func (*SumReq) ProtoMessage()

func (*SumReq) Reset 

func (m *SumReq) Reset()

func (*SumReq) String 

func (m *SumReq) String() string

func (*SumReq) XXX_DiscardUnknown 

func (m *SumReq) XXX_DiscardUnknown()

func (*SumReq) XXX_Marshal 

func (m *SumReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SumReq) XXX_Merge 

func (m *SumReq) XXX_Merge(src proto.Message)

func (*SumReq) XXX_Size 

func (m *SumReq) XXX_Size() int

func (*SumReq) XXX_Unmarshal 

func (m *SumReq) XXX_Unmarshal(b []byte) error

type SumResp 

type SumResp struct {
	Sum                  int32    `protobuf:"varint,1,opt,name=sum,proto3" json:"sum,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SumResp) Descriptor 

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

func (*SumResp) GetSum 

func (m *SumResp) GetSum() int32

func (*SumResp) ProtoMessage 

func (*SumResp) ProtoMessage()

func (*SumResp) Reset 

func (m *SumResp) Reset()

func (*SumResp) String 

func (m *SumResp) String() string

func (*SumResp) XXX_DiscardUnknown 

func (m *SumResp) XXX_DiscardUnknown()

func (*SumResp) XXX_Marshal 

func (m *SumResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SumResp) XXX_Merge 

func (m *SumResp) XXX_Merge(src proto.Message)

func (*SumResp) XXX_Size 

func (m *SumResp) XXX_Size() int

func (*SumResp) XXX_Unmarshal 

func (m *SumResp) XXX_Unmarshal(b []byte) error

type UnimplementedEntryServer 

type UnimplementedEntryServer struct {
}

UnimplementedEntryServer can be embedded to have forward compatible implementations.

func (*UnimplementedEntryServer) Insert 

func (*UnimplementedEntryServer) Insert(ctx context.Context, req *InsertReq) (*InsertResp, error)

func (*UnimplementedEntryServer) Max 

func (*UnimplementedEntryServer) Max(ctx context.Context, req *MaxReq) (*MaxResp, error)

func (*UnimplementedEntryServer) Sum 

func (*UnimplementedEntryServer) Sum(ctx context.Context, req *SumReq) (*SumResp, error)

type UnimplementedGateServer 

type UnimplementedGateServer struct {
}

UnimplementedGateServer can be embedded to have forward compatible implementations.

type UnimplementedMiddleServer 

type UnimplementedMiddleServer struct {
}

UnimplementedMiddleServer can be embedded to have forward compatible implementations.

func (*UnimplementedMiddleServer) InsertDecorator 

func (*UnimplementedMiddleServer) InsertDecorator(ctx context.Context, req *InsertReq) (*InsertResp, error)

type UnimplementedModelServer 

type UnimplementedModelServer struct {
}

UnimplementedModelServer can be embedded to have forward compatible implementations.

func (*UnimplementedModelServer) Insert 

func (*UnimplementedModelServer) Insert(ctx context.Context, req *InsertReq) (*InsertResp, error)

func (*UnimplementedModelServer) Len 

func (*UnimplementedModelServer) Len(ctx context.Context, req *LenReq) (*LenResp, error)

func (*UnimplementedModelServer) Max 

func (*UnimplementedModelServer) Max(ctx context.Context, req *MaxReq) (*MaxResp, error)

func (*UnimplementedModelServer) Sum 

func (*UnimplementedModelServer) Sum(ctx context.Context, req *SumReq) (*SumResp, 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.