bridgepb

Aug 7, 2020

Changes in this version

+ var GRPCErrCode_name = map[int32]string

+ var GRPCErrCode_value = map[string]int32

+ func RegisterBridgeServiceServer(s *grpc.Server, srv BridgeServiceServer)

+ type BridgeServiceClient interface

+ ClientInvokeUnary func(ctx context.Context, in *ClientInvokeUnary_Request, opts ...grpc.CallOption) (*ClientInvokeUnary_Reply, error)

+ ClientStreamClose func(ctx context.Context, in *ClientStreamClose_Request, opts ...grpc.CallOption) (*ClientStreamClose_Reply, error)

+ ClientStreamRecv func(ctx context.Context, in *ClientStreamRecv_Request, opts ...grpc.CallOption) (*ClientStreamRecv_Reply, error)

+ ClientStreamSend func(ctx context.Context, in *ClientStreamSend_Request, opts ...grpc.CallOption) (*ClientStreamSend_Reply, error)

+ CreateClientStream func(ctx context.Context, in *ClientCreateStream_Request, opts ...grpc.CallOption) (*ClientCreateStream_Reply, error)

+ func NewBridgeServiceClient(cc *grpc.ClientConn) BridgeServiceClient

+ type BridgeServiceServer interface

+ ClientInvokeUnary func(context.Context, *ClientInvokeUnary_Request) (*ClientInvokeUnary_Reply, error)

+ ClientStreamClose func(context.Context, *ClientStreamClose_Request) (*ClientStreamClose_Reply, error)

+ ClientStreamRecv func(context.Context, *ClientStreamRecv_Request) (*ClientStreamRecv_Reply, error)

+ ClientStreamSend func(context.Context, *ClientStreamSend_Request) (*ClientStreamSend_Reply, error)

+ CreateClientStream func(context.Context, *ClientCreateStream_Request) (*ClientCreateStream_Reply, error)

+ type ClientCreateStream struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClientCreateStream) Descriptor() ([]byte, []int)

+ func (*ClientCreateStream) ProtoMessage()

+ func (m *ClientCreateStream) Reset()

+ func (m *ClientCreateStream) String() string

+ func (m *ClientCreateStream) XXX_DiscardUnknown()

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

+ func (m *ClientCreateStream) XXX_Merge(src proto.Message)

+ func (m *ClientCreateStream) XXX_Size() int

+ func (m *ClientCreateStream) XXX_Unmarshal(b []byte) error

+ type ClientCreateStream_Reply struct

+ Error *Error

+ StreamId string

+ Trailer []*Metadata

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClientCreateStream_Reply) Descriptor() ([]byte, []int)

+ func (*ClientCreateStream_Reply) ProtoMessage()

+ func (m *ClientCreateStream_Reply) GetError() *Error

+ func (m *ClientCreateStream_Reply) GetStreamId() string

+ func (m *ClientCreateStream_Reply) GetTrailer() []*Metadata

+ func (m *ClientCreateStream_Reply) Reset()

+ func (m *ClientCreateStream_Reply) String() string

+ func (m *ClientCreateStream_Reply) XXX_DiscardUnknown()

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

+ func (m *ClientCreateStream_Reply) XXX_Merge(src proto.Message)

+ func (m *ClientCreateStream_Reply) XXX_Size() int

+ func (m *ClientCreateStream_Reply) XXX_Unmarshal(b []byte) error

+ type ClientCreateStream_Request struct

+ Header []*Metadata

+ MethodDesc *MethodDesc

+ Payload []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClientCreateStream_Request) Descriptor() ([]byte, []int)

+ func (*ClientCreateStream_Request) ProtoMessage()

+ func (m *ClientCreateStream_Request) GetHeader() []*Metadata

+ func (m *ClientCreateStream_Request) GetMethodDesc() *MethodDesc

+ func (m *ClientCreateStream_Request) GetPayload() []byte

+ func (m *ClientCreateStream_Request) Reset()

+ func (m *ClientCreateStream_Request) String() string

+ func (m *ClientCreateStream_Request) XXX_DiscardUnknown()

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

+ func (m *ClientCreateStream_Request) XXX_Merge(src proto.Message)

+ func (m *ClientCreateStream_Request) XXX_Size() int

+ func (m *ClientCreateStream_Request) XXX_Unmarshal(b []byte) error

+ type ClientInvokeUnary struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClientInvokeUnary) Descriptor() ([]byte, []int)

+ func (*ClientInvokeUnary) ProtoMessage()

+ func (m *ClientInvokeUnary) Reset()

+ func (m *ClientInvokeUnary) String() string

+ func (m *ClientInvokeUnary) XXX_DiscardUnknown()

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

+ func (m *ClientInvokeUnary) XXX_Merge(src proto.Message)

+ func (m *ClientInvokeUnary) XXX_Size() int

+ func (m *ClientInvokeUnary) XXX_Unmarshal(b []byte) error

+ type ClientInvokeUnary_Reply struct

+ Error *Error

+ Payload []byte

+ Trailer []*Metadata

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClientInvokeUnary_Reply) Descriptor() ([]byte, []int)

+ func (*ClientInvokeUnary_Reply) ProtoMessage()

+ func (m *ClientInvokeUnary_Reply) GetError() *Error

+ func (m *ClientInvokeUnary_Reply) GetPayload() []byte

+ func (m *ClientInvokeUnary_Reply) GetTrailer() []*Metadata

+ func (m *ClientInvokeUnary_Reply) Reset()

+ func (m *ClientInvokeUnary_Reply) String() string

+ func (m *ClientInvokeUnary_Reply) XXX_DiscardUnknown()

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

+ func (m *ClientInvokeUnary_Reply) XXX_Merge(src proto.Message)

+ func (m *ClientInvokeUnary_Reply) XXX_Size() int

+ func (m *ClientInvokeUnary_Reply) XXX_Unmarshal(b []byte) error

+ type ClientInvokeUnary_Request struct

+ Header []*Metadata

+ MethodDesc *MethodDesc

+ Payload []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClientInvokeUnary_Request) Descriptor() ([]byte, []int)

+ func (*ClientInvokeUnary_Request) ProtoMessage()

+ func (m *ClientInvokeUnary_Request) GetHeader() []*Metadata

+ func (m *ClientInvokeUnary_Request) GetMethodDesc() *MethodDesc

+ func (m *ClientInvokeUnary_Request) GetPayload() []byte

+ func (m *ClientInvokeUnary_Request) Reset()

+ func (m *ClientInvokeUnary_Request) String() string

+ func (m *ClientInvokeUnary_Request) XXX_DiscardUnknown()

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

+ func (m *ClientInvokeUnary_Request) XXX_Merge(src proto.Message)

+ func (m *ClientInvokeUnary_Request) XXX_Size() int

+ func (m *ClientInvokeUnary_Request) XXX_Unmarshal(b []byte) error

+ type ClientStreamClose struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClientStreamClose) Descriptor() ([]byte, []int)

+ func (*ClientStreamClose) ProtoMessage()

+ func (m *ClientStreamClose) Reset()

+ func (m *ClientStreamClose) String() string

+ func (m *ClientStreamClose) XXX_DiscardUnknown()

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

+ func (m *ClientStreamClose) XXX_Merge(src proto.Message)

+ func (m *ClientStreamClose) XXX_Size() int

+ func (m *ClientStreamClose) XXX_Unmarshal(b []byte) error

+ type ClientStreamClose_Reply struct

+ Error *Error

+ StreamId string

+ Trailer []*Metadata

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClientStreamClose_Reply) Descriptor() ([]byte, []int)

+ func (*ClientStreamClose_Reply) ProtoMessage()

+ func (m *ClientStreamClose_Reply) GetError() *Error

+ func (m *ClientStreamClose_Reply) GetStreamId() string

+ func (m *ClientStreamClose_Reply) GetTrailer() []*Metadata

+ func (m *ClientStreamClose_Reply) Reset()

+ func (m *ClientStreamClose_Reply) String() string

+ func (m *ClientStreamClose_Reply) XXX_DiscardUnknown()

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

+ func (m *ClientStreamClose_Reply) XXX_Merge(src proto.Message)

+ func (m *ClientStreamClose_Reply) XXX_Size() int

+ func (m *ClientStreamClose_Reply) XXX_Unmarshal(b []byte) error

+ type ClientStreamClose_Request struct

+ StreamId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClientStreamClose_Request) Descriptor() ([]byte, []int)

+ func (*ClientStreamClose_Request) ProtoMessage()

+ func (m *ClientStreamClose_Request) GetStreamId() string

+ func (m *ClientStreamClose_Request) Reset()

+ func (m *ClientStreamClose_Request) String() string

+ func (m *ClientStreamClose_Request) XXX_DiscardUnknown()

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

+ func (m *ClientStreamClose_Request) XXX_Merge(src proto.Message)

+ func (m *ClientStreamClose_Request) XXX_Size() int

+ func (m *ClientStreamClose_Request) XXX_Unmarshal(b []byte) error

+ type ClientStreamRecv struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClientStreamRecv) Descriptor() ([]byte, []int)

+ func (*ClientStreamRecv) ProtoMessage()

+ func (m *ClientStreamRecv) Reset()

+ func (m *ClientStreamRecv) String() string

+ func (m *ClientStreamRecv) XXX_DiscardUnknown()

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

+ func (m *ClientStreamRecv) XXX_Merge(src proto.Message)

+ func (m *ClientStreamRecv) XXX_Size() int

+ func (m *ClientStreamRecv) XXX_Unmarshal(b []byte) error

+ type ClientStreamRecv_Reply struct

+ Error *Error

+ Payload []byte

+ StreamId string

+ Trailer []*Metadata

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClientStreamRecv_Reply) Descriptor() ([]byte, []int)

+ func (*ClientStreamRecv_Reply) ProtoMessage()

+ func (m *ClientStreamRecv_Reply) GetError() *Error

+ func (m *ClientStreamRecv_Reply) GetPayload() []byte

+ func (m *ClientStreamRecv_Reply) GetStreamId() string

+ func (m *ClientStreamRecv_Reply) GetTrailer() []*Metadata

+ func (m *ClientStreamRecv_Reply) Reset()

+ func (m *ClientStreamRecv_Reply) String() string

+ func (m *ClientStreamRecv_Reply) XXX_DiscardUnknown()

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

+ func (m *ClientStreamRecv_Reply) XXX_Merge(src proto.Message)

+ func (m *ClientStreamRecv_Reply) XXX_Size() int

+ func (m *ClientStreamRecv_Reply) XXX_Unmarshal(b []byte) error

+ type ClientStreamRecv_Request struct

+ StreamId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClientStreamRecv_Request) Descriptor() ([]byte, []int)

+ func (*ClientStreamRecv_Request) ProtoMessage()

+ func (m *ClientStreamRecv_Request) GetStreamId() string

+ func (m *ClientStreamRecv_Request) Reset()

+ func (m *ClientStreamRecv_Request) String() string

+ func (m *ClientStreamRecv_Request) XXX_DiscardUnknown()

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

+ func (m *ClientStreamRecv_Request) XXX_Merge(src proto.Message)

+ func (m *ClientStreamRecv_Request) XXX_Size() int

+ func (m *ClientStreamRecv_Request) XXX_Unmarshal(b []byte) error

+ type ClientStreamSend struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClientStreamSend) Descriptor() ([]byte, []int)

+ func (*ClientStreamSend) ProtoMessage()

+ func (m *ClientStreamSend) Reset()

+ func (m *ClientStreamSend) String() string

+ func (m *ClientStreamSend) XXX_DiscardUnknown()

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

+ func (m *ClientStreamSend) XXX_Merge(src proto.Message)

+ func (m *ClientStreamSend) XXX_Size() int

+ func (m *ClientStreamSend) XXX_Unmarshal(b []byte) error

+ type ClientStreamSend_Reply struct

+ Error *Error

+ StreamId string

+ Trailer []*Metadata

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClientStreamSend_Reply) Descriptor() ([]byte, []int)

+ func (*ClientStreamSend_Reply) ProtoMessage()

+ func (m *ClientStreamSend_Reply) GetError() *Error

+ func (m *ClientStreamSend_Reply) GetStreamId() string

+ func (m *ClientStreamSend_Reply) GetTrailer() []*Metadata

+ func (m *ClientStreamSend_Reply) Reset()

+ func (m *ClientStreamSend_Reply) String() string

+ func (m *ClientStreamSend_Reply) XXX_DiscardUnknown()

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

+ func (m *ClientStreamSend_Reply) XXX_Merge(src proto.Message)

+ func (m *ClientStreamSend_Reply) XXX_Size() int

+ func (m *ClientStreamSend_Reply) XXX_Unmarshal(b []byte) error

+ type ClientStreamSend_Request struct

+ Payload []byte

+ StreamId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClientStreamSend_Request) Descriptor() ([]byte, []int)

+ func (*ClientStreamSend_Request) ProtoMessage()

+ func (m *ClientStreamSend_Request) GetPayload() []byte

+ func (m *ClientStreamSend_Request) GetStreamId() string

+ func (m *ClientStreamSend_Request) Reset()

+ func (m *ClientStreamSend_Request) String() string

+ func (m *ClientStreamSend_Request) XXX_DiscardUnknown()

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

+ func (m *ClientStreamSend_Request) XXX_Merge(src proto.Message)

+ func (m *ClientStreamSend_Request) XXX_Size() int

+ func (m *ClientStreamSend_Request) XXX_Unmarshal(b []byte) error

+ type Error struct

+ ErrorCode errcode.ErrCode

+ GrpcErrorCode GRPCErrCode

+ Message string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Error) Descriptor() ([]byte, []int)

+ func (*Error) ProtoMessage()

+ func (m *Error) GetErrorCode() errcode.ErrCode

+ func (m *Error) GetGrpcErrorCode() GRPCErrCode

+ func (m *Error) GetMessage() string

+ func (m *Error) Reset()

+ func (m *Error) String() string

+ func (m *Error) XXX_DiscardUnknown()

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

+ func (m *Error) XXX_Merge(src proto.Message)

+ func (m *Error) XXX_Size() int

+ func (m *Error) XXX_Unmarshal(b []byte) error

+ type GRPCErrCode int32

+ const GRPCErrCode_ABORTED

+ const GRPCErrCode_ALREADY_EXISTS

+ const GRPCErrCode_CANCELED

+ const GRPCErrCode_DATA_LOSS

+ const GRPCErrCode_DEADLINE_EXCEEDED

+ const GRPCErrCode_FAILED_PRECONDITION

+ const GRPCErrCode_INTERNAL

+ const GRPCErrCode_INVALID_ARGUMENT

+ const GRPCErrCode_NOT_FOUND

+ const GRPCErrCode_OK

+ const GRPCErrCode_OUT_OF_RANGE

+ const GRPCErrCode_PERMISSION_DENIED

+ const GRPCErrCode_RESOURCE_EXHAUSTED

+ const GRPCErrCode_UNAUTHENTICATED

+ const GRPCErrCode_UNAVAILABLE

+ const GRPCErrCode_UNIMPLEMENTED

+ const GRPCErrCode_UNKNOWN

+ func (GRPCErrCode) EnumDescriptor() ([]byte, []int)

+ func (x GRPCErrCode) String() string

+ type Metadata struct

+ Key string

+ Values []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Metadata) Descriptor() ([]byte, []int)

+ func (*Metadata) ProtoMessage()

+ func (m *Metadata) GetKey() string

+ func (m *Metadata) GetValues() []string

+ func (m *Metadata) Reset()

+ func (m *Metadata) String() string

+ func (m *Metadata) XXX_DiscardUnknown()

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

+ func (m *Metadata) XXX_Merge(src proto.Message)

+ func (m *Metadata) XXX_Size() int

+ func (m *Metadata) XXX_Unmarshal(b []byte) error

+ type MethodDesc struct

+ IsClientStream bool

+ IsServerStream bool

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MethodDesc) Descriptor() ([]byte, []int)

+ func (*MethodDesc) ProtoMessage()

+ func (m *MethodDesc) GetIsClientStream() bool

+ func (m *MethodDesc) GetIsServerStream() bool

+ func (m *MethodDesc) GetName() string

+ func (m *MethodDesc) Reset()

+ func (m *MethodDesc) String() string

+ func (m *MethodDesc) XXX_DiscardUnknown()

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

+ func (m *MethodDesc) XXX_Merge(src proto.Message)

+ func (m *MethodDesc) XXX_Size() int

+ func (m *MethodDesc) XXX_Unmarshal(b []byte) error

+ type UnimplementedBridgeServiceServer struct

+ func (*UnimplementedBridgeServiceServer) ClientInvokeUnary(ctx context.Context, req *ClientInvokeUnary_Request) (*ClientInvokeUnary_Reply, error)

+ func (*UnimplementedBridgeServiceServer) ClientStreamClose(ctx context.Context, req *ClientStreamClose_Request) (*ClientStreamClose_Reply, error)

+ func (*UnimplementedBridgeServiceServer) ClientStreamRecv(ctx context.Context, req *ClientStreamRecv_Request) (*ClientStreamRecv_Reply, error)

+ func (*UnimplementedBridgeServiceServer) ClientStreamSend(ctx context.Context, req *ClientStreamSend_Request) (*ClientStreamSend_Reply, error)

+ func (*UnimplementedBridgeServiceServer) CreateClientStream(ctx context.Context, req *ClientCreateStream_Request) (*ClientCreateStream_Reply, error)