Documentation ¶
Index ¶
- Variables
- type DeclareRequest
- func (*DeclareRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeclareRequest) GetLabels() []string
- func (x *DeclareRequest) GetVersion() string
- func (*DeclareRequest) ProtoMessage()
- func (x *DeclareRequest) ProtoReflect() protoreflect.Message
- func (x *DeclareRequest) Reset()
- func (x *DeclareRequest) String() string
- type DeclareResponse
- type FetchTaskRequest
- type FetchTaskResponse
- func (*FetchTaskResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FetchTaskResponse) GetTask() *Task
- func (x *FetchTaskResponse) GetTasksVersion() int64
- func (*FetchTaskResponse) ProtoMessage()
- func (x *FetchTaskResponse) ProtoReflect() protoreflect.Message
- func (x *FetchTaskResponse) Reset()
- func (x *FetchTaskResponse) String() string
- type LogRow
- type RegisterRequest
- func (*RegisterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterRequest) GetAgentLabels() []stringdeprecated
- func (x *RegisterRequest) GetCustomLabels() []stringdeprecated
- func (x *RegisterRequest) GetLabels() []string
- func (x *RegisterRequest) GetName() string
- func (x *RegisterRequest) GetToken() string
- func (x *RegisterRequest) GetVersion() string
- func (*RegisterRequest) ProtoMessage()
- func (x *RegisterRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterRequest) Reset()
- func (x *RegisterRequest) String() string
- type RegisterResponse
- type Result
- type Runner
- func (*Runner) Descriptor() ([]byte, []int)deprecated
- func (x *Runner) GetAgentLabels() []stringdeprecated
- func (x *Runner) GetCustomLabels() []stringdeprecated
- func (x *Runner) GetId() int64
- func (x *Runner) GetLabels() []string
- func (x *Runner) GetName() string
- func (x *Runner) GetStatus() RunnerStatus
- func (x *Runner) GetToken() string
- func (x *Runner) GetUuid() string
- func (x *Runner) GetVersion() string
- func (*Runner) ProtoMessage()
- func (x *Runner) ProtoReflect() protoreflect.Message
- func (x *Runner) Reset()
- func (x *Runner) String() string
- type RunnerStatus
- func (RunnerStatus) Descriptor() protoreflect.EnumDescriptor
- func (x RunnerStatus) Enum() *RunnerStatus
- func (RunnerStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x RunnerStatus) Number() protoreflect.EnumNumber
- func (x RunnerStatus) String() string
- func (RunnerStatus) Type() protoreflect.EnumType
- type StepState
- func (*StepState) Descriptor() ([]byte, []int)deprecated
- func (x *StepState) GetId() int64
- func (x *StepState) GetLogIndex() int64
- func (x *StepState) GetLogLength() int64
- func (x *StepState) GetResult() Result
- func (x *StepState) GetStartedAt() *timestamppb.Timestamp
- func (x *StepState) GetStoppedAt() *timestamppb.Timestamp
- func (*StepState) ProtoMessage()
- func (x *StepState) ProtoReflect() protoreflect.Message
- func (x *StepState) Reset()
- func (x *StepState) String() string
- type Task
- func (*Task) Descriptor() ([]byte, []int)deprecated
- func (x *Task) GetContext() *structpb.Struct
- func (x *Task) GetId() int64
- func (x *Task) GetMachine() stringdeprecated
- func (x *Task) GetNeeds() map[string]*TaskNeed
- func (x *Task) GetSecrets() map[string]string
- func (x *Task) GetVars() map[string]string
- func (x *Task) GetWorkflowPayload() []byte
- func (*Task) ProtoMessage()
- func (x *Task) ProtoReflect() protoreflect.Message
- func (x *Task) Reset()
- func (x *Task) String() string
- type TaskNeed
- type TaskState
- func (*TaskState) Descriptor() ([]byte, []int)deprecated
- func (x *TaskState) GetId() int64
- func (x *TaskState) GetResult() Result
- func (x *TaskState) GetStartedAt() *timestamppb.Timestamp
- func (x *TaskState) GetSteps() []*StepState
- func (x *TaskState) GetStoppedAt() *timestamppb.Timestamp
- func (*TaskState) ProtoMessage()
- func (x *TaskState) ProtoReflect() protoreflect.Message
- func (x *TaskState) Reset()
- func (x *TaskState) String() string
- type UpdateLogRequest
- func (*UpdateLogRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateLogRequest) GetIndex() int64
- func (x *UpdateLogRequest) GetNoMore() bool
- func (x *UpdateLogRequest) GetRows() []*LogRow
- func (x *UpdateLogRequest) GetTaskId() int64
- func (*UpdateLogRequest) ProtoMessage()
- func (x *UpdateLogRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateLogRequest) Reset()
- func (x *UpdateLogRequest) String() string
- type UpdateLogResponse
- type UpdateTaskRequest
- func (*UpdateTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateTaskRequest) GetOutputs() map[string]string
- func (x *UpdateTaskRequest) GetState() *TaskState
- func (*UpdateTaskRequest) ProtoMessage()
- func (x *UpdateTaskRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateTaskRequest) Reset()
- func (x *UpdateTaskRequest) String() string
- type UpdateTaskResponse
- func (*UpdateTaskResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateTaskResponse) GetSentOutputs() []string
- func (x *UpdateTaskResponse) GetState() *TaskState
- func (*UpdateTaskResponse) ProtoMessage()
- func (x *UpdateTaskResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateTaskResponse) Reset()
- func (x *UpdateTaskResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var ( RunnerStatus_name = map[int32]string{ 0: "RUNNER_STATUS_UNSPECIFIED", 1: "RUNNER_STATUS_IDLE", 2: "RUNNER_STATUS_ACTIVE", 3: "RUNNER_STATUS_OFFLINE", } RunnerStatus_value = map[string]int32{ "RUNNER_STATUS_UNSPECIFIED": 0, "RUNNER_STATUS_IDLE": 1, "RUNNER_STATUS_ACTIVE": 2, "RUNNER_STATUS_OFFLINE": 3, } )
Enum value maps for RunnerStatus.
var ( Result_name = map[int32]string{ 0: "RESULT_UNSPECIFIED", 1: "RESULT_SUCCESS", 2: "RESULT_FAILURE", 3: "RESULT_CANCELLED", 4: "RESULT_SKIPPED", } Result_value = map[string]int32{ "RESULT_UNSPECIFIED": 0, "RESULT_SUCCESS": 1, "RESULT_FAILURE": 2, "RESULT_CANCELLED": 3, "RESULT_SKIPPED": 4, } )
Enum value maps for Result.
var File_runner_v1_messages_proto protoreflect.FileDescriptor
var File_runner_v1_services_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type DeclareRequest ¶ added in v0.3.0
type DeclareRequest struct { Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` Labels []string `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"` // contains filtered or unexported fields }
func (*DeclareRequest) Descriptor
deprecated
added in
v0.3.0
func (*DeclareRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeclareRequest.ProtoReflect.Descriptor instead.
func (*DeclareRequest) GetLabels ¶ added in v0.3.0
func (x *DeclareRequest) GetLabels() []string
func (*DeclareRequest) GetVersion ¶ added in v0.3.0
func (x *DeclareRequest) GetVersion() string
func (*DeclareRequest) ProtoMessage ¶ added in v0.3.0
func (*DeclareRequest) ProtoMessage()
func (*DeclareRequest) ProtoReflect ¶ added in v0.3.0
func (x *DeclareRequest) ProtoReflect() protoreflect.Message
func (*DeclareRequest) Reset ¶ added in v0.3.0
func (x *DeclareRequest) Reset()
func (*DeclareRequest) String ¶ added in v0.3.0
func (x *DeclareRequest) String() string
type DeclareResponse ¶ added in v0.3.0
type DeclareResponse struct { Runner *Runner `protobuf:"bytes,1,opt,name=runner,proto3" json:"runner,omitempty"` // contains filtered or unexported fields }
func (*DeclareResponse) Descriptor
deprecated
added in
v0.3.0
func (*DeclareResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeclareResponse.ProtoReflect.Descriptor instead.
func (*DeclareResponse) GetRunner ¶ added in v0.3.0
func (x *DeclareResponse) GetRunner() *Runner
func (*DeclareResponse) ProtoMessage ¶ added in v0.3.0
func (*DeclareResponse) ProtoMessage()
func (*DeclareResponse) ProtoReflect ¶ added in v0.3.0
func (x *DeclareResponse) ProtoReflect() protoreflect.Message
func (*DeclareResponse) Reset ¶ added in v0.3.0
func (x *DeclareResponse) Reset()
func (*DeclareResponse) String ¶ added in v0.3.0
func (x *DeclareResponse) String() string
type FetchTaskRequest ¶
type FetchTaskRequest struct { TasksVersion int64 `protobuf:"varint,1,opt,name=tasks_version,json=tasksVersion,proto3" json:"tasks_version,omitempty"` // Runner use `tasks_version` to compare with Gitea and detemine whether new tasks may exist. // contains filtered or unexported fields }
func (*FetchTaskRequest) Descriptor
deprecated
func (*FetchTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use FetchTaskRequest.ProtoReflect.Descriptor instead.
func (*FetchTaskRequest) GetTasksVersion ¶ added in v0.3.1
func (x *FetchTaskRequest) GetTasksVersion() int64
func (*FetchTaskRequest) ProtoMessage ¶
func (*FetchTaskRequest) ProtoMessage()
func (*FetchTaskRequest) ProtoReflect ¶
func (x *FetchTaskRequest) ProtoReflect() protoreflect.Message
func (*FetchTaskRequest) Reset ¶
func (x *FetchTaskRequest) Reset()
func (*FetchTaskRequest) String ¶
func (x *FetchTaskRequest) String() string
type FetchTaskResponse ¶
type FetchTaskResponse struct { Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` TasksVersion int64 `protobuf:"varint,2,opt,name=tasks_version,json=tasksVersion,proto3" json:"tasks_version,omitempty"` // Gitea informs the Runner of the latest version of tasks through `tasks_version`. // contains filtered or unexported fields }
func (*FetchTaskResponse) Descriptor
deprecated
func (*FetchTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use FetchTaskResponse.ProtoReflect.Descriptor instead.
func (*FetchTaskResponse) GetTask ¶
func (x *FetchTaskResponse) GetTask() *Task
func (*FetchTaskResponse) GetTasksVersion ¶ added in v0.3.1
func (x *FetchTaskResponse) GetTasksVersion() int64
func (*FetchTaskResponse) ProtoMessage ¶
func (*FetchTaskResponse) ProtoMessage()
func (*FetchTaskResponse) ProtoReflect ¶
func (x *FetchTaskResponse) ProtoReflect() protoreflect.Message
func (*FetchTaskResponse) Reset ¶
func (x *FetchTaskResponse) Reset()
func (*FetchTaskResponse) String ¶
func (x *FetchTaskResponse) String() string
type LogRow ¶
type LogRow struct { Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"` Content string `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
LogRow represents a row of logs.
func (*LogRow) Descriptor
deprecated
func (*LogRow) GetContent ¶
func (*LogRow) GetTime ¶
func (x *LogRow) GetTime() *timestamppb.Timestamp
func (*LogRow) ProtoMessage ¶
func (*LogRow) ProtoMessage()
func (*LogRow) ProtoReflect ¶
func (x *LogRow) ProtoReflect() protoreflect.Message
type RegisterRequest ¶
type RegisterRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"` // Deprecated: Do not use. AgentLabels []string `protobuf:"bytes,3,rep,name=agent_labels,json=agentLabels,proto3" json:"agent_labels,omitempty"` // Deprecated: Do not use. CustomLabels []string `protobuf:"bytes,4,rep,name=custom_labels,json=customLabels,proto3" json:"custom_labels,omitempty"` Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"` Labels []string `protobuf:"bytes,6,rep,name=labels,proto3" json:"labels,omitempty"` // contains filtered or unexported fields }
func (*RegisterRequest) Descriptor
deprecated
func (*RegisterRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.
func (*RegisterRequest) GetAgentLabels
deprecated
func (x *RegisterRequest) GetAgentLabels() []string
Deprecated: Do not use.
func (*RegisterRequest) GetCustomLabels
deprecated
func (x *RegisterRequest) GetCustomLabels() []string
Deprecated: Do not use.
func (*RegisterRequest) GetLabels ¶ added in v0.3.0
func (x *RegisterRequest) GetLabels() []string
func (*RegisterRequest) GetName ¶
func (x *RegisterRequest) GetName() string
func (*RegisterRequest) GetToken ¶
func (x *RegisterRequest) GetToken() string
func (*RegisterRequest) GetVersion ¶ added in v0.3.0
func (x *RegisterRequest) GetVersion() string
func (*RegisterRequest) ProtoMessage ¶
func (*RegisterRequest) ProtoMessage()
func (*RegisterRequest) ProtoReflect ¶
func (x *RegisterRequest) ProtoReflect() protoreflect.Message
func (*RegisterRequest) Reset ¶
func (x *RegisterRequest) Reset()
func (*RegisterRequest) String ¶
func (x *RegisterRequest) String() string
type RegisterResponse ¶
type RegisterResponse struct { Runner *Runner `protobuf:"bytes,1,opt,name=runner,proto3" json:"runner,omitempty"` // contains filtered or unexported fields }
func (*RegisterResponse) Descriptor
deprecated
func (*RegisterResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterResponse.ProtoReflect.Descriptor instead.
func (*RegisterResponse) GetRunner ¶
func (x *RegisterResponse) GetRunner() *Runner
func (*RegisterResponse) ProtoMessage ¶
func (*RegisterResponse) ProtoMessage()
func (*RegisterResponse) ProtoReflect ¶
func (x *RegisterResponse) ProtoReflect() protoreflect.Message
func (*RegisterResponse) Reset ¶
func (x *RegisterResponse) Reset()
func (*RegisterResponse) String ¶
func (x *RegisterResponse) String() string
type Result ¶
type Result int32
The result of a task or a step, see https://docs.github.com/en/actions/learn-github-actions/contexts#jobs-context .
func (Result) Descriptor ¶
func (Result) Descriptor() protoreflect.EnumDescriptor
func (Result) EnumDescriptor
deprecated
func (Result) Number ¶
func (x Result) Number() protoreflect.EnumNumber
func (Result) Type ¶
func (Result) Type() protoreflect.EnumType
type Runner ¶
type Runner struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"` Token string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"` Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` Status RunnerStatus `protobuf:"varint,5,opt,name=status,proto3,enum=runner.v1.RunnerStatus" json:"status,omitempty"` // Deprecated: Do not use. AgentLabels []string `protobuf:"bytes,6,rep,name=agent_labels,json=agentLabels,proto3" json:"agent_labels,omitempty"` // Deprecated: Do not use. CustomLabels []string `protobuf:"bytes,7,rep,name=custom_labels,json=customLabels,proto3" json:"custom_labels,omitempty"` Version string `protobuf:"bytes,8,opt,name=version,proto3" json:"version,omitempty"` Labels []string `protobuf:"bytes,9,rep,name=labels,proto3" json:"labels,omitempty"` // contains filtered or unexported fields }
Runner Payload
func (*Runner) Descriptor
deprecated
func (*Runner) GetAgentLabels
deprecated
func (*Runner) GetCustomLabels
deprecated
func (*Runner) GetStatus ¶
func (x *Runner) GetStatus() RunnerStatus
func (*Runner) GetVersion ¶ added in v0.3.0
func (*Runner) ProtoMessage ¶
func (*Runner) ProtoMessage()
func (*Runner) ProtoReflect ¶
func (x *Runner) ProtoReflect() protoreflect.Message
type RunnerStatus ¶
type RunnerStatus int32
RunnerStatus runner all status
const ( RunnerStatus_RUNNER_STATUS_UNSPECIFIED RunnerStatus = 0 RunnerStatus_RUNNER_STATUS_IDLE RunnerStatus = 1 RunnerStatus_RUNNER_STATUS_ACTIVE RunnerStatus = 2 RunnerStatus_RUNNER_STATUS_OFFLINE RunnerStatus = 3 )
func (RunnerStatus) Descriptor ¶
func (RunnerStatus) Descriptor() protoreflect.EnumDescriptor
func (RunnerStatus) Enum ¶
func (x RunnerStatus) Enum() *RunnerStatus
func (RunnerStatus) EnumDescriptor
deprecated
func (RunnerStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use RunnerStatus.Descriptor instead.
func (RunnerStatus) Number ¶
func (x RunnerStatus) Number() protoreflect.EnumNumber
func (RunnerStatus) String ¶
func (x RunnerStatus) String() string
func (RunnerStatus) Type ¶
func (RunnerStatus) Type() protoreflect.EnumType
type StepState ¶
type StepState struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Result Result `protobuf:"varint,2,opt,name=result,proto3,enum=runner.v1.Result" json:"result,omitempty"` StartedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"` StoppedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=stopped_at,json=stoppedAt,proto3" json:"stopped_at,omitempty"` LogIndex int64 `protobuf:"varint,5,opt,name=log_index,json=logIndex,proto3" json:"log_index,omitempty"` // Where the first line log of the step. LogLength int64 `protobuf:"varint,6,opt,name=log_length,json=logLength,proto3" json:"log_length,omitempty"` // How many logs the step has. // contains filtered or unexported fields }
TaskState represents the state of a step.
func (*StepState) Descriptor
deprecated
func (*StepState) GetLogIndex ¶
func (*StepState) GetLogLength ¶
func (*StepState) GetStartedAt ¶
func (x *StepState) GetStartedAt() *timestamppb.Timestamp
func (*StepState) GetStoppedAt ¶
func (x *StepState) GetStoppedAt() *timestamppb.Timestamp
func (*StepState) ProtoMessage ¶
func (*StepState) ProtoMessage()
func (*StepState) ProtoReflect ¶
func (x *StepState) ProtoReflect() protoreflect.Message
type Task ¶
type Task struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // A unique number for each workflow run, unlike run_id or job_id, task_id never be reused. WorkflowPayload []byte `protobuf:"bytes,2,opt,name=workflow_payload,json=workflowPayload,proto3,oneof" json:"workflow_payload,omitempty"` // The content of the expanded workflow yaml file. Context *structpb.Struct `protobuf:"bytes,3,opt,name=context,proto3,oneof" json:"context,omitempty"` // See https://docs.github.com/en/actions/learn-github-actions/contexts#github-context . Secrets map[string]string `` // See https://docs.github.com/en/actions/learn-github-actions/contexts#secrets-context . /* 155-byte string literal not displayed */ // Deprecated: Do not use. Machine string `protobuf:"bytes,5,opt,name=machine,proto3" json:"machine,omitempty"` // Unused. Needs map[string]*TaskNeed `` // See https://docs.github.com/en/actions/learn-github-actions/contexts#needs-context . /* 151-byte string literal not displayed */ Vars map[string]string `` // See https://docs.github.com/en/actions/learn-github-actions/contexts#vars-context . /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
Task represents a task.
func (*Task) Descriptor
deprecated
func (*Task) GetContext ¶
func (*Task) GetMachine
deprecated
func (*Task) GetSecrets ¶
func (*Task) GetWorkflowPayload ¶
func (*Task) ProtoMessage ¶
func (*Task) ProtoMessage()
func (*Task) ProtoReflect ¶
func (x *Task) ProtoReflect() protoreflect.Message
type TaskNeed ¶ added in v0.2.1
type TaskNeed struct { Outputs map[string]string `` // The set of outputs of a job that the current job depends on. /* 155-byte string literal not displayed */ Result Result `protobuf:"varint,2,opt,name=result,proto3,enum=runner.v1.Result" json:"result,omitempty"` // The result of a job that the current job depends on. Possible values are success, failure, cancelled, or skipped. // contains filtered or unexported fields }
TaskNeed represents a task need.
func (*TaskNeed) Descriptor
deprecated
added in
v0.2.1
func (*TaskNeed) GetOutputs ¶ added in v0.2.1
func (*TaskNeed) ProtoMessage ¶ added in v0.2.1
func (*TaskNeed) ProtoMessage()
func (*TaskNeed) ProtoReflect ¶ added in v0.2.1
func (x *TaskNeed) ProtoReflect() protoreflect.Message
type TaskState ¶
type TaskState struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Result Result `protobuf:"varint,2,opt,name=result,proto3,enum=runner.v1.Result" json:"result,omitempty"` StartedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"` StoppedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=stopped_at,json=stoppedAt,proto3" json:"stopped_at,omitempty"` Steps []*StepState `protobuf:"bytes,5,rep,name=steps,proto3" json:"steps,omitempty"` // contains filtered or unexported fields }
TaskState represents the state of a task.
func (*TaskState) Descriptor
deprecated
func (*TaskState) GetStartedAt ¶
func (x *TaskState) GetStartedAt() *timestamppb.Timestamp
func (*TaskState) GetStoppedAt ¶
func (x *TaskState) GetStoppedAt() *timestamppb.Timestamp
func (*TaskState) ProtoMessage ¶
func (*TaskState) ProtoMessage()
func (*TaskState) ProtoReflect ¶
func (x *TaskState) ProtoReflect() protoreflect.Message
type UpdateLogRequest ¶
type UpdateLogRequest struct { TaskId int64 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` Index int64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` // The actual index of the first line. Rows []*LogRow `protobuf:"bytes,3,rep,name=rows,proto3" json:"rows,omitempty"` NoMore bool `protobuf:"varint,4,opt,name=no_more,json=noMore,proto3" json:"no_more,omitempty"` // No more logs. // contains filtered or unexported fields }
func (*UpdateLogRequest) Descriptor
deprecated
func (*UpdateLogRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateLogRequest.ProtoReflect.Descriptor instead.
func (*UpdateLogRequest) GetIndex ¶
func (x *UpdateLogRequest) GetIndex() int64
func (*UpdateLogRequest) GetNoMore ¶
func (x *UpdateLogRequest) GetNoMore() bool
func (*UpdateLogRequest) GetRows ¶
func (x *UpdateLogRequest) GetRows() []*LogRow
func (*UpdateLogRequest) GetTaskId ¶
func (x *UpdateLogRequest) GetTaskId() int64
func (*UpdateLogRequest) ProtoMessage ¶
func (*UpdateLogRequest) ProtoMessage()
func (*UpdateLogRequest) ProtoReflect ¶
func (x *UpdateLogRequest) ProtoReflect() protoreflect.Message
func (*UpdateLogRequest) Reset ¶
func (x *UpdateLogRequest) Reset()
func (*UpdateLogRequest) String ¶
func (x *UpdateLogRequest) String() string
type UpdateLogResponse ¶
type UpdateLogResponse struct { AckIndex int64 `protobuf:"varint,1,opt,name=ack_index,json=ackIndex,proto3" json:"ack_index,omitempty"` // If all lines are received, should be index + length(lines). // contains filtered or unexported fields }
func (*UpdateLogResponse) Descriptor
deprecated
func (*UpdateLogResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateLogResponse.ProtoReflect.Descriptor instead.
func (*UpdateLogResponse) GetAckIndex ¶
func (x *UpdateLogResponse) GetAckIndex() int64
func (*UpdateLogResponse) ProtoMessage ¶
func (*UpdateLogResponse) ProtoMessage()
func (*UpdateLogResponse) ProtoReflect ¶
func (x *UpdateLogResponse) ProtoReflect() protoreflect.Message
func (*UpdateLogResponse) Reset ¶
func (x *UpdateLogResponse) Reset()
func (*UpdateLogResponse) String ¶
func (x *UpdateLogResponse) String() string
type UpdateTaskRequest ¶
type UpdateTaskRequest struct { State *TaskState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"` Outputs map[string]string `` // The outputs of the task. Since the outputs may be large, the client does not need to send all outputs every time, only the unsent outputs. /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
func (*UpdateTaskRequest) Descriptor
deprecated
func (*UpdateTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateTaskRequest.ProtoReflect.Descriptor instead.
func (*UpdateTaskRequest) GetOutputs ¶ added in v0.2.1
func (x *UpdateTaskRequest) GetOutputs() map[string]string
func (*UpdateTaskRequest) GetState ¶
func (x *UpdateTaskRequest) GetState() *TaskState
func (*UpdateTaskRequest) ProtoMessage ¶
func (*UpdateTaskRequest) ProtoMessage()
func (*UpdateTaskRequest) ProtoReflect ¶
func (x *UpdateTaskRequest) ProtoReflect() protoreflect.Message
func (*UpdateTaskRequest) Reset ¶
func (x *UpdateTaskRequest) Reset()
func (*UpdateTaskRequest) String ¶
func (x *UpdateTaskRequest) String() string
type UpdateTaskResponse ¶
type UpdateTaskResponse struct { State *TaskState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"` SentOutputs []string `protobuf:"bytes,2,rep,name=sent_outputs,json=sentOutputs,proto3" json:"sent_outputs,omitempty"` // The keys of the outputs that have been sent, not only the ones that have been sent this time, but also those that have been sent before. // contains filtered or unexported fields }
func (*UpdateTaskResponse) Descriptor
deprecated
func (*UpdateTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateTaskResponse.ProtoReflect.Descriptor instead.
func (*UpdateTaskResponse) GetSentOutputs ¶ added in v0.2.1
func (x *UpdateTaskResponse) GetSentOutputs() []string
func (*UpdateTaskResponse) GetState ¶
func (x *UpdateTaskResponse) GetState() *TaskState
func (*UpdateTaskResponse) ProtoMessage ¶
func (*UpdateTaskResponse) ProtoMessage()
func (*UpdateTaskResponse) ProtoReflect ¶
func (x *UpdateTaskResponse) ProtoReflect() protoreflect.Message
func (*UpdateTaskResponse) Reset ¶
func (x *UpdateTaskResponse) Reset()
func (*UpdateTaskResponse) String ¶
func (x *UpdateTaskResponse) String() string