proto

Documentation

Overview

Package jobapi is a generated protocol buffer package.

It is generated from these files:

jobapi.proto

It has these top-level messages:

WorkflowStartRequest
WorkflowStartResponse
TaskOutputRecordRequest
TaskOutputRecordResponse

Index

• func RegisterJobapiServer(s *grpc.Server, srv JobapiServer)
• type JobapiClient
  • func NewJobapiClient(cc *grpc.ClientConn) JobapiClient
• type JobapiServer
• type TaskOutputRecordRequest
  • func (*TaskOutputRecordRequest) Descriptor() ([]byte, []int)
  • func (m *TaskOutputRecordRequest) GetData() []byte
  • func (m *TaskOutputRecordRequest) GetTaskId() uint64
  • func (*TaskOutputRecordRequest) ProtoMessage()
  • func (m *TaskOutputRecordRequest) Reset()
  • func (m *TaskOutputRecordRequest) String() string
• type TaskOutputRecordResponse
  • func (*TaskOutputRecordResponse) Descriptor() ([]byte, []int)
  • func (m *TaskOutputRecordResponse) GetTaskId() uint64
  • func (*TaskOutputRecordResponse) ProtoMessage()
  • func (m *TaskOutputRecordResponse) Reset()
  • func (m *TaskOutputRecordResponse) String() string
• type WorkflowStartRequest
  • func (*WorkflowStartRequest) Descriptor() ([]byte, []int)
  • func (m *WorkflowStartRequest) GetExecName() string
  • func (m *WorkflowStartRequest) GetInput() []byte
  • func (m *WorkflowStartRequest) GetWorkflowId() uint64
  • func (*WorkflowStartRequest) ProtoMessage()
  • func (m *WorkflowStartRequest) Reset()
  • func (m *WorkflowStartRequest) String() string
• type WorkflowStartResponse
  • func (*WorkflowStartResponse) Descriptor() ([]byte, []int)
  • func (m *WorkflowStartResponse) GetId() uint64
  • func (*WorkflowStartResponse) ProtoMessage()
  • func (m *WorkflowStartResponse) Reset()
  • func (m *WorkflowStartResponse) String() string

Functions

func RegisterJobapiServer

func RegisterJobapiServer(s *grpc.Server, srv JobapiServer)

Types

type JobapiClient

type JobapiClient interface {
	StartWorkflow(ctx context.Context, in *WorkflowStartRequest, opts ...grpc.CallOption) (*WorkflowStartResponse, error)
	RecordTaskOutput(ctx context.Context, in *TaskOutputRecordRequest, opts ...grpc.CallOption) (*TaskOutputRecordResponse, error)
}

func NewJobapiClient

func NewJobapiClient(cc *grpc.ClientConn) JobapiClient

type JobapiServer

type JobapiServer interface {
	StartWorkflow(context.Context, *WorkflowStartRequest) (*WorkflowStartResponse, error)
	RecordTaskOutput(context.Context, *TaskOutputRecordRequest) (*TaskOutputRecordResponse, error)
}

type TaskOutputRecordRequest

type TaskOutputRecordRequest struct {
	TaskId uint64 `protobuf:"varint,1,opt,name=task_id,json=taskId" json:"task_id,omitempty"`
	Data   []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*TaskOutputRecordRequest) Descriptor

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

func (*TaskOutputRecordRequest) GetData

func (m *TaskOutputRecordRequest) GetData() []byte

func (*TaskOutputRecordRequest) GetTaskId

func (m *TaskOutputRecordRequest) GetTaskId() uint64

func (*TaskOutputRecordRequest) ProtoMessage

func (*TaskOutputRecordRequest) ProtoMessage()

func (*TaskOutputRecordRequest) Reset

func (m *TaskOutputRecordRequest) Reset()

func (*TaskOutputRecordRequest) String

func (m *TaskOutputRecordRequest) String() string

type TaskOutputRecordResponse

type TaskOutputRecordResponse struct {
	TaskId uint64 `protobuf:"varint,1,opt,name=task_id,json=taskId" json:"task_id,omitempty"`
}

func (*TaskOutputRecordResponse) Descriptor

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

func (*TaskOutputRecordResponse) GetTaskId

func (m *TaskOutputRecordResponse) GetTaskId() uint64

func (*TaskOutputRecordResponse) ProtoMessage

func (*TaskOutputRecordResponse) ProtoMessage()

func (*TaskOutputRecordResponse) Reset

func (m *TaskOutputRecordResponse) Reset()

func (*TaskOutputRecordResponse) String

func (m *TaskOutputRecordResponse) String() string

type WorkflowStartRequest

type WorkflowStartRequest struct {
	WorkflowId uint64 `protobuf:"varint,1,opt,name=workflow_id,json=workflowId" json:"workflow_id,omitempty"`
	ExecName   string `protobuf:"bytes,2,opt,name=exec_name,json=execName" json:"exec_name,omitempty"`
	Input      []byte `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
}

func (*WorkflowStartRequest) Descriptor

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

func (*WorkflowStartRequest) GetExecName

func (m *WorkflowStartRequest) GetExecName() string

func (*WorkflowStartRequest) GetInput

func (m *WorkflowStartRequest) GetInput() []byte

func (*WorkflowStartRequest) GetWorkflowId

func (m *WorkflowStartRequest) GetWorkflowId() uint64

func (*WorkflowStartRequest) ProtoMessage

func (*WorkflowStartRequest) ProtoMessage()

func (*WorkflowStartRequest) Reset

func (m *WorkflowStartRequest) Reset()

func (*WorkflowStartRequest) String

func (m *WorkflowStartRequest) String() string

type WorkflowStartResponse

type WorkflowStartResponse struct {
	Id uint64 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
}

func (*WorkflowStartResponse) Descriptor

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

func (*WorkflowStartResponse) GetId

func (m *WorkflowStartResponse) GetId() uint64

func (*WorkflowStartResponse) ProtoMessage

func (*WorkflowStartResponse) ProtoMessage()

func (*WorkflowStartResponse) Reset

func (m *WorkflowStartResponse) Reset()

func (*WorkflowStartResponse) String

func (m *WorkflowStartResponse) String() string