Versions in this module Expand all Collapse all v0 v0.1.0 Nov 21, 2022 Changes in this version + var File_runner_v1_messages_proto protoreflect.FileDescriptor + var File_runner_v1_services_proto protoreflect.FileDescriptor + var Result_name = map[int32]string + var Result_value = map[string]int32 + var RunnerStatus_name = map[int32]string + var RunnerStatus_value = map[string]int32 + type FetchTaskRequest struct + func (*FetchTaskRequest) Descriptor() ([]byte, []int) + func (*FetchTaskRequest) ProtoMessage() + func (x *FetchTaskRequest) ProtoReflect() protoreflect.Message + func (x *FetchTaskRequest) Reset() + func (x *FetchTaskRequest) String() string + type FetchTaskResponse struct + Task *Task + func (*FetchTaskResponse) Descriptor() ([]byte, []int) + func (*FetchTaskResponse) ProtoMessage() + func (x *FetchTaskResponse) GetTask() *Task + func (x *FetchTaskResponse) ProtoReflect() protoreflect.Message + func (x *FetchTaskResponse) Reset() + func (x *FetchTaskResponse) String() string + type LogRow struct + Content string + Time *timestamppb.Timestamp + func (*LogRow) Descriptor() ([]byte, []int) + func (*LogRow) ProtoMessage() + func (x *LogRow) GetContent() string + func (x *LogRow) GetTime() *timestamppb.Timestamp + func (x *LogRow) ProtoReflect() protoreflect.Message + func (x *LogRow) Reset() + func (x *LogRow) String() string + type RegisterRequest struct + AgentLabels []string + CustomLabels []string + Name string + Token string + func (*RegisterRequest) Descriptor() ([]byte, []int) + func (*RegisterRequest) ProtoMessage() + func (x *RegisterRequest) GetAgentLabels() []string + func (x *RegisterRequest) GetCustomLabels() []string + func (x *RegisterRequest) GetName() string + func (x *RegisterRequest) GetToken() string + func (x *RegisterRequest) ProtoReflect() protoreflect.Message + func (x *RegisterRequest) Reset() + func (x *RegisterRequest) String() string + type RegisterResponse struct + Runner *Runner + func (*RegisterResponse) Descriptor() ([]byte, []int) + func (*RegisterResponse) ProtoMessage() + func (x *RegisterResponse) GetRunner() *Runner + func (x *RegisterResponse) ProtoReflect() protoreflect.Message + func (x *RegisterResponse) Reset() + func (x *RegisterResponse) String() string + type Result int32 + const Result_RESULT_CANCELLED + const Result_RESULT_FAILURE + const Result_RESULT_SKIPPED + const Result_RESULT_SUCCESS + const Result_RESULT_UNSPECIFIED + func (Result) Descriptor() protoreflect.EnumDescriptor + func (Result) EnumDescriptor() ([]byte, []int) + func (Result) Type() protoreflect.EnumType + func (x Result) Enum() *Result + func (x Result) Number() protoreflect.EnumNumber + func (x Result) String() string + type Runner struct + AgentLabels []string + CustomLabels []string + Id int64 + Name string + Status RunnerStatus + Token string + Uuid string + func (*Runner) Descriptor() ([]byte, []int) + func (*Runner) ProtoMessage() + func (x *Runner) GetAgentLabels() []string + func (x *Runner) GetCustomLabels() []string + func (x *Runner) GetId() int64 + func (x *Runner) GetName() string + func (x *Runner) GetStatus() RunnerStatus + func (x *Runner) GetToken() string + func (x *Runner) GetUuid() string + func (x *Runner) ProtoReflect() protoreflect.Message + func (x *Runner) Reset() + func (x *Runner) String() string + type RunnerStatus int32 + const RunnerStatus_RUNNER_STATUS_ACTIVE + const RunnerStatus_RUNNER_STATUS_IDLE + const RunnerStatus_RUNNER_STATUS_OFFLINE + const RunnerStatus_RUNNER_STATUS_UNSPECIFIED + func (RunnerStatus) Descriptor() protoreflect.EnumDescriptor + func (RunnerStatus) EnumDescriptor() ([]byte, []int) + func (RunnerStatus) Type() protoreflect.EnumType + func (x RunnerStatus) Enum() *RunnerStatus + func (x RunnerStatus) Number() protoreflect.EnumNumber + func (x RunnerStatus) String() string + type StepState struct + Id int64 + LogIndex int64 + LogLength int64 + Result Result + StartedAt *timestamppb.Timestamp + StoppedAt *timestamppb.Timestamp + func (*StepState) Descriptor() ([]byte, []int) + func (*StepState) ProtoMessage() + 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 (x *StepState) ProtoReflect() protoreflect.Message + func (x *StepState) Reset() + func (x *StepState) String() string + type Task struct + Context *structpb.Struct + Id int64 + Machine string + Secrets map[string]string + WorkflowPayload []byte + func (*Task) Descriptor() ([]byte, []int) + func (*Task) ProtoMessage() + func (x *Task) GetContext() *structpb.Struct + func (x *Task) GetId() int64 + func (x *Task) GetMachine() string + func (x *Task) GetSecrets() map[string]string + func (x *Task) GetWorkflowPayload() []byte + func (x *Task) ProtoReflect() protoreflect.Message + func (x *Task) Reset() + func (x *Task) String() string + type TaskState struct + Id int64 + Result Result + StartedAt *timestamppb.Timestamp + Steps []*StepState + StoppedAt *timestamppb.Timestamp + func (*TaskState) Descriptor() ([]byte, []int) + func (*TaskState) ProtoMessage() + 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 (x *TaskState) ProtoReflect() protoreflect.Message + func (x *TaskState) Reset() + func (x *TaskState) String() string + type UpdateLogRequest struct + Index int64 + NoMore bool + Rows []*LogRow + TaskId int64 + func (*UpdateLogRequest) Descriptor() ([]byte, []int) + func (*UpdateLogRequest) ProtoMessage() + func (x *UpdateLogRequest) GetIndex() int64 + func (x *UpdateLogRequest) GetNoMore() bool + func (x *UpdateLogRequest) GetRows() []*LogRow + func (x *UpdateLogRequest) GetTaskId() int64 + func (x *UpdateLogRequest) ProtoReflect() protoreflect.Message + func (x *UpdateLogRequest) Reset() + func (x *UpdateLogRequest) String() string + type UpdateLogResponse struct + AckIndex int64 + func (*UpdateLogResponse) Descriptor() ([]byte, []int) + func (*UpdateLogResponse) ProtoMessage() + func (x *UpdateLogResponse) GetAckIndex() int64 + func (x *UpdateLogResponse) ProtoReflect() protoreflect.Message + func (x *UpdateLogResponse) Reset() + func (x *UpdateLogResponse) String() string + type UpdateTaskRequest struct + State *TaskState + func (*UpdateTaskRequest) Descriptor() ([]byte, []int) + func (*UpdateTaskRequest) ProtoMessage() + func (x *UpdateTaskRequest) GetState() *TaskState + func (x *UpdateTaskRequest) ProtoReflect() protoreflect.Message + func (x *UpdateTaskRequest) Reset() + func (x *UpdateTaskRequest) String() string + type UpdateTaskResponse struct + State *TaskState + func (*UpdateTaskResponse) Descriptor() ([]byte, []int) + func (*UpdateTaskResponse) ProtoMessage() + func (x *UpdateTaskResponse) GetState() *TaskState + func (x *UpdateTaskResponse) ProtoReflect() protoreflect.Message + func (x *UpdateTaskResponse) Reset() + func (x *UpdateTaskResponse) String() string