task

package
v0.8.32 Latest Latest
Warning

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

 Go to latest Published: Jan 26, 2022 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

Package task is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTask        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTask          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTask = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Cause_name = map[int32]string{
	0:  "CAUSE_UNKNOWN",
	1:  "CAUSE_MISC_CONTROL_PROCESSING_OVERLOAD",
	2:  "CAUSE_MISC_HARDWARE_FAILURE",
	3:  "CAUSE_MISC_OM_INTERVENTION",
	4:  "CAUSE_MISC_UNSPECIFIED",
	5:  "CAUSE_PROTOCOL_TRANSFER_SYNTAX_ERROR",
	6:  "CAUSE_PROTOCOL_ABSTRACT_SYNTAX_ERROR_REJECT",
	7:  "CAUSE_PROTOCOL_ABSTRACT_SYNTAX_ERROR_IGNORE_AND_NOTIFY",
	8:  "CAUSE_PROTOCOL_MESSAGE_NOT_COMPATIBLE_WITH_RECEIVER_STATE",
	9:  "CAUSE_PROTOCOL_SEMANTIC_ERROR",
	10: "CAUSE_PROTOCOL_ABSTRACT_SYNTAX_ERROR_FALSELY_CONSTRUCTED_MESSAGE",
	11: "CAUSE_PROTOCOL_UNSPECIFIED",
	12: "CAUSE_RIC_RAN_FUNCTION_ID_INVALID",
	13: "CAUSE_RIC_ACTION_NOT_SUPPORTED",
	14: "CAUSE_RIC_EXCESSIVE_ACTIONS",
	15: "CAUSE_RIC_DUPLICATE_ACTION",
	16: "CAUSE_RIC_DUPLICATE_EVENT",
	17: "CAUSE_RIC_FUNCTION_RESOURCE_LIMIT",
	18: "CAUSE_RIC_REQUEST_ID_UNKNOWN",
	19: "CAUSE_RIC_INCONSISTENT_ACTION_SUBSEQUENT_ACTION_SEQUENCE",
	20: "CAUSE_RIC_CONTROL_MESSAGE_INVALID",
	21: "CAUSE_RIC_CALL_PROCESS_ID_INVALID",
	22: "CAUSE_RIC_UNSPECIFIED",
	23: "CAUSE_RICSERVICE_FUNCTION_NOT_REQUIRED",
	24: "CAUSE_RICSERVICE_EXCESSIVE_FUNCTIONS",
	25: "CAUSE_RICSERVICE_RIC_RESOURCE_LIMIT",
	26: "CAUSE_TRANSPORT_UNSPECIFIED",
	27: "CAUSE_TRANSPORT_TRANSPORT_RESOURCE_UNAVAILABLE",
}
View Source 
var Cause_value = map[string]int32{
	"CAUSE_UNKNOWN":                                                    0,
	"CAUSE_MISC_CONTROL_PROCESSING_OVERLOAD":                           1,
	"CAUSE_MISC_HARDWARE_FAILURE":                                      2,
	"CAUSE_MISC_OM_INTERVENTION":                                       3,
	"CAUSE_MISC_UNSPECIFIED":                                           4,
	"CAUSE_PROTOCOL_TRANSFER_SYNTAX_ERROR":                             5,
	"CAUSE_PROTOCOL_ABSTRACT_SYNTAX_ERROR_REJECT":                      6,
	"CAUSE_PROTOCOL_ABSTRACT_SYNTAX_ERROR_IGNORE_AND_NOTIFY":           7,
	"CAUSE_PROTOCOL_MESSAGE_NOT_COMPATIBLE_WITH_RECEIVER_STATE":        8,
	"CAUSE_PROTOCOL_SEMANTIC_ERROR":                                    9,
	"CAUSE_PROTOCOL_ABSTRACT_SYNTAX_ERROR_FALSELY_CONSTRUCTED_MESSAGE": 10,
	"CAUSE_PROTOCOL_UNSPECIFIED":                                       11,
	"CAUSE_RIC_RAN_FUNCTION_ID_INVALID":                                12,
	"CAUSE_RIC_ACTION_NOT_SUPPORTED":                                   13,
	"CAUSE_RIC_EXCESSIVE_ACTIONS":                                      14,
	"CAUSE_RIC_DUPLICATE_ACTION":                                       15,
	"CAUSE_RIC_DUPLICATE_EVENT":                                        16,
	"CAUSE_RIC_FUNCTION_RESOURCE_LIMIT":                                17,
	"CAUSE_RIC_REQUEST_ID_UNKNOWN":                                     18,
	"CAUSE_RIC_INCONSISTENT_ACTION_SUBSEQUENT_ACTION_SEQUENCE":         19,
	"CAUSE_RIC_CONTROL_MESSAGE_INVALID":                                20,
	"CAUSE_RIC_CALL_PROCESS_ID_INVALID":                                21,
	"CAUSE_RIC_UNSPECIFIED":                                            22,
	"CAUSE_RICSERVICE_FUNCTION_NOT_REQUIRED":                           23,
	"CAUSE_RICSERVICE_EXCESSIVE_FUNCTIONS":                             24,
	"CAUSE_RICSERVICE_RIC_RESOURCE_LIMIT":                              25,
	"CAUSE_TRANSPORT_UNSPECIFIED":                                      26,
	"CAUSE_TRANSPORT_TRANSPORT_RESOURCE_UNAVAILABLE":                   27,
}
View Source 
var EventType_name = map[int32]string{
	0: "NONE",
	1: "CREATED",
	2: "UPDATED",
	3: "REMOVED",
}
View Source 
var EventType_value = map[string]int32{
	"NONE":    0,
	"CREATED": 1,
	"UPDATED": 2,
	"REMOVED": 3,
}
View Source 
var Phase_name = map[int32]string{
	0: "OPEN",
	1: "CLOSE",
}
View Source 
var Phase_value = map[string]int32{
	"OPEN":  0,
	"CLOSE": 1,
}
View Source 
var Status_name = map[int32]string{
	0: "PENDING",
	1: "COMPLETE",
	2: "FAILED",
}
View Source 
var Status_value = map[string]int32{
	"PENDING":  0,
	"COMPLETE": 1,
	"FAILED":   2,
}

Functions

func RegisterE2SubscriptionTaskServiceServer 

func RegisterE2SubscriptionTaskServiceServer(s *grpc.Server, srv E2SubscriptionTaskServiceServer)

Types

type Cause added in v0.7.3 

type Cause int32

Cause is a failure cause 

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

func (Cause) EnumDescriptor added in v0.7.3 

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

func (Cause) String added in v0.7.3 

func (x Cause) String() string

type E2SubscriptionTaskServiceClient 

type E2SubscriptionTaskServiceClient interface {
	// GetSubscriptionTask retrieves information about a specific task
	GetSubscriptionTask(ctx context.Context, in *GetSubscriptionTaskRequest, opts ...grpc.CallOption) (*GetSubscriptionTaskResponse, error)
	// ListSubscriptionTasks returns the list of currently registered E2 Tasks.
	ListSubscriptionTasks(ctx context.Context, in *ListSubscriptionTasksRequest, opts ...grpc.CallOption) (*ListSubscriptionTasksResponse, error)
	// WatchSubscriptionTasks returns a stream of changes in the set of available E2 Tasks.
	WatchSubscriptionTasks(ctx context.Context, in *WatchSubscriptionTasksRequest, opts ...grpc.CallOption) (E2SubscriptionTaskService_WatchSubscriptionTasksClient, error)
	// UpdateSubscriptionTask updates a task status
	UpdateSubscriptionTask(ctx context.Context, in *UpdateSubscriptionTaskRequest, opts ...grpc.CallOption) (*UpdateSubscriptionTaskResponse, error)
}

E2SubscriptionTaskServiceClient is the client API for E2SubscriptionTaskService service.

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

func NewE2SubscriptionTaskServiceClient 

func NewE2SubscriptionTaskServiceClient(cc *grpc.ClientConn) E2SubscriptionTaskServiceClient

type E2SubscriptionTaskServiceServer 

type E2SubscriptionTaskServiceServer interface {
	// GetSubscriptionTask retrieves information about a specific task
	GetSubscriptionTask(context.Context, *GetSubscriptionTaskRequest) (*GetSubscriptionTaskResponse, error)
	// ListSubscriptionTasks returns the list of currently registered E2 Tasks.
	ListSubscriptionTasks(context.Context, *ListSubscriptionTasksRequest) (*ListSubscriptionTasksResponse, error)
	// WatchSubscriptionTasks returns a stream of changes in the set of available E2 Tasks.
	WatchSubscriptionTasks(*WatchSubscriptionTasksRequest, E2SubscriptionTaskService_WatchSubscriptionTasksServer) error
	// UpdateSubscriptionTask updates a task status
	UpdateSubscriptionTask(context.Context, *UpdateSubscriptionTaskRequest) (*UpdateSubscriptionTaskResponse, error)
}

E2SubscriptionTaskServiceServer is the server API for E2SubscriptionTaskService service.

type E2SubscriptionTaskService_WatchSubscriptionTasksClient 

type E2SubscriptionTaskService_WatchSubscriptionTasksClient interface {
	Recv() (*WatchSubscriptionTasksResponse, error)
	grpc.ClientStream
}

type E2SubscriptionTaskService_WatchSubscriptionTasksServer 

type E2SubscriptionTaskService_WatchSubscriptionTasksServer interface {
	Send(*WatchSubscriptionTasksResponse) error
	grpc.ServerStream
}

type Event 

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

Event is a SubscriptionTask event

func (*Event) Descriptor 

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

func (*Event) GetTask 

func (m *Event) GetTask() SubscriptionTask

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 EventType 

type EventType int32

Type of change 

const (
	EventType_NONE    EventType = 0
	EventType_CREATED 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 Failure added in v0.7.3 

type Failure struct {
	Cause   Cause  `protobuf:"varint,1,opt,name=cause,proto3,enum=onos.e2sub.task.Cause" json:"cause,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

Failure is a subscription failure status

func (*Failure) Descriptor added in v0.7.3 

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

func (*Failure) GetCause added in v0.7.3 

func (m *Failure) GetCause() Cause

func (*Failure) GetMessage added in v0.7.3 

func (m *Failure) GetMessage() string

func (*Failure) Marshal added in v0.7.3 

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

func (*Failure) MarshalTo added in v0.7.3 

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

func (*Failure) MarshalToSizedBuffer added in v0.7.3 

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

func (*Failure) ProtoMessage added in v0.7.3 

func (*Failure) ProtoMessage()

func (*Failure) Reset added in v0.7.3 

func (m *Failure) Reset()

func (*Failure) Size added in v0.7.3 

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

func (*Failure) String added in v0.7.3 

func (m *Failure) String() string

func (*Failure) Unmarshal added in v0.7.3 

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

func (*Failure) XXX_DiscardUnknown added in v0.7.3 

func (m *Failure) XXX_DiscardUnknown()

func (*Failure) XXX_Marshal added in v0.7.3 

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

func (*Failure) XXX_Merge added in v0.7.3 

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

func (*Failure) XXX_Size added in v0.7.3 

func (m *Failure) XXX_Size() int

func (*Failure) XXX_Unmarshal added in v0.7.3 

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

type GetSubscriptionTaskRequest 

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

GetSubscriptionTaskRequest is a request for getting existing SubscriptionTask

func (*GetSubscriptionTaskRequest) Descriptor 

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

func (*GetSubscriptionTaskRequest) GetID 

func (m *GetSubscriptionTaskRequest) GetID() ID

func (*GetSubscriptionTaskRequest) Marshal 

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

func (*GetSubscriptionTaskRequest) MarshalTo 

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

func (*GetSubscriptionTaskRequest) MarshalToSizedBuffer 

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

func (*GetSubscriptionTaskRequest) ProtoMessage 

func (*GetSubscriptionTaskRequest) ProtoMessage()

func (*GetSubscriptionTaskRequest) Reset 

func (m *GetSubscriptionTaskRequest) Reset()

func (*GetSubscriptionTaskRequest) Size 

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

func (*GetSubscriptionTaskRequest) String 

func (m *GetSubscriptionTaskRequest) String() string

func (*GetSubscriptionTaskRequest) Unmarshal 

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

func (*GetSubscriptionTaskRequest) XXX_DiscardUnknown 

func (m *GetSubscriptionTaskRequest) XXX_DiscardUnknown()

func (*GetSubscriptionTaskRequest) XXX_Marshal 

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

func (*GetSubscriptionTaskRequest) XXX_Merge 

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

func (*GetSubscriptionTaskRequest) XXX_Size 

func (m *GetSubscriptionTaskRequest) XXX_Size() int

func (*GetSubscriptionTaskRequest) XXX_Unmarshal 

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

type GetSubscriptionTaskResponse 

type GetSubscriptionTaskResponse struct {
	Task *SubscriptionTask `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
}

GetSubscriptionTaskResponse is a response with invormation about a requested SubscriptionTask

func (*GetSubscriptionTaskResponse) Descriptor 

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

func (*GetSubscriptionTaskResponse) GetTask 

func (m *GetSubscriptionTaskResponse) GetTask() *SubscriptionTask

func (*GetSubscriptionTaskResponse) Marshal 

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

func (*GetSubscriptionTaskResponse) MarshalTo 

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

func (*GetSubscriptionTaskResponse) MarshalToSizedBuffer 

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

func (*GetSubscriptionTaskResponse) ProtoMessage 

func (*GetSubscriptionTaskResponse) ProtoMessage()

func (*GetSubscriptionTaskResponse) Reset 

func (m *GetSubscriptionTaskResponse) Reset()

func (*GetSubscriptionTaskResponse) Size 

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

func (*GetSubscriptionTaskResponse) String 

func (m *GetSubscriptionTaskResponse) String() string

func (*GetSubscriptionTaskResponse) Unmarshal 

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

func (*GetSubscriptionTaskResponse) XXX_DiscardUnknown 

func (m *GetSubscriptionTaskResponse) XXX_DiscardUnknown()

func (*GetSubscriptionTaskResponse) XXX_Marshal 

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

func (*GetSubscriptionTaskResponse) XXX_Merge 

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

func (*GetSubscriptionTaskResponse) XXX_Size 

func (m *GetSubscriptionTaskResponse) XXX_Size() int

func (*GetSubscriptionTaskResponse) XXX_Unmarshal 

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

type ID 

type ID string

ID is a device ID

type Lifecycle 

type Lifecycle struct {
	Phase   Phase    `protobuf:"varint,1,opt,name=phase,proto3,enum=onos.e2sub.task.Phase" json:"phase,omitempty"`
	Status  Status   `protobuf:"varint,2,opt,name=status,proto3,enum=onos.e2sub.task.Status" json:"status,omitempty"`
	Failure *Failure `protobuf:"bytes,3,opt,name=failure,proto3" json:"failure,omitempty"`
}

Lifecycle is a subscription task status

func (*Lifecycle) Descriptor 

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

func (*Lifecycle) GetFailure added in v0.7.3 

func (m *Lifecycle) GetFailure() *Failure

func (*Lifecycle) GetPhase 

func (m *Lifecycle) GetPhase() Phase

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 ListSubscriptionTasksRequest 

type ListSubscriptionTasksRequest struct {
	SubscriptionID github_com_onosproject_onos_api_go_onos_e2sub_subscription.ID `` /* 174-byte string literal not displayed */
	EndpointID     github_com_onosproject_onos_api_go_onos_e2sub_endpoint.ID     `` /* 158-byte string literal not displayed */
}

ListSubscriptionTasksRequest is a request to list all available SubscriptionTasks

func (*ListSubscriptionTasksRequest) Descriptor 

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

func (*ListSubscriptionTasksRequest) GetEndpointID 

func (m *ListSubscriptionTasksRequest) GetEndpointID() github_com_onosproject_onos_api_go_onos_e2sub_endpoint.ID

func (*ListSubscriptionTasksRequest) GetSubscriptionID 

func (m *ListSubscriptionTasksRequest) GetSubscriptionID() github_com_onosproject_onos_api_go_onos_e2sub_subscription.ID

func (*ListSubscriptionTasksRequest) Marshal 

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

func (*ListSubscriptionTasksRequest) MarshalTo 

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

func (*ListSubscriptionTasksRequest) MarshalToSizedBuffer 

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

func (*ListSubscriptionTasksRequest) ProtoMessage 

func (*ListSubscriptionTasksRequest) ProtoMessage()

func (*ListSubscriptionTasksRequest) Reset 

func (m *ListSubscriptionTasksRequest) Reset()

func (*ListSubscriptionTasksRequest) Size 

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

func (*ListSubscriptionTasksRequest) String 

func (m *ListSubscriptionTasksRequest) String() string

func (*ListSubscriptionTasksRequest) Unmarshal 

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

func (*ListSubscriptionTasksRequest) XXX_DiscardUnknown 

func (m *ListSubscriptionTasksRequest) XXX_DiscardUnknown()

func (*ListSubscriptionTasksRequest) XXX_Marshal 

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

func (*ListSubscriptionTasksRequest) XXX_Merge 

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

func (*ListSubscriptionTasksRequest) XXX_Size 

func (m *ListSubscriptionTasksRequest) XXX_Size() int

func (*ListSubscriptionTasksRequest) XXX_Unmarshal 

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

type ListSubscriptionTasksResponse 

type ListSubscriptionTasksResponse struct {
	Tasks []SubscriptionTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks"`
}

ListSubscriptionTasksResponse is a response to list all available SubscriptionTasks

func (*ListSubscriptionTasksResponse) Descriptor 

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

func (*ListSubscriptionTasksResponse) GetTasks 

func (m *ListSubscriptionTasksResponse) GetTasks() []SubscriptionTask

func (*ListSubscriptionTasksResponse) Marshal 

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

func (*ListSubscriptionTasksResponse) MarshalTo 

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

func (*ListSubscriptionTasksResponse) MarshalToSizedBuffer 

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

func (*ListSubscriptionTasksResponse) ProtoMessage 

func (*ListSubscriptionTasksResponse) ProtoMessage()

func (*ListSubscriptionTasksResponse) Reset 

func (m *ListSubscriptionTasksResponse) Reset()

func (*ListSubscriptionTasksResponse) Size 

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

func (*ListSubscriptionTasksResponse) String 

func (m *ListSubscriptionTasksResponse) String() string

func (*ListSubscriptionTasksResponse) Unmarshal 

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

func (*ListSubscriptionTasksResponse) XXX_DiscardUnknown 

func (m *ListSubscriptionTasksResponse) XXX_DiscardUnknown()

func (*ListSubscriptionTasksResponse) XXX_Marshal 

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

func (*ListSubscriptionTasksResponse) XXX_Merge 

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

func (*ListSubscriptionTasksResponse) XXX_Size 

func (m *ListSubscriptionTasksResponse) XXX_Size() int

func (*ListSubscriptionTasksResponse) XXX_Unmarshal 

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

type MockE2SubscriptionTaskServiceClient added in v0.6.11 

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

MockE2SubscriptionTaskServiceClient is a mock of E2SubscriptionTaskServiceClient interface

func NewMockE2SubscriptionTaskServiceClient added in v0.6.11 

func NewMockE2SubscriptionTaskServiceClient(ctrl *gomock.Controller) *MockE2SubscriptionTaskServiceClient

NewMockE2SubscriptionTaskServiceClient creates a new mock instance

func (*MockE2SubscriptionTaskServiceClient) EXPECT added in v0.6.11 

func (m *MockE2SubscriptionTaskServiceClient) EXPECT() *MockE2SubscriptionTaskServiceClientMockRecorder

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

func (*MockE2SubscriptionTaskServiceClient) GetSubscriptionTask added in v0.6.11 

func (m *MockE2SubscriptionTaskServiceClient) GetSubscriptionTask(ctx context.Context, in *GetSubscriptionTaskRequest, opts ...grpc.CallOption) (*GetSubscriptionTaskResponse, error)

GetSubscriptionTask mocks base method

func (*MockE2SubscriptionTaskServiceClient) ListSubscriptionTasks added in v0.6.11 

func (m *MockE2SubscriptionTaskServiceClient) ListSubscriptionTasks(ctx context.Context, in *ListSubscriptionTasksRequest, opts ...grpc.CallOption) (*ListSubscriptionTasksResponse, error)

ListSubscriptionTasks mocks base method

func (*MockE2SubscriptionTaskServiceClient) UpdateSubscriptionTask added in v0.6.11 

func (m *MockE2SubscriptionTaskServiceClient) UpdateSubscriptionTask(ctx context.Context, in *UpdateSubscriptionTaskRequest, opts ...grpc.CallOption) (*UpdateSubscriptionTaskResponse, error)

UpdateSubscriptionTask mocks base method

func (*MockE2SubscriptionTaskServiceClient) WatchSubscriptionTasks added in v0.6.11 

func (m *MockE2SubscriptionTaskServiceClient) WatchSubscriptionTasks(ctx context.Context, in *WatchSubscriptionTasksRequest, opts ...grpc.CallOption) (E2SubscriptionTaskService_WatchSubscriptionTasksClient, error)

WatchSubscriptionTasks mocks base method

type MockE2SubscriptionTaskServiceClientMockRecorder added in v0.6.11 

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

MockE2SubscriptionTaskServiceClientMockRecorder is the mock recorder for MockE2SubscriptionTaskServiceClient

func (*MockE2SubscriptionTaskServiceClientMockRecorder) GetSubscriptionTask added in v0.6.11 

func (mr *MockE2SubscriptionTaskServiceClientMockRecorder) GetSubscriptionTask(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetSubscriptionTask indicates an expected call of GetSubscriptionTask

func (*MockE2SubscriptionTaskServiceClientMockRecorder) ListSubscriptionTasks added in v0.6.11 

func (mr *MockE2SubscriptionTaskServiceClientMockRecorder) ListSubscriptionTasks(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListSubscriptionTasks indicates an expected call of ListSubscriptionTasks

func (*MockE2SubscriptionTaskServiceClientMockRecorder) UpdateSubscriptionTask added in v0.6.11 

func (mr *MockE2SubscriptionTaskServiceClientMockRecorder) UpdateSubscriptionTask(ctx, in interface{}, opts ...interface{}) *gomock.Call

UpdateSubscriptionTask indicates an expected call of UpdateSubscriptionTask

func (*MockE2SubscriptionTaskServiceClientMockRecorder) WatchSubscriptionTasks added in v0.6.11 

func (mr *MockE2SubscriptionTaskServiceClientMockRecorder) WatchSubscriptionTasks(ctx, in interface{}, opts ...interface{}) *gomock.Call

WatchSubscriptionTasks indicates an expected call of WatchSubscriptionTasks

type MockE2SubscriptionTaskServiceServer added in v0.6.11 

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

MockE2SubscriptionTaskServiceServer is a mock of E2SubscriptionTaskServiceServer interface

func NewMockE2SubscriptionTaskServiceServer added in v0.6.11 

func NewMockE2SubscriptionTaskServiceServer(ctrl *gomock.Controller) *MockE2SubscriptionTaskServiceServer

NewMockE2SubscriptionTaskServiceServer creates a new mock instance

func (*MockE2SubscriptionTaskServiceServer) EXPECT added in v0.6.11 

func (m *MockE2SubscriptionTaskServiceServer) EXPECT() *MockE2SubscriptionTaskServiceServerMockRecorder

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

func (*MockE2SubscriptionTaskServiceServer) GetSubscriptionTask added in v0.6.11 

func (m *MockE2SubscriptionTaskServiceServer) GetSubscriptionTask(arg0 context.Context, arg1 *GetSubscriptionTaskRequest) (*GetSubscriptionTaskResponse, error)

GetSubscriptionTask mocks base method

func (*MockE2SubscriptionTaskServiceServer) ListSubscriptionTasks added in v0.6.11 

func (m *MockE2SubscriptionTaskServiceServer) ListSubscriptionTasks(arg0 context.Context, arg1 *ListSubscriptionTasksRequest) (*ListSubscriptionTasksResponse, error)

ListSubscriptionTasks mocks base method

func (*MockE2SubscriptionTaskServiceServer) UpdateSubscriptionTask added in v0.6.11 

func (m *MockE2SubscriptionTaskServiceServer) UpdateSubscriptionTask(arg0 context.Context, arg1 *UpdateSubscriptionTaskRequest) (*UpdateSubscriptionTaskResponse, error)

UpdateSubscriptionTask mocks base method

func (*MockE2SubscriptionTaskServiceServer) WatchSubscriptionTasks added in v0.6.11 

func (m *MockE2SubscriptionTaskServiceServer) WatchSubscriptionTasks(arg0 *WatchSubscriptionTasksRequest, arg1 E2SubscriptionTaskService_WatchSubscriptionTasksServer) error

WatchSubscriptionTasks mocks base method

type MockE2SubscriptionTaskServiceServerMockRecorder added in v0.6.11 

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

MockE2SubscriptionTaskServiceServerMockRecorder is the mock recorder for MockE2SubscriptionTaskServiceServer

func (*MockE2SubscriptionTaskServiceServerMockRecorder) GetSubscriptionTask added in v0.6.11 

func (mr *MockE2SubscriptionTaskServiceServerMockRecorder) GetSubscriptionTask(arg0, arg1 interface{}) *gomock.Call

GetSubscriptionTask indicates an expected call of GetSubscriptionTask

func (*MockE2SubscriptionTaskServiceServerMockRecorder) ListSubscriptionTasks added in v0.6.11 

func (mr *MockE2SubscriptionTaskServiceServerMockRecorder) ListSubscriptionTasks(arg0, arg1 interface{}) *gomock.Call

ListSubscriptionTasks indicates an expected call of ListSubscriptionTasks

func (*MockE2SubscriptionTaskServiceServerMockRecorder) UpdateSubscriptionTask added in v0.6.11 

func (mr *MockE2SubscriptionTaskServiceServerMockRecorder) UpdateSubscriptionTask(arg0, arg1 interface{}) *gomock.Call

UpdateSubscriptionTask indicates an expected call of UpdateSubscriptionTask

func (*MockE2SubscriptionTaskServiceServerMockRecorder) WatchSubscriptionTasks added in v0.6.11 

func (mr *MockE2SubscriptionTaskServiceServerMockRecorder) WatchSubscriptionTasks(arg0, arg1 interface{}) *gomock.Call

WatchSubscriptionTasks indicates an expected call of WatchSubscriptionTasks

type MockE2SubscriptionTaskService_WatchSubscriptionTasksClient added in v0.6.11 

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

MockE2SubscriptionTaskService_WatchSubscriptionTasksClient is a mock of E2SubscriptionTaskService_WatchSubscriptionTasksClient interface

func NewMockE2SubscriptionTaskService_WatchSubscriptionTasksClient added in v0.6.11 

func NewMockE2SubscriptionTaskService_WatchSubscriptionTasksClient(ctrl *gomock.Controller) *MockE2SubscriptionTaskService_WatchSubscriptionTasksClient

NewMockE2SubscriptionTaskService_WatchSubscriptionTasksClient creates a new mock instance

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksClient) CloseSend added in v0.6.11 

func (m *MockE2SubscriptionTaskService_WatchSubscriptionTasksClient) CloseSend() error

CloseSend mocks base method

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksClient) Context added in v0.6.11 

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

Context mocks base method

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksClient) EXPECT added in v0.6.11 

func (m *MockE2SubscriptionTaskService_WatchSubscriptionTasksClient) EXPECT() *MockE2SubscriptionTaskService_WatchSubscriptionTasksClientMockRecorder

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

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksClient) Header added in v0.6.11 

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

Header mocks base method

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksClient) Recv added in v0.6.11 

func (m *MockE2SubscriptionTaskService_WatchSubscriptionTasksClient) Recv() (*WatchSubscriptionTasksResponse, error)

Recv mocks base method

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksClient) RecvMsg added in v0.6.11 

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

RecvMsg mocks base method

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksClient) SendMsg added in v0.6.11 

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

SendMsg mocks base method

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksClient) Trailer added in v0.6.11 

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

Trailer mocks base method

type MockE2SubscriptionTaskService_WatchSubscriptionTasksClientMockRecorder added in v0.6.11 

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

MockE2SubscriptionTaskService_WatchSubscriptionTasksClientMockRecorder is the mock recorder for MockE2SubscriptionTaskService_WatchSubscriptionTasksClient

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksClientMockRecorder) CloseSend added in v0.6.11 

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

CloseSend indicates an expected call of CloseSend

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksClientMockRecorder) Context added in v0.6.11 

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

Context indicates an expected call of Context

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksClientMockRecorder) Header added in v0.6.11 

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

Header indicates an expected call of Header

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksClientMockRecorder) Recv added in v0.6.11 

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

Recv indicates an expected call of Recv

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksClientMockRecorder) RecvMsg added in v0.6.11 

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

RecvMsg indicates an expected call of RecvMsg

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksClientMockRecorder) SendMsg added in v0.6.11 

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

SendMsg indicates an expected call of SendMsg

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksClientMockRecorder) Trailer added in v0.6.11 

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

Trailer indicates an expected call of Trailer

type MockE2SubscriptionTaskService_WatchSubscriptionTasksServer added in v0.6.11 

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

MockE2SubscriptionTaskService_WatchSubscriptionTasksServer is a mock of E2SubscriptionTaskService_WatchSubscriptionTasksServer interface

func NewMockE2SubscriptionTaskService_WatchSubscriptionTasksServer added in v0.6.11 

func NewMockE2SubscriptionTaskService_WatchSubscriptionTasksServer(ctrl *gomock.Controller) *MockE2SubscriptionTaskService_WatchSubscriptionTasksServer

NewMockE2SubscriptionTaskService_WatchSubscriptionTasksServer creates a new mock instance

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksServer) Context added in v0.6.11 

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

Context mocks base method

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksServer) EXPECT added in v0.6.11 

func (m *MockE2SubscriptionTaskService_WatchSubscriptionTasksServer) EXPECT() *MockE2SubscriptionTaskService_WatchSubscriptionTasksServerMockRecorder

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

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksServer) RecvMsg added in v0.6.11 

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

RecvMsg mocks base method

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksServer) Send added in v0.6.11 

func (m *MockE2SubscriptionTaskService_WatchSubscriptionTasksServer) Send(arg0 *WatchSubscriptionTasksResponse) error

Send mocks base method

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksServer) SendHeader added in v0.6.11 

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

SendHeader mocks base method

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksServer) SendMsg added in v0.6.11 

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

SendMsg mocks base method

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksServer) SetHeader added in v0.6.11 

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

SetHeader mocks base method

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksServer) SetTrailer added in v0.6.11 

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

SetTrailer mocks base method

type MockE2SubscriptionTaskService_WatchSubscriptionTasksServerMockRecorder added in v0.6.11 

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

MockE2SubscriptionTaskService_WatchSubscriptionTasksServerMockRecorder is the mock recorder for MockE2SubscriptionTaskService_WatchSubscriptionTasksServer

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksServerMockRecorder) Context added in v0.6.11 

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

Context indicates an expected call of Context

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksServerMockRecorder) RecvMsg added in v0.6.11 

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

RecvMsg indicates an expected call of RecvMsg

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksServerMockRecorder) Send added in v0.6.11 

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

Send indicates an expected call of Send

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksServerMockRecorder) SendHeader added in v0.6.11 

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

SendHeader indicates an expected call of SendHeader

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksServerMockRecorder) SendMsg added in v0.6.11 

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

SendMsg indicates an expected call of SendMsg

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksServerMockRecorder) SetHeader added in v0.6.11 

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

SetHeader indicates an expected call of SetHeader

func (*MockE2SubscriptionTaskService_WatchSubscriptionTasksServerMockRecorder) SetTrailer added in v0.6.11 

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

SetTrailer indicates an expected call of SetTrailer

type Phase 

type Phase int32

Phase is a subscription task phase 

const (
	// OPEN is a subscription task open phase
	Phase_OPEN Phase = 0
	// CLOSE is a subscription task close phase
	Phase_CLOSE Phase = 1
)

func (Phase) EnumDescriptor 

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

func (Phase) String 

func (x Phase) String() string

type Revision 

type Revision uint64

Revision is a subscription revision

type Status 

type Status int32

Status is a subscription task status 

const (
	// PENDING indicates the subscription task phase is pending
	Status_PENDING Status = 0
	// COMPLETE indicates the subscription task phase is complete
	Status_COMPLETE Status = 1
	// FAILED indicates the subscription task phase failed
	Status_FAILED Status = 2
)

func (Status) EnumDescriptor 

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

func (Status) String 

func (x Status) String() string

type SubscriptionTask 

type SubscriptionTask 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"`
	SubscriptionID github_com_onosproject_onos_api_go_onos_e2sub_subscription.ID `` /* 174-byte string literal not displayed */
	EndpointID     github_com_onosproject_onos_api_go_onos_e2sub_endpoint.ID     `` /* 158-byte string literal not displayed */
	Lifecycle      Lifecycle                                                     `protobuf:"bytes,5,opt,name=lifecycle,proto3" json:"lifecycle"`
}

SubscriptionTask is a task representing a subscription between an E2 termination and an E2 node

func (*SubscriptionTask) Descriptor 

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

func (*SubscriptionTask) GetEndpointID 

func (m *SubscriptionTask) GetEndpointID() github_com_onosproject_onos_api_go_onos_e2sub_endpoint.ID

func (*SubscriptionTask) GetID 

func (m *SubscriptionTask) GetID() ID

func (*SubscriptionTask) GetLifecycle 

func (m *SubscriptionTask) GetLifecycle() Lifecycle

func (*SubscriptionTask) GetRevision 

func (m *SubscriptionTask) GetRevision() Revision

func (*SubscriptionTask) GetSubscriptionID 

func (m *SubscriptionTask) GetSubscriptionID() github_com_onosproject_onos_api_go_onos_e2sub_subscription.ID

func (*SubscriptionTask) Marshal 

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

func (*SubscriptionTask) MarshalTo 

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

func (*SubscriptionTask) MarshalToSizedBuffer 

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

func (*SubscriptionTask) ProtoMessage 

func (*SubscriptionTask) ProtoMessage()

func (*SubscriptionTask) Reset 

func (m *SubscriptionTask) Reset()

func (*SubscriptionTask) Size 

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

func (*SubscriptionTask) String 

func (m *SubscriptionTask) String() string

func (*SubscriptionTask) Unmarshal 

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

func (*SubscriptionTask) XXX_DiscardUnknown 

func (m *SubscriptionTask) XXX_DiscardUnknown()

func (*SubscriptionTask) XXX_Marshal 

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

func (*SubscriptionTask) XXX_Merge 

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

func (*SubscriptionTask) XXX_Size 

func (m *SubscriptionTask) XXX_Size() int

func (*SubscriptionTask) XXX_Unmarshal 

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

type UnimplementedE2SubscriptionTaskServiceServer 

type UnimplementedE2SubscriptionTaskServiceServer struct {
}

UnimplementedE2SubscriptionTaskServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedE2SubscriptionTaskServiceServer) GetSubscriptionTask 

func (*UnimplementedE2SubscriptionTaskServiceServer) GetSubscriptionTask(ctx context.Context, req *GetSubscriptionTaskRequest) (*GetSubscriptionTaskResponse, error)

func (*UnimplementedE2SubscriptionTaskServiceServer) ListSubscriptionTasks 

func (*UnimplementedE2SubscriptionTaskServiceServer) ListSubscriptionTasks(ctx context.Context, req *ListSubscriptionTasksRequest) (*ListSubscriptionTasksResponse, error)

func (*UnimplementedE2SubscriptionTaskServiceServer) UpdateSubscriptionTask 

func (*UnimplementedE2SubscriptionTaskServiceServer) UpdateSubscriptionTask(ctx context.Context, req *UpdateSubscriptionTaskRequest) (*UpdateSubscriptionTaskResponse, error)

func (*UnimplementedE2SubscriptionTaskServiceServer) WatchSubscriptionTasks 

func (*UnimplementedE2SubscriptionTaskServiceServer) WatchSubscriptionTasks(req *WatchSubscriptionTasksRequest, srv E2SubscriptionTaskService_WatchSubscriptionTasksServer) error

type UpdateSubscriptionTaskRequest 

type UpdateSubscriptionTaskRequest struct {
	Task *SubscriptionTask `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
}

UpdateSubscriptionTaskRequest is a request for updating a SubscriptionTask status

func (*UpdateSubscriptionTaskRequest) Descriptor 

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

func (*UpdateSubscriptionTaskRequest) GetTask 

func (m *UpdateSubscriptionTaskRequest) GetTask() *SubscriptionTask

func (*UpdateSubscriptionTaskRequest) Marshal 

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

func (*UpdateSubscriptionTaskRequest) MarshalTo 

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

func (*UpdateSubscriptionTaskRequest) MarshalToSizedBuffer 

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

func (*UpdateSubscriptionTaskRequest) ProtoMessage 

func (*UpdateSubscriptionTaskRequest) ProtoMessage()

func (*UpdateSubscriptionTaskRequest) Reset 

func (m *UpdateSubscriptionTaskRequest) Reset()

func (*UpdateSubscriptionTaskRequest) Size 

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

func (*UpdateSubscriptionTaskRequest) String 

func (m *UpdateSubscriptionTaskRequest) String() string

func (*UpdateSubscriptionTaskRequest) Unmarshal 

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

func (*UpdateSubscriptionTaskRequest) XXX_DiscardUnknown 

func (m *UpdateSubscriptionTaskRequest) XXX_DiscardUnknown()

func (*UpdateSubscriptionTaskRequest) XXX_Marshal 

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

func (*UpdateSubscriptionTaskRequest) XXX_Merge 

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

func (*UpdateSubscriptionTaskRequest) XXX_Size 

func (m *UpdateSubscriptionTaskRequest) XXX_Size() int

func (*UpdateSubscriptionTaskRequest) XXX_Unmarshal 

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

type UpdateSubscriptionTaskResponse 

type UpdateSubscriptionTaskResponse struct {
}

UpdateSubscriptionTaskResponse is a response to updating a SubscriptionTask status

func (*UpdateSubscriptionTaskResponse) Descriptor 

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

func (*UpdateSubscriptionTaskResponse) Marshal 

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

func (*UpdateSubscriptionTaskResponse) MarshalTo 

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

func (*UpdateSubscriptionTaskResponse) MarshalToSizedBuffer 

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

func (*UpdateSubscriptionTaskResponse) ProtoMessage 

func (*UpdateSubscriptionTaskResponse) ProtoMessage()

func (*UpdateSubscriptionTaskResponse) Reset 

func (m *UpdateSubscriptionTaskResponse) Reset()

func (*UpdateSubscriptionTaskResponse) Size 

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

func (*UpdateSubscriptionTaskResponse) String 

func (m *UpdateSubscriptionTaskResponse) String() string

func (*UpdateSubscriptionTaskResponse) Unmarshal 

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

func (*UpdateSubscriptionTaskResponse) XXX_DiscardUnknown 

func (m *UpdateSubscriptionTaskResponse) XXX_DiscardUnknown()

func (*UpdateSubscriptionTaskResponse) XXX_Marshal 

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

func (*UpdateSubscriptionTaskResponse) XXX_Merge 

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

func (*UpdateSubscriptionTaskResponse) XXX_Size 

func (m *UpdateSubscriptionTaskResponse) XXX_Size() int

func (*UpdateSubscriptionTaskResponse) XXX_Unmarshal 

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

type WatchSubscriptionTasksRequest 

type WatchSubscriptionTasksRequest struct {
	Noreplay       bool                                                          `protobuf:"varint,1,opt,name=noreplay,proto3" json:"noreplay,omitempty"`
	SubscriptionID github_com_onosproject_onos_api_go_onos_e2sub_subscription.ID `` /* 174-byte string literal not displayed */
	EndpointID     github_com_onosproject_onos_api_go_onos_e2sub_endpoint.ID     `` /* 158-byte string literal not displayed */
}

WatchSubscriptionTasksRequest is a request to receive a stream of all SubscriptionTask changes.

func (*WatchSubscriptionTasksRequest) Descriptor 

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

func (*WatchSubscriptionTasksRequest) GetEndpointID 

func (m *WatchSubscriptionTasksRequest) GetEndpointID() github_com_onosproject_onos_api_go_onos_e2sub_endpoint.ID

func (*WatchSubscriptionTasksRequest) GetNoreplay 

func (m *WatchSubscriptionTasksRequest) GetNoreplay() bool

func (*WatchSubscriptionTasksRequest) GetSubscriptionID 

func (m *WatchSubscriptionTasksRequest) GetSubscriptionID() github_com_onosproject_onos_api_go_onos_e2sub_subscription.ID

func (*WatchSubscriptionTasksRequest) Marshal 

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

func (*WatchSubscriptionTasksRequest) MarshalTo 

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

func (*WatchSubscriptionTasksRequest) MarshalToSizedBuffer 

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

func (*WatchSubscriptionTasksRequest) ProtoMessage 

func (*WatchSubscriptionTasksRequest) ProtoMessage()

func (*WatchSubscriptionTasksRequest) Reset 

func (m *WatchSubscriptionTasksRequest) Reset()

func (*WatchSubscriptionTasksRequest) Size 

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

func (*WatchSubscriptionTasksRequest) String 

func (m *WatchSubscriptionTasksRequest) String() string

func (*WatchSubscriptionTasksRequest) Unmarshal 

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

func (*WatchSubscriptionTasksRequest) XXX_DiscardUnknown 

func (m *WatchSubscriptionTasksRequest) XXX_DiscardUnknown()

func (*WatchSubscriptionTasksRequest) XXX_Marshal 

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

func (*WatchSubscriptionTasksRequest) XXX_Merge 

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

func (*WatchSubscriptionTasksRequest) XXX_Size 

func (m *WatchSubscriptionTasksRequest) XXX_Size() int

func (*WatchSubscriptionTasksRequest) XXX_Unmarshal 

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

type WatchSubscriptionTasksResponse 

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

WatchSubscriptionTasksResponse is a response indicating a change in the available SubscriptionTasks.

func (*WatchSubscriptionTasksResponse) Descriptor 

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

func (*WatchSubscriptionTasksResponse) GetEvent 

func (m *WatchSubscriptionTasksResponse) GetEvent() Event

func (*WatchSubscriptionTasksResponse) Marshal 

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

func (*WatchSubscriptionTasksResponse) MarshalTo 

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

func (*WatchSubscriptionTasksResponse) MarshalToSizedBuffer 

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

func (*WatchSubscriptionTasksResponse) ProtoMessage 

func (*WatchSubscriptionTasksResponse) ProtoMessage()

func (*WatchSubscriptionTasksResponse) Reset 

func (m *WatchSubscriptionTasksResponse) Reset()

func (*WatchSubscriptionTasksResponse) Size 

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

func (*WatchSubscriptionTasksResponse) String 

func (m *WatchSubscriptionTasksResponse) String() string

func (*WatchSubscriptionTasksResponse) Unmarshal 

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

func (*WatchSubscriptionTasksResponse) XXX_DiscardUnknown 

func (m *WatchSubscriptionTasksResponse) XXX_DiscardUnknown()

func (*WatchSubscriptionTasksResponse) XXX_Marshal 

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

func (*WatchSubscriptionTasksResponse) XXX_Merge 

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

func (*WatchSubscriptionTasksResponse) XXX_Size 

func (m *WatchSubscriptionTasksResponse) XXX_Size() int

func (*WatchSubscriptionTasksResponse) XXX_Unmarshal 

func (m *WatchSubscriptionTasksResponse) 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.