taskservice

package
v0.13.1-0...-264b242 Latest Latest
Warning

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

Go to latest
Published: Nov 13, 2019 License: MIT Imports: 16 Imported by: 0

Documentation

Overview

Package taskservice is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

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

func (*UnimplementedTaskServiceServer) GetTask

func (*UnimplementedTaskServiceServer) ListTasks

func (*UnimplementedTaskServiceServer) UpdateTask

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL