bertybridge

package
v2.468.9 Latest Latest
Warning

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

 Go to latest Published: Jun 14, 2023 License: Apache-2.0, MIT Imports: 23 Imported by: 0

Documentation

Overview

Package bertybridge is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBertybridge        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBertybridge          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBertybridge = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var BridgeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "berty.bridge.v1.BridgeService",
	HandlerType: (*BridgeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ClientInvokeUnary",
			Handler:    _BridgeService_ClientInvokeUnary_Handler,
		},
		{
			MethodName: "CreateClientStream",
			Handler:    _BridgeService_CreateClientStream_Handler,
		},
		{
			MethodName: "ClientStreamSend",
			Handler:    _BridgeService_ClientStreamSend_Handler,
		},
		{
			MethodName: "ClientStreamRecv",
			Handler:    _BridgeService_ClientStreamRecv_Handler,
		},
		{
			MethodName: "ClientStreamClose",
			Handler:    _BridgeService_ClientStreamClose_Handler,
		},
		{
			MethodName: "ClientStreamCloseAndRecv",
			Handler:    _BridgeService_ClientStreamCloseAndRecv_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "bertybridge/bertybridge.proto",
}

BridgeService_ServiceDesc is the grpc.ServiceDesc for BridgeService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

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 RegisterBridgeServiceHandler added in v2.455.0 

func RegisterBridgeServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterBridgeServiceHandler registers the http handlers for service BridgeService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterBridgeServiceHandlerClient added in v2.455.0 

func RegisterBridgeServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BridgeServiceClient) error

RegisterBridgeServiceHandlerClient registers the http handlers for service BridgeService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "BridgeServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "BridgeServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "BridgeServiceClient" to call the correct interceptors.

func RegisterBridgeServiceHandlerFromEndpoint added in v2.455.0 

func RegisterBridgeServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterBridgeServiceHandlerFromEndpoint is same as RegisterBridgeServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterBridgeServiceHandlerServer added in v2.455.0 

func RegisterBridgeServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BridgeServiceServer) error

RegisterBridgeServiceHandlerServer registers the http handlers for service BridgeService to "mux". UnaryRPC :call BridgeServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterBridgeServiceHandlerFromEndpoint instead.

func RegisterBridgeServiceServer 

func RegisterBridgeServiceServer(s grpc.ServiceRegistrar, 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewBridgeServiceClient 

func NewBridgeServiceClient(cc grpc.ClientConnInterface) 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)
	// contains filtered or unexported methods
}

BridgeServiceServer is the server API for BridgeService service. All implementations must embed UnimplementedBridgeServiceServer for forward compatibility

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) Marshal added in v2.256.1 

func (m *ClientCreateStream) Marshal() (dAtA []byte, err error)

func (*ClientCreateStream) MarshalTo added in v2.256.1 

func (m *ClientCreateStream) MarshalTo(dAtA []byte) (int, error)

func (*ClientCreateStream) MarshalToSizedBuffer added in v2.256.1 

func (m *ClientCreateStream) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientCreateStream) ProtoMessage 

func (*ClientCreateStream) ProtoMessage()

func (*ClientCreateStream) Reset 

func (m *ClientCreateStream) Reset()

func (*ClientCreateStream) Size added in v2.256.1 

func (m *ClientCreateStream) Size() (n int)

func (*ClientCreateStream) String 

func (m *ClientCreateStream) String() string

func (*ClientCreateStream) Unmarshal added in v2.256.1 

func (m *ClientCreateStream) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *ClientCreateStream_Reply) Marshal() (dAtA []byte, err error)

func (*ClientCreateStream_Reply) MarshalTo added in v2.256.1 

func (m *ClientCreateStream_Reply) MarshalTo(dAtA []byte) (int, error)

func (*ClientCreateStream_Reply) MarshalToSizedBuffer added in v2.256.1 

func (m *ClientCreateStream_Reply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientCreateStream_Reply) ProtoMessage 

func (*ClientCreateStream_Reply) ProtoMessage()

func (*ClientCreateStream_Reply) Reset 

func (m *ClientCreateStream_Reply) Reset()

func (*ClientCreateStream_Reply) Size added in v2.256.1 

func (m *ClientCreateStream_Reply) Size() (n int)

func (*ClientCreateStream_Reply) String 

func (m *ClientCreateStream_Reply) String() string

func (*ClientCreateStream_Reply) Unmarshal added in v2.256.1 

func (m *ClientCreateStream_Reply) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *ClientCreateStream_Request) Marshal() (dAtA []byte, err error)

func (*ClientCreateStream_Request) MarshalTo added in v2.256.1 

func (m *ClientCreateStream_Request) MarshalTo(dAtA []byte) (int, error)

func (*ClientCreateStream_Request) MarshalToSizedBuffer added in v2.256.1 

func (m *ClientCreateStream_Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientCreateStream_Request) ProtoMessage 

func (*ClientCreateStream_Request) ProtoMessage()

func (*ClientCreateStream_Request) Reset 

func (m *ClientCreateStream_Request) Reset()

func (*ClientCreateStream_Request) Size added in v2.256.1 

func (m *ClientCreateStream_Request) Size() (n int)

func (*ClientCreateStream_Request) String 

func (m *ClientCreateStream_Request) String() string

func (*ClientCreateStream_Request) Unmarshal added in v2.256.1 

func (m *ClientCreateStream_Request) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *ClientInvokeUnary) Marshal() (dAtA []byte, err error)

func (*ClientInvokeUnary) MarshalTo added in v2.256.1 

func (m *ClientInvokeUnary) MarshalTo(dAtA []byte) (int, error)

func (*ClientInvokeUnary) MarshalToSizedBuffer added in v2.256.1 

func (m *ClientInvokeUnary) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientInvokeUnary) ProtoMessage 

func (*ClientInvokeUnary) ProtoMessage()

func (*ClientInvokeUnary) Reset 

func (m *ClientInvokeUnary) Reset()

func (*ClientInvokeUnary) Size added in v2.256.1 

func (m *ClientInvokeUnary) Size() (n int)

func (*ClientInvokeUnary) String 

func (m *ClientInvokeUnary) String() string

func (*ClientInvokeUnary) Unmarshal added in v2.256.1 

func (m *ClientInvokeUnary) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *ClientInvokeUnary_Reply) Marshal() (dAtA []byte, err error)

func (*ClientInvokeUnary_Reply) MarshalTo added in v2.256.1 

func (m *ClientInvokeUnary_Reply) MarshalTo(dAtA []byte) (int, error)

func (*ClientInvokeUnary_Reply) MarshalToSizedBuffer added in v2.256.1 

func (m *ClientInvokeUnary_Reply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientInvokeUnary_Reply) ProtoMessage 

func (*ClientInvokeUnary_Reply) ProtoMessage()

func (*ClientInvokeUnary_Reply) Reset 

func (m *ClientInvokeUnary_Reply) Reset()

func (*ClientInvokeUnary_Reply) Size added in v2.256.1 

func (m *ClientInvokeUnary_Reply) Size() (n int)

func (*ClientInvokeUnary_Reply) String 

func (m *ClientInvokeUnary_Reply) String() string

func (*ClientInvokeUnary_Reply) Unmarshal added in v2.256.1 

func (m *ClientInvokeUnary_Reply) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *ClientInvokeUnary_Request) Marshal() (dAtA []byte, err error)

func (*ClientInvokeUnary_Request) MarshalTo added in v2.256.1 

func (m *ClientInvokeUnary_Request) MarshalTo(dAtA []byte) (int, error)

func (*ClientInvokeUnary_Request) MarshalToSizedBuffer added in v2.256.1 

func (m *ClientInvokeUnary_Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientInvokeUnary_Request) ProtoMessage 

func (*ClientInvokeUnary_Request) ProtoMessage()

func (*ClientInvokeUnary_Request) Reset 

func (m *ClientInvokeUnary_Request) Reset()

func (*ClientInvokeUnary_Request) Size added in v2.256.1 

func (m *ClientInvokeUnary_Request) Size() (n int)

func (*ClientInvokeUnary_Request) String 

func (m *ClientInvokeUnary_Request) String() string

func (*ClientInvokeUnary_Request) Unmarshal added in v2.256.1 

func (m *ClientInvokeUnary_Request) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *ClientStreamClose) Marshal() (dAtA []byte, err error)

func (*ClientStreamClose) MarshalTo added in v2.256.1 

func (m *ClientStreamClose) MarshalTo(dAtA []byte) (int, error)

func (*ClientStreamClose) MarshalToSizedBuffer added in v2.256.1 

func (m *ClientStreamClose) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientStreamClose) ProtoMessage 

func (*ClientStreamClose) ProtoMessage()

func (*ClientStreamClose) Reset 

func (m *ClientStreamClose) Reset()

func (*ClientStreamClose) Size added in v2.256.1 

func (m *ClientStreamClose) Size() (n int)

func (*ClientStreamClose) String 

func (m *ClientStreamClose) String() string

func (*ClientStreamClose) Unmarshal added in v2.256.1 

func (m *ClientStreamClose) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *ClientStreamCloseAndRecv) Marshal() (dAtA []byte, err error)

func (*ClientStreamCloseAndRecv) MarshalTo added in v2.256.1 

func (m *ClientStreamCloseAndRecv) MarshalTo(dAtA []byte) (int, error)

func (*ClientStreamCloseAndRecv) MarshalToSizedBuffer added in v2.256.1 

func (m *ClientStreamCloseAndRecv) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientStreamCloseAndRecv) ProtoMessage 

func (*ClientStreamCloseAndRecv) ProtoMessage()

func (*ClientStreamCloseAndRecv) Reset 

func (m *ClientStreamCloseAndRecv) Reset()

func (*ClientStreamCloseAndRecv) Size added in v2.256.1 

func (m *ClientStreamCloseAndRecv) Size() (n int)

func (*ClientStreamCloseAndRecv) String 

func (m *ClientStreamCloseAndRecv) String() string

func (*ClientStreamCloseAndRecv) Unmarshal added in v2.256.1 

func (m *ClientStreamCloseAndRecv) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *ClientStreamCloseAndRecv_Reply) Marshal() (dAtA []byte, err error)

func (*ClientStreamCloseAndRecv_Reply) MarshalTo added in v2.256.1 

func (m *ClientStreamCloseAndRecv_Reply) MarshalTo(dAtA []byte) (int, error)

func (*ClientStreamCloseAndRecv_Reply) MarshalToSizedBuffer added in v2.256.1 

func (m *ClientStreamCloseAndRecv_Reply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientStreamCloseAndRecv_Reply) ProtoMessage 

func (*ClientStreamCloseAndRecv_Reply) ProtoMessage()

func (*ClientStreamCloseAndRecv_Reply) Reset 

func (m *ClientStreamCloseAndRecv_Reply) Reset()

func (*ClientStreamCloseAndRecv_Reply) Size added in v2.256.1 

func (m *ClientStreamCloseAndRecv_Reply) Size() (n int)

func (*ClientStreamCloseAndRecv_Reply) String 

func (m *ClientStreamCloseAndRecv_Reply) String() string

func (*ClientStreamCloseAndRecv_Reply) Unmarshal added in v2.256.1 

func (m *ClientStreamCloseAndRecv_Reply) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *ClientStreamCloseAndRecv_Request) Marshal() (dAtA []byte, err error)

func (*ClientStreamCloseAndRecv_Request) MarshalTo added in v2.256.1 

func (m *ClientStreamCloseAndRecv_Request) MarshalTo(dAtA []byte) (int, error)

func (*ClientStreamCloseAndRecv_Request) MarshalToSizedBuffer added in v2.256.1 

func (m *ClientStreamCloseAndRecv_Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientStreamCloseAndRecv_Request) ProtoMessage 

func (*ClientStreamCloseAndRecv_Request) ProtoMessage()

func (*ClientStreamCloseAndRecv_Request) Reset 

func (m *ClientStreamCloseAndRecv_Request) Reset()

func (*ClientStreamCloseAndRecv_Request) Size added in v2.256.1 

func (m *ClientStreamCloseAndRecv_Request) Size() (n int)

func (*ClientStreamCloseAndRecv_Request) String 

func (m *ClientStreamCloseAndRecv_Request) String() string

func (*ClientStreamCloseAndRecv_Request) Unmarshal added in v2.256.1 

func (m *ClientStreamCloseAndRecv_Request) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *ClientStreamClose_Reply) Marshal() (dAtA []byte, err error)

func (*ClientStreamClose_Reply) MarshalTo added in v2.256.1 

func (m *ClientStreamClose_Reply) MarshalTo(dAtA []byte) (int, error)

func (*ClientStreamClose_Reply) MarshalToSizedBuffer added in v2.256.1 

func (m *ClientStreamClose_Reply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientStreamClose_Reply) ProtoMessage 

func (*ClientStreamClose_Reply) ProtoMessage()

func (*ClientStreamClose_Reply) Reset 

func (m *ClientStreamClose_Reply) Reset()

func (*ClientStreamClose_Reply) Size added in v2.256.1 

func (m *ClientStreamClose_Reply) Size() (n int)

func (*ClientStreamClose_Reply) String 

func (m *ClientStreamClose_Reply) String() string

func (*ClientStreamClose_Reply) Unmarshal added in v2.256.1 

func (m *ClientStreamClose_Reply) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *ClientStreamClose_Request) Marshal() (dAtA []byte, err error)

func (*ClientStreamClose_Request) MarshalTo added in v2.256.1 

func (m *ClientStreamClose_Request) MarshalTo(dAtA []byte) (int, error)

func (*ClientStreamClose_Request) MarshalToSizedBuffer added in v2.256.1 

func (m *ClientStreamClose_Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientStreamClose_Request) ProtoMessage 

func (*ClientStreamClose_Request) ProtoMessage()

func (*ClientStreamClose_Request) Reset 

func (m *ClientStreamClose_Request) Reset()

func (*ClientStreamClose_Request) Size added in v2.256.1 

func (m *ClientStreamClose_Request) Size() (n int)

func (*ClientStreamClose_Request) String 

func (m *ClientStreamClose_Request) String() string

func (*ClientStreamClose_Request) Unmarshal added in v2.256.1 

func (m *ClientStreamClose_Request) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *ClientStreamRecv) Marshal() (dAtA []byte, err error)

func (*ClientStreamRecv) MarshalTo added in v2.256.1 

func (m *ClientStreamRecv) MarshalTo(dAtA []byte) (int, error)

func (*ClientStreamRecv) MarshalToSizedBuffer added in v2.256.1 

func (m *ClientStreamRecv) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientStreamRecv) ProtoMessage 

func (*ClientStreamRecv) ProtoMessage()

func (*ClientStreamRecv) Reset 

func (m *ClientStreamRecv) Reset()

func (*ClientStreamRecv) Size added in v2.256.1 

func (m *ClientStreamRecv) Size() (n int)

func (*ClientStreamRecv) String 

func (m *ClientStreamRecv) String() string

func (*ClientStreamRecv) Unmarshal added in v2.256.1 

func (m *ClientStreamRecv) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *ClientStreamRecv_Reply) Marshal() (dAtA []byte, err error)

func (*ClientStreamRecv_Reply) MarshalTo added in v2.256.1 

func (m *ClientStreamRecv_Reply) MarshalTo(dAtA []byte) (int, error)

func (*ClientStreamRecv_Reply) MarshalToSizedBuffer added in v2.256.1 

func (m *ClientStreamRecv_Reply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientStreamRecv_Reply) ProtoMessage 

func (*ClientStreamRecv_Reply) ProtoMessage()

func (*ClientStreamRecv_Reply) Reset 

func (m *ClientStreamRecv_Reply) Reset()

func (*ClientStreamRecv_Reply) Size added in v2.256.1 

func (m *ClientStreamRecv_Reply) Size() (n int)

func (*ClientStreamRecv_Reply) String 

func (m *ClientStreamRecv_Reply) String() string

func (*ClientStreamRecv_Reply) Unmarshal added in v2.256.1 

func (m *ClientStreamRecv_Reply) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *ClientStreamRecv_Request) Marshal() (dAtA []byte, err error)

func (*ClientStreamRecv_Request) MarshalTo added in v2.256.1 

func (m *ClientStreamRecv_Request) MarshalTo(dAtA []byte) (int, error)

func (*ClientStreamRecv_Request) MarshalToSizedBuffer added in v2.256.1 

func (m *ClientStreamRecv_Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientStreamRecv_Request) ProtoMessage 

func (*ClientStreamRecv_Request) ProtoMessage()

func (*ClientStreamRecv_Request) Reset 

func (m *ClientStreamRecv_Request) Reset()

func (*ClientStreamRecv_Request) Size added in v2.256.1 

func (m *ClientStreamRecv_Request) Size() (n int)

func (*ClientStreamRecv_Request) String 

func (m *ClientStreamRecv_Request) String() string

func (*ClientStreamRecv_Request) Unmarshal added in v2.256.1 

func (m *ClientStreamRecv_Request) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *ClientStreamSend) Marshal() (dAtA []byte, err error)

func (*ClientStreamSend) MarshalTo added in v2.256.1 

func (m *ClientStreamSend) MarshalTo(dAtA []byte) (int, error)

func (*ClientStreamSend) MarshalToSizedBuffer added in v2.256.1 

func (m *ClientStreamSend) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientStreamSend) ProtoMessage 

func (*ClientStreamSend) ProtoMessage()

func (*ClientStreamSend) Reset 

func (m *ClientStreamSend) Reset()

func (*ClientStreamSend) Size added in v2.256.1 

func (m *ClientStreamSend) Size() (n int)

func (*ClientStreamSend) String 

func (m *ClientStreamSend) String() string

func (*ClientStreamSend) Unmarshal added in v2.256.1 

func (m *ClientStreamSend) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *ClientStreamSend_Reply) Marshal() (dAtA []byte, err error)

func (*ClientStreamSend_Reply) MarshalTo added in v2.256.1 

func (m *ClientStreamSend_Reply) MarshalTo(dAtA []byte) (int, error)

func (*ClientStreamSend_Reply) MarshalToSizedBuffer added in v2.256.1 

func (m *ClientStreamSend_Reply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientStreamSend_Reply) ProtoMessage 

func (*ClientStreamSend_Reply) ProtoMessage()

func (*ClientStreamSend_Reply) Reset 

func (m *ClientStreamSend_Reply) Reset()

func (*ClientStreamSend_Reply) Size added in v2.256.1 

func (m *ClientStreamSend_Reply) Size() (n int)

func (*ClientStreamSend_Reply) String 

func (m *ClientStreamSend_Reply) String() string

func (*ClientStreamSend_Reply) Unmarshal added in v2.256.1 

func (m *ClientStreamSend_Reply) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *ClientStreamSend_Request) Marshal() (dAtA []byte, err error)

func (*ClientStreamSend_Request) MarshalTo added in v2.256.1 

func (m *ClientStreamSend_Request) MarshalTo(dAtA []byte) (int, error)

func (*ClientStreamSend_Request) MarshalToSizedBuffer added in v2.256.1 

func (m *ClientStreamSend_Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientStreamSend_Request) ProtoMessage 

func (*ClientStreamSend_Request) ProtoMessage()

func (*ClientStreamSend_Request) Reset 

func (m *ClientStreamSend_Request) Reset()

func (*ClientStreamSend_Request) Size added in v2.256.1 

func (m *ClientStreamSend_Request) Size() (n int)

func (*ClientStreamSend_Request) String 

func (m *ClientStreamSend_Request) String() string

func (*ClientStreamSend_Request) Unmarshal added in v2.256.1 

func (m *ClientStreamSend_Request) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *Error) Marshal() (dAtA []byte, err error)

func (*Error) MarshalTo added in v2.256.1 

func (m *Error) MarshalTo(dAtA []byte) (int, error)

func (*Error) MarshalToSizedBuffer added in v2.256.1 

func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size added in v2.256.1 

func (m *Error) Size() (n int)

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal added in v2.256.1 

func (m *Error) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *Metadata) Marshal() (dAtA []byte, err error)

func (*Metadata) MarshalTo added in v2.256.1 

func (m *Metadata) MarshalTo(dAtA []byte) (int, error)

func (*Metadata) MarshalToSizedBuffer added in v2.256.1 

func (m *Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) Size added in v2.256.1 

func (m *Metadata) Size() (n int)

func (*Metadata) String 

func (m *Metadata) String() string

func (*Metadata) Unmarshal added in v2.256.1 

func (m *Metadata) Unmarshal(dAtA []byte) error

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) Marshal added in v2.256.1 

func (m *MethodDesc) Marshal() (dAtA []byte, err error)

func (*MethodDesc) MarshalTo added in v2.256.1 

func (m *MethodDesc) MarshalTo(dAtA []byte) (int, error)

func (*MethodDesc) MarshalToSizedBuffer added in v2.256.1 

func (m *MethodDesc) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MethodDesc) ProtoMessage 

func (*MethodDesc) ProtoMessage()

func (*MethodDesc) Reset 

func (m *MethodDesc) Reset()

func (*MethodDesc) Size added in v2.256.1 

func (m *MethodDesc) Size() (n int)

func (*MethodDesc) String 

func (m *MethodDesc) String() string

func (*MethodDesc) Unmarshal added in v2.256.1 

func (m *MethodDesc) Unmarshal(dAtA []byte) error

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 must be embedded to have forward compatible implementations.

func (UnimplementedBridgeServiceServer) ClientInvokeUnary 

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

func (UnimplementedBridgeServiceServer) ClientStreamClose 

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

func (UnimplementedBridgeServiceServer) ClientStreamCloseAndRecv 

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

func (UnimplementedBridgeServiceServer) ClientStreamRecv 

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

func (UnimplementedBridgeServiceServer) ClientStreamSend 

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

func (UnimplementedBridgeServiceServer) CreateClientStream 

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

type UnsafeBridgeServiceServer added in v2.455.0 

type UnsafeBridgeServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeBridgeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BridgeServiceServer will result in compilation errors.

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.