task

package
v0.6.9 Latest Latest
Warning

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

 Go to latest Published: Dec 7, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

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 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",
}
View Source 
var Status_value = map[string]int32{
	"PENDING":  0,
	"COMPLETE": 1,
}

Functions

func RegisterE2SubscriptionTaskServiceServer 

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

Types

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

Lifecycle is a subscription task status

func (*Lifecycle) Descriptor 

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

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

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.