v1beta1

package
v0.9.2 Latest Latest
Warning

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

Go to latest
Published: Feb 17, 2022 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"`
	Finalizers []string `protobuf:"bytes,9,rep,name=finalizers,proto3" json:"finalizers,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) GetFinalizers added in v0.7.106

func (m *ChannelMeta) GetFinalizers() []string

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      TermID       `protobuf:"varint,5,opt,name=term,proto3,casttype=TermID" json:"term,omitempty"`
	Master    MasterID     `protobuf:"bytes,6,opt,name=master,proto3,casttype=MasterID" 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() MasterID

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() TermID

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 E2TInstanceID added in v0.7.109

type E2TInstanceID string

E2TInstanceID is an E2T instance 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 (*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 (*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 (*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 (*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

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 (*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

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 MasterID added in v0.7.110

type MasterID string

MasterID is a master identifier

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

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

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 (*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"`
	Finalizers   []string     `protobuf:"bytes,5,rep,name=finalizers,proto3" json:"finalizers,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) GetFinalizers added in v0.7.106

func (m *SubscriptionMeta) GetFinalizers() []string

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"`
	Term     TermID            `protobuf:"varint,5,opt,name=term,proto3,casttype=TermID" json:"term,omitempty"`
	Master   MasterID          `protobuf:"bytes,6,opt,name=master,proto3,casttype=MasterID" json:"master,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) GetMaster added in v0.7.109

func (m *SubscriptionStatus) GetMaster() MasterID

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) GetTerm added in v0.7.109

func (m *SubscriptionStatus) GetTerm() TermID

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 (*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 TermID added in v0.7.109

type TermID uint64

TermID is a mastership term identifier

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

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

func (*UnimplementedSubscriptionAdminServiceServer) ListChannels added in v0.7.62

func (*UnimplementedSubscriptionAdminServiceServer) ListSubscriptions added in v0.7.62

func (*UnimplementedSubscriptionAdminServiceServer) WatchChannels added in v0.7.62

func (*UnimplementedSubscriptionAdminServiceServer) WatchSubscriptions added in v0.7.62

type UnimplementedSubscriptionServiceServer

type UnimplementedSubscriptionServiceServer struct {
}

UnimplementedSubscriptionServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSubscriptionServiceServer) Subscribe

func (*UnimplementedSubscriptionServiceServer) Unsubscribe added in v0.7.55

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 (*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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL