Documentation ¶
Overview ¶
Package taskservice is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- func RegisterTaskServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterTaskServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client TaskServiceClient) error
- func RegisterTaskServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterTaskServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server TaskServiceServer) error
- func RegisterTaskServiceServer(s *grpc.Server, srv TaskServiceServer)
- type CreateTaskServiceRequest
- func (*CreateTaskServiceRequest) Descriptor() ([]byte, []int)
- func (m *CreateTaskServiceRequest) GetData() *task.Task
- func (*CreateTaskServiceRequest) ProtoMessage()
- func (m *CreateTaskServiceRequest) Reset()
- func (m *CreateTaskServiceRequest) String() string
- func (m *CreateTaskServiceRequest) XXX_DiscardUnknown()
- func (m *CreateTaskServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateTaskServiceRequest) XXX_Merge(src proto.Message)
- func (m *CreateTaskServiceRequest) XXX_Size() int
- func (m *CreateTaskServiceRequest) XXX_Unmarshal(b []byte) error
- type DeleteTaskServiceRequest
- func (*DeleteTaskServiceRequest) Descriptor() ([]byte, []int)
- func (m *DeleteTaskServiceRequest) GetData() *empty.Empty
- func (m *DeleteTaskServiceRequest) GetTsk() string
- func (*DeleteTaskServiceRequest) ProtoMessage()
- func (m *DeleteTaskServiceRequest) Reset()
- func (m *DeleteTaskServiceRequest) String() string
- func (m *DeleteTaskServiceRequest) XXX_DiscardUnknown()
- func (m *DeleteTaskServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteTaskServiceRequest) XXX_Merge(src proto.Message)
- func (m *DeleteTaskServiceRequest) XXX_Size() int
- func (m *DeleteTaskServiceRequest) XXX_Unmarshal(b []byte) error
- type GetTaskServiceRequest
- func (*GetTaskServiceRequest) Descriptor() ([]byte, []int)
- func (m *GetTaskServiceRequest) GetTsk() string
- func (*GetTaskServiceRequest) ProtoMessage()
- func (m *GetTaskServiceRequest) Reset()
- func (m *GetTaskServiceRequest) String() string
- func (m *GetTaskServiceRequest) XXX_DiscardUnknown()
- func (m *GetTaskServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTaskServiceRequest) XXX_Merge(src proto.Message)
- func (m *GetTaskServiceRequest) XXX_Size() int
- func (m *GetTaskServiceRequest) XXX_Unmarshal(b []byte) error
- type ListTaskServiceRequest
- func (*ListTaskServiceRequest) Descriptor() ([]byte, []int)
- func (m *ListTaskServiceRequest) GetFields() string
- func (m *ListTaskServiceRequest) GetFilter() string
- func (m *ListTaskServiceRequest) GetLimit() int32
- func (m *ListTaskServiceRequest) GetOrderBy() string
- func (m *ListTaskServiceRequest) GetPage() int32
- func (m *ListTaskServiceRequest) GetQ() string
- func (m *ListTaskServiceRequest) GetView() string
- func (*ListTaskServiceRequest) ProtoMessage()
- func (m *ListTaskServiceRequest) Reset()
- func (m *ListTaskServiceRequest) String() string
- func (m *ListTaskServiceRequest) XXX_DiscardUnknown()
- func (m *ListTaskServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListTaskServiceRequest) XXX_Merge(src proto.Message)
- func (m *ListTaskServiceRequest) XXX_Size() int
- func (m *ListTaskServiceRequest) XXX_Unmarshal(b []byte) error
- type TaskServiceClient
- type TaskServiceServer
- type UnimplementedTaskServiceServer
- func (*UnimplementedTaskServiceServer) CreateTask(ctx context.Context, req *CreateTaskServiceRequest) (*task.TaskEntity, error)
- func (*UnimplementedTaskServiceServer) DeleteTask(ctx context.Context, req *DeleteTaskServiceRequest) (*empty.Empty, error)
- func (*UnimplementedTaskServiceServer) GetTask(ctx context.Context, req *GetTaskServiceRequest) (*task.TaskEntity, error)
- func (*UnimplementedTaskServiceServer) ListTasks(ctx context.Context, req *ListTaskServiceRequest) (*task.TaskCollection, error)
- func (*UnimplementedTaskServiceServer) UpdateTask(ctx context.Context, req *UpdateTaskServiceRequest) (*task.TaskEntity, error)
- type UpdateTaskServiceRequest
- func (*UpdateTaskServiceRequest) Descriptor() ([]byte, []int)
- func (m *UpdateTaskServiceRequest) GetData() *task.Task
- func (m *UpdateTaskServiceRequest) GetTsk() string
- func (*UpdateTaskServiceRequest) ProtoMessage()
- func (m *UpdateTaskServiceRequest) Reset()
- func (m *UpdateTaskServiceRequest) String() string
- func (m *UpdateTaskServiceRequest) XXX_DiscardUnknown()
- func (m *UpdateTaskServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateTaskServiceRequest) XXX_Merge(src proto.Message)
- func (m *UpdateTaskServiceRequest) XXX_Size() int
- func (m *UpdateTaskServiceRequest) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterTaskServiceHandler ¶
func RegisterTaskServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterTaskServiceHandler registers the http handlers for service TaskService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterTaskServiceHandlerClient ¶
func RegisterTaskServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client TaskServiceClient) error
RegisterTaskServiceHandlerClient registers the http handlers for service TaskService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "TaskServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "TaskServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "TaskServiceClient" to call the correct interceptors.
func RegisterTaskServiceHandlerFromEndpoint ¶
func RegisterTaskServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterTaskServiceHandlerFromEndpoint is same as RegisterTaskServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterTaskServiceHandlerServer ¶
func RegisterTaskServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server TaskServiceServer) error
RegisterTaskServiceHandlerServer registers the http handlers for service TaskService to "mux". UnaryRPC :call TaskServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
func RegisterTaskServiceServer ¶
func RegisterTaskServiceServer(s *grpc.Server, srv TaskServiceServer)
Types ¶
type CreateTaskServiceRequest ¶
type CreateTaskServiceRequest struct { Data *task.Task `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateTaskServiceRequest) Descriptor ¶
func (*CreateTaskServiceRequest) Descriptor() ([]byte, []int)
func (*CreateTaskServiceRequest) GetData ¶
func (m *CreateTaskServiceRequest) GetData() *task.Task
func (*CreateTaskServiceRequest) ProtoMessage ¶
func (*CreateTaskServiceRequest) ProtoMessage()
func (*CreateTaskServiceRequest) Reset ¶
func (m *CreateTaskServiceRequest) Reset()
func (*CreateTaskServiceRequest) String ¶
func (m *CreateTaskServiceRequest) String() string
func (*CreateTaskServiceRequest) XXX_DiscardUnknown ¶
func (m *CreateTaskServiceRequest) XXX_DiscardUnknown()
func (*CreateTaskServiceRequest) XXX_Marshal ¶
func (m *CreateTaskServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateTaskServiceRequest) XXX_Merge ¶
func (m *CreateTaskServiceRequest) XXX_Merge(src proto.Message)
func (*CreateTaskServiceRequest) XXX_Size ¶
func (m *CreateTaskServiceRequest) XXX_Size() int
func (*CreateTaskServiceRequest) XXX_Unmarshal ¶
func (m *CreateTaskServiceRequest) XXX_Unmarshal(b []byte) error
type DeleteTaskServiceRequest ¶
type DeleteTaskServiceRequest struct { Tsk string `protobuf:"bytes,1,opt,name=tsk,proto3" json:"tsk,omitempty"` Data *empty.Empty `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteTaskServiceRequest) Descriptor ¶
func (*DeleteTaskServiceRequest) Descriptor() ([]byte, []int)
func (*DeleteTaskServiceRequest) GetData ¶
func (m *DeleteTaskServiceRequest) GetData() *empty.Empty
func (*DeleteTaskServiceRequest) GetTsk ¶
func (m *DeleteTaskServiceRequest) GetTsk() string
func (*DeleteTaskServiceRequest) ProtoMessage ¶
func (*DeleteTaskServiceRequest) ProtoMessage()
func (*DeleteTaskServiceRequest) Reset ¶
func (m *DeleteTaskServiceRequest) Reset()
func (*DeleteTaskServiceRequest) String ¶
func (m *DeleteTaskServiceRequest) String() string
func (*DeleteTaskServiceRequest) XXX_DiscardUnknown ¶
func (m *DeleteTaskServiceRequest) XXX_DiscardUnknown()
func (*DeleteTaskServiceRequest) XXX_Marshal ¶
func (m *DeleteTaskServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteTaskServiceRequest) XXX_Merge ¶
func (m *DeleteTaskServiceRequest) XXX_Merge(src proto.Message)
func (*DeleteTaskServiceRequest) XXX_Size ¶
func (m *DeleteTaskServiceRequest) XXX_Size() int
func (*DeleteTaskServiceRequest) XXX_Unmarshal ¶
func (m *DeleteTaskServiceRequest) XXX_Unmarshal(b []byte) error
type GetTaskServiceRequest ¶
type GetTaskServiceRequest struct { Tsk string `protobuf:"bytes,1,opt,name=tsk,proto3" json:"tsk,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTaskServiceRequest) Descriptor ¶
func (*GetTaskServiceRequest) Descriptor() ([]byte, []int)
func (*GetTaskServiceRequest) GetTsk ¶
func (m *GetTaskServiceRequest) GetTsk() string
func (*GetTaskServiceRequest) ProtoMessage ¶
func (*GetTaskServiceRequest) ProtoMessage()
func (*GetTaskServiceRequest) Reset ¶
func (m *GetTaskServiceRequest) Reset()
func (*GetTaskServiceRequest) String ¶
func (m *GetTaskServiceRequest) String() string
func (*GetTaskServiceRequest) XXX_DiscardUnknown ¶
func (m *GetTaskServiceRequest) XXX_DiscardUnknown()
func (*GetTaskServiceRequest) XXX_Marshal ¶
func (m *GetTaskServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTaskServiceRequest) XXX_Merge ¶
func (m *GetTaskServiceRequest) XXX_Merge(src proto.Message)
func (*GetTaskServiceRequest) XXX_Size ¶
func (m *GetTaskServiceRequest) XXX_Size() int
func (*GetTaskServiceRequest) XXX_Unmarshal ¶
func (m *GetTaskServiceRequest) XXX_Unmarshal(b []byte) error
type ListTaskServiceRequest ¶
type ListTaskServiceRequest struct { //Partial representation, fields=id,name Fields string `protobuf:"bytes,1,opt,name=fields,proto3" json:"fields,omitempty"` //* // Sort fields, comma separated list for the ordering // use **?filter=-display_name** with a dash to sort descending // use **?filter=display_name** to sort ascending OrderBy string `protobuf:"bytes,2,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"` //Filter Filter string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"` //Page number for paginated content. Tipp: follow the HATEOAS next, prev,... Page int32 `protobuf:"varint,4,opt,name=page,proto3" json:"page,omitempty"` //Number of elements to return per page Limit int32 `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"` //https://cloud.google.com/apis/design/design_patterns#resource_view View string `protobuf:"bytes,8,opt,name=view,proto3" json:"view,omitempty"` //Query term to search a task Q string `protobuf:"bytes,11,opt,name=q,proto3" json:"q,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListTaskServiceRequest) Descriptor ¶
func (*ListTaskServiceRequest) Descriptor() ([]byte, []int)
func (*ListTaskServiceRequest) GetFields ¶
func (m *ListTaskServiceRequest) GetFields() string
func (*ListTaskServiceRequest) GetFilter ¶
func (m *ListTaskServiceRequest) GetFilter() string
func (*ListTaskServiceRequest) GetLimit ¶
func (m *ListTaskServiceRequest) GetLimit() int32
func (*ListTaskServiceRequest) GetOrderBy ¶
func (m *ListTaskServiceRequest) GetOrderBy() string
func (*ListTaskServiceRequest) GetPage ¶
func (m *ListTaskServiceRequest) GetPage() int32
func (*ListTaskServiceRequest) GetQ ¶
func (m *ListTaskServiceRequest) GetQ() string
func (*ListTaskServiceRequest) GetView ¶
func (m *ListTaskServiceRequest) GetView() string
func (*ListTaskServiceRequest) ProtoMessage ¶
func (*ListTaskServiceRequest) ProtoMessage()
func (*ListTaskServiceRequest) Reset ¶
func (m *ListTaskServiceRequest) Reset()
func (*ListTaskServiceRequest) String ¶
func (m *ListTaskServiceRequest) String() string
func (*ListTaskServiceRequest) XXX_DiscardUnknown ¶
func (m *ListTaskServiceRequest) XXX_DiscardUnknown()
func (*ListTaskServiceRequest) XXX_Marshal ¶
func (m *ListTaskServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListTaskServiceRequest) XXX_Merge ¶
func (m *ListTaskServiceRequest) XXX_Merge(src proto.Message)
func (*ListTaskServiceRequest) XXX_Size ¶
func (m *ListTaskServiceRequest) XXX_Size() int
func (*ListTaskServiceRequest) XXX_Unmarshal ¶
func (m *ListTaskServiceRequest) XXX_Unmarshal(b []byte) error
type TaskServiceClient ¶
type TaskServiceClient interface { // Creates a new Task CreateTask(ctx context.Context, in *CreateTaskServiceRequest, opts ...grpc.CallOption) (*task.TaskEntity, error) // Delete a Task DeleteTask(ctx context.Context, in *DeleteTaskServiceRequest, opts ...grpc.CallOption) (*empty.Empty, error) // The Get method takes zero or more parameters, and returns a TaskEntity which contains a Task GetTask(ctx context.Context, in *GetTaskServiceRequest, opts ...grpc.CallOption) (*task.TaskEntity, error) // The List method takes zero or more parameters as input, and returns a TaskCollection of TaskEntity that match the input parameters. ListTasks(ctx context.Context, in *ListTaskServiceRequest, opts ...grpc.CallOption) (*task.TaskCollection, error) // Updates a Task, partial updates are not supported UpdateTask(ctx context.Context, in *UpdateTaskServiceRequest, opts ...grpc.CallOption) (*task.TaskEntity, 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 { // Creates a new Task CreateTask(context.Context, *CreateTaskServiceRequest) (*task.TaskEntity, error) // Delete a Task DeleteTask(context.Context, *DeleteTaskServiceRequest) (*empty.Empty, error) // The Get method takes zero or more parameters, and returns a TaskEntity which contains a Task GetTask(context.Context, *GetTaskServiceRequest) (*task.TaskEntity, error) // The List method takes zero or more parameters as input, and returns a TaskCollection of TaskEntity that match the input parameters. ListTasks(context.Context, *ListTaskServiceRequest) (*task.TaskCollection, error) // Updates a Task, partial updates are not supported UpdateTask(context.Context, *UpdateTaskServiceRequest) (*task.TaskEntity, 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) CreateTask ¶
func (*UnimplementedTaskServiceServer) CreateTask(ctx context.Context, req *CreateTaskServiceRequest) (*task.TaskEntity, error)
func (*UnimplementedTaskServiceServer) DeleteTask ¶
func (*UnimplementedTaskServiceServer) DeleteTask(ctx context.Context, req *DeleteTaskServiceRequest) (*empty.Empty, error)
func (*UnimplementedTaskServiceServer) GetTask ¶
func (*UnimplementedTaskServiceServer) GetTask(ctx context.Context, req *GetTaskServiceRequest) (*task.TaskEntity, error)
func (*UnimplementedTaskServiceServer) ListTasks ¶
func (*UnimplementedTaskServiceServer) ListTasks(ctx context.Context, req *ListTaskServiceRequest) (*task.TaskCollection, error)
func (*UnimplementedTaskServiceServer) UpdateTask ¶
func (*UnimplementedTaskServiceServer) UpdateTask(ctx context.Context, req *UpdateTaskServiceRequest) (*task.TaskEntity, error)
type UpdateTaskServiceRequest ¶
type UpdateTaskServiceRequest struct { Tsk string `protobuf:"bytes,1,opt,name=tsk,proto3" json:"tsk,omitempty"` Data *task.Task `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateTaskServiceRequest) Descriptor ¶
func (*UpdateTaskServiceRequest) Descriptor() ([]byte, []int)
func (*UpdateTaskServiceRequest) GetData ¶
func (m *UpdateTaskServiceRequest) GetData() *task.Task
func (*UpdateTaskServiceRequest) GetTsk ¶
func (m *UpdateTaskServiceRequest) GetTsk() string
func (*UpdateTaskServiceRequest) ProtoMessage ¶
func (*UpdateTaskServiceRequest) ProtoMessage()
func (*UpdateTaskServiceRequest) Reset ¶
func (m *UpdateTaskServiceRequest) Reset()
func (*UpdateTaskServiceRequest) String ¶
func (m *UpdateTaskServiceRequest) String() string
func (*UpdateTaskServiceRequest) XXX_DiscardUnknown ¶
func (m *UpdateTaskServiceRequest) XXX_DiscardUnknown()
func (*UpdateTaskServiceRequest) XXX_Marshal ¶
func (m *UpdateTaskServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateTaskServiceRequest) XXX_Merge ¶
func (m *UpdateTaskServiceRequest) XXX_Merge(src proto.Message)
func (*UpdateTaskServiceRequest) XXX_Size ¶
func (m *UpdateTaskServiceRequest) XXX_Size() int
func (*UpdateTaskServiceRequest) XXX_Unmarshal ¶
func (m *UpdateTaskServiceRequest) XXX_Unmarshal(b []byte) error