subscription

package
v0.7.9 Latest Latest
Warning

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

 Go to latest Published: Mar 1, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Package subscription is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthSubscription        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSubscription          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSubscription = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ActionType_name = map[int32]string{
	0: "ACTION_TYPE_REPORT",
	1: "ACTION_TYPE_INSERT",
	2: "ACTION_TYPE_POLICY",
}
View Source 
var ActionType_value = map[string]int32{
	"ACTION_TYPE_REPORT": 0,
	"ACTION_TYPE_INSERT": 1,
	"ACTION_TYPE_POLICY": 2,
}
View Source 
var Encoding_name = map[int32]string{
	0: "ENCODING_ASN1",
	1: "ENCODING_PROTO",
}
View Source 
var Encoding_value = map[string]int32{
	"ENCODING_ASN1":  0,
	"ENCODING_PROTO": 1,
}
View Source 
var EventType_name = map[int32]string{
	0: "NONE",
	1: "ADDED",
	2: "UPDATED",
	3: "REMOVED",
}
View Source 
var EventType_value = map[string]int32{
	"NONE":    0,
	"ADDED":   1,
	"UPDATED": 2,
	"REMOVED": 3,
}
View Source 
var Status_name = map[int32]string{
	0: "ACTIVE",
	1: "PENDING_DELETE",
	2: "FAILED",
}
View Source 
var Status_value = map[string]int32{
	"ACTIVE":         0,
	"PENDING_DELETE": 1,
	"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 RegisterE2SubscriptionServiceServer 

func RegisterE2SubscriptionServiceServer(s *grpc.Server, srv E2SubscriptionServiceServer)

Types

type Action added in v0.6.10 

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.e2sub.subscription.ActionType" json:"type,omitempty"`
	Payload          Payload           `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload"`
	SubsequentAction *SubsequentAction `protobuf:"bytes,4,opt,name=subsequent_action,json=subsequentAction,proto3" json:"subsequent_action,omitempty"`
}

func (*Action) Descriptor added in v0.6.10 

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

func (*Action) GetID added in v0.6.10 

func (m *Action) GetID() int32

func (*Action) GetPayload added in v0.6.10 

func (m *Action) GetPayload() Payload

func (*Action) GetSubsequentAction added in v0.6.10 

func (m *Action) GetSubsequentAction() *SubsequentAction

func (*Action) GetType added in v0.6.10 

func (m *Action) GetType() ActionType

func (*Action) Marshal added in v0.6.10 

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

func (*Action) MarshalTo added in v0.6.10 

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

func (*Action) MarshalToSizedBuffer added in v0.6.10 

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

func (*Action) ProtoMessage added in v0.6.10 

func (*Action) ProtoMessage()

func (*Action) Reset added in v0.6.10 

func (m *Action) Reset()

func (*Action) Size added in v0.6.10 

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

func (*Action) String added in v0.6.10 

func (m *Action) String() string

func (*Action) Unmarshal added in v0.6.10 

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

func (*Action) XXX_DiscardUnknown added in v0.6.10 

func (m *Action) XXX_DiscardUnknown()

func (*Action) XXX_Marshal added in v0.6.10 

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

func (*Action) XXX_Merge added in v0.6.10 

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

func (*Action) XXX_Size added in v0.6.10 

func (m *Action) XXX_Size() int

func (*Action) XXX_Unmarshal added in v0.6.10 

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

type ActionType added in v0.6.10 

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

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

func (ActionType) String added in v0.6.10 

func (x ActionType) String() string

type AddSubscriptionRequest 

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

AddSubscriptionRequest a subscription request

func (*AddSubscriptionRequest) Descriptor 

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

func (*AddSubscriptionRequest) GetSubscription 

func (m *AddSubscriptionRequest) GetSubscription() *Subscription

func (*AddSubscriptionRequest) Marshal 

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

func (*AddSubscriptionRequest) MarshalTo 

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

func (*AddSubscriptionRequest) MarshalToSizedBuffer 

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

func (*AddSubscriptionRequest) ProtoMessage 

func (*AddSubscriptionRequest) ProtoMessage()

func (*AddSubscriptionRequest) Reset 

func (m *AddSubscriptionRequest) Reset()

func (*AddSubscriptionRequest) Size 

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

func (*AddSubscriptionRequest) String 

func (m *AddSubscriptionRequest) String() string

func (*AddSubscriptionRequest) Unmarshal 

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

func (*AddSubscriptionRequest) XXX_DiscardUnknown 

func (m *AddSubscriptionRequest) XXX_DiscardUnknown()

func (*AddSubscriptionRequest) XXX_Marshal 

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

func (*AddSubscriptionRequest) XXX_Merge 

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

func (*AddSubscriptionRequest) XXX_Size 

func (m *AddSubscriptionRequest) XXX_Size() int

func (*AddSubscriptionRequest) XXX_Unmarshal 

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

type AddSubscriptionResponse 

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

AddSubscriptionResponse a subscription response

func (*AddSubscriptionResponse) Descriptor 

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

func (*AddSubscriptionResponse) GetSubscription 

func (m *AddSubscriptionResponse) GetSubscription() *Subscription

func (*AddSubscriptionResponse) Marshal 

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

func (*AddSubscriptionResponse) MarshalTo 

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

func (*AddSubscriptionResponse) MarshalToSizedBuffer 

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

func (*AddSubscriptionResponse) ProtoMessage 

func (*AddSubscriptionResponse) ProtoMessage()

func (*AddSubscriptionResponse) Reset 

func (m *AddSubscriptionResponse) Reset()

func (*AddSubscriptionResponse) Size 

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

func (*AddSubscriptionResponse) String 

func (m *AddSubscriptionResponse) String() string

func (*AddSubscriptionResponse) Unmarshal 

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

func (*AddSubscriptionResponse) XXX_DiscardUnknown 

func (m *AddSubscriptionResponse) XXX_DiscardUnknown()

func (*AddSubscriptionResponse) XXX_Marshal 

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

func (*AddSubscriptionResponse) XXX_Merge 

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

func (*AddSubscriptionResponse) XXX_Size 

func (m *AddSubscriptionResponse) XXX_Size() int

func (*AddSubscriptionResponse) XXX_Unmarshal 

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

type AppID 

type AppID string

AppID is an application identifier

type E2NodeID 

type E2NodeID string

E2NodeID is an E2 node identifier

type E2SubscriptionServiceClient 

type E2SubscriptionServiceClient interface {
	// AddSubscription establishes E2 subscriptions on E2 Node.
	AddSubscription(ctx context.Context, in *AddSubscriptionRequest, opts ...grpc.CallOption) (*AddSubscriptionResponse, error)
	// RemoveSubscription removes E2 subscriptions on E2 Node.
	RemoveSubscription(ctx context.Context, in *RemoveSubscriptionRequest, opts ...grpc.CallOption) (*RemoveSubscriptionResponse, error)
	// GetSubscription retrieves information about a specific subscription in the list of existing subscriptions
	GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*GetSubscriptionResponse, error)
	// ListSubscriptions returns the list of current existing subscriptions
	ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error)
	// WatchSubscriptions returns a stream of subscription changes
	WatchSubscriptions(ctx context.Context, in *WatchSubscriptionsRequest, opts ...grpc.CallOption) (E2SubscriptionService_WatchSubscriptionsClient, error)
}

E2SubscriptionServiceClient is the client API for E2SubscriptionService service.

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

func NewE2SubscriptionServiceClient 

func NewE2SubscriptionServiceClient(cc *grpc.ClientConn) E2SubscriptionServiceClient

type E2SubscriptionServiceServer 

type E2SubscriptionServiceServer interface {
	// AddSubscription establishes E2 subscriptions on E2 Node.
	AddSubscription(context.Context, *AddSubscriptionRequest) (*AddSubscriptionResponse, error)
	// RemoveSubscription removes E2 subscriptions on E2 Node.
	RemoveSubscription(context.Context, *RemoveSubscriptionRequest) (*RemoveSubscriptionResponse, error)
	// GetSubscription retrieves information about a specific subscription in the list of existing subscriptions
	GetSubscription(context.Context, *GetSubscriptionRequest) (*GetSubscriptionResponse, error)
	// ListSubscriptions returns the list of current existing subscriptions
	ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)
	// WatchSubscriptions returns a stream of subscription changes
	WatchSubscriptions(*WatchSubscriptionsRequest, E2SubscriptionService_WatchSubscriptionsServer) error
}

E2SubscriptionServiceServer is the server API for E2SubscriptionService service.

type E2SubscriptionService_WatchSubscriptionsClient 

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

type E2SubscriptionService_WatchSubscriptionsServer 

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

type Encoding 

type Encoding int32

Encoding indicates a payload encoding 

const (
	Encoding_ENCODING_ASN1  Encoding = 0
	Encoding_ENCODING_PROTO Encoding = 1
)

func (Encoding) EnumDescriptor 

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

func (Encoding) String 

func (x Encoding) String() string

type Event 

type Event struct {
	Type         EventType    `protobuf:"varint,1,opt,name=type,proto3,enum=onos.e2sub.subscription.EventType" json:"type,omitempty"`
	Subscription Subscription `protobuf:"bytes,2,opt,name=subscription,proto3" json:"subscription"`
}

Event is a subscription event

func (*Event) Descriptor 

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

func (*Event) GetSubscription 

func (m *Event) GetSubscription() Subscription

func (*Event) GetType 

func (m *Event) GetType() EventType

func (*Event) Marshal 

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

func (*Event) MarshalTo 

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

func (*Event) MarshalToSizedBuffer 

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

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

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

func (*Event) String 

func (m *Event) String() string

func (*Event) Unmarshal 

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

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

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

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type EventTrigger added in v0.6.10 

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

func (*EventTrigger) Descriptor added in v0.6.10 

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

func (*EventTrigger) GetPayload added in v0.6.10 

func (m *EventTrigger) GetPayload() Payload

func (*EventTrigger) Marshal added in v0.6.10 

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

func (*EventTrigger) MarshalTo added in v0.6.10 

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

func (*EventTrigger) MarshalToSizedBuffer added in v0.6.10 

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

func (*EventTrigger) ProtoMessage added in v0.6.10 

func (*EventTrigger) ProtoMessage()

func (*EventTrigger) Reset added in v0.6.10 

func (m *EventTrigger) Reset()

func (*EventTrigger) Size added in v0.6.10 

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

func (*EventTrigger) String added in v0.6.10 

func (m *EventTrigger) String() string

func (*EventTrigger) Unmarshal added in v0.6.10 

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

func (*EventTrigger) XXX_DiscardUnknown added in v0.6.10 

func (m *EventTrigger) XXX_DiscardUnknown()

func (*EventTrigger) XXX_Marshal added in v0.6.10 

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

func (*EventTrigger) XXX_Merge added in v0.6.10 

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

func (*EventTrigger) XXX_Size added in v0.6.10 

func (m *EventTrigger) XXX_Size() int

func (*EventTrigger) XXX_Unmarshal added in v0.6.10 

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

type EventType 

type EventType int32

EventType is a subscription event type 

const (
	EventType_NONE    EventType = 0
	EventType_ADDED   EventType = 1
	EventType_UPDATED EventType = 2
	EventType_REMOVED EventType = 3
)

func (EventType) EnumDescriptor 

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

func (EventType) String 

func (x EventType) String() string

type GetSubscriptionRequest 

type GetSubscriptionRequest struct {
	ID ID `protobuf:"bytes,1,opt,name=id,proto3,casttype=ID" json:"id,omitempty"`
}

func (*GetSubscriptionRequest) Descriptor 

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

func (*GetSubscriptionRequest) GetID 

func (m *GetSubscriptionRequest) GetID() ID

func (*GetSubscriptionRequest) Marshal 

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

func (*GetSubscriptionRequest) MarshalTo 

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

func (*GetSubscriptionRequest) MarshalToSizedBuffer 

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

func (*GetSubscriptionRequest) ProtoMessage 

func (*GetSubscriptionRequest) ProtoMessage()

func (*GetSubscriptionRequest) Reset 

func (m *GetSubscriptionRequest) Reset()

func (*GetSubscriptionRequest) Size 

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

func (*GetSubscriptionRequest) String 

func (m *GetSubscriptionRequest) String() string

func (*GetSubscriptionRequest) Unmarshal 

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

func (*GetSubscriptionRequest) XXX_DiscardUnknown 

func (m *GetSubscriptionRequest) XXX_DiscardUnknown()

func (*GetSubscriptionRequest) XXX_Marshal 

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

func (*GetSubscriptionRequest) XXX_Merge 

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

func (*GetSubscriptionRequest) XXX_Size 

func (m *GetSubscriptionRequest) XXX_Size() int

func (*GetSubscriptionRequest) XXX_Unmarshal 

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

type GetSubscriptionResponse 

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

func (*GetSubscriptionResponse) Descriptor 

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

func (*GetSubscriptionResponse) GetSubscription 

func (m *GetSubscriptionResponse) GetSubscription() *Subscription

func (*GetSubscriptionResponse) Marshal 

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

func (*GetSubscriptionResponse) MarshalTo 

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

func (*GetSubscriptionResponse) MarshalToSizedBuffer 

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

func (*GetSubscriptionResponse) ProtoMessage 

func (*GetSubscriptionResponse) ProtoMessage()

func (*GetSubscriptionResponse) Reset 

func (m *GetSubscriptionResponse) Reset()

func (*GetSubscriptionResponse) Size 

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

func (*GetSubscriptionResponse) String 

func (m *GetSubscriptionResponse) String() string

func (*GetSubscriptionResponse) Unmarshal 

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

func (*GetSubscriptionResponse) XXX_DiscardUnknown 

func (m *GetSubscriptionResponse) XXX_DiscardUnknown()

func (*GetSubscriptionResponse) XXX_Marshal 

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

func (*GetSubscriptionResponse) XXX_Merge 

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

func (*GetSubscriptionResponse) XXX_Size 

func (m *GetSubscriptionResponse) XXX_Size() int

func (*GetSubscriptionResponse) XXX_Unmarshal 

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

type ID 

type ID string

ID is a device ID

type Lifecycle 

type Lifecycle struct {
	Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=onos.e2sub.subscription.Status" json:"status,omitempty"`
}

Lifecycle is the subscription lifecycle

func (*Lifecycle) Descriptor 

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

func (*Lifecycle) GetStatus 

func (m *Lifecycle) GetStatus() Status

func (*Lifecycle) Marshal 

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

func (*Lifecycle) MarshalTo 

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

func (*Lifecycle) MarshalToSizedBuffer 

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

func (*Lifecycle) ProtoMessage 

func (*Lifecycle) ProtoMessage()

func (*Lifecycle) Reset 

func (m *Lifecycle) Reset()

func (*Lifecycle) Size 

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

func (*Lifecycle) String 

func (m *Lifecycle) String() string

func (*Lifecycle) Unmarshal 

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

func (*Lifecycle) XXX_DiscardUnknown 

func (m *Lifecycle) XXX_DiscardUnknown()

func (*Lifecycle) XXX_Marshal 

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

func (*Lifecycle) XXX_Merge 

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

func (*Lifecycle) XXX_Size 

func (m *Lifecycle) XXX_Size() int

func (*Lifecycle) XXX_Unmarshal 

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

type ListSubscriptionsRequest 

type ListSubscriptionsRequest struct {
}

func (*ListSubscriptionsRequest) Descriptor 

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

func (*ListSubscriptionsRequest) Marshal 

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

func (*ListSubscriptionsRequest) MarshalTo 

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

func (*ListSubscriptionsRequest) MarshalToSizedBuffer 

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

func (*ListSubscriptionsRequest) ProtoMessage 

func (*ListSubscriptionsRequest) ProtoMessage()

func (*ListSubscriptionsRequest) Reset 

func (m *ListSubscriptionsRequest) Reset()

func (*ListSubscriptionsRequest) Size 

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

func (*ListSubscriptionsRequest) String 

func (m *ListSubscriptionsRequest) String() string

func (*ListSubscriptionsRequest) Unmarshal 

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

func (*ListSubscriptionsRequest) XXX_DiscardUnknown 

func (m *ListSubscriptionsRequest) XXX_DiscardUnknown()

func (*ListSubscriptionsRequest) XXX_Marshal 

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

func (*ListSubscriptionsRequest) XXX_Merge 

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

func (*ListSubscriptionsRequest) XXX_Size 

func (m *ListSubscriptionsRequest) XXX_Size() int

func (*ListSubscriptionsRequest) XXX_Unmarshal 

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

type ListSubscriptionsResponse 

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

func (*ListSubscriptionsResponse) Descriptor 

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

func (*ListSubscriptionsResponse) GetSubscriptions 

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

func (*ListSubscriptionsResponse) Marshal 

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

func (*ListSubscriptionsResponse) MarshalTo 

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

func (*ListSubscriptionsResponse) MarshalToSizedBuffer 

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

func (*ListSubscriptionsResponse) ProtoMessage 

func (*ListSubscriptionsResponse) ProtoMessage()

func (*ListSubscriptionsResponse) Reset 

func (m *ListSubscriptionsResponse) Reset()

func (*ListSubscriptionsResponse) Size 

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

func (*ListSubscriptionsResponse) String 

func (m *ListSubscriptionsResponse) String() string

func (*ListSubscriptionsResponse) Unmarshal 

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

func (*ListSubscriptionsResponse) XXX_DiscardUnknown 

func (m *ListSubscriptionsResponse) XXX_DiscardUnknown()

func (*ListSubscriptionsResponse) XXX_Marshal 

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

func (*ListSubscriptionsResponse) XXX_Merge 

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

func (*ListSubscriptionsResponse) XXX_Size 

func (m *ListSubscriptionsResponse) XXX_Size() int

func (*ListSubscriptionsResponse) XXX_Unmarshal 

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

type MockE2SubscriptionServiceClient added in v0.6.11 

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

MockE2SubscriptionServiceClient is a mock of E2SubscriptionServiceClient interface

func NewMockE2SubscriptionServiceClient added in v0.6.11 

func NewMockE2SubscriptionServiceClient(ctrl *gomock.Controller) *MockE2SubscriptionServiceClient

NewMockE2SubscriptionServiceClient creates a new mock instance

func (*MockE2SubscriptionServiceClient) AddSubscription added in v0.6.11 

func (m *MockE2SubscriptionServiceClient) AddSubscription(ctx context.Context, in *AddSubscriptionRequest, opts ...grpc.CallOption) (*AddSubscriptionResponse, error)

AddSubscription mocks base method

func (*MockE2SubscriptionServiceClient) EXPECT added in v0.6.11 

func (m *MockE2SubscriptionServiceClient) EXPECT() *MockE2SubscriptionServiceClientMockRecorder

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

func (*MockE2SubscriptionServiceClient) GetSubscription added in v0.6.11 

func (m *MockE2SubscriptionServiceClient) GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*GetSubscriptionResponse, error)

GetSubscription mocks base method

func (*MockE2SubscriptionServiceClient) ListSubscriptions added in v0.6.11 

func (m *MockE2SubscriptionServiceClient) ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error)

ListSubscriptions mocks base method

func (*MockE2SubscriptionServiceClient) RemoveSubscription added in v0.6.11 

func (m *MockE2SubscriptionServiceClient) RemoveSubscription(ctx context.Context, in *RemoveSubscriptionRequest, opts ...grpc.CallOption) (*RemoveSubscriptionResponse, error)

RemoveSubscription mocks base method

func (*MockE2SubscriptionServiceClient) WatchSubscriptions added in v0.6.11 

func (m *MockE2SubscriptionServiceClient) WatchSubscriptions(ctx context.Context, in *WatchSubscriptionsRequest, opts ...grpc.CallOption) (E2SubscriptionService_WatchSubscriptionsClient, error)

WatchSubscriptions mocks base method

type MockE2SubscriptionServiceClientMockRecorder added in v0.6.11 

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

MockE2SubscriptionServiceClientMockRecorder is the mock recorder for MockE2SubscriptionServiceClient

func (*MockE2SubscriptionServiceClientMockRecorder) AddSubscription added in v0.6.11 

func (mr *MockE2SubscriptionServiceClientMockRecorder) AddSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

AddSubscription indicates an expected call of AddSubscription

func (*MockE2SubscriptionServiceClientMockRecorder) GetSubscription added in v0.6.11 

func (mr *MockE2SubscriptionServiceClientMockRecorder) GetSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetSubscription indicates an expected call of GetSubscription

func (*MockE2SubscriptionServiceClientMockRecorder) ListSubscriptions added in v0.6.11 

func (mr *MockE2SubscriptionServiceClientMockRecorder) ListSubscriptions(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListSubscriptions indicates an expected call of ListSubscriptions

func (*MockE2SubscriptionServiceClientMockRecorder) RemoveSubscription added in v0.6.11 

func (mr *MockE2SubscriptionServiceClientMockRecorder) RemoveSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

RemoveSubscription indicates an expected call of RemoveSubscription

func (*MockE2SubscriptionServiceClientMockRecorder) WatchSubscriptions added in v0.6.11 

func (mr *MockE2SubscriptionServiceClientMockRecorder) WatchSubscriptions(ctx, in interface{}, opts ...interface{}) *gomock.Call

WatchSubscriptions indicates an expected call of WatchSubscriptions

type MockE2SubscriptionServiceServer added in v0.6.11 

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

MockE2SubscriptionServiceServer is a mock of E2SubscriptionServiceServer interface

func NewMockE2SubscriptionServiceServer added in v0.6.11 

func NewMockE2SubscriptionServiceServer(ctrl *gomock.Controller) *MockE2SubscriptionServiceServer

NewMockE2SubscriptionServiceServer creates a new mock instance

func (*MockE2SubscriptionServiceServer) AddSubscription added in v0.6.11 

func (m *MockE2SubscriptionServiceServer) AddSubscription(arg0 context.Context, arg1 *AddSubscriptionRequest) (*AddSubscriptionResponse, error)

AddSubscription mocks base method

func (*MockE2SubscriptionServiceServer) EXPECT added in v0.6.11 

func (m *MockE2SubscriptionServiceServer) EXPECT() *MockE2SubscriptionServiceServerMockRecorder

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

func (*MockE2SubscriptionServiceServer) GetSubscription added in v0.6.11 

func (m *MockE2SubscriptionServiceServer) GetSubscription(arg0 context.Context, arg1 *GetSubscriptionRequest) (*GetSubscriptionResponse, error)

GetSubscription mocks base method

func (*MockE2SubscriptionServiceServer) ListSubscriptions added in v0.6.11 

func (m *MockE2SubscriptionServiceServer) ListSubscriptions(arg0 context.Context, arg1 *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)

ListSubscriptions mocks base method

func (*MockE2SubscriptionServiceServer) RemoveSubscription added in v0.6.11 

func (m *MockE2SubscriptionServiceServer) RemoveSubscription(arg0 context.Context, arg1 *RemoveSubscriptionRequest) (*RemoveSubscriptionResponse, error)

RemoveSubscription mocks base method

func (*MockE2SubscriptionServiceServer) WatchSubscriptions added in v0.6.11 

func (m *MockE2SubscriptionServiceServer) WatchSubscriptions(arg0 *WatchSubscriptionsRequest, arg1 E2SubscriptionService_WatchSubscriptionsServer) error

WatchSubscriptions mocks base method

type MockE2SubscriptionServiceServerMockRecorder added in v0.6.11 

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

MockE2SubscriptionServiceServerMockRecorder is the mock recorder for MockE2SubscriptionServiceServer

func (*MockE2SubscriptionServiceServerMockRecorder) AddSubscription added in v0.6.11 

func (mr *MockE2SubscriptionServiceServerMockRecorder) AddSubscription(arg0, arg1 interface{}) *gomock.Call

AddSubscription indicates an expected call of AddSubscription

func (*MockE2SubscriptionServiceServerMockRecorder) GetSubscription added in v0.6.11 

func (mr *MockE2SubscriptionServiceServerMockRecorder) GetSubscription(arg0, arg1 interface{}) *gomock.Call

GetSubscription indicates an expected call of GetSubscription

func (*MockE2SubscriptionServiceServerMockRecorder) ListSubscriptions added in v0.6.11 

func (mr *MockE2SubscriptionServiceServerMockRecorder) ListSubscriptions(arg0, arg1 interface{}) *gomock.Call

ListSubscriptions indicates an expected call of ListSubscriptions

func (*MockE2SubscriptionServiceServerMockRecorder) RemoveSubscription added in v0.6.11 

func (mr *MockE2SubscriptionServiceServerMockRecorder) RemoveSubscription(arg0, arg1 interface{}) *gomock.Call

RemoveSubscription indicates an expected call of RemoveSubscription

func (*MockE2SubscriptionServiceServerMockRecorder) WatchSubscriptions added in v0.6.11 

func (mr *MockE2SubscriptionServiceServerMockRecorder) WatchSubscriptions(arg0, arg1 interface{}) *gomock.Call

WatchSubscriptions indicates an expected call of WatchSubscriptions

type MockE2SubscriptionService_WatchSubscriptionsClient added in v0.6.11 

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

MockE2SubscriptionService_WatchSubscriptionsClient is a mock of E2SubscriptionService_WatchSubscriptionsClient interface

func NewMockE2SubscriptionService_WatchSubscriptionsClient added in v0.6.11 

func NewMockE2SubscriptionService_WatchSubscriptionsClient(ctrl *gomock.Controller) *MockE2SubscriptionService_WatchSubscriptionsClient

NewMockE2SubscriptionService_WatchSubscriptionsClient creates a new mock instance

func (*MockE2SubscriptionService_WatchSubscriptionsClient) CloseSend added in v0.6.11 

func (m *MockE2SubscriptionService_WatchSubscriptionsClient) CloseSend() error

CloseSend mocks base method

func (*MockE2SubscriptionService_WatchSubscriptionsClient) Context added in v0.6.11 

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

Context mocks base method

func (*MockE2SubscriptionService_WatchSubscriptionsClient) EXPECT added in v0.6.11 

func (m *MockE2SubscriptionService_WatchSubscriptionsClient) EXPECT() *MockE2SubscriptionService_WatchSubscriptionsClientMockRecorder

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

func (*MockE2SubscriptionService_WatchSubscriptionsClient) Header added in v0.6.11 

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

Header mocks base method

func (*MockE2SubscriptionService_WatchSubscriptionsClient) Recv added in v0.6.11 

func (m *MockE2SubscriptionService_WatchSubscriptionsClient) Recv() (*WatchSubscriptionsResponse, error)

Recv mocks base method

func (*MockE2SubscriptionService_WatchSubscriptionsClient) RecvMsg added in v0.6.11 

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

RecvMsg mocks base method

func (*MockE2SubscriptionService_WatchSubscriptionsClient) SendMsg added in v0.6.11 

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

SendMsg mocks base method

func (*MockE2SubscriptionService_WatchSubscriptionsClient) Trailer added in v0.6.11 

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

Trailer mocks base method

type MockE2SubscriptionService_WatchSubscriptionsClientMockRecorder added in v0.6.11 

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

MockE2SubscriptionService_WatchSubscriptionsClientMockRecorder is the mock recorder for MockE2SubscriptionService_WatchSubscriptionsClient

func (*MockE2SubscriptionService_WatchSubscriptionsClientMockRecorder) CloseSend added in v0.6.11 

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

CloseSend indicates an expected call of CloseSend

func (*MockE2SubscriptionService_WatchSubscriptionsClientMockRecorder) Context added in v0.6.11 

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

Context indicates an expected call of Context

func (*MockE2SubscriptionService_WatchSubscriptionsClientMockRecorder) Header added in v0.6.11 

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

Header indicates an expected call of Header

func (*MockE2SubscriptionService_WatchSubscriptionsClientMockRecorder) Recv added in v0.6.11 

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

Recv indicates an expected call of Recv

func (*MockE2SubscriptionService_WatchSubscriptionsClientMockRecorder) RecvMsg added in v0.6.11 

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

RecvMsg indicates an expected call of RecvMsg

func (*MockE2SubscriptionService_WatchSubscriptionsClientMockRecorder) SendMsg added in v0.6.11 

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

SendMsg indicates an expected call of SendMsg

func (*MockE2SubscriptionService_WatchSubscriptionsClientMockRecorder) Trailer added in v0.6.11 

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

Trailer indicates an expected call of Trailer

type MockE2SubscriptionService_WatchSubscriptionsServer added in v0.6.11 

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

MockE2SubscriptionService_WatchSubscriptionsServer is a mock of E2SubscriptionService_WatchSubscriptionsServer interface

func NewMockE2SubscriptionService_WatchSubscriptionsServer added in v0.6.11 

func NewMockE2SubscriptionService_WatchSubscriptionsServer(ctrl *gomock.Controller) *MockE2SubscriptionService_WatchSubscriptionsServer

NewMockE2SubscriptionService_WatchSubscriptionsServer creates a new mock instance

func (*MockE2SubscriptionService_WatchSubscriptionsServer) Context added in v0.6.11 

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

Context mocks base method

func (*MockE2SubscriptionService_WatchSubscriptionsServer) EXPECT added in v0.6.11 

func (m *MockE2SubscriptionService_WatchSubscriptionsServer) EXPECT() *MockE2SubscriptionService_WatchSubscriptionsServerMockRecorder

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

func (*MockE2SubscriptionService_WatchSubscriptionsServer) RecvMsg added in v0.6.11 

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

RecvMsg mocks base method

func (*MockE2SubscriptionService_WatchSubscriptionsServer) Send added in v0.6.11 

func (m *MockE2SubscriptionService_WatchSubscriptionsServer) Send(arg0 *WatchSubscriptionsResponse) error

Send mocks base method

func (*MockE2SubscriptionService_WatchSubscriptionsServer) SendHeader added in v0.6.11 

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

SendHeader mocks base method

func (*MockE2SubscriptionService_WatchSubscriptionsServer) SendMsg added in v0.6.11 

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

SendMsg mocks base method

func (*MockE2SubscriptionService_WatchSubscriptionsServer) SetHeader added in v0.6.11 

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

SetHeader mocks base method

func (*MockE2SubscriptionService_WatchSubscriptionsServer) SetTrailer added in v0.6.11 

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

SetTrailer mocks base method

type MockE2SubscriptionService_WatchSubscriptionsServerMockRecorder added in v0.6.11 

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

MockE2SubscriptionService_WatchSubscriptionsServerMockRecorder is the mock recorder for MockE2SubscriptionService_WatchSubscriptionsServer

func (*MockE2SubscriptionService_WatchSubscriptionsServerMockRecorder) Context added in v0.6.11 

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

Context indicates an expected call of Context

func (*MockE2SubscriptionService_WatchSubscriptionsServerMockRecorder) RecvMsg added in v0.6.11 

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

RecvMsg indicates an expected call of RecvMsg

func (*MockE2SubscriptionService_WatchSubscriptionsServerMockRecorder) Send added in v0.6.11 

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

Send indicates an expected call of Send

func (*MockE2SubscriptionService_WatchSubscriptionsServerMockRecorder) SendHeader added in v0.6.11 

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

SendHeader indicates an expected call of SendHeader

func (*MockE2SubscriptionService_WatchSubscriptionsServerMockRecorder) SendMsg added in v0.6.11 

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

SendMsg indicates an expected call of SendMsg

func (*MockE2SubscriptionService_WatchSubscriptionsServerMockRecorder) SetHeader added in v0.6.11 

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

SetHeader indicates an expected call of SetHeader

func (*MockE2SubscriptionService_WatchSubscriptionsServerMockRecorder) SetTrailer added in v0.6.11 

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

SetTrailer indicates an expected call of SetTrailer

type Payload 

type Payload struct {
	Encoding Encoding `protobuf:"varint,1,opt,name=encoding,proto3,enum=onos.e2sub.subscription.Encoding" json:"encoding,omitempty"`
	Data     []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Payload) Descriptor 

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

func (*Payload) GetData added in v0.6.10 

func (m *Payload) GetData() []byte

func (*Payload) GetEncoding 

func (m *Payload) GetEncoding() Encoding

func (*Payload) Marshal 

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

func (*Payload) MarshalTo 

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

func (*Payload) MarshalToSizedBuffer 

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

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) Reset 

func (m *Payload) Reset()

func (*Payload) Size 

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

func (*Payload) String 

func (m *Payload) String() string

func (*Payload) Unmarshal 

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

func (*Payload) XXX_DiscardUnknown 

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal 

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

func (*Payload) XXX_Merge 

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

func (*Payload) XXX_Size 

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal 

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

type RemoveSubscriptionRequest 

type RemoveSubscriptionRequest struct {
	ID ID `protobuf:"bytes,1,opt,name=id,proto3,casttype=ID" json:"id,omitempty"`
}

RemoveSubscriptionRequest a subscription delete request

func (*RemoveSubscriptionRequest) Descriptor 

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

func (*RemoveSubscriptionRequest) GetID 

func (m *RemoveSubscriptionRequest) GetID() ID

func (*RemoveSubscriptionRequest) Marshal 

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

func (*RemoveSubscriptionRequest) MarshalTo 

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

func (*RemoveSubscriptionRequest) MarshalToSizedBuffer 

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

func (*RemoveSubscriptionRequest) ProtoMessage 

func (*RemoveSubscriptionRequest) ProtoMessage()

func (*RemoveSubscriptionRequest) Reset 

func (m *RemoveSubscriptionRequest) Reset()

func (*RemoveSubscriptionRequest) Size 

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

func (*RemoveSubscriptionRequest) String 

func (m *RemoveSubscriptionRequest) String() string

func (*RemoveSubscriptionRequest) Unmarshal 

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

func (*RemoveSubscriptionRequest) XXX_DiscardUnknown 

func (m *RemoveSubscriptionRequest) XXX_DiscardUnknown()

func (*RemoveSubscriptionRequest) XXX_Marshal 

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

func (*RemoveSubscriptionRequest) XXX_Merge 

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

func (*RemoveSubscriptionRequest) XXX_Size 

func (m *RemoveSubscriptionRequest) XXX_Size() int

func (*RemoveSubscriptionRequest) XXX_Unmarshal 

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

type RemoveSubscriptionResponse 

type RemoveSubscriptionResponse struct {
}

RemoveSubscriptionResponse a subscription delete response

func (*RemoveSubscriptionResponse) Descriptor 

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

func (*RemoveSubscriptionResponse) Marshal 

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

func (*RemoveSubscriptionResponse) MarshalTo 

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

func (*RemoveSubscriptionResponse) MarshalToSizedBuffer 

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

func (*RemoveSubscriptionResponse) ProtoMessage 

func (*RemoveSubscriptionResponse) ProtoMessage()

func (*RemoveSubscriptionResponse) Reset 

func (m *RemoveSubscriptionResponse) Reset()

func (*RemoveSubscriptionResponse) Size 

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

func (*RemoveSubscriptionResponse) String 

func (m *RemoveSubscriptionResponse) String() string

func (*RemoveSubscriptionResponse) Unmarshal 

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

func (*RemoveSubscriptionResponse) XXX_DiscardUnknown 

func (m *RemoveSubscriptionResponse) XXX_DiscardUnknown()

func (*RemoveSubscriptionResponse) XXX_Marshal 

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

func (*RemoveSubscriptionResponse) XXX_Merge 

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

func (*RemoveSubscriptionResponse) XXX_Size 

func (m *RemoveSubscriptionResponse) XXX_Size() int

func (*RemoveSubscriptionResponse) XXX_Unmarshal 

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

type Revision 

type Revision uint64

Revision is a subscription revision

type ServiceModel 

type ServiceModel struct {
	ID ServiceModelID `protobuf:"bytes,4,opt,name=id,proto3,casttype=ServiceModelID" json:"id,omitempty"`
}

ServiceModel is a service model definition

func (*ServiceModel) Descriptor 

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

func (*ServiceModel) GetID 

func (m *ServiceModel) GetID() ServiceModelID

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 ServiceModelID 

type ServiceModelID string

ServiceModelID is a service model identifier

type Status 

type Status int32

Status is a subscription status 

const (
	Status_ACTIVE         Status = 0
	Status_PENDING_DELETE Status = 1
	Status_FAILED         Status = 2
)

func (Status) EnumDescriptor 

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

func (Status) String 

func (x Status) String() string

type Subscription 

type Subscription struct {
	ID        ID                   `protobuf:"bytes,1,opt,name=id,proto3,casttype=ID" json:"id,omitempty"`
	Revision  Revision             `protobuf:"varint,2,opt,name=revision,proto3,casttype=Revision" json:"revision,omitempty"`
	AppID     AppID                `protobuf:"bytes,3,opt,name=app_id,json=appId,proto3,casttype=AppID" json:"app_id,omitempty"`
	Details   *SubscriptionDetails `protobuf:"bytes,4,opt,name=details,proto3" json:"details,omitempty"`
	Lifecycle Lifecycle            `protobuf:"bytes,5,opt,name=lifecycle,proto3" json:"lifecycle"`
}

Subscription is a subscription state

func (*Subscription) Descriptor 

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

func (*Subscription) GetAppID 

func (m *Subscription) GetAppID() AppID

func (*Subscription) GetDetails added in v0.6.10 

func (m *Subscription) GetDetails() *SubscriptionDetails

func (*Subscription) GetID 

func (m *Subscription) GetID() ID

func (*Subscription) GetLifecycle 

func (m *Subscription) GetLifecycle() Lifecycle

func (*Subscription) GetRevision 

func (m *Subscription) GetRevision() Revision

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 SubscriptionDetails added in v0.6.10 

type SubscriptionDetails 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"`
	EventTrigger EventTrigger `protobuf:"bytes,3,opt,name=event_trigger,json=eventTrigger,proto3" json:"event_trigger"`
	Actions      []Action     `protobuf:"bytes,4,rep,name=actions,proto3" json:"actions"`
}

func (*SubscriptionDetails) Descriptor added in v0.6.10 

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

func (*SubscriptionDetails) GetActions added in v0.6.10 

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

func (*SubscriptionDetails) GetE2NodeID added in v0.6.10 

func (m *SubscriptionDetails) GetE2NodeID() E2NodeID

func (*SubscriptionDetails) GetEventTrigger added in v0.6.10 

func (m *SubscriptionDetails) GetEventTrigger() EventTrigger

func (*SubscriptionDetails) GetServiceModel added in v0.6.10 

func (m *SubscriptionDetails) GetServiceModel() ServiceModel

func (*SubscriptionDetails) Marshal added in v0.6.10 

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

func (*SubscriptionDetails) MarshalTo added in v0.6.10 

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

func (*SubscriptionDetails) MarshalToSizedBuffer added in v0.6.10 

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

func (*SubscriptionDetails) ProtoMessage added in v0.6.10 

func (*SubscriptionDetails) ProtoMessage()

func (*SubscriptionDetails) Reset added in v0.6.10 

func (m *SubscriptionDetails) Reset()

func (*SubscriptionDetails) Size added in v0.6.10 

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

func (*SubscriptionDetails) String added in v0.6.10 

func (m *SubscriptionDetails) String() string

func (*SubscriptionDetails) Unmarshal added in v0.6.10 

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

func (*SubscriptionDetails) XXX_DiscardUnknown added in v0.6.10 

func (m *SubscriptionDetails) XXX_DiscardUnknown()

func (*SubscriptionDetails) XXX_Marshal added in v0.6.10 

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

func (*SubscriptionDetails) XXX_Merge added in v0.6.10 

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

func (*SubscriptionDetails) XXX_Size added in v0.6.10 

func (m *SubscriptionDetails) XXX_Size() int

func (*SubscriptionDetails) XXX_Unmarshal added in v0.6.10 

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

type SubsequentAction added in v0.6.10 

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

sequence from e2ap-v01.00.00.asn1:1132

func (*SubsequentAction) Descriptor added in v0.6.10 

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

func (*SubsequentAction) GetTimeToWait added in v0.6.10 

func (m *SubsequentAction) GetTimeToWait() TimeToWait

func (*SubsequentAction) GetType added in v0.6.10 

func (m *SubsequentAction) GetType() SubsequentActionType

func (*SubsequentAction) Marshal added in v0.6.10 

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

func (*SubsequentAction) MarshalTo added in v0.6.10 

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

func (*SubsequentAction) MarshalToSizedBuffer added in v0.6.10 

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

func (*SubsequentAction) ProtoMessage added in v0.6.10 

func (*SubsequentAction) ProtoMessage()

func (*SubsequentAction) Reset added in v0.6.10 

func (m *SubsequentAction) Reset()

func (*SubsequentAction) Size added in v0.6.10 

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

func (*SubsequentAction) String added in v0.6.10 

func (m *SubsequentAction) String() string

func (*SubsequentAction) Unmarshal added in v0.6.10 

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

func (*SubsequentAction) XXX_DiscardUnknown added in v0.6.10 

func (m *SubsequentAction) XXX_DiscardUnknown()

func (*SubsequentAction) XXX_Marshal added in v0.6.10 

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

func (*SubsequentAction) XXX_Merge added in v0.6.10 

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

func (*SubsequentAction) XXX_Size added in v0.6.10 

func (m *SubsequentAction) XXX_Size() int

func (*SubsequentAction) XXX_Unmarshal added in v0.6.10 

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

type SubsequentActionType added in v0.6.10 

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

func (SubsequentActionType) EnumDescriptor added in v0.6.10 

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

func (SubsequentActionType) String added in v0.6.10 

func (x SubsequentActionType) String() string

type TimeToWait added in v0.6.10 

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

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

func (TimeToWait) String added in v0.6.10 

func (x TimeToWait) String() string

type UnimplementedE2SubscriptionServiceServer 

type UnimplementedE2SubscriptionServiceServer struct {
}

UnimplementedE2SubscriptionServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedE2SubscriptionServiceServer) AddSubscription 

func (*UnimplementedE2SubscriptionServiceServer) AddSubscription(ctx context.Context, req *AddSubscriptionRequest) (*AddSubscriptionResponse, error)

func (*UnimplementedE2SubscriptionServiceServer) GetSubscription 

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

func (*UnimplementedE2SubscriptionServiceServer) ListSubscriptions 

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

func (*UnimplementedE2SubscriptionServiceServer) RemoveSubscription 

func (*UnimplementedE2SubscriptionServiceServer) RemoveSubscription(ctx context.Context, req *RemoveSubscriptionRequest) (*RemoveSubscriptionResponse, error)

func (*UnimplementedE2SubscriptionServiceServer) WatchSubscriptions 

func (*UnimplementedE2SubscriptionServiceServer) WatchSubscriptions(req *WatchSubscriptionsRequest, srv E2SubscriptionService_WatchSubscriptionsServer) error

type WatchSubscriptionsRequest 

type WatchSubscriptionsRequest struct {
	Noreplay bool `protobuf:"varint,1,opt,name=noreplay,proto3" json:"noreplay,omitempty"`
}

func (*WatchSubscriptionsRequest) Descriptor 

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

func (*WatchSubscriptionsRequest) GetNoreplay 

func (m *WatchSubscriptionsRequest) GetNoreplay() bool

func (*WatchSubscriptionsRequest) Marshal 

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

func (*WatchSubscriptionsRequest) MarshalTo 

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

func (*WatchSubscriptionsRequest) MarshalToSizedBuffer 

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

func (*WatchSubscriptionsRequest) ProtoMessage 

func (*WatchSubscriptionsRequest) ProtoMessage()

func (*WatchSubscriptionsRequest) Reset 

func (m *WatchSubscriptionsRequest) Reset()

func (*WatchSubscriptionsRequest) Size 

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

func (*WatchSubscriptionsRequest) String 

func (m *WatchSubscriptionsRequest) String() string

func (*WatchSubscriptionsRequest) Unmarshal 

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

func (*WatchSubscriptionsRequest) XXX_DiscardUnknown 

func (m *WatchSubscriptionsRequest) XXX_DiscardUnknown()

func (*WatchSubscriptionsRequest) XXX_Marshal 

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

func (*WatchSubscriptionsRequest) XXX_Merge 

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

func (*WatchSubscriptionsRequest) XXX_Size 

func (m *WatchSubscriptionsRequest) XXX_Size() int

func (*WatchSubscriptionsRequest) XXX_Unmarshal 

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

type WatchSubscriptionsResponse 

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

func (*WatchSubscriptionsResponse) Descriptor 

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

func (*WatchSubscriptionsResponse) GetEvent 

func (m *WatchSubscriptionsResponse) GetEvent() Event

func (*WatchSubscriptionsResponse) Marshal 

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

func (*WatchSubscriptionsResponse) MarshalTo 

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

func (*WatchSubscriptionsResponse) MarshalToSizedBuffer 

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

func (*WatchSubscriptionsResponse) ProtoMessage 

func (*WatchSubscriptionsResponse) ProtoMessage()

func (*WatchSubscriptionsResponse) Reset 

func (m *WatchSubscriptionsResponse) Reset()

func (*WatchSubscriptionsResponse) Size 

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

func (*WatchSubscriptionsResponse) String 

func (m *WatchSubscriptionsResponse) String() string

func (*WatchSubscriptionsResponse) Unmarshal 

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

func (*WatchSubscriptionsResponse) XXX_DiscardUnknown 

func (m *WatchSubscriptionsResponse) XXX_DiscardUnknown()

func (*WatchSubscriptionsResponse) XXX_Marshal 

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

func (*WatchSubscriptionsResponse) XXX_Merge 

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

func (*WatchSubscriptionsResponse) XXX_Size 

func (m *WatchSubscriptionsResponse) XXX_Size() int

func (*WatchSubscriptionsResponse) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.