v1beta1

package
v0.7.105 Latest Latest
Warning

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

 Go to latest Published: Oct 11, 2021 License: Apache-2.0 Imports: 13 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 ChannelEventType_name = map[int32]string{
	0: "CHANNEL_EVENT_UNKNOWN",
	1: "CHANNEL_CREATED",
	2: "CHANNEL_UPDATED",
	3: "CHANNEL_DELETED",
	4: "CHANNEL_REPLAYED",
}
View Source 
var ChannelEventType_value = map[string]int32{
	"CHANNEL_EVENT_UNKNOWN": 0,
	"CHANNEL_CREATED":       1,
	"CHANNEL_UPDATED":       2,
	"CHANNEL_DELETED":       3,
	"CHANNEL_REPLAYED":      4,
}
View Source 
var ChannelPhase_name = map[int32]string{
	0: "CHANNEL_CLOSED",
	1: "CHANNEL_OPEN",
}
View Source 
var ChannelPhase_value = map[string]int32{
	"CHANNEL_CLOSED": 0,
	"CHANNEL_OPEN":   1,
}
View Source 
var ChannelState_name = map[int32]string{
	0: "CHANNEL_PENDING",
	1: "CHANNEL_COMPLETE",
	2: "CHANNEL_FAILED",
}
View Source 
var ChannelState_value = map[string]int32{
	"CHANNEL_PENDING":  0,
	"CHANNEL_COMPLETE": 1,
	"CHANNEL_FAILED":   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 SubscriptionEventType_name = map[int32]string{
	0: "SUBSCRIPTION_EVENT_UNKNOWN",
	1: "SUBSCRIPTION_CREATED",
	2: "SUBSCRIPTION_UPDATED",
	3: "SUBSCRIPTION_DELETED",
	4: "SUBSCRIPTION_REPLAYED",
}
View Source 
var SubscriptionEventType_value = map[string]int32{
	"SUBSCRIPTION_EVENT_UNKNOWN": 0,
	"SUBSCRIPTION_CREATED":       1,
	"SUBSCRIPTION_UPDATED":       2,
	"SUBSCRIPTION_DELETED":       3,
	"SUBSCRIPTION_REPLAYED":      4,
}
View Source 
var SubscriptionPhase_name = map[int32]string{
	0: "SUBSCRIPTION_CLOSED",
	1: "SUBSCRIPTION_OPEN",
}
View Source 
var SubscriptionPhase_value = map[string]int32{
	"SUBSCRIPTION_CLOSED": 0,
	"SUBSCRIPTION_OPEN":   1,
}
View Source 
var SubscriptionState_name = map[int32]string{
	0: "SUBSCRIPTION_PENDING",
	1: "SUBSCRIPTION_COMPLETE",
	2: "SUBSCRIPTION_FAILED",
}
View Source 
var SubscriptionState_value = map[string]int32{
	"SUBSCRIPTION_PENDING":  0,
	"SUBSCRIPTION_COMPLETE": 1,
	"SUBSCRIPTION_FAILED":   2,
}
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 RegisterSubscriptionAdminServiceServer added in v0.7.62 

func RegisterSubscriptionAdminServiceServer(s *grpc.Server, srv SubscriptionAdminServiceServer)

func RegisterSubscriptionServiceServer 

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

Types

type Acknowledgement 

type Acknowledgement struct {
	ChannelID ChannelID `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3,casttype=ChannelID" json:"channel_id,omitempty"`
}

func (*Acknowledgement) Descriptor 

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

func (*Acknowledgement) GetChannelID added in v0.7.62 

func (m *Acknowledgement) GetChannelID() ChannelID

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 AppInstanceID added in v0.7.62 

type AppInstanceID string

AppInstanceID is an xApp instance identifier

type Channel added in v0.7.62 

type Channel struct {
	ID          ChannelID `protobuf:"bytes,1,opt,name=id,proto3,casttype=ChannelID" json:"id,omitempty"`
	ChannelMeta `protobuf:"bytes,2,opt,name=meta,proto3,embedded=meta" json:"meta"`
	Spec        ChannelSpec   `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec"`
	Status      ChannelStatus `protobuf:"bytes,4,opt,name=status,proto3" json:"status"`
}

func (*Channel) Descriptor added in v0.7.62 

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

func (*Channel) GetID added in v0.7.62 

func (m *Channel) GetID() ChannelID

func (*Channel) GetSpec added in v0.7.62 

func (m *Channel) GetSpec() ChannelSpec

func (*Channel) GetStatus added in v0.7.62 

func (m *Channel) GetStatus() ChannelStatus

func (*Channel) Marshal added in v0.7.62 

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

func (*Channel) MarshalTo added in v0.7.62 

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

func (*Channel) MarshalToSizedBuffer added in v0.7.62 

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

func (*Channel) ProtoMessage added in v0.7.62 

func (*Channel) ProtoMessage()

func (*Channel) Reset added in v0.7.62 

func (m *Channel) Reset()

func (*Channel) Size added in v0.7.62 

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

func (*Channel) String added in v0.7.62 

func (m *Channel) String() string

func (*Channel) Unmarshal added in v0.7.62 

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

func (*Channel) XXX_DiscardUnknown added in v0.7.62 

func (m *Channel) XXX_DiscardUnknown()

func (*Channel) XXX_Marshal added in v0.7.62 

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

func (*Channel) XXX_Merge added in v0.7.62 

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

func (*Channel) XXX_Size added in v0.7.62 

func (m *Channel) XXX_Size() int

func (*Channel) XXX_Unmarshal added in v0.7.62 

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

type ChannelEvent added in v0.7.62 

type ChannelEvent struct {
	Type    ChannelEventType `protobuf:"varint,1,opt,name=type,proto3,enum=onos.e2t.e2.v1beta1.ChannelEventType" json:"type,omitempty"`
	Channel Channel          `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel"`
}

func (*ChannelEvent) Descriptor added in v0.7.62 

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

func (*ChannelEvent) GetChannel added in v0.7.62 

func (m *ChannelEvent) GetChannel() Channel

func (*ChannelEvent) GetType added in v0.7.62 

func (m *ChannelEvent) GetType() ChannelEventType

func (*ChannelEvent) Marshal added in v0.7.62 

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

func (*ChannelEvent) MarshalTo added in v0.7.62 

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

func (*ChannelEvent) MarshalToSizedBuffer added in v0.7.62 

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

func (*ChannelEvent) ProtoMessage added in v0.7.62 

func (*ChannelEvent) ProtoMessage()

func (*ChannelEvent) Reset added in v0.7.62 

func (m *ChannelEvent) Reset()

func (*ChannelEvent) Size added in v0.7.62 

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

func (*ChannelEvent) String added in v0.7.62 

func (m *ChannelEvent) String() string

func (*ChannelEvent) Unmarshal added in v0.7.62 

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

func (*ChannelEvent) XXX_DiscardUnknown added in v0.7.62 

func (m *ChannelEvent) XXX_DiscardUnknown()

func (*ChannelEvent) XXX_Marshal added in v0.7.62 

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

func (*ChannelEvent) XXX_Merge added in v0.7.62 

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

func (*ChannelEvent) XXX_Size added in v0.7.62 

func (m *ChannelEvent) XXX_Size() int

func (*ChannelEvent) XXX_Unmarshal added in v0.7.62 

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

type ChannelEventType added in v0.7.62 

type ChannelEventType int32
const (
	ChannelEventType_CHANNEL_EVENT_UNKNOWN ChannelEventType = 0
	ChannelEventType_CHANNEL_CREATED       ChannelEventType = 1
	ChannelEventType_CHANNEL_UPDATED       ChannelEventType = 2
	ChannelEventType_CHANNEL_DELETED       ChannelEventType = 3
	ChannelEventType_CHANNEL_REPLAYED      ChannelEventType = 4
)

func (ChannelEventType) EnumDescriptor added in v0.7.62 

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

func (ChannelEventType) String added in v0.7.62 

func (x ChannelEventType) String() string

type ChannelID added in v0.7.62 

type ChannelID string

ChannelID is a subscription channel identifier

type ChannelMeta added in v0.7.62 

type ChannelMeta struct {
	// app_id is an identifier for the application that created the channel shared across all instances of the application
	AppID AppID `protobuf:"bytes,1,opt,name=app_id,json=appId,proto3,casttype=AppID" json:"app_id,omitempty"`
	// app_instance_id is an identifier unique to a single node within the application that created the channel
	AppInstanceID AppInstanceID `protobuf:"bytes,2,opt,name=app_instance_id,json=appInstanceId,proto3,casttype=AppInstanceID" json:"app_instance_id,omitempty"`
	// e2_node_id is the identifier for the E2 node to which the subscription is targeted
	E2NodeID E2NodeID `protobuf:"bytes,3,opt,name=e2_node_id,json=e2NodeId,proto3,casttype=E2NodeID" json:"e2_node_id,omitempty"`
	// transaction_id is a persistent identifier for the transaction
	TransactionID TransactionID `protobuf:"bytes,4,opt,name=transaction_id,json=transactionId,proto3,casttype=TransactionID" json:"transaction_id,omitempty"`
	// subscription_id is the identifier for the underlying subscription
	SubscriptionID SubscriptionID `` /* 127-byte string literal not displayed */
	// service_model is the service model specification
	ServiceModel ServiceModel `protobuf:"bytes,6,opt,name=service_model,json=serviceModel,proto3" json:"service_model"`
	// encoding indicates the type of encoding used within the parent message
	Encoding Encoding `protobuf:"varint,7,opt,name=encoding,proto3,enum=onos.e2t.e2.v1beta1.Encoding" json:"encoding,omitempty"`
	Revision Revision `protobuf:"varint,8,opt,name=revision,proto3,casttype=Revision" json:"revision,omitempty"`
}

ChannelMeta contains metadata relating to a subscription channel

func (*ChannelMeta) Descriptor added in v0.7.62 

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

func (*ChannelMeta) GetAppID added in v0.7.62 

func (m *ChannelMeta) GetAppID() AppID

func (*ChannelMeta) GetAppInstanceID added in v0.7.62 

func (m *ChannelMeta) GetAppInstanceID() AppInstanceID

func (*ChannelMeta) GetE2NodeID added in v0.7.62 

func (m *ChannelMeta) GetE2NodeID() E2NodeID

func (*ChannelMeta) GetEncoding added in v0.7.62 

func (m *ChannelMeta) GetEncoding() Encoding

func (*ChannelMeta) GetRevision added in v0.7.62 

func (m *ChannelMeta) GetRevision() Revision

func (*ChannelMeta) GetServiceModel added in v0.7.62 

func (m *ChannelMeta) GetServiceModel() ServiceModel

func (*ChannelMeta) GetSubscriptionID added in v0.7.62 

func (m *ChannelMeta) GetSubscriptionID() SubscriptionID

func (*ChannelMeta) GetTransactionID added in v0.7.62 

func (m *ChannelMeta) GetTransactionID() TransactionID

func (*ChannelMeta) Marshal added in v0.7.62 

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

func (*ChannelMeta) MarshalTo added in v0.7.62 

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

func (*ChannelMeta) MarshalToSizedBuffer added in v0.7.62 

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

func (*ChannelMeta) ProtoMessage added in v0.7.62 

func (*ChannelMeta) ProtoMessage()

func (*ChannelMeta) Reset added in v0.7.62 

func (m *ChannelMeta) Reset()

func (*ChannelMeta) Size added in v0.7.62 

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

func (*ChannelMeta) String added in v0.7.62 

func (m *ChannelMeta) String() string

func (*ChannelMeta) Unmarshal added in v0.7.62 

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

func (*ChannelMeta) XXX_DiscardUnknown added in v0.7.62 

func (m *ChannelMeta) XXX_DiscardUnknown()

func (*ChannelMeta) XXX_Marshal added in v0.7.62 

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

func (*ChannelMeta) XXX_Merge added in v0.7.62 

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

func (*ChannelMeta) XXX_Size added in v0.7.62 

func (m *ChannelMeta) XXX_Size() int

func (*ChannelMeta) XXX_Unmarshal added in v0.7.62 

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

type ChannelPhase added in v0.7.62 

type ChannelPhase int32
const (
	ChannelPhase_CHANNEL_CLOSED ChannelPhase = 0
	ChannelPhase_CHANNEL_OPEN   ChannelPhase = 1
)

func (ChannelPhase) EnumDescriptor added in v0.7.62 

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

func (ChannelPhase) String added in v0.7.62 

func (x ChannelPhase) String() string

type ChannelSpec added in v0.7.62 

type ChannelSpec struct {
	SubscriptionSpec   `protobuf:"bytes,1,opt,name=subscription,proto3,embedded=subscription" json:"subscription"`
	TransactionTimeout *time.Duration `` /* 127-byte string literal not displayed */
}

func (*ChannelSpec) Descriptor added in v0.7.62 

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

func (*ChannelSpec) GetTransactionTimeout added in v0.7.94 

func (m *ChannelSpec) GetTransactionTimeout() *time.Duration

func (*ChannelSpec) Marshal added in v0.7.62 

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

func (*ChannelSpec) MarshalTo added in v0.7.62 

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

func (*ChannelSpec) MarshalToSizedBuffer added in v0.7.62 

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

func (*ChannelSpec) ProtoMessage added in v0.7.62 

func (*ChannelSpec) ProtoMessage()

func (*ChannelSpec) Reset added in v0.7.62 

func (m *ChannelSpec) Reset()

func (*ChannelSpec) Size added in v0.7.62 

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

func (*ChannelSpec) String added in v0.7.62 

func (m *ChannelSpec) String() string

func (*ChannelSpec) Unmarshal added in v0.7.62 

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

func (*ChannelSpec) XXX_DiscardUnknown added in v0.7.62 

func (m *ChannelSpec) XXX_DiscardUnknown()

func (*ChannelSpec) XXX_Marshal added in v0.7.62 

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

func (*ChannelSpec) XXX_Merge added in v0.7.62 

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

func (*ChannelSpec) XXX_Size added in v0.7.62 

func (m *ChannelSpec) XXX_Size() int

func (*ChannelSpec) XXX_Unmarshal added in v0.7.62 

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

type ChannelState added in v0.7.62 

type ChannelState int32
const (
	// CHANNEL_PENDING indicates the channel phase is pending
	ChannelState_CHANNEL_PENDING ChannelState = 0
	// CHANNEL_COMPLETE indicates the channel phase is complete
	ChannelState_CHANNEL_COMPLETE ChannelState = 1
	// CHANNEL_FAILED indicates the channel phase failed
	ChannelState_CHANNEL_FAILED ChannelState = 2
)

func (ChannelState) EnumDescriptor added in v0.7.62 

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

func (ChannelState) String added in v0.7.62 

func (x ChannelState) String() string

type ChannelStatus added in v0.7.62 

type ChannelStatus struct {
	Phase     ChannelPhase `protobuf:"varint,1,opt,name=phase,proto3,enum=onos.e2t.e2.v1beta1.ChannelPhase" json:"phase,omitempty"`
	State     ChannelState `protobuf:"varint,2,opt,name=state,proto3,enum=onos.e2t.e2.v1beta1.ChannelState" json:"state,omitempty"`
	Error     *Error       `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	Timestamp *time.Time   `protobuf:"bytes,4,opt,name=timestamp,proto3,stdtime" json:"timestamp,omitempty"`
	Term      uint64       `protobuf:"varint,5,opt,name=term,proto3" json:"term,omitempty"`
	Master    string       `protobuf:"bytes,6,opt,name=master,proto3" json:"master,omitempty"`
}

func (*ChannelStatus) Descriptor added in v0.7.62 

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

func (*ChannelStatus) GetError added in v0.7.62 

func (m *ChannelStatus) GetError() *Error

func (*ChannelStatus) GetMaster added in v0.7.105 

func (m *ChannelStatus) GetMaster() string

func (*ChannelStatus) GetPhase added in v0.7.62 

func (m *ChannelStatus) GetPhase() ChannelPhase

func (*ChannelStatus) GetState added in v0.7.62 

func (m *ChannelStatus) GetState() ChannelState

func (*ChannelStatus) GetTerm added in v0.7.92 

func (m *ChannelStatus) GetTerm() uint64

func (*ChannelStatus) GetTimestamp added in v0.7.92 

func (m *ChannelStatus) GetTimestamp() *time.Time

func (*ChannelStatus) Marshal added in v0.7.62 

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

func (*ChannelStatus) MarshalTo added in v0.7.62 

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

func (*ChannelStatus) MarshalToSizedBuffer added in v0.7.62 

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

func (*ChannelStatus) ProtoMessage added in v0.7.62 

func (*ChannelStatus) ProtoMessage()

func (*ChannelStatus) Reset added in v0.7.62 

func (m *ChannelStatus) Reset()

func (*ChannelStatus) Size added in v0.7.62 

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

func (*ChannelStatus) String added in v0.7.62 

func (m *ChannelStatus) String() string

func (*ChannelStatus) Unmarshal added in v0.7.62 

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

func (*ChannelStatus) XXX_DiscardUnknown added in v0.7.62 

func (m *ChannelStatus) XXX_DiscardUnknown()

func (*ChannelStatus) XXX_Marshal added in v0.7.62 

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

func (*ChannelStatus) XXX_Merge added in v0.7.62 

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

func (*ChannelStatus) XXX_Size added in v0.7.62 

func (m *ChannelStatus) XXX_Size() int

func (*ChannelStatus) XXX_Unmarshal added in v0.7.62 

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

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 E2NodeID added in v0.7.62 

type E2NodeID string

E2NodeID is an E2 node identifier

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 GetChannelRequest added in v0.7.62 

type GetChannelRequest struct {
	ChannelID ChannelID `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3,casttype=ChannelID" json:"channel_id,omitempty"`
}

func (*GetChannelRequest) Descriptor added in v0.7.62 

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

func (*GetChannelRequest) GetChannelID added in v0.7.62 

func (m *GetChannelRequest) GetChannelID() ChannelID

func (*GetChannelRequest) Marshal added in v0.7.62 

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

func (*GetChannelRequest) MarshalTo added in v0.7.62 

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

func (*GetChannelRequest) MarshalToSizedBuffer added in v0.7.62 

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

func (*GetChannelRequest) ProtoMessage added in v0.7.62 

func (*GetChannelRequest) ProtoMessage()

func (*GetChannelRequest) Reset added in v0.7.62 

func (m *GetChannelRequest) Reset()

func (*GetChannelRequest) Size added in v0.7.62 

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

func (*GetChannelRequest) String added in v0.7.62 

func (m *GetChannelRequest) String() string

func (*GetChannelRequest) Unmarshal added in v0.7.62 

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

func (*GetChannelRequest) XXX_DiscardUnknown added in v0.7.62 

func (m *GetChannelRequest) XXX_DiscardUnknown()

func (*GetChannelRequest) XXX_Marshal added in v0.7.62 

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

func (*GetChannelRequest) XXX_Merge added in v0.7.62 

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

func (*GetChannelRequest) XXX_Size added in v0.7.62 

func (m *GetChannelRequest) XXX_Size() int

func (*GetChannelRequest) XXX_Unmarshal added in v0.7.62 

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

type GetChannelResponse added in v0.7.62 

type GetChannelResponse struct {
	Channel Channel `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel"`
}

func (*GetChannelResponse) Descriptor added in v0.7.62 

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

func (*GetChannelResponse) GetChannel added in v0.7.62 

func (m *GetChannelResponse) GetChannel() Channel

func (*GetChannelResponse) Marshal added in v0.7.62 

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

func (*GetChannelResponse) MarshalTo added in v0.7.62 

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

func (*GetChannelResponse) MarshalToSizedBuffer added in v0.7.62 

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

func (*GetChannelResponse) ProtoMessage added in v0.7.62 

func (*GetChannelResponse) ProtoMessage()

func (*GetChannelResponse) Reset added in v0.7.62 

func (m *GetChannelResponse) Reset()

func (*GetChannelResponse) Size added in v0.7.62 

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

func (*GetChannelResponse) String added in v0.7.62 

func (m *GetChannelResponse) String() string

func (*GetChannelResponse) Unmarshal added in v0.7.62 

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

func (*GetChannelResponse) XXX_DiscardUnknown added in v0.7.62 

func (m *GetChannelResponse) XXX_DiscardUnknown()

func (*GetChannelResponse) XXX_Marshal added in v0.7.62 

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

func (*GetChannelResponse) XXX_Merge added in v0.7.62 

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

func (*GetChannelResponse) XXX_Size added in v0.7.62 

func (m *GetChannelResponse) XXX_Size() int

func (*GetChannelResponse) XXX_Unmarshal added in v0.7.62 

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

type GetSubscriptionRequest added in v0.7.62 

type GetSubscriptionRequest struct {
	SubscriptionID SubscriptionID `` /* 127-byte string literal not displayed */
}

func (*GetSubscriptionRequest) Descriptor added in v0.7.62 

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

func (*GetSubscriptionRequest) GetSubscriptionID added in v0.7.62 

func (m *GetSubscriptionRequest) GetSubscriptionID() SubscriptionID

func (*GetSubscriptionRequest) Marshal added in v0.7.62 

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

func (*GetSubscriptionRequest) MarshalTo added in v0.7.62 

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

func (*GetSubscriptionRequest) MarshalToSizedBuffer added in v0.7.62 

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

func (*GetSubscriptionRequest) ProtoMessage added in v0.7.62 

func (*GetSubscriptionRequest) ProtoMessage()

func (*GetSubscriptionRequest) Reset added in v0.7.62 

func (m *GetSubscriptionRequest) Reset()

func (*GetSubscriptionRequest) Size added in v0.7.62 

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

func (*GetSubscriptionRequest) String added in v0.7.62 

func (m *GetSubscriptionRequest) String() string

func (*GetSubscriptionRequest) Unmarshal added in v0.7.62 

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

func (*GetSubscriptionRequest) XXX_DiscardUnknown added in v0.7.62 

func (m *GetSubscriptionRequest) XXX_DiscardUnknown()

func (*GetSubscriptionRequest) XXX_Marshal added in v0.7.62 

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

func (*GetSubscriptionRequest) XXX_Merge added in v0.7.62 

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

func (*GetSubscriptionRequest) XXX_Size added in v0.7.62 

func (m *GetSubscriptionRequest) XXX_Size() int

func (*GetSubscriptionRequest) XXX_Unmarshal added in v0.7.62 

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

type GetSubscriptionResponse added in v0.7.62 

type GetSubscriptionResponse struct {
	Subscription Subscription `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription"`
}

func (*GetSubscriptionResponse) Descriptor added in v0.7.62 

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

func (*GetSubscriptionResponse) GetSubscription added in v0.7.62 

func (m *GetSubscriptionResponse) GetSubscription() Subscription

func (*GetSubscriptionResponse) Marshal added in v0.7.62 

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

func (*GetSubscriptionResponse) MarshalTo added in v0.7.62 

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

func (*GetSubscriptionResponse) MarshalToSizedBuffer added in v0.7.62 

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

func (*GetSubscriptionResponse) ProtoMessage added in v0.7.62 

func (*GetSubscriptionResponse) ProtoMessage()

func (*GetSubscriptionResponse) Reset added in v0.7.62 

func (m *GetSubscriptionResponse) Reset()

func (*GetSubscriptionResponse) Size added in v0.7.62 

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

func (*GetSubscriptionResponse) String added in v0.7.62 

func (m *GetSubscriptionResponse) String() string

func (*GetSubscriptionResponse) Unmarshal added in v0.7.62 

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

func (*GetSubscriptionResponse) XXX_DiscardUnknown added in v0.7.62 

func (m *GetSubscriptionResponse) XXX_DiscardUnknown()

func (*GetSubscriptionResponse) XXX_Marshal added in v0.7.62 

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

func (*GetSubscriptionResponse) XXX_Merge added in v0.7.62 

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

func (*GetSubscriptionResponse) XXX_Size added in v0.7.62 

func (m *GetSubscriptionResponse) XXX_Size() int

func (*GetSubscriptionResponse) XXX_Unmarshal added in v0.7.62 

func (m *GetSubscriptionResponse) 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 ListChannelsRequest added in v0.7.62 

type ListChannelsRequest struct {
}

func (*ListChannelsRequest) Descriptor added in v0.7.62 

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

func (*ListChannelsRequest) Marshal added in v0.7.62 

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

func (*ListChannelsRequest) MarshalTo added in v0.7.62 

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

func (*ListChannelsRequest) MarshalToSizedBuffer added in v0.7.62 

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

func (*ListChannelsRequest) ProtoMessage added in v0.7.62 

func (*ListChannelsRequest) ProtoMessage()

func (*ListChannelsRequest) Reset added in v0.7.62 

func (m *ListChannelsRequest) Reset()

func (*ListChannelsRequest) Size added in v0.7.62 

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

func (*ListChannelsRequest) String added in v0.7.62 

func (m *ListChannelsRequest) String() string

func (*ListChannelsRequest) Unmarshal added in v0.7.62 

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

func (*ListChannelsRequest) XXX_DiscardUnknown added in v0.7.62 

func (m *ListChannelsRequest) XXX_DiscardUnknown()

func (*ListChannelsRequest) XXX_Marshal added in v0.7.62 

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

func (*ListChannelsRequest) XXX_Merge added in v0.7.62 

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

func (*ListChannelsRequest) XXX_Size added in v0.7.62 

func (m *ListChannelsRequest) XXX_Size() int

func (*ListChannelsRequest) XXX_Unmarshal added in v0.7.62 

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

type ListChannelsResponse added in v0.7.62 

type ListChannelsResponse struct {
	Channels []Channel `protobuf:"bytes,1,rep,name=channels,proto3" json:"channels"`
}

func (*ListChannelsResponse) Descriptor added in v0.7.62 

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

func (*ListChannelsResponse) GetChannels added in v0.7.62 

func (m *ListChannelsResponse) GetChannels() []Channel

func (*ListChannelsResponse) Marshal added in v0.7.62 

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

func (*ListChannelsResponse) MarshalTo added in v0.7.62 

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

func (*ListChannelsResponse) MarshalToSizedBuffer added in v0.7.62 

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

func (*ListChannelsResponse) ProtoMessage added in v0.7.62 

func (*ListChannelsResponse) ProtoMessage()

func (*ListChannelsResponse) Reset added in v0.7.62 

func (m *ListChannelsResponse) Reset()

func (*ListChannelsResponse) Size added in v0.7.62 

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

func (*ListChannelsResponse) String added in v0.7.62 

func (m *ListChannelsResponse) String() string

func (*ListChannelsResponse) Unmarshal added in v0.7.62 

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

func (*ListChannelsResponse) XXX_DiscardUnknown added in v0.7.62 

func (m *ListChannelsResponse) XXX_DiscardUnknown()

func (*ListChannelsResponse) XXX_Marshal added in v0.7.62 

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

func (*ListChannelsResponse) XXX_Merge added in v0.7.62 

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

func (*ListChannelsResponse) XXX_Size added in v0.7.62 

func (m *ListChannelsResponse) XXX_Size() int

func (*ListChannelsResponse) XXX_Unmarshal added in v0.7.62 

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

type ListSubscriptionsRequest added in v0.7.62 

type ListSubscriptionsRequest struct {
}

func (*ListSubscriptionsRequest) Descriptor added in v0.7.62 

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

func (*ListSubscriptionsRequest) Marshal added in v0.7.62 

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

func (*ListSubscriptionsRequest) MarshalTo added in v0.7.62 

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

func (*ListSubscriptionsRequest) MarshalToSizedBuffer added in v0.7.62 

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

func (*ListSubscriptionsRequest) ProtoMessage added in v0.7.62 

func (*ListSubscriptionsRequest) ProtoMessage()

func (*ListSubscriptionsRequest) Reset added in v0.7.62 

func (m *ListSubscriptionsRequest) Reset()

func (*ListSubscriptionsRequest) Size added in v0.7.62 

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

func (*ListSubscriptionsRequest) String added in v0.7.62 

func (m *ListSubscriptionsRequest) String() string

func (*ListSubscriptionsRequest) Unmarshal added in v0.7.62 

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

func (*ListSubscriptionsRequest) XXX_DiscardUnknown added in v0.7.62 

func (m *ListSubscriptionsRequest) XXX_DiscardUnknown()

func (*ListSubscriptionsRequest) XXX_Marshal added in v0.7.62 

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

func (*ListSubscriptionsRequest) XXX_Merge added in v0.7.62 

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

func (*ListSubscriptionsRequest) XXX_Size added in v0.7.62 

func (m *ListSubscriptionsRequest) XXX_Size() int

func (*ListSubscriptionsRequest) XXX_Unmarshal added in v0.7.62 

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

type ListSubscriptionsResponse added in v0.7.62 

type ListSubscriptionsResponse struct {
	Subscriptions []Subscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions"`
}

func (*ListSubscriptionsResponse) Descriptor added in v0.7.62 

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

func (*ListSubscriptionsResponse) GetSubscriptions added in v0.7.62 

func (m *ListSubscriptionsResponse) GetSubscriptions() []Subscription

func (*ListSubscriptionsResponse) Marshal added in v0.7.62 

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

func (*ListSubscriptionsResponse) MarshalTo added in v0.7.62 

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

func (*ListSubscriptionsResponse) MarshalToSizedBuffer added in v0.7.62 

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

func (*ListSubscriptionsResponse) ProtoMessage added in v0.7.62 

func (*ListSubscriptionsResponse) ProtoMessage()

func (*ListSubscriptionsResponse) Reset added in v0.7.62 

func (m *ListSubscriptionsResponse) Reset()

func (*ListSubscriptionsResponse) Size added in v0.7.62 

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

func (*ListSubscriptionsResponse) String added in v0.7.62 

func (m *ListSubscriptionsResponse) String() string

func (*ListSubscriptionsResponse) Unmarshal added in v0.7.62 

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

func (*ListSubscriptionsResponse) XXX_DiscardUnknown added in v0.7.62 

func (m *ListSubscriptionsResponse) XXX_DiscardUnknown()

func (*ListSubscriptionsResponse) XXX_Marshal added in v0.7.62 

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

func (*ListSubscriptionsResponse) XXX_Merge added in v0.7.62 

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

func (*ListSubscriptionsResponse) XXX_Size added in v0.7.62 

func (m *ListSubscriptionsResponse) XXX_Size() int

func (*ListSubscriptionsResponse) XXX_Unmarshal added in v0.7.62 

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

type RequestHeaders 

type RequestHeaders struct {
	AppID         AppID         `protobuf:"bytes,1,opt,name=app_id,json=appId,proto3,casttype=AppID" json:"app_id,omitempty"`
	AppInstanceID AppInstanceID `protobuf:"bytes,2,opt,name=app_instance_id,json=appInstanceId,proto3,casttype=AppInstanceID" json:"app_instance_id,omitempty"`
	E2NodeID      E2NodeID      `protobuf:"bytes,3,opt,name=e2_node_id,json=e2NodeId,proto3,casttype=E2NodeID" json:"e2_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) GetAppInstanceID added in v0.7.62 

func (m *RequestHeaders) GetAppInstanceID() AppInstanceID

func (*RequestHeaders) GetE2NodeID added in v0.7.62 

func (m *RequestHeaders) GetE2NodeID() E2NodeID

func (*RequestHeaders) GetEncoding 

func (m *RequestHeaders) GetEncoding() Encoding

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 Revision added in v0.7.62 

type Revision uint64

Revision is a subscription revision number

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"`
	TransactionID      TransactionID    `protobuf:"bytes,2,opt,name=transaction_id,json=transactionId,proto3,casttype=TransactionID" json:"transaction_id,omitempty"`
	Subscription       SubscriptionSpec `protobuf:"bytes,3,opt,name=subscription,proto3" json:"subscription"`
	TransactionTimeout *time.Duration   `` /* 127-byte string literal not displayed */
}

func (*SubscribeRequest) Descriptor 

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

func (*SubscribeRequest) GetHeaders 

func (m *SubscribeRequest) GetHeaders() RequestHeaders

func (*SubscribeRequest) GetSubscription 

func (m *SubscribeRequest) GetSubscription() SubscriptionSpec

func (*SubscribeRequest) GetTransactionID added in v0.7.62 

func (m *SubscribeRequest) GetTransactionID() TransactionID

func (*SubscribeRequest) GetTransactionTimeout added in v0.7.94 

func (m *SubscribeRequest) GetTransactionTimeout() *time.Duration

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"`
	SubscriptionMeta `protobuf:"bytes,2,opt,name=meta,proto3,embedded=meta" json:"meta"`
	Spec             SubscriptionSpec   `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec"`
	Status           SubscriptionStatus `protobuf:"bytes,4,opt,name=status,proto3" json:"status"`
}

func (*Subscription) Descriptor 

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

func (*Subscription) GetID 

func (m *Subscription) GetID() SubscriptionID

func (*Subscription) GetSpec added in v0.7.62 

func (m *Subscription) GetSpec() SubscriptionSpec

func (*Subscription) GetStatus added in v0.7.62 

func (m *Subscription) GetStatus() SubscriptionStatus

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 SubscriptionAdminServiceClient added in v0.7.62 

type SubscriptionAdminServiceClient interface {
	GetChannel(ctx context.Context, in *GetChannelRequest, opts ...grpc.CallOption) (*GetChannelResponse, error)
	ListChannels(ctx context.Context, in *ListChannelsRequest, opts ...grpc.CallOption) (*ListChannelsResponse, error)
	WatchChannels(ctx context.Context, in *WatchChannelsRequest, opts ...grpc.CallOption) (SubscriptionAdminService_WatchChannelsClient, error)
	GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*GetSubscriptionResponse, error)
	ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error)
	WatchSubscriptions(ctx context.Context, in *WatchSubscriptionsRequest, opts ...grpc.CallOption) (SubscriptionAdminService_WatchSubscriptionsClient, error)
}

SubscriptionAdminServiceClient is the client API for SubscriptionAdminService service.

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

func NewSubscriptionAdminServiceClient added in v0.7.62 

func NewSubscriptionAdminServiceClient(cc *grpc.ClientConn) SubscriptionAdminServiceClient

type SubscriptionAdminServiceServer added in v0.7.62 

type SubscriptionAdminServiceServer interface {
	GetChannel(context.Context, *GetChannelRequest) (*GetChannelResponse, error)
	ListChannels(context.Context, *ListChannelsRequest) (*ListChannelsResponse, error)
	WatchChannels(*WatchChannelsRequest, SubscriptionAdminService_WatchChannelsServer) error
	GetSubscription(context.Context, *GetSubscriptionRequest) (*GetSubscriptionResponse, error)
	ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)
	WatchSubscriptions(*WatchSubscriptionsRequest, SubscriptionAdminService_WatchSubscriptionsServer) error
}

SubscriptionAdminServiceServer is the server API for SubscriptionAdminService service.

type SubscriptionAdminService_WatchChannelsClient added in v0.7.62 

type SubscriptionAdminService_WatchChannelsClient interface {
	Recv() (*WatchChannelsResponse, error)
	grpc.ClientStream
}

type SubscriptionAdminService_WatchChannelsServer added in v0.7.62 

type SubscriptionAdminService_WatchChannelsServer interface {
	Send(*WatchChannelsResponse) error
	grpc.ServerStream
}

type SubscriptionAdminService_WatchSubscriptionsClient added in v0.7.62 

type SubscriptionAdminService_WatchSubscriptionsClient interface {
	Recv() (*WatchSubscriptionsResponse, error)
	grpc.ClientStream
}

type SubscriptionAdminService_WatchSubscriptionsServer added in v0.7.62 

type SubscriptionAdminService_WatchSubscriptionsServer interface {
	Send(*WatchSubscriptionsResponse) error
	grpc.ServerStream
}

type SubscriptionEvent added in v0.7.62 

type SubscriptionEvent struct {
	Type         SubscriptionEventType `protobuf:"varint,1,opt,name=type,proto3,enum=onos.e2t.e2.v1beta1.SubscriptionEventType" json:"type,omitempty"`
	Subscription Subscription          `protobuf:"bytes,2,opt,name=subscription,proto3" json:"subscription"`
}

func (*SubscriptionEvent) Descriptor added in v0.7.62 

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

func (*SubscriptionEvent) GetSubscription added in v0.7.62 

func (m *SubscriptionEvent) GetSubscription() Subscription

func (*SubscriptionEvent) GetType added in v0.7.62 

func (m *SubscriptionEvent) GetType() SubscriptionEventType

func (*SubscriptionEvent) Marshal added in v0.7.62 

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

func (*SubscriptionEvent) MarshalTo added in v0.7.62 

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

func (*SubscriptionEvent) MarshalToSizedBuffer added in v0.7.62 

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

func (*SubscriptionEvent) ProtoMessage added in v0.7.62 

func (*SubscriptionEvent) ProtoMessage()

func (*SubscriptionEvent) Reset added in v0.7.62 

func (m *SubscriptionEvent) Reset()

func (*SubscriptionEvent) Size added in v0.7.62 

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

func (*SubscriptionEvent) String added in v0.7.62 

func (m *SubscriptionEvent) String() string

func (*SubscriptionEvent) Unmarshal added in v0.7.62 

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

func (*SubscriptionEvent) XXX_DiscardUnknown added in v0.7.62 

func (m *SubscriptionEvent) XXX_DiscardUnknown()

func (*SubscriptionEvent) XXX_Marshal added in v0.7.62 

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

func (*SubscriptionEvent) XXX_Merge added in v0.7.62 

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

func (*SubscriptionEvent) XXX_Size added in v0.7.62 

func (m *SubscriptionEvent) XXX_Size() int

func (*SubscriptionEvent) XXX_Unmarshal added in v0.7.62 

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

type SubscriptionEventType added in v0.7.62 

type SubscriptionEventType int32
const (
	SubscriptionEventType_SUBSCRIPTION_EVENT_UNKNOWN SubscriptionEventType = 0
	SubscriptionEventType_SUBSCRIPTION_CREATED       SubscriptionEventType = 1
	SubscriptionEventType_SUBSCRIPTION_UPDATED       SubscriptionEventType = 2
	SubscriptionEventType_SUBSCRIPTION_DELETED       SubscriptionEventType = 3
	SubscriptionEventType_SUBSCRIPTION_REPLAYED      SubscriptionEventType = 4
)

func (SubscriptionEventType) EnumDescriptor added in v0.7.62 

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

func (SubscriptionEventType) String added in v0.7.62 

func (x SubscriptionEventType) String() string

type SubscriptionID 

type SubscriptionID string

SubscriptionID is a subscription identifier

type SubscriptionMeta added in v0.7.62 

type SubscriptionMeta struct {
	E2NodeID     E2NodeID     `protobuf:"bytes,1,opt,name=e2_node_id,json=e2NodeId,proto3,casttype=E2NodeID" json:"e2_node_id,omitempty"`
	ServiceModel ServiceModel `protobuf:"bytes,2,opt,name=service_model,json=serviceModel,proto3" json:"service_model"`
	Encoding     Encoding     `protobuf:"varint,3,opt,name=encoding,proto3,enum=onos.e2t.e2.v1beta1.Encoding" json:"encoding,omitempty"`
	Revision     Revision     `protobuf:"varint,4,opt,name=revision,proto3,casttype=Revision" json:"revision,omitempty"`
}

func (*SubscriptionMeta) Descriptor added in v0.7.62 

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

func (*SubscriptionMeta) GetE2NodeID added in v0.7.62 

func (m *SubscriptionMeta) GetE2NodeID() E2NodeID

func (*SubscriptionMeta) GetEncoding added in v0.7.62 

func (m *SubscriptionMeta) GetEncoding() Encoding

func (*SubscriptionMeta) GetRevision added in v0.7.62 

func (m *SubscriptionMeta) GetRevision() Revision

func (*SubscriptionMeta) GetServiceModel added in v0.7.62 

func (m *SubscriptionMeta) GetServiceModel() ServiceModel

func (*SubscriptionMeta) Marshal added in v0.7.62 

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

func (*SubscriptionMeta) MarshalTo added in v0.7.62 

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

func (*SubscriptionMeta) MarshalToSizedBuffer added in v0.7.62 

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

func (*SubscriptionMeta) ProtoMessage added in v0.7.62 

func (*SubscriptionMeta) ProtoMessage()

func (*SubscriptionMeta) Reset added in v0.7.62 

func (m *SubscriptionMeta) Reset()

func (*SubscriptionMeta) Size added in v0.7.62 

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

func (*SubscriptionMeta) String added in v0.7.62 

func (m *SubscriptionMeta) String() string

func (*SubscriptionMeta) Unmarshal added in v0.7.62 

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

func (*SubscriptionMeta) XXX_DiscardUnknown added in v0.7.62 

func (m *SubscriptionMeta) XXX_DiscardUnknown()

func (*SubscriptionMeta) XXX_Marshal added in v0.7.62 

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

func (*SubscriptionMeta) XXX_Merge added in v0.7.62 

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

func (*SubscriptionMeta) XXX_Size added in v0.7.62 

func (m *SubscriptionMeta) XXX_Size() int

func (*SubscriptionMeta) XXX_Unmarshal added in v0.7.62 

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

type SubscriptionPhase added in v0.7.62 

type SubscriptionPhase int32
const (
	SubscriptionPhase_SUBSCRIPTION_CLOSED SubscriptionPhase = 0
	SubscriptionPhase_SUBSCRIPTION_OPEN   SubscriptionPhase = 1
)

func (SubscriptionPhase) EnumDescriptor added in v0.7.62 

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

func (SubscriptionPhase) String added in v0.7.62 

func (x SubscriptionPhase) String() string

type SubscriptionServiceClient 

type SubscriptionServiceClient interface {
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (SubscriptionService_SubscribeClient, error)
	Unsubscribe(ctx context.Context, in *UnsubscribeRequest, opts ...grpc.CallOption) (*UnsubscribeResponse, 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
	Unsubscribe(context.Context, *UnsubscribeRequest) (*UnsubscribeResponse, 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 SubscriptionSpec added in v0.7.62 

type SubscriptionSpec struct {
	EventTrigger EventTrigger `protobuf:"bytes,1,opt,name=event_trigger,json=eventTrigger,proto3" json:"event_trigger"`
	Actions      []Action     `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions"`
}

func (*SubscriptionSpec) Descriptor added in v0.7.62 

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

func (*SubscriptionSpec) GetActions added in v0.7.62 

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

func (*SubscriptionSpec) GetEventTrigger added in v0.7.62 

func (m *SubscriptionSpec) GetEventTrigger() EventTrigger

func (*SubscriptionSpec) Marshal added in v0.7.62 

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

func (*SubscriptionSpec) MarshalTo added in v0.7.62 

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

func (*SubscriptionSpec) MarshalToSizedBuffer added in v0.7.62 

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

func (*SubscriptionSpec) ProtoMessage added in v0.7.62 

func (*SubscriptionSpec) ProtoMessage()

func (*SubscriptionSpec) Reset added in v0.7.62 

func (m *SubscriptionSpec) Reset()

func (*SubscriptionSpec) Size added in v0.7.62 

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

func (*SubscriptionSpec) String added in v0.7.62 

func (m *SubscriptionSpec) String() string

func (*SubscriptionSpec) Unmarshal added in v0.7.62 

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

func (*SubscriptionSpec) XXX_DiscardUnknown added in v0.7.62 

func (m *SubscriptionSpec) XXX_DiscardUnknown()

func (*SubscriptionSpec) XXX_Marshal added in v0.7.62 

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

func (*SubscriptionSpec) XXX_Merge added in v0.7.62 

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

func (*SubscriptionSpec) XXX_Size added in v0.7.62 

func (m *SubscriptionSpec) XXX_Size() int

func (*SubscriptionSpec) XXX_Unmarshal added in v0.7.62 

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

type SubscriptionState added in v0.7.62 

type SubscriptionState int32
const (
	// SUBSCRIPTION_PENDING indicates the subscription phase is pending
	SubscriptionState_SUBSCRIPTION_PENDING SubscriptionState = 0
	// SUBSCRIPTION_COMPLETE indicates the subscription phase is complete
	SubscriptionState_SUBSCRIPTION_COMPLETE SubscriptionState = 1
	// SUBSCRIPTION_FAILED indicates the subscription phase failed
	SubscriptionState_SUBSCRIPTION_FAILED SubscriptionState = 2
)

func (SubscriptionState) EnumDescriptor added in v0.7.62 

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

func (SubscriptionState) String added in v0.7.62 

func (x SubscriptionState) String() string

type SubscriptionStatus added in v0.7.62 

type SubscriptionStatus struct {
	Phase    SubscriptionPhase `protobuf:"varint,1,opt,name=phase,proto3,enum=onos.e2t.e2.v1beta1.SubscriptionPhase" json:"phase,omitempty"`
	State    SubscriptionState `protobuf:"varint,2,opt,name=state,proto3,enum=onos.e2t.e2.v1beta1.SubscriptionState" json:"state,omitempty"`
	Error    *Error            `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	Channels []ChannelID       `protobuf:"bytes,4,rep,name=channels,proto3,casttype=ChannelID" json:"channels,omitempty"`
}

func (*SubscriptionStatus) Descriptor added in v0.7.62 

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

func (*SubscriptionStatus) GetChannels added in v0.7.62 

func (m *SubscriptionStatus) GetChannels() []ChannelID

func (*SubscriptionStatus) GetError added in v0.7.62 

func (m *SubscriptionStatus) GetError() *Error

func (*SubscriptionStatus) GetPhase added in v0.7.62 

func (m *SubscriptionStatus) GetPhase() SubscriptionPhase

func (*SubscriptionStatus) GetState added in v0.7.62 

func (m *SubscriptionStatus) GetState() SubscriptionState

func (*SubscriptionStatus) Marshal added in v0.7.62 

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

func (*SubscriptionStatus) MarshalTo added in v0.7.62 

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

func (*SubscriptionStatus) MarshalToSizedBuffer added in v0.7.62 

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

func (*SubscriptionStatus) ProtoMessage added in v0.7.62 

func (*SubscriptionStatus) ProtoMessage()

func (*SubscriptionStatus) Reset added in v0.7.62 

func (m *SubscriptionStatus) Reset()

func (*SubscriptionStatus) Size added in v0.7.62 

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

func (*SubscriptionStatus) String added in v0.7.62 

func (m *SubscriptionStatus) String() string

func (*SubscriptionStatus) Unmarshal added in v0.7.62 

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

func (*SubscriptionStatus) XXX_DiscardUnknown added in v0.7.62 

func (m *SubscriptionStatus) XXX_DiscardUnknown()

func (*SubscriptionStatus) XXX_Marshal added in v0.7.62 

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

func (*SubscriptionStatus) XXX_Merge added in v0.7.62 

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

func (*SubscriptionStatus) XXX_Size added in v0.7.62 

func (m *SubscriptionStatus) XXX_Size() int

func (*SubscriptionStatus) XXX_Unmarshal added in v0.7.62 

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

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 TransactionID added in v0.7.62 

type TransactionID string

TransactionID is a transaction identifier

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 UnimplementedSubscriptionAdminServiceServer added in v0.7.62 

type UnimplementedSubscriptionAdminServiceServer struct {
}

UnimplementedSubscriptionAdminServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSubscriptionAdminServiceServer) GetChannel added in v0.7.62 

func (*UnimplementedSubscriptionAdminServiceServer) GetChannel(ctx context.Context, req *GetChannelRequest) (*GetChannelResponse, error)

func (*UnimplementedSubscriptionAdminServiceServer) GetSubscription added in v0.7.62 

func (*UnimplementedSubscriptionAdminServiceServer) GetSubscription(ctx context.Context, req *GetSubscriptionRequest) (*GetSubscriptionResponse, error)

func (*UnimplementedSubscriptionAdminServiceServer) ListChannels added in v0.7.62 

func (*UnimplementedSubscriptionAdminServiceServer) ListChannels(ctx context.Context, req *ListChannelsRequest) (*ListChannelsResponse, error)

func (*UnimplementedSubscriptionAdminServiceServer) ListSubscriptions added in v0.7.62 

func (*UnimplementedSubscriptionAdminServiceServer) ListSubscriptions(ctx context.Context, req *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)

func (*UnimplementedSubscriptionAdminServiceServer) WatchChannels added in v0.7.62 

func (*UnimplementedSubscriptionAdminServiceServer) WatchChannels(req *WatchChannelsRequest, srv SubscriptionAdminService_WatchChannelsServer) error

func (*UnimplementedSubscriptionAdminServiceServer) WatchSubscriptions added in v0.7.62 

func (*UnimplementedSubscriptionAdminServiceServer) WatchSubscriptions(req *WatchSubscriptionsRequest, srv SubscriptionAdminService_WatchSubscriptionsServer) 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

func (*UnimplementedSubscriptionServiceServer) Unsubscribe added in v0.7.55 

func (*UnimplementedSubscriptionServiceServer) Unsubscribe(ctx context.Context, req *UnsubscribeRequest) (*UnsubscribeResponse, error)

type UnsubscribeRequest added in v0.7.55 

type UnsubscribeRequest struct {
	Headers       RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"`
	TransactionID TransactionID  `protobuf:"bytes,2,opt,name=transaction_id,json=transactionId,proto3,casttype=TransactionID" json:"transaction_id,omitempty"`
}

func (*UnsubscribeRequest) Descriptor added in v0.7.55 

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

func (*UnsubscribeRequest) GetHeaders added in v0.7.55 

func (m *UnsubscribeRequest) GetHeaders() RequestHeaders

func (*UnsubscribeRequest) GetTransactionID added in v0.7.62 

func (m *UnsubscribeRequest) GetTransactionID() TransactionID

func (*UnsubscribeRequest) Marshal added in v0.7.55 

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

func (*UnsubscribeRequest) MarshalTo added in v0.7.55 

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

func (*UnsubscribeRequest) MarshalToSizedBuffer added in v0.7.55 

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

func (*UnsubscribeRequest) ProtoMessage added in v0.7.55 

func (*UnsubscribeRequest) ProtoMessage()

func (*UnsubscribeRequest) Reset added in v0.7.55 

func (m *UnsubscribeRequest) Reset()

func (*UnsubscribeRequest) Size added in v0.7.55 

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

func (*UnsubscribeRequest) String added in v0.7.55 

func (m *UnsubscribeRequest) String() string

func (*UnsubscribeRequest) Unmarshal added in v0.7.55 

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

func (*UnsubscribeRequest) XXX_DiscardUnknown added in v0.7.55 

func (m *UnsubscribeRequest) XXX_DiscardUnknown()

func (*UnsubscribeRequest) XXX_Marshal added in v0.7.55 

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

func (*UnsubscribeRequest) XXX_Merge added in v0.7.55 

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

func (*UnsubscribeRequest) XXX_Size added in v0.7.55 

func (m *UnsubscribeRequest) XXX_Size() int

func (*UnsubscribeRequest) XXX_Unmarshal added in v0.7.55 

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

type UnsubscribeResponse added in v0.7.55 

type UnsubscribeResponse struct {
	Headers ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"`
}

func (*UnsubscribeResponse) Descriptor added in v0.7.55 

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

func (*UnsubscribeResponse) GetHeaders added in v0.7.55 

func (m *UnsubscribeResponse) GetHeaders() ResponseHeaders

func (*UnsubscribeResponse) Marshal added in v0.7.55 

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

func (*UnsubscribeResponse) MarshalTo added in v0.7.55 

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

func (*UnsubscribeResponse) MarshalToSizedBuffer added in v0.7.55 

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

func (*UnsubscribeResponse) ProtoMessage added in v0.7.55 

func (*UnsubscribeResponse) ProtoMessage()

func (*UnsubscribeResponse) Reset added in v0.7.55 

func (m *UnsubscribeResponse) Reset()

func (*UnsubscribeResponse) Size added in v0.7.55 

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

func (*UnsubscribeResponse) String added in v0.7.55 

func (m *UnsubscribeResponse) String() string

func (*UnsubscribeResponse) Unmarshal added in v0.7.55 

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

func (*UnsubscribeResponse) XXX_DiscardUnknown added in v0.7.55 

func (m *UnsubscribeResponse) XXX_DiscardUnknown()

func (*UnsubscribeResponse) XXX_Marshal added in v0.7.55 

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

func (*UnsubscribeResponse) XXX_Merge added in v0.7.55 

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

func (*UnsubscribeResponse) XXX_Size added in v0.7.55 

func (m *UnsubscribeResponse) XXX_Size() int

func (*UnsubscribeResponse) XXX_Unmarshal added in v0.7.55 

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

type WatchChannelsRequest added in v0.7.62 

type WatchChannelsRequest struct {
	NoReplay bool `protobuf:"varint,1,opt,name=no_replay,json=noReplay,proto3" json:"no_replay,omitempty"`
}

func (*WatchChannelsRequest) Descriptor added in v0.7.62 

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

func (*WatchChannelsRequest) GetNoReplay added in v0.7.62 

func (m *WatchChannelsRequest) GetNoReplay() bool

func (*WatchChannelsRequest) Marshal added in v0.7.62 

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

func (*WatchChannelsRequest) MarshalTo added in v0.7.62 

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

func (*WatchChannelsRequest) MarshalToSizedBuffer added in v0.7.62 

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

func (*WatchChannelsRequest) ProtoMessage added in v0.7.62 

func (*WatchChannelsRequest) ProtoMessage()

func (*WatchChannelsRequest) Reset added in v0.7.62 

func (m *WatchChannelsRequest) Reset()

func (*WatchChannelsRequest) Size added in v0.7.62 

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

func (*WatchChannelsRequest) String added in v0.7.62 

func (m *WatchChannelsRequest) String() string

func (*WatchChannelsRequest) Unmarshal added in v0.7.62 

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

func (*WatchChannelsRequest) XXX_DiscardUnknown added in v0.7.62 

func (m *WatchChannelsRequest) XXX_DiscardUnknown()

func (*WatchChannelsRequest) XXX_Marshal added in v0.7.62 

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

func (*WatchChannelsRequest) XXX_Merge added in v0.7.62 

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

func (*WatchChannelsRequest) XXX_Size added in v0.7.62 

func (m *WatchChannelsRequest) XXX_Size() int

func (*WatchChannelsRequest) XXX_Unmarshal added in v0.7.62 

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

type WatchChannelsResponse added in v0.7.62 

type WatchChannelsResponse struct {
	Event ChannelEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event"`
}

func (*WatchChannelsResponse) Descriptor added in v0.7.62 

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

func (*WatchChannelsResponse) GetEvent added in v0.7.62 

func (m *WatchChannelsResponse) GetEvent() ChannelEvent

func (*WatchChannelsResponse) Marshal added in v0.7.62 

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

func (*WatchChannelsResponse) MarshalTo added in v0.7.62 

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

func (*WatchChannelsResponse) MarshalToSizedBuffer added in v0.7.62 

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

func (*WatchChannelsResponse) ProtoMessage added in v0.7.62 

func (*WatchChannelsResponse) ProtoMessage()

func (*WatchChannelsResponse) Reset added in v0.7.62 

func (m *WatchChannelsResponse) Reset()

func (*WatchChannelsResponse) Size added in v0.7.62 

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

func (*WatchChannelsResponse) String added in v0.7.62 

func (m *WatchChannelsResponse) String() string

func (*WatchChannelsResponse) Unmarshal added in v0.7.62 

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

func (*WatchChannelsResponse) XXX_DiscardUnknown added in v0.7.62 

func (m *WatchChannelsResponse) XXX_DiscardUnknown()

func (*WatchChannelsResponse) XXX_Marshal added in v0.7.62 

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

func (*WatchChannelsResponse) XXX_Merge added in v0.7.62 

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

func (*WatchChannelsResponse) XXX_Size added in v0.7.62 

func (m *WatchChannelsResponse) XXX_Size() int

func (*WatchChannelsResponse) XXX_Unmarshal added in v0.7.62 

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

type WatchSubscriptionsRequest added in v0.7.62 

type WatchSubscriptionsRequest struct {
	NoReplay bool `protobuf:"varint,1,opt,name=no_replay,json=noReplay,proto3" json:"no_replay,omitempty"`
}

func (*WatchSubscriptionsRequest) Descriptor added in v0.7.62 

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

func (*WatchSubscriptionsRequest) GetNoReplay added in v0.7.62 

func (m *WatchSubscriptionsRequest) GetNoReplay() bool

func (*WatchSubscriptionsRequest) Marshal added in v0.7.62 

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

func (*WatchSubscriptionsRequest) MarshalTo added in v0.7.62 

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

func (*WatchSubscriptionsRequest) MarshalToSizedBuffer added in v0.7.62 

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

func (*WatchSubscriptionsRequest) ProtoMessage added in v0.7.62 

func (*WatchSubscriptionsRequest) ProtoMessage()

func (*WatchSubscriptionsRequest) Reset added in v0.7.62 

func (m *WatchSubscriptionsRequest) Reset()

func (*WatchSubscriptionsRequest) Size added in v0.7.62 

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

func (*WatchSubscriptionsRequest) String added in v0.7.62 

func (m *WatchSubscriptionsRequest) String() string

func (*WatchSubscriptionsRequest) Unmarshal added in v0.7.62 

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

func (*WatchSubscriptionsRequest) XXX_DiscardUnknown added in v0.7.62 

func (m *WatchSubscriptionsRequest) XXX_DiscardUnknown()

func (*WatchSubscriptionsRequest) XXX_Marshal added in v0.7.62 

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

func (*WatchSubscriptionsRequest) XXX_Merge added in v0.7.62 

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

func (*WatchSubscriptionsRequest) XXX_Size added in v0.7.62 

func (m *WatchSubscriptionsRequest) XXX_Size() int

func (*WatchSubscriptionsRequest) XXX_Unmarshal added in v0.7.62 

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

type WatchSubscriptionsResponse added in v0.7.62 

type WatchSubscriptionsResponse struct {
	Event SubscriptionEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event"`
}

func (*WatchSubscriptionsResponse) Descriptor added in v0.7.62 

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

func (*WatchSubscriptionsResponse) GetEvent added in v0.7.62 

func (m *WatchSubscriptionsResponse) GetEvent() SubscriptionEvent

func (*WatchSubscriptionsResponse) Marshal added in v0.7.62 

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

func (*WatchSubscriptionsResponse) MarshalTo added in v0.7.62 

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

func (*WatchSubscriptionsResponse) MarshalToSizedBuffer added in v0.7.62 

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

func (*WatchSubscriptionsResponse) ProtoMessage added in v0.7.62 

func (*WatchSubscriptionsResponse) ProtoMessage()

func (*WatchSubscriptionsResponse) Reset added in v0.7.62 

func (m *WatchSubscriptionsResponse) Reset()

func (*WatchSubscriptionsResponse) Size added in v0.7.62 

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

func (*WatchSubscriptionsResponse) String added in v0.7.62 

func (m *WatchSubscriptionsResponse) String() string

func (*WatchSubscriptionsResponse) Unmarshal added in v0.7.62 

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

func (*WatchSubscriptionsResponse) XXX_DiscardUnknown added in v0.7.62 

func (m *WatchSubscriptionsResponse) XXX_DiscardUnknown()

func (*WatchSubscriptionsResponse) XXX_Marshal added in v0.7.62 

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

func (*WatchSubscriptionsResponse) XXX_Merge added in v0.7.62 

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

func (*WatchSubscriptionsResponse) XXX_Size added in v0.7.62 

func (m *WatchSubscriptionsResponse) XXX_Size() int

func (*WatchSubscriptionsResponse) XXX_Unmarshal added in v0.7.62 

func (m *WatchSubscriptionsResponse) XXX_Unmarshal(b []byte) 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.