v1beta1

package
v0.7.51 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2021 License: Apache-2.0 Imports: 10 Imported by: 69

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthControl        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowControl          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupControl = fmt.Errorf("proto: unexpected end of group")
)
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 (
	ErrInvalidLengthSubscription        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSubscription          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSubscription = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ActionType_name = map[int32]string{
	0: "ACTION_TYPE_REPORT",
	1: "ACTION_TYPE_INSERT",
	2: "ACTION_TYPE_POLICY",
}
View Source 
var ActionType_value = map[string]int32{
	"ACTION_TYPE_REPORT": 0,
	"ACTION_TYPE_INSERT": 1,
	"ACTION_TYPE_POLICY": 2,
}
View Source 
var Encoding_name = map[int32]string{
	0: "PROTO",
	1: "ASN1_PER",
	2: "ASN1_XER",
}
View Source 
var Encoding_value = map[string]int32{
	"PROTO":    0,
	"ASN1_PER": 1,
	"ASN1_XER": 2,
}
View Source 
var Error_Cause_Misc_Type_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "CONTROL_PROCESSING_OVERLOAD",
	2: "HARDWARE_FAILURE",
	3: "OM_INTERVENTION",
}
View Source 
var Error_Cause_Misc_Type_value = map[string]int32{
	"UNSPECIFIED":                 0,
	"CONTROL_PROCESSING_OVERLOAD": 1,
	"HARDWARE_FAILURE":            2,
	"OM_INTERVENTION":             3,
}
View Source 
var Error_Cause_Protocol_Type_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "TRANSFER_SYNTAX_ERROR",
	2: "ABSTRACT_SYNTAX_ERROR_REJECT",
	3: "ABSTRACT_SYNTAX_ERROR_IGNORE_AND_NOTIFY",
	4: "MESSAGE_NOT_COMPATIBLE_WITH_RECEIVER_STATE",
	5: "SEMANTIC_ERROR",
	6: "ABSTRACT_SYNTAX_ERROR_FALSELY_CONSTRUCTED_MESSAGE",
}
View Source 
var Error_Cause_Protocol_Type_value = map[string]int32{
	"UNSPECIFIED":                                       0,
	"TRANSFER_SYNTAX_ERROR":                             1,
	"ABSTRACT_SYNTAX_ERROR_REJECT":                      2,
	"ABSTRACT_SYNTAX_ERROR_IGNORE_AND_NOTIFY":           3,
	"MESSAGE_NOT_COMPATIBLE_WITH_RECEIVER_STATE":        4,
	"SEMANTIC_ERROR":                                    5,
	"ABSTRACT_SYNTAX_ERROR_FALSELY_CONSTRUCTED_MESSAGE": 6,
}
View Source 
var Error_Cause_RicService_Type_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "FUNCTION_NOT_REQUIRED",
	2: "EXCESSIVE_FUNCTIONS",
	3: "RIC_RESOURCE_LIMIT",
}
View Source 
var Error_Cause_RicService_Type_value = map[string]int32{
	"UNSPECIFIED":           0,
	"FUNCTION_NOT_REQUIRED": 1,
	"EXCESSIVE_FUNCTIONS":   2,
	"RIC_RESOURCE_LIMIT":    3,
}
View Source 
var Error_Cause_Ric_Type_name = map[int32]string{
	0:  "UNSPECIFIED",
	1:  "RAN_FUNCTION_ID_INVALID",
	2:  "ACTION_NOT_SUPPORTED",
	3:  "EXCESSIVE_ACTIONS",
	4:  "DUPLICATE_ACTION",
	5:  "DUPLICATE_EVENT",
	6:  "FUNCTION_RESOURCE_LIMIT",
	7:  "REQUEST_ID_UNKNOWN",
	8:  "INCONSISTENT_ACTION_SUBSEQUENT_ACTION_SEQUENCE",
	9:  "CONTROL_MESSAGE_INVALID",
	10: "CALL_PROCESS_ID_INVALID",
}
View Source 
var Error_Cause_Ric_Type_value = map[string]int32{
	"UNSPECIFIED":                                    0,
	"RAN_FUNCTION_ID_INVALID":                        1,
	"ACTION_NOT_SUPPORTED":                           2,
	"EXCESSIVE_ACTIONS":                              3,
	"DUPLICATE_ACTION":                               4,
	"DUPLICATE_EVENT":                                5,
	"FUNCTION_RESOURCE_LIMIT":                        6,
	"REQUEST_ID_UNKNOWN":                             7,
	"INCONSISTENT_ACTION_SUBSEQUENT_ACTION_SEQUENCE": 8,
	"CONTROL_MESSAGE_INVALID":                        9,
	"CALL_PROCESS_ID_INVALID":                        10,
}
View Source 
var Error_Cause_Transport_Type_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "TRANSPORT_RESOURCE_UNAVAILABLE",
}
View Source 
var Error_Cause_Transport_Type_value = map[string]int32{
	"UNSPECIFIED":                    0,
	"TRANSPORT_RESOURCE_UNAVAILABLE": 1,
}
View Source 
var SubsequentActionType_name = map[int32]string{
	0: "SUBSEQUENT_ACTION_TYPE_CONTINUE",
	1: "SUBSEQUENT_ACTION_TYPE_WAIT",
}
View Source 
var SubsequentActionType_value = map[string]int32{
	"SUBSEQUENT_ACTION_TYPE_CONTINUE": 0,
	"SUBSEQUENT_ACTION_TYPE_WAIT":     1,
}
View Source 
var TimeToWait_name = map[int32]string{
	0:  "TIME_TO_WAIT_ZERO",
	1:  "TIME_TO_WAIT_W1MS",
	2:  "TIME_TO_WAIT_W2MS",
	3:  "TIME_TO_WAIT_W5MS",
	4:  "TIME_TO_WAIT_W10MS",
	5:  "TIME_TO_WAIT_W20MS",
	6:  "TIME_TO_WAIT_W30MS",
	7:  "TIME_TO_WAIT_W40MS",
	8:  "TIME_TO_WAIT_W50MS",
	9:  "TIME_TO_WAIT_W100MS",
	10: "TIME_TO_WAIT_W200MS",
	11: "TIME_TO_WAIT_W500MS",
	12: "TIME_TO_WAIT_W1S",
	13: "TIME_TO_WAIT_W2S",
	14: "TIME_TO_WAIT_W5S",
	15: "TIME_TO_WAIT_W10S",
	16: "TIME_TO_WAIT_W20S",
	17: "TIME_TO_WAIT_W60S",
}
View Source 
var TimeToWait_value = map[string]int32{
	"TIME_TO_WAIT_ZERO":   0,
	"TIME_TO_WAIT_W1MS":   1,
	"TIME_TO_WAIT_W2MS":   2,
	"TIME_TO_WAIT_W5MS":   3,
	"TIME_TO_WAIT_W10MS":  4,
	"TIME_TO_WAIT_W20MS":  5,
	"TIME_TO_WAIT_W30MS":  6,
	"TIME_TO_WAIT_W40MS":  7,
	"TIME_TO_WAIT_W50MS":  8,
	"TIME_TO_WAIT_W100MS": 9,
	"TIME_TO_WAIT_W200MS": 10,
	"TIME_TO_WAIT_W500MS": 11,
	"TIME_TO_WAIT_W1S":    12,
	"TIME_TO_WAIT_W2S":    13,
	"TIME_TO_WAIT_W5S":    14,
	"TIME_TO_WAIT_W10S":   15,
	"TIME_TO_WAIT_W20S":   16,
	"TIME_TO_WAIT_W60S":   17,
}

Functions

func RegisterControlServiceServer 

func RegisterControlServiceServer(s *grpc.Server, srv ControlServiceServer)

func RegisterSubscriptionServiceServer 

func RegisterSubscriptionServiceServer(s *grpc.Server, srv SubscriptionServiceServer)

Types

type Acknowledgement 

type Acknowledgement struct {
}

func (*Acknowledgement) Descriptor 

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

func (*Acknowledgement) Marshal 

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

func (*Acknowledgement) MarshalTo 

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

func (*Acknowledgement) MarshalToSizedBuffer 

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

func (*Acknowledgement) ProtoMessage 

func (*Acknowledgement) ProtoMessage()

func (*Acknowledgement) Reset 

func (m *Acknowledgement) Reset()

func (*Acknowledgement) Size 

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

func (*Acknowledgement) String 

func (m *Acknowledgement) String() string

func (*Acknowledgement) Unmarshal 

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

func (*Acknowledgement) XXX_DiscardUnknown 

func (m *Acknowledgement) XXX_DiscardUnknown()

func (*Acknowledgement) XXX_Marshal 

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

func (*Acknowledgement) XXX_Merge 

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

func (*Acknowledgement) XXX_Size 

func (m *Acknowledgement) XXX_Size() int

func (*Acknowledgement) XXX_Unmarshal 

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

type Action 

type Action struct {
	ID               int32             `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Type             ActionType        `protobuf:"varint,2,opt,name=type,proto3,enum=onos.e2t.e2.v1beta1.ActionType" json:"type,omitempty"`
	Payload          []byte            `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	SubsequentAction *SubsequentAction `protobuf:"bytes,4,opt,name=subsequent_action,json=subsequentAction,proto3" json:"subsequent_action,omitempty"`
}

func (*Action) Descriptor 

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

func (*Action) GetID 

func (m *Action) GetID() int32

func (*Action) GetPayload 

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

func (*Action) GetSubsequentAction 

func (m *Action) GetSubsequentAction() *SubsequentAction

func (*Action) GetType 

func (m *Action) GetType() ActionType

func (*Action) Marshal 

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

func (*Action) MarshalTo 

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

func (*Action) MarshalToSizedBuffer 

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

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) Reset 

func (m *Action) Reset()

func (*Action) Size 

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

func (*Action) String 

func (m *Action) String() string

func (*Action) Unmarshal 

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

func (*Action) XXX_DiscardUnknown 

func (m *Action) XXX_DiscardUnknown()

func (*Action) XXX_Marshal 

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

func (*Action) XXX_Merge 

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

func (*Action) XXX_Size 

func (m *Action) XXX_Size() int

func (*Action) XXX_Unmarshal 

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

type ActionType 

type ActionType int32
const (
	ActionType_ACTION_TYPE_REPORT ActionType = 0
	ActionType_ACTION_TYPE_INSERT ActionType = 1
	ActionType_ACTION_TYPE_POLICY ActionType = 2
)

func (ActionType) EnumDescriptor 

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

func (ActionType) String 

func (x ActionType) String() string

type AppID 

type AppID string

AppID is an xApp identifier

type ControlMessage 

type ControlMessage struct {
	Header  []byte `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*ControlMessage) Descriptor 

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

func (*ControlMessage) GetHeader 

func (m *ControlMessage) GetHeader() []byte

func (*ControlMessage) GetPayload 

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

func (*ControlMessage) Marshal 

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

func (*ControlMessage) MarshalTo 

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

func (*ControlMessage) MarshalToSizedBuffer 

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

func (*ControlMessage) ProtoMessage 

func (*ControlMessage) ProtoMessage()

func (*ControlMessage) Reset 

func (m *ControlMessage) Reset()

func (*ControlMessage) Size 

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

func (*ControlMessage) String 

func (m *ControlMessage) String() string

func (*ControlMessage) Unmarshal 

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

func (*ControlMessage) XXX_DiscardUnknown 

func (m *ControlMessage) XXX_DiscardUnknown()

func (*ControlMessage) XXX_Marshal 

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

func (*ControlMessage) XXX_Merge 

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

func (*ControlMessage) XXX_Size 

func (m *ControlMessage) XXX_Size() int

func (*ControlMessage) XXX_Unmarshal 

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

type ControlOutcome 

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

func (*ControlOutcome) Descriptor 

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

func (*ControlOutcome) GetPayload 

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

func (*ControlOutcome) Marshal 

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

func (*ControlOutcome) MarshalTo 

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

func (*ControlOutcome) MarshalToSizedBuffer 

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

func (*ControlOutcome) ProtoMessage 

func (*ControlOutcome) ProtoMessage()

func (*ControlOutcome) Reset 

func (m *ControlOutcome) Reset()

func (*ControlOutcome) Size 

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

func (*ControlOutcome) String 

func (m *ControlOutcome) String() string

func (*ControlOutcome) Unmarshal 

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

func (*ControlOutcome) XXX_DiscardUnknown 

func (m *ControlOutcome) XXX_DiscardUnknown()

func (*ControlOutcome) XXX_Marshal 

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

func (*ControlOutcome) XXX_Merge 

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

func (*ControlOutcome) XXX_Size 

func (m *ControlOutcome) XXX_Size() int

func (*ControlOutcome) XXX_Unmarshal 

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

type ControlRequest 

type ControlRequest struct {
	Headers RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"`
	Message ControlMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message"`
}

func (*ControlRequest) Descriptor 

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

func (*ControlRequest) GetHeaders 

func (m *ControlRequest) GetHeaders() RequestHeaders

func (*ControlRequest) GetMessage 

func (m *ControlRequest) GetMessage() ControlMessage

func (*ControlRequest) Marshal 

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

func (*ControlRequest) MarshalTo 

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

func (*ControlRequest) MarshalToSizedBuffer 

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

func (*ControlRequest) ProtoMessage 

func (*ControlRequest) ProtoMessage()

func (*ControlRequest) Reset 

func (m *ControlRequest) Reset()

func (*ControlRequest) Size 

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

func (*ControlRequest) String 

func (m *ControlRequest) String() string

func (*ControlRequest) Unmarshal 

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

func (*ControlRequest) XXX_DiscardUnknown 

func (m *ControlRequest) XXX_DiscardUnknown()

func (*ControlRequest) XXX_Marshal 

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

func (*ControlRequest) XXX_Merge 

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

func (*ControlRequest) XXX_Size 

func (m *ControlRequest) XXX_Size() int

func (*ControlRequest) XXX_Unmarshal 

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

type ControlResponse 

type ControlResponse struct {
	Headers ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"`
	Outcome ControlOutcome  `protobuf:"bytes,2,opt,name=outcome,proto3" json:"outcome"`
}

func (*ControlResponse) Descriptor 

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

func (*ControlResponse) GetHeaders 

func (m *ControlResponse) GetHeaders() ResponseHeaders

func (*ControlResponse) GetOutcome 

func (m *ControlResponse) GetOutcome() ControlOutcome

func (*ControlResponse) Marshal 

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

func (*ControlResponse) MarshalTo 

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

func (*ControlResponse) MarshalToSizedBuffer 

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

func (*ControlResponse) ProtoMessage 

func (*ControlResponse) ProtoMessage()

func (*ControlResponse) Reset 

func (m *ControlResponse) Reset()

func (*ControlResponse) Size 

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

func (*ControlResponse) String 

func (m *ControlResponse) String() string

func (*ControlResponse) Unmarshal 

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

func (*ControlResponse) XXX_DiscardUnknown 

func (m *ControlResponse) XXX_DiscardUnknown()

func (*ControlResponse) XXX_Marshal 

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

func (*ControlResponse) XXX_Merge 

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

func (*ControlResponse) XXX_Size 

func (m *ControlResponse) XXX_Size() int

func (*ControlResponse) XXX_Unmarshal 

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

type ControlServiceClient 

type ControlServiceClient interface {
	Control(ctx context.Context, in *ControlRequest, opts ...grpc.CallOption) (*ControlResponse, error)
}

ControlServiceClient is the client API for ControlService service.

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

func NewControlServiceClient 

func NewControlServiceClient(cc *grpc.ClientConn) ControlServiceClient

type ControlServiceServer 

type ControlServiceServer interface {
	Control(context.Context, *ControlRequest) (*ControlResponse, error)
}

ControlServiceServer is the server API for ControlService service.

type Encoding 

type Encoding int32
const (
	Encoding_PROTO    Encoding = 0
	Encoding_ASN1_PER Encoding = 1
	Encoding_ASN1_XER Encoding = 2
)

func (Encoding) EnumDescriptor 

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

func (Encoding) String 

func (x Encoding) String() string

type Error 

type Error struct {
	Cause *Error_Cause `protobuf:"bytes,1,opt,name=cause,proto3" json:"cause,omitempty"`
}

Error is an E2AP protocol error

func (*Error) Descriptor 

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

func (*Error) GetCause 

func (m *Error) GetCause() *Error_Cause

func (*Error) Marshal 

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

func (*Error) MarshalTo 

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

func (*Error) MarshalToSizedBuffer 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

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

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal 

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 Error_Cause 

type Error_Cause struct {
	// Types that are valid to be assigned to Cause:
	//	*Error_Cause_Unknown_
	//	*Error_Cause_Protocol_
	//	*Error_Cause_Ric_
	//	*Error_Cause_RicService_
	//	*Error_Cause_Transport_
	//	*Error_Cause_Misc_
	Cause isError_Cause_Cause `protobuf_oneof:"cause"`
}

func (*Error_Cause) Descriptor 

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

func (*Error_Cause) GetCause 

func (m *Error_Cause) GetCause() isError_Cause_Cause

func (*Error_Cause) GetMisc 

func (m *Error_Cause) GetMisc() *Error_Cause_Misc

func (*Error_Cause) GetProtocol 

func (m *Error_Cause) GetProtocol() *Error_Cause_Protocol

func (*Error_Cause) GetRic 

func (m *Error_Cause) GetRic() *Error_Cause_Ric

func (*Error_Cause) GetRicService 

func (m *Error_Cause) GetRicService() *Error_Cause_RicService

func (*Error_Cause) GetTransport 

func (m *Error_Cause) GetTransport() *Error_Cause_Transport

func (*Error_Cause) GetUnknown 

func (m *Error_Cause) GetUnknown() *Error_Cause_Unknown

func (*Error_Cause) Marshal 

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

func (*Error_Cause) MarshalTo 

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

func (*Error_Cause) MarshalToSizedBuffer 

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

func (*Error_Cause) ProtoMessage 

func (*Error_Cause) ProtoMessage()

func (*Error_Cause) Reset 

func (m *Error_Cause) Reset()

func (*Error_Cause) Size 

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

func (*Error_Cause) String 

func (m *Error_Cause) String() string

func (*Error_Cause) Unmarshal 

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

func (*Error_Cause) XXX_DiscardUnknown 

func (m *Error_Cause) XXX_DiscardUnknown()

func (*Error_Cause) XXX_Marshal 

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

func (*Error_Cause) XXX_Merge 

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

func (*Error_Cause) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Error_Cause) XXX_Size 

func (m *Error_Cause) XXX_Size() int

func (*Error_Cause) XXX_Unmarshal 

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

type Error_Cause_Misc 

type Error_Cause_Misc struct {
	Type Error_Cause_Misc_Type `protobuf:"varint,1,opt,name=type,proto3,enum=onos.e2t.e2.v1beta1.Error_Cause_Misc_Type" json:"type,omitempty"`
}

func (*Error_Cause_Misc) Descriptor 

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

func (*Error_Cause_Misc) GetType 

func (m *Error_Cause_Misc) GetType() Error_Cause_Misc_Type

func (*Error_Cause_Misc) Marshal 

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

func (*Error_Cause_Misc) MarshalTo 

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

func (*Error_Cause_Misc) MarshalToSizedBuffer 

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

func (*Error_Cause_Misc) ProtoMessage 

func (*Error_Cause_Misc) ProtoMessage()

func (*Error_Cause_Misc) Reset 

func (m *Error_Cause_Misc) Reset()

func (*Error_Cause_Misc) Size 

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

func (*Error_Cause_Misc) String 

func (m *Error_Cause_Misc) String() string

func (*Error_Cause_Misc) Unmarshal 

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

func (*Error_Cause_Misc) XXX_DiscardUnknown 

func (m *Error_Cause_Misc) XXX_DiscardUnknown()

func (*Error_Cause_Misc) XXX_Marshal 

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

func (*Error_Cause_Misc) XXX_Merge 

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

func (*Error_Cause_Misc) XXX_Size 

func (m *Error_Cause_Misc) XXX_Size() int

func (*Error_Cause_Misc) XXX_Unmarshal 

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

type Error_Cause_Misc_ 

type Error_Cause_Misc_ struct {
	Misc *Error_Cause_Misc `protobuf:"bytes,6,opt,name=misc,proto3,oneof" json:"misc,omitempty"`
}

func (*Error_Cause_Misc_) MarshalTo 

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

func (*Error_Cause_Misc_) MarshalToSizedBuffer 

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

func (*Error_Cause_Misc_) Size 

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

type Error_Cause_Misc_Type 

type Error_Cause_Misc_Type int32
const (
	Error_Cause_Misc_UNSPECIFIED                 Error_Cause_Misc_Type = 0
	Error_Cause_Misc_CONTROL_PROCESSING_OVERLOAD Error_Cause_Misc_Type = 1
	Error_Cause_Misc_HARDWARE_FAILURE            Error_Cause_Misc_Type = 2
	Error_Cause_Misc_OM_INTERVENTION             Error_Cause_Misc_Type = 3
)

func (Error_Cause_Misc_Type) EnumDescriptor 

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

func (Error_Cause_Misc_Type) String 

func (x Error_Cause_Misc_Type) String() string

type Error_Cause_Protocol 

type Error_Cause_Protocol struct {
	Type Error_Cause_Protocol_Type `protobuf:"varint,1,opt,name=type,proto3,enum=onos.e2t.e2.v1beta1.Error_Cause_Protocol_Type" json:"type,omitempty"`
}

func (*Error_Cause_Protocol) Descriptor 

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

func (*Error_Cause_Protocol) GetType 

func (m *Error_Cause_Protocol) GetType() Error_Cause_Protocol_Type

func (*Error_Cause_Protocol) Marshal 

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

func (*Error_Cause_Protocol) MarshalTo 

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

func (*Error_Cause_Protocol) MarshalToSizedBuffer 

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

func (*Error_Cause_Protocol) ProtoMessage 

func (*Error_Cause_Protocol) ProtoMessage()

func (*Error_Cause_Protocol) Reset 

func (m *Error_Cause_Protocol) Reset()

func (*Error_Cause_Protocol) Size 

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

func (*Error_Cause_Protocol) String 

func (m *Error_Cause_Protocol) String() string

func (*Error_Cause_Protocol) Unmarshal 

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

func (*Error_Cause_Protocol) XXX_DiscardUnknown 

func (m *Error_Cause_Protocol) XXX_DiscardUnknown()

func (*Error_Cause_Protocol) XXX_Marshal 

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

func (*Error_Cause_Protocol) XXX_Merge 

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

func (*Error_Cause_Protocol) XXX_Size 

func (m *Error_Cause_Protocol) XXX_Size() int

func (*Error_Cause_Protocol) XXX_Unmarshal 

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

type Error_Cause_Protocol_ 

type Error_Cause_Protocol_ struct {
	Protocol *Error_Cause_Protocol `protobuf:"bytes,2,opt,name=protocol,proto3,oneof" json:"protocol,omitempty"`
}

func (*Error_Cause_Protocol_) MarshalTo 

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

func (*Error_Cause_Protocol_) MarshalToSizedBuffer 

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

func (*Error_Cause_Protocol_) Size 

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

type Error_Cause_Protocol_Type 

type Error_Cause_Protocol_Type int32
const (
	Error_Cause_Protocol_UNSPECIFIED                                       Error_Cause_Protocol_Type = 0
	Error_Cause_Protocol_TRANSFER_SYNTAX_ERROR                             Error_Cause_Protocol_Type = 1
	Error_Cause_Protocol_ABSTRACT_SYNTAX_ERROR_REJECT                      Error_Cause_Protocol_Type = 2
	Error_Cause_Protocol_ABSTRACT_SYNTAX_ERROR_IGNORE_AND_NOTIFY           Error_Cause_Protocol_Type = 3
	Error_Cause_Protocol_MESSAGE_NOT_COMPATIBLE_WITH_RECEIVER_STATE        Error_Cause_Protocol_Type = 4
	Error_Cause_Protocol_SEMANTIC_ERROR                                    Error_Cause_Protocol_Type = 5
	Error_Cause_Protocol_ABSTRACT_SYNTAX_ERROR_FALSELY_CONSTRUCTED_MESSAGE Error_Cause_Protocol_Type = 6
)

func (Error_Cause_Protocol_Type) EnumDescriptor 

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

func (Error_Cause_Protocol_Type) String 

func (x Error_Cause_Protocol_Type) String() string

type Error_Cause_Ric 

type Error_Cause_Ric struct {
	Type Error_Cause_Ric_Type `protobuf:"varint,1,opt,name=type,proto3,enum=onos.e2t.e2.v1beta1.Error_Cause_Ric_Type" json:"type,omitempty"`
}

func (*Error_Cause_Ric) Descriptor 

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

func (*Error_Cause_Ric) GetType 

func (m *Error_Cause_Ric) GetType() Error_Cause_Ric_Type

func (*Error_Cause_Ric) Marshal 

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

func (*Error_Cause_Ric) MarshalTo 

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

func (*Error_Cause_Ric) MarshalToSizedBuffer 

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

func (*Error_Cause_Ric) ProtoMessage 

func (*Error_Cause_Ric) ProtoMessage()

func (*Error_Cause_Ric) Reset 

func (m *Error_Cause_Ric) Reset()

func (*Error_Cause_Ric) Size 

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

func (*Error_Cause_Ric) String 

func (m *Error_Cause_Ric) String() string

func (*Error_Cause_Ric) Unmarshal 

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

func (*Error_Cause_Ric) XXX_DiscardUnknown 

func (m *Error_Cause_Ric) XXX_DiscardUnknown()

func (*Error_Cause_Ric) XXX_Marshal 

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

func (*Error_Cause_Ric) XXX_Merge 

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

func (*Error_Cause_Ric) XXX_Size 

func (m *Error_Cause_Ric) XXX_Size() int

func (*Error_Cause_Ric) XXX_Unmarshal 

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

type Error_Cause_RicService 

type Error_Cause_RicService struct {
	Type Error_Cause_RicService_Type `protobuf:"varint,1,opt,name=type,proto3,enum=onos.e2t.e2.v1beta1.Error_Cause_RicService_Type" json:"type,omitempty"`
}

func (*Error_Cause_RicService) Descriptor 

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

func (*Error_Cause_RicService) GetType 

func (m *Error_Cause_RicService) GetType() Error_Cause_RicService_Type

func (*Error_Cause_RicService) Marshal 

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

func (*Error_Cause_RicService) MarshalTo 

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

func (*Error_Cause_RicService) MarshalToSizedBuffer 

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

func (*Error_Cause_RicService) ProtoMessage 

func (*Error_Cause_RicService) ProtoMessage()

func (*Error_Cause_RicService) Reset 

func (m *Error_Cause_RicService) Reset()

func (*Error_Cause_RicService) Size 

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

func (*Error_Cause_RicService) String 

func (m *Error_Cause_RicService) String() string

func (*Error_Cause_RicService) Unmarshal 

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

func (*Error_Cause_RicService) XXX_DiscardUnknown 

func (m *Error_Cause_RicService) XXX_DiscardUnknown()

func (*Error_Cause_RicService) XXX_Marshal 

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

func (*Error_Cause_RicService) XXX_Merge 

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

func (*Error_Cause_RicService) XXX_Size 

func (m *Error_Cause_RicService) XXX_Size() int

func (*Error_Cause_RicService) XXX_Unmarshal 

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

type Error_Cause_RicService_ 

type Error_Cause_RicService_ struct {
	RicService *Error_Cause_RicService `protobuf:"bytes,4,opt,name=ric_service,json=ricService,proto3,oneof" json:"ric_service,omitempty"`
}

func (*Error_Cause_RicService_) MarshalTo 

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

func (*Error_Cause_RicService_) MarshalToSizedBuffer 

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

func (*Error_Cause_RicService_) Size 

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

type Error_Cause_RicService_Type 

type Error_Cause_RicService_Type int32
const (
	Error_Cause_RicService_UNSPECIFIED           Error_Cause_RicService_Type = 0
	Error_Cause_RicService_FUNCTION_NOT_REQUIRED Error_Cause_RicService_Type = 1
	Error_Cause_RicService_EXCESSIVE_FUNCTIONS   Error_Cause_RicService_Type = 2
	Error_Cause_RicService_RIC_RESOURCE_LIMIT    Error_Cause_RicService_Type = 3
)

func (Error_Cause_RicService_Type) EnumDescriptor 

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

func (Error_Cause_RicService_Type) String 

func (x Error_Cause_RicService_Type) String() string

type Error_Cause_Ric_ 

type Error_Cause_Ric_ struct {
	Ric *Error_Cause_Ric `protobuf:"bytes,3,opt,name=ric,proto3,oneof" json:"ric,omitempty"`
}

func (*Error_Cause_Ric_) MarshalTo 

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

func (*Error_Cause_Ric_) MarshalToSizedBuffer 

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

func (*Error_Cause_Ric_) Size 

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

type Error_Cause_Ric_Type 

type Error_Cause_Ric_Type int32
const (
	Error_Cause_Ric_UNSPECIFIED                                    Error_Cause_Ric_Type = 0
	Error_Cause_Ric_RAN_FUNCTION_ID_INVALID                        Error_Cause_Ric_Type = 1
	Error_Cause_Ric_ACTION_NOT_SUPPORTED                           Error_Cause_Ric_Type = 2
	Error_Cause_Ric_EXCESSIVE_ACTIONS                              Error_Cause_Ric_Type = 3
	Error_Cause_Ric_DUPLICATE_ACTION                               Error_Cause_Ric_Type = 4
	Error_Cause_Ric_DUPLICATE_EVENT                                Error_Cause_Ric_Type = 5
	Error_Cause_Ric_FUNCTION_RESOURCE_LIMIT                        Error_Cause_Ric_Type = 6
	Error_Cause_Ric_REQUEST_ID_UNKNOWN                             Error_Cause_Ric_Type = 7
	Error_Cause_Ric_INCONSISTENT_ACTION_SUBSEQUENT_ACTION_SEQUENCE Error_Cause_Ric_Type = 8
	Error_Cause_Ric_CONTROL_MESSAGE_INVALID                        Error_Cause_Ric_Type = 9
	Error_Cause_Ric_CALL_PROCESS_ID_INVALID                        Error_Cause_Ric_Type = 10
)

func (Error_Cause_Ric_Type) EnumDescriptor 

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

func (Error_Cause_Ric_Type) String 

func (x Error_Cause_Ric_Type) String() string

type Error_Cause_Transport 

type Error_Cause_Transport struct {
	Type Error_Cause_Transport_Type `protobuf:"varint,1,opt,name=type,proto3,enum=onos.e2t.e2.v1beta1.Error_Cause_Transport_Type" json:"type,omitempty"`
}

func (*Error_Cause_Transport) Descriptor 

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

func (*Error_Cause_Transport) GetType 

func (m *Error_Cause_Transport) GetType() Error_Cause_Transport_Type

func (*Error_Cause_Transport) Marshal 

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

func (*Error_Cause_Transport) MarshalTo 

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

func (*Error_Cause_Transport) MarshalToSizedBuffer 

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

func (*Error_Cause_Transport) ProtoMessage 

func (*Error_Cause_Transport) ProtoMessage()

func (*Error_Cause_Transport) Reset 

func (m *Error_Cause_Transport) Reset()

func (*Error_Cause_Transport) Size 

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

func (*Error_Cause_Transport) String 

func (m *Error_Cause_Transport) String() string

func (*Error_Cause_Transport) Unmarshal 

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

func (*Error_Cause_Transport) XXX_DiscardUnknown 

func (m *Error_Cause_Transport) XXX_DiscardUnknown()

func (*Error_Cause_Transport) XXX_Marshal 

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

func (*Error_Cause_Transport) XXX_Merge 

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

func (*Error_Cause_Transport) XXX_Size 

func (m *Error_Cause_Transport) XXX_Size() int

func (*Error_Cause_Transport) XXX_Unmarshal 

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

type Error_Cause_Transport_ 

type Error_Cause_Transport_ struct {
	Transport *Error_Cause_Transport `protobuf:"bytes,5,opt,name=transport,proto3,oneof" json:"transport,omitempty"`
}

func (*Error_Cause_Transport_) MarshalTo 

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

func (*Error_Cause_Transport_) MarshalToSizedBuffer 

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

func (*Error_Cause_Transport_) Size 

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

type Error_Cause_Transport_Type 

type Error_Cause_Transport_Type int32
const (
	Error_Cause_Transport_UNSPECIFIED                    Error_Cause_Transport_Type = 0
	Error_Cause_Transport_TRANSPORT_RESOURCE_UNAVAILABLE Error_Cause_Transport_Type = 1
)

func (Error_Cause_Transport_Type) EnumDescriptor 

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

func (Error_Cause_Transport_Type) String 

func (x Error_Cause_Transport_Type) String() string

type Error_Cause_Unknown 

type Error_Cause_Unknown struct {
}

func (*Error_Cause_Unknown) Descriptor 

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

func (*Error_Cause_Unknown) Marshal 

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

func (*Error_Cause_Unknown) MarshalTo 

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

func (*Error_Cause_Unknown) MarshalToSizedBuffer 

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

func (*Error_Cause_Unknown) ProtoMessage 

func (*Error_Cause_Unknown) ProtoMessage()

func (*Error_Cause_Unknown) Reset 

func (m *Error_Cause_Unknown) Reset()

func (*Error_Cause_Unknown) Size 

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

func (*Error_Cause_Unknown) String 

func (m *Error_Cause_Unknown) String() string

func (*Error_Cause_Unknown) Unmarshal 

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

func (*Error_Cause_Unknown) XXX_DiscardUnknown 

func (m *Error_Cause_Unknown) XXX_DiscardUnknown()

func (*Error_Cause_Unknown) XXX_Marshal 

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

func (*Error_Cause_Unknown) XXX_Merge 

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

func (*Error_Cause_Unknown) XXX_Size 

func (m *Error_Cause_Unknown) XXX_Size() int

func (*Error_Cause_Unknown) XXX_Unmarshal 

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

type Error_Cause_Unknown_ 

type Error_Cause_Unknown_ struct {
	Unknown *Error_Cause_Unknown `protobuf:"bytes,1,opt,name=unknown,proto3,oneof" json:"unknown,omitempty"`
}

func (*Error_Cause_Unknown_) MarshalTo 

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

func (*Error_Cause_Unknown_) MarshalToSizedBuffer 

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

func (*Error_Cause_Unknown_) Size 

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

type EventTrigger 

type EventTrigger struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*EventTrigger) Descriptor 

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

func (*EventTrigger) GetPayload 

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

func (*EventTrigger) Marshal 

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

func (*EventTrigger) MarshalTo 

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

func (*EventTrigger) MarshalToSizedBuffer 

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

func (*EventTrigger) ProtoMessage 

func (*EventTrigger) ProtoMessage()

func (*EventTrigger) Reset 

func (m *EventTrigger) Reset()

func (*EventTrigger) Size 

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

func (*EventTrigger) String 

func (m *EventTrigger) String() string

func (*EventTrigger) Unmarshal 

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

func (*EventTrigger) XXX_DiscardUnknown 

func (m *EventTrigger) XXX_DiscardUnknown()

func (*EventTrigger) XXX_Marshal 

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

func (*EventTrigger) XXX_Merge 

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

func (*EventTrigger) XXX_Size 

func (m *EventTrigger) XXX_Size() int

func (*EventTrigger) XXX_Unmarshal 

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

type Indication 

type Indication struct {
	Header  []byte `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*Indication) Descriptor 

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

func (*Indication) GetHeader 

func (m *Indication) GetHeader() []byte

func (*Indication) GetPayload 

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

func (*Indication) Marshal 

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

func (*Indication) MarshalTo 

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

func (*Indication) MarshalToSizedBuffer 

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

func (*Indication) ProtoMessage 

func (*Indication) ProtoMessage()

func (*Indication) Reset 

func (m *Indication) Reset()

func (*Indication) Size 

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

func (*Indication) String 

func (m *Indication) String() string

func (*Indication) Unmarshal 

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

func (*Indication) XXX_DiscardUnknown 

func (m *Indication) XXX_DiscardUnknown()

func (*Indication) XXX_Marshal 

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

func (*Indication) XXX_Merge 

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

func (*Indication) XXX_Size 

func (m *Indication) XXX_Size() int

func (*Indication) XXX_Unmarshal 

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

type InstanceID 

type InstanceID string

InstanceID is an xApp instance identifier

type NodeID 

type NodeID string

NodeID is an E2 node identifier

type RequestHeaders 

type RequestHeaders struct {
	AppID        AppID        `protobuf:"bytes,1,opt,name=app_id,json=appId,proto3,casttype=AppID" json:"app_id,omitempty"`
	InstanceID   InstanceID   `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3,casttype=InstanceID" json:"instance_id,omitempty"`
	NodeID       NodeID       `protobuf:"bytes,3,opt,name=node_id,json=nodeId,proto3,casttype=NodeID" json:"node_id,omitempty"`
	ServiceModel ServiceModel `protobuf:"bytes,4,opt,name=service_model,json=serviceModel,proto3" json:"service_model"`
	Encoding     Encoding     `protobuf:"varint,5,opt,name=encoding,proto3,enum=onos.e2t.e2.v1beta1.Encoding" json:"encoding,omitempty"`
}

func (*RequestHeaders) Descriptor 

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

func (*RequestHeaders) GetAppID 

func (m *RequestHeaders) GetAppID() AppID

func (*RequestHeaders) GetEncoding 

func (m *RequestHeaders) GetEncoding() Encoding

func (*RequestHeaders) GetInstanceID 

func (m *RequestHeaders) GetInstanceID() InstanceID

func (*RequestHeaders) GetNodeID 

func (m *RequestHeaders) GetNodeID() NodeID

func (*RequestHeaders) GetServiceModel 

func (m *RequestHeaders) GetServiceModel() ServiceModel

func (*RequestHeaders) Marshal 

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

func (*RequestHeaders) MarshalTo 

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

func (*RequestHeaders) MarshalToSizedBuffer 

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

func (*RequestHeaders) ProtoMessage 

func (*RequestHeaders) ProtoMessage()

func (*RequestHeaders) Reset 

func (m *RequestHeaders) Reset()

func (*RequestHeaders) Size 

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

func (*RequestHeaders) String 

func (m *RequestHeaders) String() string

func (*RequestHeaders) Unmarshal 

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

func (*RequestHeaders) XXX_DiscardUnknown 

func (m *RequestHeaders) XXX_DiscardUnknown()

func (*RequestHeaders) XXX_Marshal 

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

func (*RequestHeaders) XXX_Merge 

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

func (*RequestHeaders) XXX_Size 

func (m *RequestHeaders) XXX_Size() int

func (*RequestHeaders) XXX_Unmarshal 

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

type ResponseHeaders 

type ResponseHeaders struct {
	Encoding Encoding `protobuf:"varint,1,opt,name=encoding,proto3,enum=onos.e2t.e2.v1beta1.Encoding" json:"encoding,omitempty"`
}

func (*ResponseHeaders) Descriptor 

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

func (*ResponseHeaders) GetEncoding 

func (m *ResponseHeaders) GetEncoding() Encoding

func (*ResponseHeaders) Marshal 

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

func (*ResponseHeaders) MarshalTo 

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

func (*ResponseHeaders) MarshalToSizedBuffer 

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

func (*ResponseHeaders) ProtoMessage 

func (*ResponseHeaders) ProtoMessage()

func (*ResponseHeaders) Reset 

func (m *ResponseHeaders) Reset()

func (*ResponseHeaders) Size 

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

func (*ResponseHeaders) String 

func (m *ResponseHeaders) String() string

func (*ResponseHeaders) Unmarshal 

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

func (*ResponseHeaders) XXX_DiscardUnknown 

func (m *ResponseHeaders) XXX_DiscardUnknown()

func (*ResponseHeaders) XXX_Marshal 

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

func (*ResponseHeaders) XXX_Merge 

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

func (*ResponseHeaders) XXX_Size 

func (m *ResponseHeaders) XXX_Size() int

func (*ResponseHeaders) XXX_Unmarshal 

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

type ServiceModel 

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"`
}

func (*ServiceModel) Descriptor 

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

func (*ServiceModel) GetName 

func (m *ServiceModel) GetName() ServiceModelName

func (*ServiceModel) GetVersion 

func (m *ServiceModel) GetVersion() ServiceModelVersion

func (*ServiceModel) Marshal 

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

func (*ServiceModel) MarshalTo 

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

func (*ServiceModel) MarshalToSizedBuffer 

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

func (*ServiceModel) ProtoMessage 

func (*ServiceModel) ProtoMessage()

func (*ServiceModel) Reset 

func (m *ServiceModel) Reset()

func (*ServiceModel) Size 

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

func (*ServiceModel) String 

func (m *ServiceModel) String() string

func (*ServiceModel) Unmarshal 

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

func (*ServiceModel) XXX_DiscardUnknown 

func (m *ServiceModel) XXX_DiscardUnknown()

func (*ServiceModel) XXX_Marshal 

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

func (*ServiceModel) XXX_Merge 

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

func (*ServiceModel) XXX_Size 

func (m *ServiceModel) XXX_Size() int

func (*ServiceModel) XXX_Unmarshal 

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

type ServiceModelName 

type ServiceModelName string

ServiceModelName is a service model name

type ServiceModelVersion 

type ServiceModelVersion string

ServiceModelVersion is a service model version name

type SubscribeRequest 

type SubscribeRequest struct {
	Headers      RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"`
	Subscription Subscription   `protobuf:"bytes,2,opt,name=subscription,proto3" json:"subscription"`
}

func (*SubscribeRequest) Descriptor 

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

func (*SubscribeRequest) GetHeaders 

func (m *SubscribeRequest) GetHeaders() RequestHeaders

func (*SubscribeRequest) GetSubscription 

func (m *SubscribeRequest) GetSubscription() Subscription

func (*SubscribeRequest) Marshal 

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

func (*SubscribeRequest) MarshalTo 

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

func (*SubscribeRequest) MarshalToSizedBuffer 

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

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset 

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) Size 

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

func (*SubscribeRequest) String 

func (m *SubscribeRequest) String() string

func (*SubscribeRequest) Unmarshal 

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

func (*SubscribeRequest) XXX_DiscardUnknown 

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal 

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

func (*SubscribeRequest) XXX_Merge 

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

func (*SubscribeRequest) XXX_Size 

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal 

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

type SubscribeResponse 

type SubscribeResponse struct {
	Headers ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"`
	// Types that are valid to be assigned to Message:
	//	*SubscribeResponse_Ack
	//	*SubscribeResponse_Indication
	Message isSubscribeResponse_Message `protobuf_oneof:"message"`
}

func (*SubscribeResponse) Descriptor 

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

func (*SubscribeResponse) GetAck 

func (m *SubscribeResponse) GetAck() *Acknowledgement

func (*SubscribeResponse) GetHeaders 

func (m *SubscribeResponse) GetHeaders() ResponseHeaders

func (*SubscribeResponse) GetIndication 

func (m *SubscribeResponse) GetIndication() *Indication

func (*SubscribeResponse) GetMessage 

func (m *SubscribeResponse) GetMessage() isSubscribeResponse_Message

func (*SubscribeResponse) Marshal 

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

func (*SubscribeResponse) MarshalTo 

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

func (*SubscribeResponse) MarshalToSizedBuffer 

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

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) Reset 

func (m *SubscribeResponse) Reset()

func (*SubscribeResponse) Size 

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

func (*SubscribeResponse) String 

func (m *SubscribeResponse) String() string

func (*SubscribeResponse) Unmarshal 

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

func (*SubscribeResponse) XXX_DiscardUnknown 

func (m *SubscribeResponse) XXX_DiscardUnknown()

func (*SubscribeResponse) XXX_Marshal 

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

func (*SubscribeResponse) XXX_Merge 

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

func (*SubscribeResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*SubscribeResponse) XXX_Size 

func (m *SubscribeResponse) XXX_Size() int

func (*SubscribeResponse) XXX_Unmarshal 

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

type SubscribeResponse_Ack 

type SubscribeResponse_Ack struct {
	Ack *Acknowledgement `protobuf:"bytes,2,opt,name=ack,proto3,oneof" json:"ack,omitempty"`
}

func (*SubscribeResponse_Ack) MarshalTo 

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

func (*SubscribeResponse_Ack) MarshalToSizedBuffer 

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

func (*SubscribeResponse_Ack) Size 

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

type SubscribeResponse_Indication 

type SubscribeResponse_Indication struct {
	Indication *Indication `protobuf:"bytes,3,opt,name=indication,proto3,oneof" json:"indication,omitempty"`
}

func (*SubscribeResponse_Indication) MarshalTo 

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

func (*SubscribeResponse_Indication) MarshalToSizedBuffer 

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

func (*SubscribeResponse_Indication) Size 

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

type Subscription 

type Subscription struct {
	ID           SubscriptionID `protobuf:"bytes,1,opt,name=id,proto3,casttype=SubscriptionID" json:"id,omitempty"`
	EventTrigger EventTrigger   `protobuf:"bytes,2,opt,name=event_trigger,json=eventTrigger,proto3" json:"event_trigger"`
	Actions      []Action       `protobuf:"bytes,3,rep,name=actions,proto3" json:"actions"`
}

func (*Subscription) Descriptor 

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

func (*Subscription) GetActions 

func (m *Subscription) GetActions() []Action

func (*Subscription) GetEventTrigger 

func (m *Subscription) GetEventTrigger() EventTrigger

func (*Subscription) GetID 

func (m *Subscription) GetID() SubscriptionID

func (*Subscription) Marshal 

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

func (*Subscription) MarshalTo 

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

func (*Subscription) MarshalToSizedBuffer 

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

func (*Subscription) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) Reset 

func (m *Subscription) Reset()

func (*Subscription) Size 

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

func (*Subscription) String 

func (m *Subscription) String() string

func (*Subscription) Unmarshal 

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

func (*Subscription) XXX_DiscardUnknown 

func (m *Subscription) XXX_DiscardUnknown()

func (*Subscription) XXX_Marshal 

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

func (*Subscription) XXX_Merge 

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

func (*Subscription) XXX_Size 

func (m *Subscription) XXX_Size() int

func (*Subscription) XXX_Unmarshal 

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

type SubscriptionID 

type SubscriptionID string

SubscriptionID is an E2AP subscription identifier

type SubscriptionServiceClient 

type SubscriptionServiceClient interface {
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (SubscriptionService_SubscribeClient, error)
}

SubscriptionServiceClient is the client API for SubscriptionService service.

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

func NewSubscriptionServiceClient 

func NewSubscriptionServiceClient(cc *grpc.ClientConn) SubscriptionServiceClient

type SubscriptionServiceServer 

type SubscriptionServiceServer interface {
	Subscribe(*SubscribeRequest, SubscriptionService_SubscribeServer) error
}

SubscriptionServiceServer is the server API for SubscriptionService service.

type SubscriptionService_SubscribeClient 

type SubscriptionService_SubscribeClient interface {
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type SubscriptionService_SubscribeServer 

type SubscriptionService_SubscribeServer interface {
	Send(*SubscribeResponse) error
	grpc.ServerStream
}

type SubsequentAction 

type SubsequentAction struct {
	Type       SubsequentActionType `protobuf:"varint,1,opt,name=type,proto3,enum=onos.e2t.e2.v1beta1.SubsequentActionType" json:"type,omitempty"`
	TimeToWait TimeToWait           `` /* 130-byte string literal not displayed */
}

func (*SubsequentAction) Descriptor 

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

func (*SubsequentAction) GetTimeToWait 

func (m *SubsequentAction) GetTimeToWait() TimeToWait

func (*SubsequentAction) GetType 

func (m *SubsequentAction) GetType() SubsequentActionType

func (*SubsequentAction) Marshal 

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

func (*SubsequentAction) MarshalTo 

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

func (*SubsequentAction) MarshalToSizedBuffer 

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

func (*SubsequentAction) ProtoMessage 

func (*SubsequentAction) ProtoMessage()

func (*SubsequentAction) Reset 

func (m *SubsequentAction) Reset()

func (*SubsequentAction) Size 

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

func (*SubsequentAction) String 

func (m *SubsequentAction) String() string

func (*SubsequentAction) Unmarshal 

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

func (*SubsequentAction) XXX_DiscardUnknown 

func (m *SubsequentAction) XXX_DiscardUnknown()

func (*SubsequentAction) XXX_Marshal 

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

func (*SubsequentAction) XXX_Merge 

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

func (*SubsequentAction) XXX_Size 

func (m *SubsequentAction) XXX_Size() int

func (*SubsequentAction) XXX_Unmarshal 

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

type SubsequentActionType 

type SubsequentActionType int32
const (
	SubsequentActionType_SUBSEQUENT_ACTION_TYPE_CONTINUE SubsequentActionType = 0
	SubsequentActionType_SUBSEQUENT_ACTION_TYPE_WAIT     SubsequentActionType = 1
)

func (SubsequentActionType) EnumDescriptor 

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

func (SubsequentActionType) String 

func (x SubsequentActionType) String() string

type TimeToWait 

type TimeToWait int32
const (
	TimeToWait_TIME_TO_WAIT_ZERO   TimeToWait = 0
	TimeToWait_TIME_TO_WAIT_W1MS   TimeToWait = 1
	TimeToWait_TIME_TO_WAIT_W2MS   TimeToWait = 2
	TimeToWait_TIME_TO_WAIT_W5MS   TimeToWait = 3
	TimeToWait_TIME_TO_WAIT_W10MS  TimeToWait = 4
	TimeToWait_TIME_TO_WAIT_W20MS  TimeToWait = 5
	TimeToWait_TIME_TO_WAIT_W30MS  TimeToWait = 6
	TimeToWait_TIME_TO_WAIT_W40MS  TimeToWait = 7
	TimeToWait_TIME_TO_WAIT_W50MS  TimeToWait = 8
	TimeToWait_TIME_TO_WAIT_W100MS TimeToWait = 9
	TimeToWait_TIME_TO_WAIT_W200MS TimeToWait = 10
	TimeToWait_TIME_TO_WAIT_W500MS TimeToWait = 11
	TimeToWait_TIME_TO_WAIT_W1S    TimeToWait = 12
	TimeToWait_TIME_TO_WAIT_W2S    TimeToWait = 13
	TimeToWait_TIME_TO_WAIT_W5S    TimeToWait = 14
	TimeToWait_TIME_TO_WAIT_W10S   TimeToWait = 15
	TimeToWait_TIME_TO_WAIT_W20S   TimeToWait = 16
	TimeToWait_TIME_TO_WAIT_W60S   TimeToWait = 17
)

func (TimeToWait) EnumDescriptor 

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

func (TimeToWait) String 

func (x TimeToWait) String() string

type UnimplementedControlServiceServer 

type UnimplementedControlServiceServer struct {
}

UnimplementedControlServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedControlServiceServer) Control 

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

type UnimplementedSubscriptionServiceServer 

type UnimplementedSubscriptionServiceServer struct {
}

UnimplementedSubscriptionServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSubscriptionServiceServer) Subscribe 

func (*UnimplementedSubscriptionServiceServer) Subscribe(req *SubscribeRequest, srv SubscriptionService_SubscribeServer) 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.