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