e2

package
v0.8.24 Latest Latest
Warning

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

 Go to latest Published: Jan 20, 2022 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 Cause_name = map[int32]string{
	0:  "CAUSE_UNKNOWN",
	1:  "CAUSE_MISC_CONTROL_PROCESSING_OVERLOAD",
	2:  "CAUSE_MISC_HARDWARE_FAILURE",
	3:  "CAUSE_MISC_OM_INTERVENTION",
	4:  "CAUSE_MISC_UNSPECIFIED",
	5:  "CAUSE_PROTOCOL_TRANSFER_SYNTAX_ERROR",
	6:  "CAUSE_PROTOCOL_ABSTRACT_SYNTAX_ERROR_REJECT",
	7:  "CAUSE_PROTOCOL_ABSTRACT_SYNTAX_ERROR_IGNORE_AND_NOTIFY",
	8:  "CAUSE_PROTOCOL_MESSAGE_NOT_COMPATIBLE_WITH_RECEIVER_STATE",
	9:  "CAUSE_PROTOCOL_SEMANTIC_ERROR",
	10: "CAUSE_PROTOCOL_ABSTRACT_SYNTAX_ERROR_FALSELY_CONSTRUCTED_MESSAGE",
	11: "CAUSE_PROTOCOL_UNSPECIFIED",
	12: "CAUSE_RIC_RAN_FUNCTION_ID_INVALID",
	13: "CAUSE_RIC_ACTION_NOT_SUPPORTED",
	14: "CAUSE_RIC_EXCESSIVE_ACTIONS",
	15: "CAUSE_RIC_DUPLICATE_ACTION",
	16: "CAUSE_RIC_DUPLICATE_EVENT",
	17: "CAUSE_RIC_FUNCTION_RESOURCE_LIMIT",
	18: "CAUSE_RIC_REQUEST_ID_UNKNOWN",
	19: "CAUSE_RIC_INCONSISTENT_ACTION_SUBSEQUENT_ACTION_SEQUENCE",
	20: "CAUSE_RIC_CONTROL_MESSAGE_INVALID",
	21: "CAUSE_RIC_CALL_PROCESS_ID_INVALID",
	22: "CAUSE_RIC_UNSPECIFIED",
	23: "CAUSE_RICSERVICE_FUNCTION_NOT_REQUIRED",
	24: "CAUSE_RICSERVICE_EXCESSIVE_FUNCTIONS",
	25: "CAUSE_RICSERVICE_RIC_RESOURCE_LIMIT",
	26: "CAUSE_TRANSPORT_UNSPECIFIED",
	27: "CAUSE_TRANSPORT_TRANSPORT_RESOURCE_UNAVAILABLE",
}
View Source 
var Cause_value = map[string]int32{
	"CAUSE_UNKNOWN":                                                    0,
	"CAUSE_MISC_CONTROL_PROCESSING_OVERLOAD":                           1,
	"CAUSE_MISC_HARDWARE_FAILURE":                                      2,
	"CAUSE_MISC_OM_INTERVENTION":                                       3,
	"CAUSE_MISC_UNSPECIFIED":                                           4,
	"CAUSE_PROTOCOL_TRANSFER_SYNTAX_ERROR":                             5,
	"CAUSE_PROTOCOL_ABSTRACT_SYNTAX_ERROR_REJECT":                      6,
	"CAUSE_PROTOCOL_ABSTRACT_SYNTAX_ERROR_IGNORE_AND_NOTIFY":           7,
	"CAUSE_PROTOCOL_MESSAGE_NOT_COMPATIBLE_WITH_RECEIVER_STATE":        8,
	"CAUSE_PROTOCOL_SEMANTIC_ERROR":                                    9,
	"CAUSE_PROTOCOL_ABSTRACT_SYNTAX_ERROR_FALSELY_CONSTRUCTED_MESSAGE": 10,
	"CAUSE_PROTOCOL_UNSPECIFIED":                                       11,
	"CAUSE_RIC_RAN_FUNCTION_ID_INVALID":                                12,
	"CAUSE_RIC_ACTION_NOT_SUPPORTED":                                   13,
	"CAUSE_RIC_EXCESSIVE_ACTIONS":                                      14,
	"CAUSE_RIC_DUPLICATE_ACTION":                                       15,
	"CAUSE_RIC_DUPLICATE_EVENT":                                        16,
	"CAUSE_RIC_FUNCTION_RESOURCE_LIMIT":                                17,
	"CAUSE_RIC_REQUEST_ID_UNKNOWN":                                     18,
	"CAUSE_RIC_INCONSISTENT_ACTION_SUBSEQUENT_ACTION_SEQUENCE":         19,
	"CAUSE_RIC_CONTROL_MESSAGE_INVALID":                                20,
	"CAUSE_RIC_CALL_PROCESS_ID_INVALID":                                21,
	"CAUSE_RIC_UNSPECIFIED":                                            22,
	"CAUSE_RICSERVICE_FUNCTION_NOT_REQUIRED":                           23,
	"CAUSE_RICSERVICE_EXCESSIVE_FUNCTIONS":                             24,
	"CAUSE_RICSERVICE_RIC_RESOURCE_LIMIT":                              25,
	"CAUSE_TRANSPORT_UNSPECIFIED":                                      26,
	"CAUSE_TRANSPORT_TRANSPORT_RESOURCE_UNAVAILABLE":                   27,
}
View Source 
var ControlAckRequest_name = map[int32]string{
	0: "ACK",
	1: "NO_ACK",
	2: "NACK",
}
View Source 
var ControlAckRequest_value = map[string]int32{
	"ACK":    0,
	"NO_ACK": 1,
	"NACK":   2,
}
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",
	2: "REJECTED",
}
View Source 
var ResponseStatus_value = map[string]int32{
	"FAILED":    0,
	"SUCCEEDED": 1,
	"REJECTED":  2,
}

Functions

func RegisterE2TServiceServer 

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

Types

type AppID 

type AppID string

AppID is an application identifier

type Cause added in v0.7.4 

type Cause int32

Cause is a failure cause 

const (
	Cause_CAUSE_UNKNOWN                                                    Cause = 0
	Cause_CAUSE_MISC_CONTROL_PROCESSING_OVERLOAD                           Cause = 1
	Cause_CAUSE_MISC_HARDWARE_FAILURE                                      Cause = 2
	Cause_CAUSE_MISC_OM_INTERVENTION                                       Cause = 3
	Cause_CAUSE_MISC_UNSPECIFIED                                           Cause = 4
	Cause_CAUSE_PROTOCOL_TRANSFER_SYNTAX_ERROR                             Cause = 5
	Cause_CAUSE_PROTOCOL_ABSTRACT_SYNTAX_ERROR_REJECT                      Cause = 6
	Cause_CAUSE_PROTOCOL_ABSTRACT_SYNTAX_ERROR_IGNORE_AND_NOTIFY           Cause = 7
	Cause_CAUSE_PROTOCOL_MESSAGE_NOT_COMPATIBLE_WITH_RECEIVER_STATE        Cause = 8
	Cause_CAUSE_PROTOCOL_SEMANTIC_ERROR                                    Cause = 9
	Cause_CAUSE_PROTOCOL_ABSTRACT_SYNTAX_ERROR_FALSELY_CONSTRUCTED_MESSAGE Cause = 10
	Cause_CAUSE_PROTOCOL_UNSPECIFIED                                       Cause = 11
	Cause_CAUSE_RIC_RAN_FUNCTION_ID_INVALID                                Cause = 12
	Cause_CAUSE_RIC_ACTION_NOT_SUPPORTED                                   Cause = 13
	Cause_CAUSE_RIC_EXCESSIVE_ACTIONS                                      Cause = 14
	Cause_CAUSE_RIC_DUPLICATE_ACTION                                       Cause = 15
	Cause_CAUSE_RIC_DUPLICATE_EVENT                                        Cause = 16
	Cause_CAUSE_RIC_FUNCTION_RESOURCE_LIMIT                                Cause = 17
	Cause_CAUSE_RIC_REQUEST_ID_UNKNOWN                                     Cause = 18
	Cause_CAUSE_RIC_INCONSISTENT_ACTION_SUBSEQUENT_ACTION_SEQUENCE         Cause = 19
	Cause_CAUSE_RIC_CONTROL_MESSAGE_INVALID                                Cause = 20
	Cause_CAUSE_RIC_CALL_PROCESS_ID_INVALID                                Cause = 21
	Cause_CAUSE_RIC_UNSPECIFIED                                            Cause = 22
	Cause_CAUSE_RICSERVICE_FUNCTION_NOT_REQUIRED                           Cause = 23
	Cause_CAUSE_RICSERVICE_EXCESSIVE_FUNCTIONS                             Cause = 24
	Cause_CAUSE_RICSERVICE_RIC_RESOURCE_LIMIT                              Cause = 25
	Cause_CAUSE_TRANSPORT_UNSPECIFIED                                      Cause = 26
	Cause_CAUSE_TRANSPORT_TRANSPORT_RESOURCE_UNAVAILABLE                   Cause = 27
)

func (Cause) EnumDescriptor added in v0.7.4 

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

func (Cause) String added in v0.7.4 

func (x Cause) String() string

type ControlAckRequest added in v0.7.4 

type ControlAckRequest int32
const (
	// Optional RIC Control Acknowledgement is required
	ControlAckRequest_ACK ControlAckRequest = 0
	// Optional RIC Control Acknowledgement is not required
	ControlAckRequest_NO_ACK ControlAckRequest = 1
	// Optional RIC Control Acknowledgement is only required to report failure
	ControlAckRequest_NACK ControlAckRequest = 2
)

func (ControlAckRequest) EnumDescriptor added in v0.7.4 

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

func (ControlAckRequest) String added in v0.7.4 

func (x ControlAckRequest) String() string

type ControlAcknowledge added in v0.7.4 

type ControlAcknowledge struct {
	ControlOutcome []byte `protobuf:"bytes,1,opt,name=control_outcome,json=controlOutcome,proto3" json:"control_outcome,omitempty"`
}

ControlAcknowledge control acknowledgement

func (*ControlAcknowledge) Descriptor added in v0.7.4 

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

func (*ControlAcknowledge) GetControlOutcome added in v0.7.4 

func (m *ControlAcknowledge) GetControlOutcome() []byte

func (*ControlAcknowledge) Marshal added in v0.7.4 

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

func (*ControlAcknowledge) MarshalTo added in v0.7.4 

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

func (*ControlAcknowledge) MarshalToSizedBuffer added in v0.7.4 

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

func (*ControlAcknowledge) ProtoMessage added in v0.7.4 

func (*ControlAcknowledge) ProtoMessage()

func (*ControlAcknowledge) Reset added in v0.7.4 

func (m *ControlAcknowledge) Reset()

func (*ControlAcknowledge) Size added in v0.7.4 

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

func (*ControlAcknowledge) String added in v0.7.4 

func (m *ControlAcknowledge) String() string

func (*ControlAcknowledge) Unmarshal added in v0.7.4 

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

func (*ControlAcknowledge) XXX_DiscardUnknown added in v0.7.4 

func (m *ControlAcknowledge) XXX_DiscardUnknown()

func (*ControlAcknowledge) XXX_Marshal added in v0.7.4 

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

func (*ControlAcknowledge) XXX_Merge added in v0.7.4 

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

func (*ControlAcknowledge) XXX_Size added in v0.7.4 

func (m *ControlAcknowledge) XXX_Size() int

func (*ControlAcknowledge) XXX_Unmarshal added in v0.7.4 

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

type ControlFailure added in v0.7.4 

type ControlFailure struct {
	Cause          Cause  `protobuf:"varint,1,opt,name=cause,proto3,enum=onos.e2t.e2.Cause" json:"cause,omitempty"`
	ControlOutcome []byte `protobuf:"bytes,2,opt,name=control_outcome,json=controlOutcome,proto3" json:"control_outcome,omitempty"`
	Message        string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
}

ControlFailure control failure message

func (*ControlFailure) Descriptor added in v0.7.4 

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

func (*ControlFailure) GetCause added in v0.7.4 

func (m *ControlFailure) GetCause() Cause

func (*ControlFailure) GetControlOutcome added in v0.7.4 

func (m *ControlFailure) GetControlOutcome() []byte

func (*ControlFailure) GetMessage added in v0.7.4 

func (m *ControlFailure) GetMessage() string

func (*ControlFailure) Marshal added in v0.7.4 

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

func (*ControlFailure) MarshalTo added in v0.7.4 

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

func (*ControlFailure) MarshalToSizedBuffer added in v0.7.4 

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

func (*ControlFailure) ProtoMessage added in v0.7.4 

func (*ControlFailure) ProtoMessage()

func (*ControlFailure) Reset added in v0.7.4 

func (m *ControlFailure) Reset()

func (*ControlFailure) Size added in v0.7.4 

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

func (*ControlFailure) String added in v0.7.4 

func (m *ControlFailure) String() string

func (*ControlFailure) Unmarshal added in v0.7.4 

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

func (*ControlFailure) XXX_DiscardUnknown added in v0.7.4 

func (m *ControlFailure) XXX_DiscardUnknown()

func (*ControlFailure) XXX_Marshal added in v0.7.4 

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

func (*ControlFailure) XXX_Merge added in v0.7.4 

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

func (*ControlFailure) XXX_Size added in v0.7.4 

func (m *ControlFailure) XXX_Size() int

func (*ControlFailure) XXX_Unmarshal added in v0.7.4 

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

type ControlRequest added in v0.7.4 

type ControlRequest struct {
	Header            *RequestHeader    `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	E2NodeID          E2NodeID          `protobuf:"bytes,2,opt,name=e2_node_id,json=e2NodeId,proto3,casttype=E2NodeID" json:"e2_node_id,omitempty"`
	ControlHeader     []byte            `protobuf:"bytes,3,opt,name=control_header,json=controlHeader,proto3" json:"control_header,omitempty"`
	ControlMessage    []byte            `protobuf:"bytes,4,opt,name=control_message,json=controlMessage,proto3" json:"control_message,omitempty"`
	ControlAckRequest ControlAckRequest `` /* 150-byte string literal not displayed */
}

ControlRequest E2 control request

func (*ControlRequest) Descriptor added in v0.7.4 

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

func (*ControlRequest) GetControlAckRequest added in v0.7.4 

func (m *ControlRequest) GetControlAckRequest() ControlAckRequest

func (*ControlRequest) GetControlHeader added in v0.7.4 

func (m *ControlRequest) GetControlHeader() []byte

func (*ControlRequest) GetControlMessage added in v0.7.4 

func (m *ControlRequest) GetControlMessage() []byte

func (*ControlRequest) GetE2NodeID added in v0.7.4 

func (m *ControlRequest) GetE2NodeID() E2NodeID

func (*ControlRequest) GetHeader added in v0.7.4 

func (m *ControlRequest) GetHeader() *RequestHeader

func (*ControlRequest) Marshal added in v0.7.4 

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

func (*ControlRequest) MarshalTo added in v0.7.4 

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

func (*ControlRequest) MarshalToSizedBuffer added in v0.7.4 

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

func (*ControlRequest) ProtoMessage added in v0.7.4 

func (*ControlRequest) ProtoMessage()

func (*ControlRequest) Reset added in v0.7.4 

func (m *ControlRequest) Reset()

func (*ControlRequest) Size added in v0.7.4 

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

func (*ControlRequest) String added in v0.7.4 

func (m *ControlRequest) String() string

func (*ControlRequest) Unmarshal added in v0.7.4 

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

func (*ControlRequest) XXX_DiscardUnknown added in v0.7.4 

func (m *ControlRequest) XXX_DiscardUnknown()

func (*ControlRequest) XXX_Marshal added in v0.7.4 

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

func (*ControlRequest) XXX_Merge added in v0.7.4 

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

func (*ControlRequest) XXX_Size added in v0.7.4 

func (m *ControlRequest) XXX_Size() int

func (*ControlRequest) XXX_Unmarshal added in v0.7.4 

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

type ControlResponse added in v0.7.4 

type ControlResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Types that are valid to be assigned to Response:
	//	*ControlResponse_ControlAcknowledge
	//	*ControlResponse_ControlFailure
	Response isControlResponse_Response `protobuf_oneof:"response"`
}

ControlResponse E2 control response

func (*ControlResponse) Descriptor added in v0.7.4 

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

func (*ControlResponse) GetControlAcknowledge added in v0.7.4 

func (m *ControlResponse) GetControlAcknowledge() *ControlAcknowledge

func (*ControlResponse) GetControlFailure added in v0.7.4 

func (m *ControlResponse) GetControlFailure() *ControlFailure

func (*ControlResponse) GetHeader added in v0.7.4 

func (m *ControlResponse) GetHeader() *ResponseHeader

func (*ControlResponse) GetResponse added in v0.7.4 

func (m *ControlResponse) GetResponse() isControlResponse_Response

func (*ControlResponse) Marshal added in v0.7.4 

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

func (*ControlResponse) MarshalTo added in v0.7.4 

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

func (*ControlResponse) MarshalToSizedBuffer added in v0.7.4 

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

func (*ControlResponse) ProtoMessage added in v0.7.4 

func (*ControlResponse) ProtoMessage()

func (*ControlResponse) Reset added in v0.7.4 

func (m *ControlResponse) Reset()

func (*ControlResponse) Size added in v0.7.4 

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

func (*ControlResponse) String added in v0.7.4 

func (m *ControlResponse) String() string

func (*ControlResponse) Unmarshal added in v0.7.4 

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

func (*ControlResponse) XXX_DiscardUnknown added in v0.7.4 

func (m *ControlResponse) XXX_DiscardUnknown()

func (*ControlResponse) XXX_Marshal added in v0.7.4 

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

func (*ControlResponse) XXX_Merge added in v0.7.4 

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

func (*ControlResponse) XXX_OneofWrappers added in v0.7.4 

func (*ControlResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ControlResponse) XXX_Size added in v0.7.4 

func (m *ControlResponse) XXX_Size() int

func (*ControlResponse) XXX_Unmarshal added in v0.7.4 

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

type ControlResponse_ControlAcknowledge added in v0.7.4 

type ControlResponse_ControlAcknowledge struct {
	ControlAcknowledge *ControlAcknowledge `protobuf:"bytes,2,opt,name=control_acknowledge,json=controlAcknowledge,proto3,oneof" json:"control_acknowledge,omitempty"`
}

func (*ControlResponse_ControlAcknowledge) MarshalTo added in v0.7.4 

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

func (*ControlResponse_ControlAcknowledge) MarshalToSizedBuffer added in v0.7.4 

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

func (*ControlResponse_ControlAcknowledge) Size added in v0.7.4 

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

type ControlResponse_ControlFailure added in v0.7.4 

type ControlResponse_ControlFailure struct {
	ControlFailure *ControlFailure `protobuf:"bytes,3,opt,name=control_failure,json=controlFailure,proto3,oneof" json:"control_failure,omitempty"`
}

func (*ControlResponse_ControlFailure) MarshalTo added in v0.7.4 

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

func (*ControlResponse_ControlFailure) MarshalToSizedBuffer added in v0.7.4 

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

func (*ControlResponse_ControlFailure) Size added in v0.7.4 

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

type E2NodeID added in v0.7.4 

type E2NodeID string

E2NodeID is an E2 node identifier

type E2TServiceClient 

type E2TServiceClient interface {
	// Stream opens an indications stream
	Stream(ctx context.Context, opts ...grpc.CallOption) (E2TService_StreamClient, error)
	// Control sends a E2 control request
	Control(ctx context.Context, in *ControlRequest, opts ...grpc.CallOption) (*ControlResponse, 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
	// Control sends a E2 control request
	Control(context.Context, *ControlRequest) (*ControlResponse, 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 */
	ServiceModel *ServiceModel `protobuf:"bytes,2,opt,name=service_model,json=serviceModel,proto3" json:"service_model,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) GetServiceModel added in v0.7.4 

func (m *RequestHeader) GetServiceModel() *ServiceModel

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 */
	ServiceModel   *ServiceModel  `protobuf:"bytes,2,opt,name=service_model,json=serviceModel,proto3" json:"service_model,omitempty"`
	ResponseStatus ResponseStatus `` /* 136-byte string literal not displayed */
}

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) GetResponseStatus 

func (m *ResponseHeader) GetResponseStatus() ResponseStatus

func (*ResponseHeader) GetServiceModel added in v0.7.4 

func (m *ResponseHeader) GetServiceModel() *ServiceModel

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
	ResponseStatus_REJECTED  ResponseStatus = 2
)

func (ResponseStatus) EnumDescriptor 

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

func (ResponseStatus) String 

func (x ResponseStatus) String() string

type ServiceModel added in v0.7.4 

type ServiceModel struct {
	Name    ServiceModelName    `protobuf:"bytes,1,opt,name=name,proto3,casttype=ServiceModelName" json:"name,omitempty"`
	Version ServiceModelVersion `protobuf:"bytes,2,opt,name=version,proto3,casttype=ServiceModelVersion" json:"version,omitempty"`
}

ServiceModelInfo E2 service model information

func (*ServiceModel) Descriptor added in v0.7.4 

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

func (*ServiceModel) GetName added in v0.7.20 

func (m *ServiceModel) GetName() ServiceModelName

func (*ServiceModel) GetVersion added in v0.7.20 

func (m *ServiceModel) GetVersion() ServiceModelVersion

func (*ServiceModel) Marshal added in v0.7.4 

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

func (*ServiceModel) MarshalTo added in v0.7.4 

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

func (*ServiceModel) MarshalToSizedBuffer added in v0.7.4 

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

func (*ServiceModel) ProtoMessage added in v0.7.4 

func (*ServiceModel) ProtoMessage()

func (*ServiceModel) Reset added in v0.7.4 

func (m *ServiceModel) Reset()

func (*ServiceModel) Size added in v0.7.4 

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

func (*ServiceModel) String added in v0.7.4 

func (m *ServiceModel) String() string

func (*ServiceModel) Unmarshal added in v0.7.4 

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

func (*ServiceModel) XXX_DiscardUnknown added in v0.7.4 

func (m *ServiceModel) XXX_DiscardUnknown()

func (*ServiceModel) XXX_Marshal added in v0.7.4 

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

func (*ServiceModel) XXX_Merge added in v0.7.4 

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

func (*ServiceModel) XXX_Size added in v0.7.4 

func (m *ServiceModel) XXX_Size() int

func (*ServiceModel) XXX_Unmarshal added in v0.7.4 

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

type ServiceModelName added in v0.7.20 

type ServiceModelName string

ServiceModelName is a service model name

type ServiceModelVersion added in v0.7.20 

type ServiceModelVersion string

ServiceModelVersion is a service model version

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"`
	IndicationHeader  []byte          `protobuf:"bytes,2,opt,name=indication_header,json=indicationHeader,proto3" json:"indication_header,omitempty"`
	IndicationMessage []byte          `protobuf:"bytes,3,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) GetIndicationHeader added in v0.7.4 

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

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) Control added in v0.7.4 

func (*UnimplementedE2TServiceServer) Control(ctx context.Context, req *ControlRequest) (*ControlResponse, error)

func (*UnimplementedE2TServiceServer) Stream 

func (*UnimplementedE2TServiceServer) Stream(srv E2TService_StreamServer) error

Source Files

View all Source files

Directories

Path Synopsis

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.