bertybridge

package
v2.251.3 Latest Latest
Warning

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

 Go to latest Published: Jan 31, 2021 License: Apache-2.0, MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GRPCErrCode_name = map[int32]string{
	0:  "OK",
	1:  "CANCELED",
	2:  "UNKNOWN",
	3:  "INVALID_ARGUMENT",
	4:  "DEADLINE_EXCEEDED",
	5:  "NOT_FOUND",
	6:  "ALREADY_EXISTS",
	7:  "PERMISSION_DENIED",
	8:  "RESOURCE_EXHAUSTED",
	9:  "FAILED_PRECONDITION",
	10: "ABORTED",
	11: "OUT_OF_RANGE",
	12: "UNIMPLEMENTED",
	13: "INTERNAL",
	14: "UNAVAILABLE",
	15: "DATA_LOSS",
	16: "UNAUTHENTICATED",
}
View Source 
var GRPCErrCode_value = map[string]int32{
	"OK":                  0,
	"CANCELED":            1,
	"UNKNOWN":             2,
	"INVALID_ARGUMENT":    3,
	"DEADLINE_EXCEEDED":   4,
	"NOT_FOUND":           5,
	"ALREADY_EXISTS":      6,
	"PERMISSION_DENIED":   7,
	"RESOURCE_EXHAUSTED":  8,
	"FAILED_PRECONDITION": 9,
	"ABORTED":             10,
	"OUT_OF_RANGE":        11,
	"UNIMPLEMENTED":       12,
	"INTERNAL":            13,
	"UNAVAILABLE":         14,
	"DATA_LOSS":           15,
	"UNAUTHENTICATED":     16,
}

Functions

func RegisterBridgeServiceServer 

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

Types

type BridgeServiceClient 

type BridgeServiceClient interface {
	// ClientInvokeUnary invoke a unary method
	ClientInvokeUnary(ctx context.Context, in *ClientInvokeUnary_Request, opts ...grpc.CallOption) (*ClientInvokeUnary_Reply, error)
	// CreateStream create a stream
	CreateClientStream(ctx context.Context, in *ClientCreateStream_Request, opts ...grpc.CallOption) (*ClientCreateStream_Reply, error)
	// Send Message over the given stream
	ClientStreamSend(ctx context.Context, in *ClientStreamSend_Request, opts ...grpc.CallOption) (*ClientStreamSend_Reply, error)
	// Recv message over the given stream
	ClientStreamRecv(ctx context.Context, in *ClientStreamRecv_Request, opts ...grpc.CallOption) (*ClientStreamRecv_Reply, error)
	// Close the given stream (should not be used)
	ClientStreamClose(ctx context.Context, in *ClientStreamClose_Request, opts ...grpc.CallOption) (*ClientStreamClose_Reply, error)
	// Close the writing end of a stream and return the next reply
	ClientStreamCloseAndRecv(ctx context.Context, in *ClientStreamCloseAndRecv_Request, opts ...grpc.CallOption) (*ClientStreamCloseAndRecv_Reply, error)
}

BridgeServiceClient is the client API for BridgeService service.

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

func NewBridgeServiceClient 

func NewBridgeServiceClient(cc *grpc.ClientConn) BridgeServiceClient

type BridgeServiceServer 

type BridgeServiceServer interface {
	// ClientInvokeUnary invoke a unary method
	ClientInvokeUnary(context.Context, *ClientInvokeUnary_Request) (*ClientInvokeUnary_Reply, error)
	// CreateStream create a stream
	CreateClientStream(context.Context, *ClientCreateStream_Request) (*ClientCreateStream_Reply, error)
	// Send Message over the given stream
	ClientStreamSend(context.Context, *ClientStreamSend_Request) (*ClientStreamSend_Reply, error)
	// Recv message over the given stream
	ClientStreamRecv(context.Context, *ClientStreamRecv_Request) (*ClientStreamRecv_Reply, error)
	// Close the given stream (should not be used)
	ClientStreamClose(context.Context, *ClientStreamClose_Request) (*ClientStreamClose_Reply, error)
	// Close the writing end of a stream and return the next reply
	ClientStreamCloseAndRecv(context.Context, *ClientStreamCloseAndRecv_Request) (*ClientStreamCloseAndRecv_Reply, error)
}

BridgeServiceServer is the server API for BridgeService service.

type ClientCreateStream 

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

func (*ClientCreateStream) Descriptor 

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

func (*ClientCreateStream) ProtoMessage 

func (*ClientCreateStream) ProtoMessage()

func (*ClientCreateStream) Reset 

func (m *ClientCreateStream) Reset()

func (*ClientCreateStream) String 

func (m *ClientCreateStream) String() string

func (*ClientCreateStream) XXX_DiscardUnknown 

func (m *ClientCreateStream) XXX_DiscardUnknown()

func (*ClientCreateStream) XXX_Marshal 

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

func (*ClientCreateStream) XXX_Merge 

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

func (*ClientCreateStream) XXX_Size 

func (m *ClientCreateStream) XXX_Size() int

func (*ClientCreateStream) XXX_Unmarshal 

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

type ClientCreateStream_Reply 

type ClientCreateStream_Reply struct {
	StreamId             string      `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Trailer              []*Metadata `protobuf:"bytes,2,rep,name=trailer,proto3" json:"trailer,omitempty"`
	Error                *Error      `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ClientCreateStream_Reply) Descriptor 

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

func (*ClientCreateStream_Reply) GetError 

func (m *ClientCreateStream_Reply) GetError() *Error

func (*ClientCreateStream_Reply) GetStreamId 

func (m *ClientCreateStream_Reply) GetStreamId() string

func (*ClientCreateStream_Reply) GetTrailer 

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

func (*ClientCreateStream_Reply) ProtoMessage 

func (*ClientCreateStream_Reply) ProtoMessage()

func (*ClientCreateStream_Reply) Reset 

func (m *ClientCreateStream_Reply) Reset()

func (*ClientCreateStream_Reply) String 

func (m *ClientCreateStream_Reply) String() string

func (*ClientCreateStream_Reply) XXX_DiscardUnknown 

func (m *ClientCreateStream_Reply) XXX_DiscardUnknown()

func (*ClientCreateStream_Reply) XXX_Marshal 

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

func (*ClientCreateStream_Reply) XXX_Merge 

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

func (*ClientCreateStream_Reply) XXX_Size 

func (m *ClientCreateStream_Reply) XXX_Size() int

func (*ClientCreateStream_Reply) XXX_Unmarshal 

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

type ClientCreateStream_Request 

type ClientCreateStream_Request struct {
	MethodDesc           *MethodDesc `protobuf:"bytes,2,opt,name=method_desc,json=methodDesc,proto3" json:"method_desc,omitempty"`
	Payload              []byte      `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	Header               []*Metadata `protobuf:"bytes,4,rep,name=header,proto3" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ClientCreateStream_Request) Descriptor 

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

func (*ClientCreateStream_Request) GetHeader 

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

func (*ClientCreateStream_Request) GetMethodDesc 

func (m *ClientCreateStream_Request) GetMethodDesc() *MethodDesc

func (*ClientCreateStream_Request) GetPayload 

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

func (*ClientCreateStream_Request) ProtoMessage 

func (*ClientCreateStream_Request) ProtoMessage()

func (*ClientCreateStream_Request) Reset 

func (m *ClientCreateStream_Request) Reset()

func (*ClientCreateStream_Request) String 

func (m *ClientCreateStream_Request) String() string

func (*ClientCreateStream_Request) XXX_DiscardUnknown 

func (m *ClientCreateStream_Request) XXX_DiscardUnknown()

func (*ClientCreateStream_Request) XXX_Marshal 

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

func (*ClientCreateStream_Request) XXX_Merge 

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

func (*ClientCreateStream_Request) XXX_Size 

func (m *ClientCreateStream_Request) XXX_Size() int

func (*ClientCreateStream_Request) XXX_Unmarshal 

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

type ClientInvokeUnary 

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

func (*ClientInvokeUnary) Descriptor 

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

func (*ClientInvokeUnary) ProtoMessage 

func (*ClientInvokeUnary) ProtoMessage()

func (*ClientInvokeUnary) Reset 

func (m *ClientInvokeUnary) Reset()

func (*ClientInvokeUnary) String 

func (m *ClientInvokeUnary) String() string

func (*ClientInvokeUnary) XXX_DiscardUnknown 

func (m *ClientInvokeUnary) XXX_DiscardUnknown()

func (*ClientInvokeUnary) XXX_Marshal 

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

func (*ClientInvokeUnary) XXX_Merge 

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

func (*ClientInvokeUnary) XXX_Size 

func (m *ClientInvokeUnary) XXX_Size() int

func (*ClientInvokeUnary) XXX_Unmarshal 

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

type ClientInvokeUnary_Reply 

type ClientInvokeUnary_Reply struct {
	Payload              []byte      `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Trailer              []*Metadata `protobuf:"bytes,3,rep,name=trailer,proto3" json:"trailer,omitempty"`
	Error                *Error      `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ClientInvokeUnary_Reply) Descriptor 

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

func (*ClientInvokeUnary_Reply) GetError 

func (m *ClientInvokeUnary_Reply) GetError() *Error

func (*ClientInvokeUnary_Reply) GetPayload 

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

func (*ClientInvokeUnary_Reply) GetTrailer 

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

func (*ClientInvokeUnary_Reply) ProtoMessage 

func (*ClientInvokeUnary_Reply) ProtoMessage()

func (*ClientInvokeUnary_Reply) Reset 

func (m *ClientInvokeUnary_Reply) Reset()

func (*ClientInvokeUnary_Reply) String 

func (m *ClientInvokeUnary_Reply) String() string

func (*ClientInvokeUnary_Reply) XXX_DiscardUnknown 

func (m *ClientInvokeUnary_Reply) XXX_DiscardUnknown()

func (*ClientInvokeUnary_Reply) XXX_Marshal 

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

func (*ClientInvokeUnary_Reply) XXX_Merge 

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

func (*ClientInvokeUnary_Reply) XXX_Size 

func (m *ClientInvokeUnary_Reply) XXX_Size() int

func (*ClientInvokeUnary_Reply) XXX_Unmarshal 

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

type ClientInvokeUnary_Request 

type ClientInvokeUnary_Request struct {
	MethodDesc           *MethodDesc `protobuf:"bytes,2,opt,name=method_desc,json=methodDesc,proto3" json:"method_desc,omitempty"`
	Payload              []byte      `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	Header               []*Metadata `protobuf:"bytes,4,rep,name=header,proto3" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ClientInvokeUnary_Request) Descriptor 

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

func (*ClientInvokeUnary_Request) GetHeader 

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

func (*ClientInvokeUnary_Request) GetMethodDesc 

func (m *ClientInvokeUnary_Request) GetMethodDesc() *MethodDesc

func (*ClientInvokeUnary_Request) GetPayload 

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

func (*ClientInvokeUnary_Request) ProtoMessage 

func (*ClientInvokeUnary_Request) ProtoMessage()

func (*ClientInvokeUnary_Request) Reset 

func (m *ClientInvokeUnary_Request) Reset()

func (*ClientInvokeUnary_Request) String 

func (m *ClientInvokeUnary_Request) String() string

func (*ClientInvokeUnary_Request) XXX_DiscardUnknown 

func (m *ClientInvokeUnary_Request) XXX_DiscardUnknown()

func (*ClientInvokeUnary_Request) XXX_Marshal 

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

func (*ClientInvokeUnary_Request) XXX_Merge 

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

func (*ClientInvokeUnary_Request) XXX_Size 

func (m *ClientInvokeUnary_Request) XXX_Size() int

func (*ClientInvokeUnary_Request) XXX_Unmarshal 

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

type ClientStreamClose 

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

func (*ClientStreamClose) Descriptor 

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

func (*ClientStreamClose) ProtoMessage 

func (*ClientStreamClose) ProtoMessage()

func (*ClientStreamClose) Reset 

func (m *ClientStreamClose) Reset()

func (*ClientStreamClose) String 

func (m *ClientStreamClose) String() string

func (*ClientStreamClose) XXX_DiscardUnknown 

func (m *ClientStreamClose) XXX_DiscardUnknown()

func (*ClientStreamClose) XXX_Marshal 

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

func (*ClientStreamClose) XXX_Merge 

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

func (*ClientStreamClose) XXX_Size 

func (m *ClientStreamClose) XXX_Size() int

func (*ClientStreamClose) XXX_Unmarshal 

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

type ClientStreamCloseAndRecv 

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

func (*ClientStreamCloseAndRecv) Descriptor 

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

func (*ClientStreamCloseAndRecv) ProtoMessage 

func (*ClientStreamCloseAndRecv) ProtoMessage()

func (*ClientStreamCloseAndRecv) Reset 

func (m *ClientStreamCloseAndRecv) Reset()

func (*ClientStreamCloseAndRecv) String 

func (m *ClientStreamCloseAndRecv) String() string

func (*ClientStreamCloseAndRecv) XXX_DiscardUnknown 

func (m *ClientStreamCloseAndRecv) XXX_DiscardUnknown()

func (*ClientStreamCloseAndRecv) XXX_Marshal 

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

func (*ClientStreamCloseAndRecv) XXX_Merge 

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

func (*ClientStreamCloseAndRecv) XXX_Size 

func (m *ClientStreamCloseAndRecv) XXX_Size() int

func (*ClientStreamCloseAndRecv) XXX_Unmarshal 

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

type ClientStreamCloseAndRecv_Reply 

type ClientStreamCloseAndRecv_Reply struct {
	StreamId             string      `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Payload              []byte      `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Trailer              []*Metadata `protobuf:"bytes,3,rep,name=trailer,proto3" json:"trailer,omitempty"`
	Error                *Error      `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ClientStreamCloseAndRecv_Reply) Descriptor 

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

func (*ClientStreamCloseAndRecv_Reply) GetError 

func (m *ClientStreamCloseAndRecv_Reply) GetError() *Error

func (*ClientStreamCloseAndRecv_Reply) GetPayload 

func (m *ClientStreamCloseAndRecv_Reply) GetPayload() []byte

func (*ClientStreamCloseAndRecv_Reply) GetStreamId 

func (m *ClientStreamCloseAndRecv_Reply) GetStreamId() string

func (*ClientStreamCloseAndRecv_Reply) GetTrailer 

func (m *ClientStreamCloseAndRecv_Reply) GetTrailer() []*Metadata

func (*ClientStreamCloseAndRecv_Reply) ProtoMessage 

func (*ClientStreamCloseAndRecv_Reply) ProtoMessage()

func (*ClientStreamCloseAndRecv_Reply) Reset 

func (m *ClientStreamCloseAndRecv_Reply) Reset()

func (*ClientStreamCloseAndRecv_Reply) String 

func (m *ClientStreamCloseAndRecv_Reply) String() string

func (*ClientStreamCloseAndRecv_Reply) XXX_DiscardUnknown 

func (m *ClientStreamCloseAndRecv_Reply) XXX_DiscardUnknown()

func (*ClientStreamCloseAndRecv_Reply) XXX_Marshal 

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

func (*ClientStreamCloseAndRecv_Reply) XXX_Merge 

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

func (*ClientStreamCloseAndRecv_Reply) XXX_Size 

func (m *ClientStreamCloseAndRecv_Reply) XXX_Size() int

func (*ClientStreamCloseAndRecv_Reply) XXX_Unmarshal 

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

type ClientStreamCloseAndRecv_Request 

type ClientStreamCloseAndRecv_Request struct {
	StreamId             string   `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClientStreamCloseAndRecv_Request) Descriptor 

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

func (*ClientStreamCloseAndRecv_Request) GetStreamId 

func (m *ClientStreamCloseAndRecv_Request) GetStreamId() string

func (*ClientStreamCloseAndRecv_Request) ProtoMessage 

func (*ClientStreamCloseAndRecv_Request) ProtoMessage()

func (*ClientStreamCloseAndRecv_Request) Reset 

func (m *ClientStreamCloseAndRecv_Request) Reset()

func (*ClientStreamCloseAndRecv_Request) String 

func (m *ClientStreamCloseAndRecv_Request) String() string

func (*ClientStreamCloseAndRecv_Request) XXX_DiscardUnknown 

func (m *ClientStreamCloseAndRecv_Request) XXX_DiscardUnknown()

func (*ClientStreamCloseAndRecv_Request) XXX_Marshal 

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

func (*ClientStreamCloseAndRecv_Request) XXX_Merge 

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

func (*ClientStreamCloseAndRecv_Request) XXX_Size 

func (m *ClientStreamCloseAndRecv_Request) XXX_Size() int

func (*ClientStreamCloseAndRecv_Request) XXX_Unmarshal 

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

type ClientStreamClose_Reply 

type ClientStreamClose_Reply struct {
	StreamId             string      `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Trailer              []*Metadata `protobuf:"bytes,2,rep,name=trailer,proto3" json:"trailer,omitempty"`
	Error                *Error      `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ClientStreamClose_Reply) Descriptor 

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

func (*ClientStreamClose_Reply) GetError 

func (m *ClientStreamClose_Reply) GetError() *Error

func (*ClientStreamClose_Reply) GetStreamId 

func (m *ClientStreamClose_Reply) GetStreamId() string

func (*ClientStreamClose_Reply) GetTrailer 

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

func (*ClientStreamClose_Reply) ProtoMessage 

func (*ClientStreamClose_Reply) ProtoMessage()

func (*ClientStreamClose_Reply) Reset 

func (m *ClientStreamClose_Reply) Reset()

func (*ClientStreamClose_Reply) String 

func (m *ClientStreamClose_Reply) String() string

func (*ClientStreamClose_Reply) XXX_DiscardUnknown 

func (m *ClientStreamClose_Reply) XXX_DiscardUnknown()

func (*ClientStreamClose_Reply) XXX_Marshal 

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

func (*ClientStreamClose_Reply) XXX_Merge 

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

func (*ClientStreamClose_Reply) XXX_Size 

func (m *ClientStreamClose_Reply) XXX_Size() int

func (*ClientStreamClose_Reply) XXX_Unmarshal 

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

type ClientStreamClose_Request 

type ClientStreamClose_Request struct {
	StreamId             string   `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClientStreamClose_Request) Descriptor 

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

func (*ClientStreamClose_Request) GetStreamId 

func (m *ClientStreamClose_Request) GetStreamId() string

func (*ClientStreamClose_Request) ProtoMessage 

func (*ClientStreamClose_Request) ProtoMessage()

func (*ClientStreamClose_Request) Reset 

func (m *ClientStreamClose_Request) Reset()

func (*ClientStreamClose_Request) String 

func (m *ClientStreamClose_Request) String() string

func (*ClientStreamClose_Request) XXX_DiscardUnknown 

func (m *ClientStreamClose_Request) XXX_DiscardUnknown()

func (*ClientStreamClose_Request) XXX_Marshal 

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

func (*ClientStreamClose_Request) XXX_Merge 

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

func (*ClientStreamClose_Request) XXX_Size 

func (m *ClientStreamClose_Request) XXX_Size() int

func (*ClientStreamClose_Request) XXX_Unmarshal 

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

type ClientStreamRecv 

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

func (*ClientStreamRecv) Descriptor 

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

func (*ClientStreamRecv) ProtoMessage 

func (*ClientStreamRecv) ProtoMessage()

func (*ClientStreamRecv) Reset 

func (m *ClientStreamRecv) Reset()

func (*ClientStreamRecv) String 

func (m *ClientStreamRecv) String() string

func (*ClientStreamRecv) XXX_DiscardUnknown 

func (m *ClientStreamRecv) XXX_DiscardUnknown()

func (*ClientStreamRecv) XXX_Marshal 

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

func (*ClientStreamRecv) XXX_Merge 

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

func (*ClientStreamRecv) XXX_Size 

func (m *ClientStreamRecv) XXX_Size() int

func (*ClientStreamRecv) XXX_Unmarshal 

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

type ClientStreamRecv_Reply 

type ClientStreamRecv_Reply struct {
	StreamId             string      `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Payload              []byte      `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Trailer              []*Metadata `protobuf:"bytes,3,rep,name=trailer,proto3" json:"trailer,omitempty"`
	Error                *Error      `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ClientStreamRecv_Reply) Descriptor 

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

func (*ClientStreamRecv_Reply) GetError 

func (m *ClientStreamRecv_Reply) GetError() *Error

func (*ClientStreamRecv_Reply) GetPayload 

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

func (*ClientStreamRecv_Reply) GetStreamId 

func (m *ClientStreamRecv_Reply) GetStreamId() string

func (*ClientStreamRecv_Reply) GetTrailer 

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

func (*ClientStreamRecv_Reply) ProtoMessage 

func (*ClientStreamRecv_Reply) ProtoMessage()

func (*ClientStreamRecv_Reply) Reset 

func (m *ClientStreamRecv_Reply) Reset()

func (*ClientStreamRecv_Reply) String 

func (m *ClientStreamRecv_Reply) String() string

func (*ClientStreamRecv_Reply) XXX_DiscardUnknown 

func (m *ClientStreamRecv_Reply) XXX_DiscardUnknown()

func (*ClientStreamRecv_Reply) XXX_Marshal 

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

func (*ClientStreamRecv_Reply) XXX_Merge 

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

func (*ClientStreamRecv_Reply) XXX_Size 

func (m *ClientStreamRecv_Reply) XXX_Size() int

func (*ClientStreamRecv_Reply) XXX_Unmarshal 

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

type ClientStreamRecv_Request 

type ClientStreamRecv_Request struct {
	StreamId             string   `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClientStreamRecv_Request) Descriptor 

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

func (*ClientStreamRecv_Request) GetStreamId 

func (m *ClientStreamRecv_Request) GetStreamId() string

func (*ClientStreamRecv_Request) ProtoMessage 

func (*ClientStreamRecv_Request) ProtoMessage()

func (*ClientStreamRecv_Request) Reset 

func (m *ClientStreamRecv_Request) Reset()

func (*ClientStreamRecv_Request) String 

func (m *ClientStreamRecv_Request) String() string

func (*ClientStreamRecv_Request) XXX_DiscardUnknown 

func (m *ClientStreamRecv_Request) XXX_DiscardUnknown()

func (*ClientStreamRecv_Request) XXX_Marshal 

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

func (*ClientStreamRecv_Request) XXX_Merge 

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

func (*ClientStreamRecv_Request) XXX_Size 

func (m *ClientStreamRecv_Request) XXX_Size() int

func (*ClientStreamRecv_Request) XXX_Unmarshal 

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

type ClientStreamSend 

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

func (*ClientStreamSend) Descriptor 

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

func (*ClientStreamSend) ProtoMessage 

func (*ClientStreamSend) ProtoMessage()

func (*ClientStreamSend) Reset 

func (m *ClientStreamSend) Reset()

func (*ClientStreamSend) String 

func (m *ClientStreamSend) String() string

func (*ClientStreamSend) XXX_DiscardUnknown 

func (m *ClientStreamSend) XXX_DiscardUnknown()

func (*ClientStreamSend) XXX_Marshal 

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

func (*ClientStreamSend) XXX_Merge 

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

func (*ClientStreamSend) XXX_Size 

func (m *ClientStreamSend) XXX_Size() int

func (*ClientStreamSend) XXX_Unmarshal 

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

type ClientStreamSend_Reply 

type ClientStreamSend_Reply struct {
	StreamId             string      `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Trailer              []*Metadata `protobuf:"bytes,2,rep,name=trailer,proto3" json:"trailer,omitempty"`
	Error                *Error      `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ClientStreamSend_Reply) Descriptor 

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

func (*ClientStreamSend_Reply) GetError 

func (m *ClientStreamSend_Reply) GetError() *Error

func (*ClientStreamSend_Reply) GetStreamId 

func (m *ClientStreamSend_Reply) GetStreamId() string

func (*ClientStreamSend_Reply) GetTrailer 

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

func (*ClientStreamSend_Reply) ProtoMessage 

func (*ClientStreamSend_Reply) ProtoMessage()

func (*ClientStreamSend_Reply) Reset 

func (m *ClientStreamSend_Reply) Reset()

func (*ClientStreamSend_Reply) String 

func (m *ClientStreamSend_Reply) String() string

func (*ClientStreamSend_Reply) XXX_DiscardUnknown 

func (m *ClientStreamSend_Reply) XXX_DiscardUnknown()

func (*ClientStreamSend_Reply) XXX_Marshal 

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

func (*ClientStreamSend_Reply) XXX_Merge 

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

func (*ClientStreamSend_Reply) XXX_Size 

func (m *ClientStreamSend_Reply) XXX_Size() int

func (*ClientStreamSend_Reply) XXX_Unmarshal 

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

type ClientStreamSend_Request 

type ClientStreamSend_Request struct {
	StreamId             string   `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Payload              []byte   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClientStreamSend_Request) Descriptor 

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

func (*ClientStreamSend_Request) GetPayload 

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

func (*ClientStreamSend_Request) GetStreamId 

func (m *ClientStreamSend_Request) GetStreamId() string

func (*ClientStreamSend_Request) ProtoMessage 

func (*ClientStreamSend_Request) ProtoMessage()

func (*ClientStreamSend_Request) Reset 

func (m *ClientStreamSend_Request) Reset()

func (*ClientStreamSend_Request) String 

func (m *ClientStreamSend_Request) String() string

func (*ClientStreamSend_Request) XXX_DiscardUnknown 

func (m *ClientStreamSend_Request) XXX_DiscardUnknown()

func (*ClientStreamSend_Request) XXX_Marshal 

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

func (*ClientStreamSend_Request) XXX_Merge 

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

func (*ClientStreamSend_Request) XXX_Size 

func (m *ClientStreamSend_Request) XXX_Size() int

func (*ClientStreamSend_Request) XXX_Unmarshal 

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

type Error 

type Error struct {
	// grpc error code
	GrpcErrorCode GRPCErrCode `` /* 136-byte string literal not displayed */
	// toplevel error
	ErrorCode errcode.ErrCode `protobuf:"varint,2,opt,name=error_code,json=errorCode,proto3,enum=berty.errcode.ErrCode" json:"error_code,omitempty"`
	// toplevel error message
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// detailed errors
	ErrorDetails         *errcode.ErrDetails `protobuf:"bytes,4,opt,name=error_details,json=errorDetails,proto3" json:"error_details,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*Error) Descriptor 

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

func (*Error) GetErrorCode 

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

func (*Error) GetErrorDetails 

func (m *Error) GetErrorDetails() *errcode.ErrDetails

func (*Error) GetGrpcErrorCode 

func (m *Error) GetGrpcErrorCode() GRPCErrCode

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

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

func (*Error) XXX_Merge 

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

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

type GRPCErrCode 

type GRPCErrCode int32
const (
	// OK is returned on success.
	GRPCErrCode_OK GRPCErrCode = 0
	// Canceled indicates the operation was canceled (typically by the caller).
	//
	// The gRPC framework will generate this error code when cancellation
	// is requested.
	GRPCErrCode_CANCELED GRPCErrCode = 1
	// Unknown error. An example of where this error may be returned is
	// if a Status value received from another address space belongs to
	// an error-space that is not known in this address space. Also
	// errors raised by APIs that do not return enough error information
	// may be converted to this error.
	//
	// The gRPC framework will generate this error code in the above two
	// mentioned cases.
	GRPCErrCode_UNKNOWN GRPCErrCode = 2
	// InvalidArgument indicates client specified an invalid argument.
	// Note that this differs from FailedPrecondition. It indicates arguments
	// that are problematic regardless of the state of the system
	// (e.g., a malformed file name).
	//
	// This error code will not be generated by the gRPC framework.
	GRPCErrCode_INVALID_ARGUMENT GRPCErrCode = 3
	// DeadlineExceeded means operation expired before completion.
	// For operations that change the state of the system, this error may be
	// returned even if the operation has completed successfully. For
	// example, a successful response from a server could have been delayed
	// long enough for the deadline to expire.
	//
	// The gRPC framework will generate this error code when the deadline is
	// exceeded.
	GRPCErrCode_DEADLINE_EXCEEDED GRPCErrCode = 4
	// NotFound means some requested entity (e.g., file or directory) was
	// not found.
	//
	// This error code will not be generated by the gRPC framework.
	GRPCErrCode_NOT_FOUND GRPCErrCode = 5
	// AlreadyExists means an attempt to create an entity failed because one
	// already exists.
	//
	// This error code will not be generated by the gRPC framework.
	GRPCErrCode_ALREADY_EXISTS GRPCErrCode = 6
	// PermissionDenied indicates the caller does not have permission to
	// execute the specified operation. It must not be used for rejections
	// caused by exhausting some resource (use ResourceExhausted
	// instead for those errors). It must not be
	// used if the caller cannot be identified (use Unauthenticated
	// instead for those errors).
	//
	// This error code will not be generated by the gRPC core framework,
	// but expect authentication middleware to use it.
	GRPCErrCode_PERMISSION_DENIED GRPCErrCode = 7
	// ResourceExhausted indicates some resource has been exhausted, perhaps
	// a per-user quota, or perhaps the entire file system is out of space.
	//
	// This error code will be generated by the gRPC framework in
	// out-of-memory and server overload situations, or when a message is
	// larger than the configured maximum size.
	GRPCErrCode_RESOURCE_EXHAUSTED GRPCErrCode = 8
	// FailedPrecondition indicates operation was rejected because the
	// system is not in a state required for the operation's execution.
	// For example, directory to be deleted may be non-empty, an rmdir
	// operation is applied to a non-directory, etc.
	//
	// A litmus test that may help a service implementor in deciding
	// between FailedPrecondition, Aborted, and Unavailable:
	//  (a) Use Unavailable if the client can retry just the failing call.
	//  (b) Use Aborted if the client should retry at a higher-level
	//      (e.g., restarting a read-modify-write sequence).
	//  (c) Use FailedPrecondition if the client should not retry until
	//      the system state has been explicitly fixed. E.g., if an "rmdir"
	//      fails because the directory is non-empty, FailedPrecondition
	//      should be returned since the client should not retry unless
	//      they have first fixed up the directory by deleting files from it.
	//  (d) Use FailedPrecondition if the client performs conditional
	//      REST Get/Update/Delete on a resource and the resource on the
	//      server does not match the condition. E.g., conflicting
	//      read-modify-write on the same resource.
	//
	// This error code will not be generated by the gRPC framework.
	GRPCErrCode_FAILED_PRECONDITION GRPCErrCode = 9
	// Aborted indicates the operation was aborted, typically due to a
	// concurrency issue like sequencer check failures, transaction aborts,
	// etc.
	//
	// See litmus test above for deciding between FailedPrecondition,
	// Aborted, and Unavailable.
	//
	// This error code will not be generated by the gRPC framework.
	GRPCErrCode_ABORTED GRPCErrCode = 10
	// OutOfRange means operation was attempted past the valid range.
	// E.g., seeking or reading past end of file.
	//
	// Unlike InvalidArgument, this error indicates a problem that may
	// be fixed if the system state changes. For example, a 32-bit file
	// system will generate InvalidArgument if asked to read at an
	// offset that is not in the range [0,2^32-1], but it will generate
	// OutOfRange if asked to read from an offset past the current
	// file size.
	//
	// There is a fair bit of overlap between FailedPrecondition and
	// OutOfRange. We recommend using OutOfRange (the more specific
	// error) when it applies so that callers who are iterating through
	// a space can easily look for an OutOfRange error to detect when
	// they are done.
	//
	// This error code will not be generated by the gRPC framework.
	GRPCErrCode_OUT_OF_RANGE GRPCErrCode = 11
	// Unimplemented indicates operation is not implemented or not
	// supported/enabled in this service.
	//
	// This error code will be generated by the gRPC framework. Most
	// commonly, you will see this error code when a method implementation
	// is missing on the server. It can also be generated for unknown
	// compression algorithms or a disagreement as to whether an RPC should
	// be streaming.
	GRPCErrCode_UNIMPLEMENTED GRPCErrCode = 12
	// Internal errors. Means some invariants expected by underlying
	// system has been broken. If you see one of these errors,
	// something is very broken.
	//
	// This error code will be generated by the gRPC framework in several
	// internal error conditions.
	GRPCErrCode_INTERNAL GRPCErrCode = 13
	// Unavailable indicates the service is currently unavailable.
	// This is a most likely a transient condition and may be corrected
	// by retrying with a backoff. Note that it is not always safe to retry
	// non-idempotent operations.
	//
	// See litmus test above for deciding between FailedPrecondition,
	// Aborted, and Unavailable.
	//
	// This error code will be generated by the gRPC framework during
	// abrupt shutdown of a server process or network connection.
	GRPCErrCode_UNAVAILABLE GRPCErrCode = 14
	// DataLoss indicates unrecoverable data loss or corruption.
	//
	// This error code will not be generated by the gRPC framework.
	GRPCErrCode_DATA_LOSS GRPCErrCode = 15
	// Unauthenticated indicates the request does not have valid
	// authentication credentials for the operation.
	//
	// The gRPC framework will generate this error code when the
	// authentication metadata is invalid or a Credentials callback fails,
	// but also expect authentication middleware to generate it.
	GRPCErrCode_UNAUTHENTICATED GRPCErrCode = 16
)

func (GRPCErrCode) EnumDescriptor 

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

func (GRPCErrCode) String 

func (x GRPCErrCode) String() string

type Metadata 

type Metadata struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values               []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Metadata) Descriptor 

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

func (*Metadata) GetKey 

func (m *Metadata) GetKey() string

func (*Metadata) GetValues 

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

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) String 

func (m *Metadata) String() string

func (*Metadata) XXX_DiscardUnknown 

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal 

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

func (*Metadata) XXX_Merge 

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

func (*Metadata) XXX_Size 

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal 

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

type MethodDesc 

type MethodDesc struct {
	// Name is the method name only, without the service name or package name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// IsClientStream indicates whether the RPC is a client streaming RPC.
	IsClientStream bool `protobuf:"varint,2,opt,name=is_client_stream,json=isClientStream,proto3" json:"is_client_stream,omitempty"`
	// IsServerStream indicates whether the RPC is a server streaming RPC.
	IsServerStream       bool     `protobuf:"varint,3,opt,name=is_server_stream,json=isServerStream,proto3" json:"is_server_stream,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MethodDesc) Descriptor 

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

func (*MethodDesc) GetIsClientStream 

func (m *MethodDesc) GetIsClientStream() bool

func (*MethodDesc) GetIsServerStream 

func (m *MethodDesc) GetIsServerStream() bool

func (*MethodDesc) GetName 

func (m *MethodDesc) GetName() string

func (*MethodDesc) ProtoMessage 

func (*MethodDesc) ProtoMessage()

func (*MethodDesc) Reset 

func (m *MethodDesc) Reset()

func (*MethodDesc) String 

func (m *MethodDesc) String() string

func (*MethodDesc) XXX_DiscardUnknown 

func (m *MethodDesc) XXX_DiscardUnknown()

func (*MethodDesc) XXX_Marshal 

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

func (*MethodDesc) XXX_Merge 

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

func (*MethodDesc) XXX_Size 

func (m *MethodDesc) XXX_Size() int

func (*MethodDesc) XXX_Unmarshal 

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

type Options 

type Options struct {
	Logger *zap.Logger
}

type Service 

type Service interface {
	BridgeServiceServer

	ServiceClientRegister

	Close() error
}

func NewService 

func NewService(opts *Options) Service

type ServiceClientRegister 

type ServiceClientRegister interface {
	RegisterService(name string, cc *grpc.ClientConn)
}

func NewNoopServiceClientRegister 

func NewNoopServiceClientRegister() ServiceClientRegister

type UnimplementedBridgeServiceServer 

type UnimplementedBridgeServiceServer struct {
}

UnimplementedBridgeServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedBridgeServiceServer) ClientInvokeUnary 

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

func (*UnimplementedBridgeServiceServer) ClientStreamClose 

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

func (*UnimplementedBridgeServiceServer) ClientStreamCloseAndRecv 

func (*UnimplementedBridgeServiceServer) ClientStreamCloseAndRecv(ctx context.Context, req *ClientStreamCloseAndRecv_Request) (*ClientStreamCloseAndRecv_Reply, error)

func (*UnimplementedBridgeServiceServer) ClientStreamRecv 

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

func (*UnimplementedBridgeServiceServer) ClientStreamSend 

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

func (*UnimplementedBridgeServiceServer) CreateClientStream 

func (*UnimplementedBridgeServiceServer) CreateClientStream(ctx context.Context, req *ClientCreateStream_Request) (*ClientCreateStream_Reply, 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.