job

Documentation

Index

• func RegisterTaskServiceServer(s *grpc.Server, srv TaskServiceServer)
• type ExecuteRequest
  • func (*ExecuteRequest) Descriptor() ([]byte, []int)
  • func (m *ExecuteRequest) GetBody() *any.Any
  • func (m *ExecuteRequest) GetTaskId() string
  • func (*ExecuteRequest) ProtoMessage()
  • func (m *ExecuteRequest) Reset()
  • func (m *ExecuteRequest) String() string
  • func (m *ExecuteRequest) XXX_DiscardUnknown()
  • func (m *ExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ExecuteRequest) XXX_Merge(src proto.Message)
  • func (m *ExecuteRequest) XXX_Size() int
  • func (m *ExecuteRequest) XXX_Unmarshal(b []byte) error
• type ExecuteResponse
  • func (*ExecuteResponse) Descriptor() ([]byte, []int)
  • func (m *ExecuteResponse) GetBody() *any.Any
  • func (m *ExecuteResponse) GetErr() *errors.BusinessError
  • func (*ExecuteResponse) ProtoMessage()
  • func (m *ExecuteResponse) Reset()
  • func (m *ExecuteResponse) String() string
  • func (m *ExecuteResponse) XXX_DiscardUnknown()
  • func (m *ExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ExecuteResponse) XXX_Merge(src proto.Message)
  • func (m *ExecuteResponse) XXX_Size() int
  • func (m *ExecuteResponse) XXX_Unmarshal(b []byte) error
• type TaskServiceClient
  • func NewTaskServiceClient(cc *grpc.ClientConn) TaskServiceClient
• type TaskServiceServer

Functions

func RegisterTaskServiceServer

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

Types

type ExecuteRequest

type ExecuteRequest struct {
	// 任务ID
	TaskId               string   `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId,omitempty"`
	Body                 *any.Any `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ExecuteRequest 执行请求

func (*ExecuteRequest) Descriptor

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

func (*ExecuteRequest) GetBody

func (m *ExecuteRequest) GetBody() *any.Any

func (*ExecuteRequest) GetTaskId

func (m *ExecuteRequest) GetTaskId() string

func (*ExecuteRequest) ProtoMessage

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) Reset

func (m *ExecuteRequest) Reset()

func (*ExecuteRequest) String

func (m *ExecuteRequest) String() string

func (*ExecuteRequest) XXX_DiscardUnknown

func (m *ExecuteRequest) XXX_DiscardUnknown()

func (*ExecuteRequest) XXX_Marshal

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

func (*ExecuteRequest) XXX_Merge

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

func (*ExecuteRequest) XXX_Size

func (m *ExecuteRequest) XXX_Size() int

func (*ExecuteRequest) XXX_Unmarshal

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

type ExecuteResponse

type ExecuteResponse struct {
	Body                 *any.Any              `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	Err                  *errors.BusinessError `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

ExecuteResponse 执行请求响应

func (*ExecuteResponse) Descriptor

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

func (*ExecuteResponse) GetBody

func (m *ExecuteResponse) GetBody() *any.Any

func (*ExecuteResponse) GetErr

func (m *ExecuteResponse) GetErr() *errors.BusinessError

func (*ExecuteResponse) ProtoMessage

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) Reset

func (m *ExecuteResponse) Reset()

func (*ExecuteResponse) String

func (m *ExecuteResponse) String() string

func (*ExecuteResponse) XXX_DiscardUnknown

func (m *ExecuteResponse) XXX_DiscardUnknown()

func (*ExecuteResponse) XXX_Marshal

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

func (*ExecuteResponse) XXX_Merge

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

func (*ExecuteResponse) XXX_Size

func (m *ExecuteResponse) XXX_Size() int

func (*ExecuteResponse) XXX_Unmarshal

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

type TaskServiceClient

type TaskServiceClient interface {
	// Execute 执行
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error)
	// ExecuteAsync 执行异步
	ExecuteAsync(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, 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 {
	// Execute 执行
	Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
	// ExecuteAsync 执行异步
	ExecuteAsync(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
}

TaskServiceServer is the server API for TaskService service.