pb

package
v0.0.0-...-7cf6ef0 Latest Latest
Warning

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

 Go to latest Published: Dec 10, 2018 License: Apache-2.0 Imports: 5 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterSynchronizerServer 

func RegisterSynchronizerServer(s *grpc.Server, srv SynchronizerServer)

Types

type ListenReq 

type ListenReq struct {
	ServerName           string   `protobuf:"bytes,1,opt,name=serverName,proto3" json:"serverName,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Ip                   string   `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	Type                 string   `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Msg                  []byte   `protobuf:"bytes,5,opt,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListenReq) Descriptor 

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

func (*ListenReq) GetIp 

func (m *ListenReq) GetIp() string

func (*ListenReq) GetMsg 

func (m *ListenReq) GetMsg() []byte

func (*ListenReq) GetName 

func (m *ListenReq) GetName() string

func (*ListenReq) GetServerName 

func (m *ListenReq) GetServerName() string

func (*ListenReq) GetType 

func (m *ListenReq) GetType() string

func (*ListenReq) ProtoMessage 

func (*ListenReq) ProtoMessage()

func (*ListenReq) Reset 

func (m *ListenReq) Reset()

func (*ListenReq) String 

func (m *ListenReq) String() string

func (*ListenReq) XXX_DiscardUnknown 

func (m *ListenReq) XXX_DiscardUnknown()

func (*ListenReq) XXX_Marshal 

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

func (*ListenReq) XXX_Merge 

func (dst *ListenReq) XXX_Merge(src proto.Message)

func (*ListenReq) XXX_Size 

func (m *ListenReq) XXX_Size() int

func (*ListenReq) XXX_Unmarshal 

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

type RouterRequest 

type RouterRequest struct {
	RouterType           string   `protobuf:"bytes,1,opt,name=routerType,proto3" json:"routerType,omitempty"`
	RouterName           string   `protobuf:"bytes,2,opt,name=routerName,proto3" json:"routerName,omitempty"`
	Msg                  []byte   `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RouterRequest) Descriptor 

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

func (*RouterRequest) GetMsg 

func (m *RouterRequest) GetMsg() []byte

func (*RouterRequest) GetRouterName 

func (m *RouterRequest) GetRouterName() string

func (*RouterRequest) GetRouterType 

func (m *RouterRequest) GetRouterType() string

func (*RouterRequest) ProtoMessage 

func (*RouterRequest) ProtoMessage()

func (*RouterRequest) Reset 

func (m *RouterRequest) Reset()

func (*RouterRequest) String 

func (m *RouterRequest) String() string

func (*RouterRequest) XXX_DiscardUnknown 

func (m *RouterRequest) XXX_DiscardUnknown()

func (*RouterRequest) XXX_Marshal 

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

func (*RouterRequest) XXX_Merge 

func (dst *RouterRequest) XXX_Merge(src proto.Message)

func (*RouterRequest) XXX_Size 

func (m *RouterRequest) XXX_Size() int

func (*RouterRequest) XXX_Unmarshal 

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

type RouterResponse 

type RouterResponse struct {
	Code                 string   `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg                  []byte   `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RouterResponse) Descriptor 

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

func (*RouterResponse) GetCode 

func (m *RouterResponse) GetCode() string

func (*RouterResponse) GetMsg 

func (m *RouterResponse) GetMsg() []byte

func (*RouterResponse) ProtoMessage 

func (*RouterResponse) ProtoMessage()

func (*RouterResponse) Reset 

func (m *RouterResponse) Reset()

func (*RouterResponse) String 

func (m *RouterResponse) String() string

func (*RouterResponse) XXX_DiscardUnknown 

func (m *RouterResponse) XXX_DiscardUnknown()

func (*RouterResponse) XXX_Marshal 

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

func (*RouterResponse) XXX_Merge 

func (dst *RouterResponse) XXX_Merge(src proto.Message)

func (*RouterResponse) XXX_Size 

func (m *RouterResponse) XXX_Size() int

func (*RouterResponse) XXX_Unmarshal 

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

type StreamRsp 

type StreamRsp struct {
	Type                 string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Msg                  []byte   `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamRsp) Descriptor 

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

func (*StreamRsp) GetMsg 

func (m *StreamRsp) GetMsg() []byte

func (*StreamRsp) GetType 

func (m *StreamRsp) GetType() string

func (*StreamRsp) ProtoMessage 

func (*StreamRsp) ProtoMessage()

func (*StreamRsp) Reset 

func (m *StreamRsp) Reset()

func (*StreamRsp) String 

func (m *StreamRsp) String() string

func (*StreamRsp) XXX_DiscardUnknown 

func (m *StreamRsp) XXX_DiscardUnknown()

func (*StreamRsp) XXX_Marshal 

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

func (*StreamRsp) XXX_Merge 

func (dst *StreamRsp) XXX_Merge(src proto.Message)

func (*StreamRsp) XXX_Size 

func (m *StreamRsp) XXX_Size() int

func (*StreamRsp) XXX_Unmarshal 

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

type SynchronizerClient 

type SynchronizerClient interface {
	Router(ctx context.Context, in *RouterRequest, opts ...grpc.CallOption) (*RouterResponse, error)
	Listen(ctx context.Context, opts ...grpc.CallOption) (Synchronizer_ListenClient, error)
}

SynchronizerClient is the client API for Synchronizer service.

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

func NewSynchronizerClient 

func NewSynchronizerClient(cc *grpc.ClientConn) SynchronizerClient

type SynchronizerServer 

type SynchronizerServer interface {
	Router(context.Context, *RouterRequest) (*RouterResponse, error)
	Listen(Synchronizer_ListenServer) error
}

SynchronizerServer is the server API for Synchronizer service.

type Synchronizer_ListenClient 

type Synchronizer_ListenClient interface {
	Send(*ListenReq) error
	Recv() (*StreamRsp, error)
	grpc.ClientStream
}

type Synchronizer_ListenServer 

type Synchronizer_ListenServer interface {
	Send(*StreamRsp) error
	Recv() (*ListenReq, error)
	grpc.ServerStream
}

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.