Documentation ¶
Index ¶
- Variables
- func RegisterTaskServiceServer(s *grpc.Server, srv TaskServiceServer)
- type CancelTaskRequest
- func (*CancelTaskRequest) Descriptor() ([]byte, []int)
- func (m *CancelTaskRequest) GetKey() string
- func (m *CancelTaskRequest) Marshal() (dAtA []byte, err error)
- func (m *CancelTaskRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CancelTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CancelTaskRequest) ProtoMessage()
- func (m *CancelTaskRequest) Reset()
- func (m *CancelTaskRequest) Size() (n int)
- func (m *CancelTaskRequest) String() string
- func (m *CancelTaskRequest) Unmarshal(dAtA []byte) error
- func (m *CancelTaskRequest) XXX_DiscardUnknown()
- func (m *CancelTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CancelTaskRequest) XXX_Merge(src proto.Message)
- func (m *CancelTaskRequest) XXX_Size() int
- func (m *CancelTaskRequest) XXX_Unmarshal(b []byte) error
- type GetTaskRequest
- func (*GetTaskRequest) Descriptor() ([]byte, []int)
- func (m *GetTaskRequest) GetKey() string
- func (m *GetTaskRequest) Marshal() (dAtA []byte, err error)
- func (m *GetTaskRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetTaskRequest) ProtoMessage()
- func (m *GetTaskRequest) Reset()
- func (m *GetTaskRequest) Size() (n int)
- func (m *GetTaskRequest) String() string
- func (m *GetTaskRequest) Unmarshal(dAtA []byte) error
- func (m *GetTaskRequest) XXX_DiscardUnknown()
- func (m *GetTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTaskRequest) XXX_Merge(src proto.Message)
- func (m *GetTaskRequest) XXX_Size() int
- func (m *GetTaskRequest) XXX_Unmarshal(b []byte) error
- type GetTaskResponse
- func (*GetTaskResponse) Descriptor() ([]byte, []int)
- func (m *GetTaskResponse) GetTask() *types.TaskInfo
- func (m *GetTaskResponse) Marshal() (dAtA []byte, err error)
- func (m *GetTaskResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetTaskResponse) ProtoMessage()
- func (m *GetTaskResponse) Reset()
- func (m *GetTaskResponse) Size() (n int)
- func (m *GetTaskResponse) String() string
- func (m *GetTaskResponse) Unmarshal(dAtA []byte) error
- func (m *GetTaskResponse) XXX_DiscardUnknown()
- func (m *GetTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTaskResponse) XXX_Merge(src proto.Message)
- func (m *GetTaskResponse) XXX_Size() int
- func (m *GetTaskResponse) XXX_Unmarshal(b []byte) error
- type ListKeysResponse
- func (*ListKeysResponse) Descriptor() ([]byte, []int)
- func (m *ListKeysResponse) GetTasks() []string
- func (m *ListKeysResponse) Marshal() (dAtA []byte, err error)
- func (m *ListKeysResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ListKeysResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListKeysResponse) ProtoMessage()
- func (m *ListKeysResponse) Reset()
- func (m *ListKeysResponse) Size() (n int)
- func (m *ListKeysResponse) String() string
- func (m *ListKeysResponse) Unmarshal(dAtA []byte) error
- func (m *ListKeysResponse) XXX_DiscardUnknown()
- func (m *ListKeysResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListKeysResponse) XXX_Merge(src proto.Message)
- func (m *ListKeysResponse) XXX_Size() int
- func (m *ListKeysResponse) XXX_Unmarshal(b []byte) error
- type ListTasksResponse
- func (*ListTasksResponse) Descriptor() ([]byte, []int)
- func (m *ListTasksResponse) GetTasks() []*types.TaskInfo
- func (m *ListTasksResponse) Marshal() (dAtA []byte, err error)
- func (m *ListTasksResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ListTasksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListTasksResponse) ProtoMessage()
- func (m *ListTasksResponse) Reset()
- func (m *ListTasksResponse) Size() (n int)
- func (m *ListTasksResponse) String() string
- func (m *ListTasksResponse) Unmarshal(dAtA []byte) error
- func (m *ListTasksResponse) XXX_DiscardUnknown()
- func (m *ListTasksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListTasksResponse) XXX_Merge(src proto.Message)
- func (m *ListTasksResponse) XXX_Size() int
- func (m *ListTasksResponse) XXX_Unmarshal(b []byte) error
- type TaskServiceClient
- type TaskServiceServer
- type UnimplementedTaskServiceServer
- func (*UnimplementedTaskServiceServer) Cancel(ctx context.Context, req *CancelTaskRequest) (*empty.Empty, error)
- func (*UnimplementedTaskServiceServer) Get(ctx context.Context, req *GetTaskRequest) (*GetTaskResponse, error)
- func (*UnimplementedTaskServiceServer) List(ctx context.Context, req *empty.Empty) (*ListTasksResponse, error)
- func (*UnimplementedTaskServiceServer) ListKeys(ctx context.Context, req *empty.Empty) (*ListKeysResponse, error)
Constants ¶
This section is empty.
Variables ¶
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) 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) 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) 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)
Click to show internal directories.
Click to hide internal directories.