tasks

package
v1.2.1 Latest Latest
Warning

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

 Go to latest Published: Jun 18, 2023 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTasks        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTasks          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTasks = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterTaskServiceServer 

func RegisterTaskServiceServer(s *grpc.Server, srv TaskServiceServer)

Types

type CancelTaskRequest 

type CancelTaskRequest struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CancelTaskRequest) Descriptor 

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

func (*CancelTaskRequest) GetKey 

func (m *CancelTaskRequest) GetKey() string

func (*CancelTaskRequest) Marshal 

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

func (*CancelTaskRequest) MarshalTo 

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

func (*CancelTaskRequest) MarshalToSizedBuffer 

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

func (*CancelTaskRequest) ProtoMessage 

func (*CancelTaskRequest) ProtoMessage()

func (*CancelTaskRequest) Reset 

func (m *CancelTaskRequest) Reset()

func (*CancelTaskRequest) Size 

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

func (*CancelTaskRequest) String 

func (m *CancelTaskRequest) String() string

func (*CancelTaskRequest) Unmarshal 

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

func (*CancelTaskRequest) XXX_DiscardUnknown 

func (m *CancelTaskRequest) XXX_DiscardUnknown()

func (*CancelTaskRequest) XXX_Marshal 

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

func (*CancelTaskRequest) XXX_Merge 

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

func (*CancelTaskRequest) XXX_Size 

func (m *CancelTaskRequest) XXX_Size() int

func (*CancelTaskRequest) XXX_Unmarshal 

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

type GetTaskRequest 

type GetTaskRequest struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTaskRequest) Descriptor 

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

func (*GetTaskRequest) GetKey 

func (m *GetTaskRequest) GetKey() string

func (*GetTaskRequest) Marshal 

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

func (*GetTaskRequest) MarshalTo 

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

func (*GetTaskRequest) MarshalToSizedBuffer 

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

func (*GetTaskRequest) ProtoMessage 

func (*GetTaskRequest) ProtoMessage()

func (*GetTaskRequest) Reset 

func (m *GetTaskRequest) Reset()

func (*GetTaskRequest) Size 

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

func (*GetTaskRequest) String 

func (m *GetTaskRequest) String() string

func (*GetTaskRequest) Unmarshal 

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

func (*GetTaskRequest) XXX_DiscardUnknown 

func (m *GetTaskRequest) XXX_DiscardUnknown()

func (*GetTaskRequest) XXX_Marshal 

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

func (*GetTaskRequest) XXX_Merge 

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

func (*GetTaskRequest) XXX_Size 

func (m *GetTaskRequest) XXX_Size() int

func (*GetTaskRequest) XXX_Unmarshal 

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

type GetTaskResponse 

type GetTaskResponse struct {
	Task                 *types.TaskInfo `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetTaskResponse) Descriptor 

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

func (*GetTaskResponse) GetTask 

func (m *GetTaskResponse) GetTask() *types.TaskInfo

func (*GetTaskResponse) Marshal 

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

func (*GetTaskResponse) MarshalTo 

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

func (*GetTaskResponse) MarshalToSizedBuffer 

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

func (*GetTaskResponse) ProtoMessage 

func (*GetTaskResponse) ProtoMessage()

func (*GetTaskResponse) Reset 

func (m *GetTaskResponse) Reset()

func (*GetTaskResponse) Size 

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

func (*GetTaskResponse) String 

func (m *GetTaskResponse) String() string

func (*GetTaskResponse) Unmarshal 

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

func (*GetTaskResponse) XXX_DiscardUnknown 

func (m *GetTaskResponse) XXX_DiscardUnknown()

func (*GetTaskResponse) XXX_Marshal 

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

func (*GetTaskResponse) XXX_Merge 

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

func (*GetTaskResponse) XXX_Size 

func (m *GetTaskResponse) XXX_Size() int

func (*GetTaskResponse) XXX_Unmarshal 

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

type ListKeysResponse 

type ListKeysResponse struct {
	Tasks                []string `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListKeysResponse) Descriptor 

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

func (*ListKeysResponse) GetTasks 

func (m *ListKeysResponse) GetTasks() []string

func (*ListKeysResponse) Marshal 

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

func (*ListKeysResponse) MarshalTo 

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

func (*ListKeysResponse) MarshalToSizedBuffer 

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

func (*ListKeysResponse) ProtoMessage 

func (*ListKeysResponse) ProtoMessage()

func (*ListKeysResponse) Reset 

func (m *ListKeysResponse) Reset()

func (*ListKeysResponse) Size 

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

func (*ListKeysResponse) String 

func (m *ListKeysResponse) String() string

func (*ListKeysResponse) Unmarshal 

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

func (*ListKeysResponse) XXX_DiscardUnknown 

func (m *ListKeysResponse) XXX_DiscardUnknown()

func (*ListKeysResponse) XXX_Marshal 

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

func (*ListKeysResponse) XXX_Merge 

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

func (*ListKeysResponse) XXX_Size 

func (m *ListKeysResponse) XXX_Size() int

func (*ListKeysResponse) XXX_Unmarshal 

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

type ListTasksResponse 

type ListTasksResponse struct {
	Tasks                []*types.TaskInfo `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ListTasksResponse) Descriptor 

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

func (*ListTasksResponse) GetTasks 

func (m *ListTasksResponse) GetTasks() []*types.TaskInfo

func (*ListTasksResponse) Marshal 

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

func (*ListTasksResponse) MarshalTo 

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

func (*ListTasksResponse) MarshalToSizedBuffer 

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

func (*ListTasksResponse) ProtoMessage 

func (*ListTasksResponse) ProtoMessage()

func (*ListTasksResponse) Reset 

func (m *ListTasksResponse) Reset()

func (*ListTasksResponse) Size 

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

func (*ListTasksResponse) String 

func (m *ListTasksResponse) String() string

func (*ListTasksResponse) Unmarshal 

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

func (*ListTasksResponse) XXX_DiscardUnknown 

func (m *ListTasksResponse) XXX_DiscardUnknown()

func (*ListTasksResponse) XXX_Marshal 

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

func (*ListTasksResponse) XXX_Merge 

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

func (*ListTasksResponse) XXX_Size 

func (m *ListTasksResponse) XXX_Size() int

func (*ListTasksResponse) XXX_Unmarshal 

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

type TaskServiceClient 

type TaskServiceClient interface {
	Get(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*GetTaskResponse, error)
	List(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListTasksResponse, error)
	ListKeys(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListKeysResponse, error)
	Cancel(ctx context.Context, in *CancelTaskRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

TaskServiceClient is the client API for TaskService service.

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

func NewTaskServiceClient 

func NewTaskServiceClient(cc *grpc.ClientConn) TaskServiceClient

type TaskServiceServer 

type TaskServiceServer interface {
	Get(context.Context, *GetTaskRequest) (*GetTaskResponse, error)
	List(context.Context, *empty.Empty) (*ListTasksResponse, error)
	ListKeys(context.Context, *empty.Empty) (*ListKeysResponse, error)
	Cancel(context.Context, *CancelTaskRequest) (*empty.Empty, error)
}

TaskServiceServer is the server API for TaskService service.

type UnimplementedTaskServiceServer 

type UnimplementedTaskServiceServer struct {
}

UnimplementedTaskServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedTaskServiceServer) Cancel 

func (*UnimplementedTaskServiceServer) Cancel(ctx context.Context, req *CancelTaskRequest) (*empty.Empty, error)

func (*UnimplementedTaskServiceServer) Get 

func (*UnimplementedTaskServiceServer) Get(ctx context.Context, req *GetTaskRequest) (*GetTaskResponse, error)

func (*UnimplementedTaskServiceServer) List 

func (*UnimplementedTaskServiceServer) List(ctx context.Context, req *empty.Empty) (*ListTasksResponse, error)

func (*UnimplementedTaskServiceServer) ListKeys 

func (*UnimplementedTaskServiceServer) ListKeys(ctx context.Context, req *empty.Empty) (*ListKeysResponse, 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.