e2

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Dec 15, 2020 License: Apache-2.0 Imports: 13 Imported by: 3

Documentation

Overview

Package e2 is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthE2        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowE2          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupE2 = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var EncodingType_name = map[int32]string{
	0: "PROTO",
	1: "ASN1_PER",
	2: "ASN1_XER",
}
View Source 
var EncodingType_value = map[string]int32{
	"PROTO":    0,
	"ASN1_PER": 1,
	"ASN1_XER": 2,
}
View Source 
var ResponseStatus_name = map[int32]string{
	0: "FAILED",
	1: "SUCCEEDED",
}
View Source 
var ResponseStatus_value = map[string]int32{
	"FAILED":    0,
	"SUCCEEDED": 1,
}

Functions

func RegisterE2TServiceServer 

func RegisterE2TServiceServer(s *grpc.Server, srv E2TServiceServer)

Types

type AppID 

type AppID string

AppID is an application identifier

type E2TServiceClient 

type E2TServiceClient interface {
	// Stream opens an indications stream
	Stream(ctx context.Context, opts ...grpc.CallOption) (E2TService_StreamClient, error)
}

E2TServiceClient is the client API for E2TService service.

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

func NewE2TServiceClient 

func NewE2TServiceClient(cc *grpc.ClientConn) E2TServiceClient

type E2TServiceServer 

type E2TServiceServer interface {
	// Stream opens an indications stream
	Stream(E2TService_StreamServer) error
}

E2TServiceServer is the server API for E2TService service.

type E2TService_StreamClient 

type E2TService_StreamClient interface {
	Send(*StreamRequest) error
	Recv() (*StreamResponse, error)
	grpc.ClientStream
}

type E2TService_StreamServer 

type E2TService_StreamServer interface {
	Send(*StreamResponse) error
	Recv() (*StreamRequest, error)
	grpc.ServerStream
}

type EncodingType 

type EncodingType int32

EncodingType determines encoding type for the response messages 

const (
	EncodingType_PROTO    EncodingType = 0
	EncodingType_ASN1_PER EncodingType = 1
	EncodingType_ASN1_XER EncodingType = 2
)

func (EncodingType) EnumDescriptor 

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

func (EncodingType) String 

func (x EncodingType) String() string

type InstanceID 

type InstanceID string

InstanceID is an application instance identifier

type MockE2TServiceClient added in v0.6.11 

type MockE2TServiceClient struct {
	// contains filtered or unexported fields
}

MockE2TServiceClient is a mock of E2TServiceClient interface

func NewMockE2TServiceClient added in v0.6.11 

func NewMockE2TServiceClient(ctrl *gomock.Controller) *MockE2TServiceClient

NewMockE2TServiceClient creates a new mock instance

func (*MockE2TServiceClient) EXPECT added in v0.6.11 

func (m *MockE2TServiceClient) EXPECT() *MockE2TServiceClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockE2TServiceClient) Stream added in v0.6.11 

func (m *MockE2TServiceClient) Stream(ctx context.Context, opts ...grpc.CallOption) (E2TService_StreamClient, error)

Stream mocks base method

type MockE2TServiceClientMockRecorder added in v0.6.11 

type MockE2TServiceClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockE2TServiceClientMockRecorder is the mock recorder for MockE2TServiceClient

func (*MockE2TServiceClientMockRecorder) Stream added in v0.6.11 

func (mr *MockE2TServiceClientMockRecorder) Stream(ctx interface{}, opts ...interface{}) *gomock.Call

Stream indicates an expected call of Stream

type MockE2TServiceServer added in v0.6.11 

type MockE2TServiceServer struct {
	// contains filtered or unexported fields
}

MockE2TServiceServer is a mock of E2TServiceServer interface

func NewMockE2TServiceServer added in v0.6.11 

func NewMockE2TServiceServer(ctrl *gomock.Controller) *MockE2TServiceServer

NewMockE2TServiceServer creates a new mock instance

func (*MockE2TServiceServer) EXPECT added in v0.6.11 

func (m *MockE2TServiceServer) EXPECT() *MockE2TServiceServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockE2TServiceServer) Stream added in v0.6.11 

func (m *MockE2TServiceServer) Stream(arg0 E2TService_StreamServer) error

Stream mocks base method

type MockE2TServiceServerMockRecorder added in v0.6.11 

type MockE2TServiceServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockE2TServiceServerMockRecorder is the mock recorder for MockE2TServiceServer

func (*MockE2TServiceServerMockRecorder) Stream added in v0.6.11 

func (mr *MockE2TServiceServerMockRecorder) Stream(arg0 interface{}) *gomock.Call

Stream indicates an expected call of Stream

type MockE2TService_StreamClient added in v0.6.11 

type MockE2TService_StreamClient struct {
	// contains filtered or unexported fields
}

MockE2TService_StreamClient is a mock of E2TService_StreamClient interface

func NewMockE2TService_StreamClient added in v0.6.11 

func NewMockE2TService_StreamClient(ctrl *gomock.Controller) *MockE2TService_StreamClient

NewMockE2TService_StreamClient creates a new mock instance

func (*MockE2TService_StreamClient) CloseSend added in v0.6.11 

func (m *MockE2TService_StreamClient) CloseSend() error

CloseSend mocks base method

func (*MockE2TService_StreamClient) Context added in v0.6.11 

func (m *MockE2TService_StreamClient) Context() context.Context

Context mocks base method

func (*MockE2TService_StreamClient) EXPECT added in v0.6.11 

func (m *MockE2TService_StreamClient) EXPECT() *MockE2TService_StreamClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockE2TService_StreamClient) Header added in v0.6.11 

func (m *MockE2TService_StreamClient) Header() (metadata.MD, error)

Header mocks base method

func (*MockE2TService_StreamClient) Recv added in v0.6.11 

func (m *MockE2TService_StreamClient) Recv() (*StreamResponse, error)

Recv mocks base method

func (*MockE2TService_StreamClient) RecvMsg added in v0.6.11 

func (m_2 *MockE2TService_StreamClient) RecvMsg(m interface{}) error

RecvMsg mocks base method

func (*MockE2TService_StreamClient) Send added in v0.6.11 

func (m *MockE2TService_StreamClient) Send(arg0 *StreamRequest) error

Send mocks base method

func (*MockE2TService_StreamClient) SendMsg added in v0.6.11 

func (m_2 *MockE2TService_StreamClient) SendMsg(m interface{}) error

SendMsg mocks base method

func (*MockE2TService_StreamClient) Trailer added in v0.6.11 

func (m *MockE2TService_StreamClient) Trailer() metadata.MD

Trailer mocks base method

type MockE2TService_StreamClientMockRecorder added in v0.6.11 

type MockE2TService_StreamClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockE2TService_StreamClientMockRecorder is the mock recorder for MockE2TService_StreamClient

func (*MockE2TService_StreamClientMockRecorder) CloseSend added in v0.6.11 

func (mr *MockE2TService_StreamClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend

func (*MockE2TService_StreamClientMockRecorder) Context added in v0.6.11 

func (mr *MockE2TService_StreamClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockE2TService_StreamClientMockRecorder) Header added in v0.6.11 

func (mr *MockE2TService_StreamClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header

func (*MockE2TService_StreamClientMockRecorder) Recv added in v0.6.11 

func (mr *MockE2TService_StreamClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv

func (*MockE2TService_StreamClientMockRecorder) RecvMsg added in v0.6.11 

func (mr *MockE2TService_StreamClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg

func (*MockE2TService_StreamClientMockRecorder) Send added in v0.6.11 

func (mr *MockE2TService_StreamClientMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send

func (*MockE2TService_StreamClientMockRecorder) SendMsg added in v0.6.11 

func (mr *MockE2TService_StreamClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg

func (*MockE2TService_StreamClientMockRecorder) Trailer added in v0.6.11 

func (mr *MockE2TService_StreamClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer

type MockE2TService_StreamServer added in v0.6.11 

type MockE2TService_StreamServer struct {
	// contains filtered or unexported fields
}

MockE2TService_StreamServer is a mock of E2TService_StreamServer interface

func NewMockE2TService_StreamServer added in v0.6.11 

func NewMockE2TService_StreamServer(ctrl *gomock.Controller) *MockE2TService_StreamServer

NewMockE2TService_StreamServer creates a new mock instance

func (*MockE2TService_StreamServer) Context added in v0.6.11 

func (m *MockE2TService_StreamServer) Context() context.Context

Context mocks base method

func (*MockE2TService_StreamServer) EXPECT added in v0.6.11 

func (m *MockE2TService_StreamServer) EXPECT() *MockE2TService_StreamServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockE2TService_StreamServer) Recv added in v0.6.11 

func (m *MockE2TService_StreamServer) Recv() (*StreamRequest, error)

Recv mocks base method

func (*MockE2TService_StreamServer) RecvMsg added in v0.6.11 

func (m_2 *MockE2TService_StreamServer) RecvMsg(m interface{}) error

RecvMsg mocks base method

func (*MockE2TService_StreamServer) Send added in v0.6.11 

func (m *MockE2TService_StreamServer) Send(arg0 *StreamResponse) error

Send mocks base method

func (*MockE2TService_StreamServer) SendHeader added in v0.6.11 

func (m *MockE2TService_StreamServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method

func (*MockE2TService_StreamServer) SendMsg added in v0.6.11 

func (m_2 *MockE2TService_StreamServer) SendMsg(m interface{}) error

SendMsg mocks base method

func (*MockE2TService_StreamServer) SetHeader added in v0.6.11 

func (m *MockE2TService_StreamServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method

func (*MockE2TService_StreamServer) SetTrailer added in v0.6.11 

func (m *MockE2TService_StreamServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method

type MockE2TService_StreamServerMockRecorder added in v0.6.11 

type MockE2TService_StreamServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockE2TService_StreamServerMockRecorder is the mock recorder for MockE2TService_StreamServer

func (*MockE2TService_StreamServerMockRecorder) Context added in v0.6.11 

func (mr *MockE2TService_StreamServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockE2TService_StreamServerMockRecorder) Recv added in v0.6.11 

func (mr *MockE2TService_StreamServerMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv

func (*MockE2TService_StreamServerMockRecorder) RecvMsg added in v0.6.11 

func (mr *MockE2TService_StreamServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg

func (*MockE2TService_StreamServerMockRecorder) Send added in v0.6.11 

func (mr *MockE2TService_StreamServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send

func (*MockE2TService_StreamServerMockRecorder) SendHeader added in v0.6.11 

func (mr *MockE2TService_StreamServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader

func (*MockE2TService_StreamServerMockRecorder) SendMsg added in v0.6.11 

func (mr *MockE2TService_StreamServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg

func (*MockE2TService_StreamServerMockRecorder) SetHeader added in v0.6.11 

func (mr *MockE2TService_StreamServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader

func (*MockE2TService_StreamServerMockRecorder) SetTrailer added in v0.6.11 

func (mr *MockE2TService_StreamServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer

type RequestHeader 

type RequestHeader struct {
	EncodingType     EncodingType      `` /* 128-byte string literal not displayed */
	ServiceModelInfo *ServiceModelInfo `protobuf:"bytes,2,opt,name=service_model_info,json=serviceModelInfo,proto3" json:"service_model_info,omitempty"`
}

RequestHeader a common request header for all requests including encoding type, client/xApp/session info, ordering info, etc

func (*RequestHeader) Descriptor 

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

func (*RequestHeader) GetEncodingType 

func (m *RequestHeader) GetEncodingType() EncodingType

func (*RequestHeader) GetServiceModelInfo 

func (m *RequestHeader) GetServiceModelInfo() *ServiceModelInfo

func (*RequestHeader) Marshal 

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

func (*RequestHeader) MarshalTo 

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

func (*RequestHeader) MarshalToSizedBuffer 

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

func (*RequestHeader) ProtoMessage 

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) Reset 

func (m *RequestHeader) Reset()

func (*RequestHeader) Size 

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

func (*RequestHeader) String 

func (m *RequestHeader) String() string

func (*RequestHeader) Unmarshal 

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

func (*RequestHeader) XXX_DiscardUnknown 

func (m *RequestHeader) XXX_DiscardUnknown()

func (*RequestHeader) XXX_Marshal 

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

func (*RequestHeader) XXX_Merge 

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

func (*RequestHeader) XXX_Size 

func (m *RequestHeader) XXX_Size() int

func (*RequestHeader) XXX_Unmarshal 

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

type ResponseHeader 

type ResponseHeader struct {
	EncodingType     EncodingType      `` /* 128-byte string literal not displayed */
	ServiceModelInfo *ServiceModelInfo `protobuf:"bytes,2,opt,name=service_model_info,json=serviceModelInfo,proto3" json:"service_model_info,omitempty"`
	ResponseStatus   ResponseStatus    `` /* 136-byte string literal not displayed */
	IndicationHeader []byte            `protobuf:"bytes,4,opt,name=indication_header,json=indicationHeader,proto3" json:"indication_header,omitempty"`
}

ResponseHeader a common response header for all responses including encoding type, client/xApp/session info, ordering info, etc

func (*ResponseHeader) Descriptor 

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

func (*ResponseHeader) GetEncodingType 

func (m *ResponseHeader) GetEncodingType() EncodingType

func (*ResponseHeader) GetIndicationHeader added in v0.6.8 

func (m *ResponseHeader) GetIndicationHeader() []byte

func (*ResponseHeader) GetResponseStatus 

func (m *ResponseHeader) GetResponseStatus() ResponseStatus

func (*ResponseHeader) GetServiceModelInfo 

func (m *ResponseHeader) GetServiceModelInfo() *ServiceModelInfo

func (*ResponseHeader) Marshal 

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

func (*ResponseHeader) MarshalTo 

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

func (*ResponseHeader) MarshalToSizedBuffer 

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

func (*ResponseHeader) ProtoMessage 

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) Reset 

func (m *ResponseHeader) Reset()

func (*ResponseHeader) Size 

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

func (*ResponseHeader) String 

func (m *ResponseHeader) String() string

func (*ResponseHeader) Unmarshal 

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

func (*ResponseHeader) XXX_DiscardUnknown 

func (m *ResponseHeader) XXX_DiscardUnknown()

func (*ResponseHeader) XXX_Marshal 

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

func (*ResponseHeader) XXX_Merge 

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

func (*ResponseHeader) XXX_Size 

func (m *ResponseHeader) XXX_Size() int

func (*ResponseHeader) XXX_Unmarshal 

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

type ResponseStatus 

type ResponseStatus int32

ResponseStatus 

const (
	ResponseStatus_FAILED    ResponseStatus = 0
	ResponseStatus_SUCCEEDED ResponseStatus = 1
)

func (ResponseStatus) EnumDescriptor 

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

func (ResponseStatus) String 

func (x ResponseStatus) String() string

type ServiceModelInfo 

type ServiceModelInfo struct {
	ServiceModelId string `protobuf:"bytes,1,opt,name=service_model_id,json=serviceModelId,proto3" json:"service_model_id,omitempty"`
}

ServiceModelInfo E2 service model information

func (*ServiceModelInfo) Descriptor 

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

func (*ServiceModelInfo) GetServiceModelId 

func (m *ServiceModelInfo) GetServiceModelId() string

func (*ServiceModelInfo) Marshal 

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

func (*ServiceModelInfo) MarshalTo 

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

func (*ServiceModelInfo) MarshalToSizedBuffer 

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

func (*ServiceModelInfo) ProtoMessage 

func (*ServiceModelInfo) ProtoMessage()

func (*ServiceModelInfo) Reset 

func (m *ServiceModelInfo) Reset()

func (*ServiceModelInfo) Size 

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

func (*ServiceModelInfo) String 

func (m *ServiceModelInfo) String() string

func (*ServiceModelInfo) Unmarshal 

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

func (*ServiceModelInfo) XXX_DiscardUnknown 

func (m *ServiceModelInfo) XXX_DiscardUnknown()

func (*ServiceModelInfo) XXX_Marshal 

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

func (*ServiceModelInfo) XXX_Merge 

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

func (*ServiceModelInfo) XXX_Size 

func (m *ServiceModelInfo) XXX_Size() int

func (*ServiceModelInfo) XXX_Unmarshal 

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

type StreamRequest 

type StreamRequest struct {
	Header         *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	AppID          AppID          `protobuf:"bytes,2,opt,name=app_id,json=appId,proto3,casttype=AppID" json:"app_id,omitempty"`
	InstanceID     InstanceID     `protobuf:"bytes,3,opt,name=instance_id,json=instanceId,proto3,casttype=InstanceID" json:"instance_id,omitempty"`
	SubscriptionID SubscriptionID `` /* 127-byte string literal not displayed */
}

StreamRequest

func (*StreamRequest) Descriptor 

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

func (*StreamRequest) GetAppID 

func (m *StreamRequest) GetAppID() AppID

func (*StreamRequest) GetHeader 

func (m *StreamRequest) GetHeader() *RequestHeader

func (*StreamRequest) GetInstanceID 

func (m *StreamRequest) GetInstanceID() InstanceID

func (*StreamRequest) GetSubscriptionID 

func (m *StreamRequest) GetSubscriptionID() SubscriptionID

func (*StreamRequest) Marshal 

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

func (*StreamRequest) MarshalTo 

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

func (*StreamRequest) MarshalToSizedBuffer 

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

func (*StreamRequest) ProtoMessage 

func (*StreamRequest) ProtoMessage()

func (*StreamRequest) Reset 

func (m *StreamRequest) Reset()

func (*StreamRequest) Size 

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

func (*StreamRequest) String 

func (m *StreamRequest) String() string

func (*StreamRequest) Unmarshal 

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

func (*StreamRequest) XXX_DiscardUnknown 

func (m *StreamRequest) XXX_DiscardUnknown()

func (*StreamRequest) XXX_Marshal 

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

func (*StreamRequest) XXX_Merge 

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

func (*StreamRequest) XXX_Size 

func (m *StreamRequest) XXX_Size() int

func (*StreamRequest) XXX_Unmarshal 

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

type StreamResponse 

type StreamResponse struct {
	Header            *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	IndicationMessage []byte          `protobuf:"bytes,2,opt,name=indication_message,json=indicationMessage,proto3" json:"indication_message,omitempty"`
}

StreamResponse

func (*StreamResponse) Descriptor 

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

func (*StreamResponse) GetHeader 

func (m *StreamResponse) GetHeader() *ResponseHeader

func (*StreamResponse) GetIndicationMessage added in v0.6.8 

func (m *StreamResponse) GetIndicationMessage() []byte

func (*StreamResponse) Marshal 

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

func (*StreamResponse) MarshalTo 

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

func (*StreamResponse) MarshalToSizedBuffer 

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

func (*StreamResponse) ProtoMessage 

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) Reset 

func (m *StreamResponse) Reset()

func (*StreamResponse) Size 

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

func (*StreamResponse) String 

func (m *StreamResponse) String() string

func (*StreamResponse) Unmarshal 

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

func (*StreamResponse) XXX_DiscardUnknown 

func (m *StreamResponse) XXX_DiscardUnknown()

func (*StreamResponse) XXX_Marshal 

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

func (*StreamResponse) XXX_Merge 

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

func (*StreamResponse) XXX_Size 

func (m *StreamResponse) XXX_Size() int

func (*StreamResponse) XXX_Unmarshal 

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

type SubscriptionID 

type SubscriptionID string

SubscriptionID is a subscription identifier

type UnimplementedE2TServiceServer 

type UnimplementedE2TServiceServer struct {
}

UnimplementedE2TServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedE2TServiceServer) Stream 

func (*UnimplementedE2TServiceServer) Stream(srv E2TService_StreamServer) 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.