optimus

package
v0.8.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 27, 2023 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CommandLogType_name = map[int32]string{
		0: "COMMAND_LOG_TYPE_UNSPECIFIED",
		1: "COMMAND_LOG_TYPE_NOOP",
		2: "COMMAND_LOG_TYPE_SCHEDULE_JOB",
		3: "COMMAND_LOG_TYPE_UPDATE_JOB",
	}
	CommandLogType_value = map[string]int32{
		"COMMAND_LOG_TYPE_UNSPECIFIED":  0,
		"COMMAND_LOG_TYPE_NOOP":         1,
		"COMMAND_LOG_TYPE_SCHEDULE_JOB": 2,
		"COMMAND_LOG_TYPE_UPDATE_JOB":   3,
	}
)

Enum value maps for CommandLogType.

View Source 
var File_gotocompany_optimus_cluster_v1beta1_command_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CommandLog 

type CommandLog struct {
	Type    CommandLogType `protobuf:"varint,1,opt,name=type,proto3,enum=gotocompany.optimus.cluster.v1beta1.CommandLogType" json:"type,omitempty"`
	Payload []byte         `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandLog) Descriptor deprecated 

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

Deprecated: Use CommandLog.ProtoReflect.Descriptor instead.

func (*CommandLog) GetPayload 

func (x *CommandLog) GetPayload() []byte

func (*CommandLog) GetType 

func (x *CommandLog) GetType() CommandLogType

func (*CommandLog) ProtoMessage 

func (*CommandLog) ProtoMessage()

func (*CommandLog) ProtoReflect 

func (x *CommandLog) ProtoReflect() protoreflect.Message

func (*CommandLog) Reset 

func (x *CommandLog) Reset()

func (*CommandLog) String 

func (x *CommandLog) String() string

type CommandLogType 

type CommandLogType int32
const (
	CommandLogType_COMMAND_LOG_TYPE_UNSPECIFIED  CommandLogType = 0
	CommandLogType_COMMAND_LOG_TYPE_NOOP         CommandLogType = 1
	CommandLogType_COMMAND_LOG_TYPE_SCHEDULE_JOB CommandLogType = 2
	CommandLogType_COMMAND_LOG_TYPE_UPDATE_JOB   CommandLogType = 3
)

func (CommandLogType) Descriptor 

func (CommandLogType) Descriptor() protoreflect.EnumDescriptor

func (CommandLogType) Enum 

func (x CommandLogType) Enum() *CommandLogType

func (CommandLogType) EnumDescriptor deprecated 

func (CommandLogType) EnumDescriptor() ([]byte, []int)

Deprecated: Use CommandLogType.Descriptor instead.

func (CommandLogType) Number 

func (x CommandLogType) Number() protoreflect.EnumNumber

func (CommandLogType) String 

func (x CommandLogType) String() string

func (CommandLogType) Type 

func (CommandLogType) Type() protoreflect.EnumType

type CommandNoop 

type CommandNoop struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandNoop) Descriptor deprecated 

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

Deprecated: Use CommandNoop.ProtoReflect.Descriptor instead.

func (*CommandNoop) GetId 

func (x *CommandNoop) GetId() string

func (*CommandNoop) ProtoMessage 

func (*CommandNoop) ProtoMessage()

func (*CommandNoop) ProtoReflect 

func (x *CommandNoop) ProtoReflect() protoreflect.Message

func (*CommandNoop) Reset 

func (x *CommandNoop) Reset()

func (*CommandNoop) String 

func (x *CommandNoop) String() string

type CommandScheduleJob 

type CommandScheduleJob struct {

	// peer_id is the node name to which this job is assigned to get
	// executed
	PeerId string   `protobuf:"bytes,1,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	RunIds []string `protobuf:"bytes,2,rep,name=run_ids,json=runIds,proto3" json:"run_ids,omitempty"`
	// contains filtered or unexported fields
}

CommandScheduleJob will be sent to assign job for execution to a peer

func (*CommandScheduleJob) Descriptor deprecated 

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

Deprecated: Use CommandScheduleJob.ProtoReflect.Descriptor instead.

func (*CommandScheduleJob) GetPeerId 

func (x *CommandScheduleJob) GetPeerId() string

func (*CommandScheduleJob) GetRunIds 

func (x *CommandScheduleJob) GetRunIds() []string

func (*CommandScheduleJob) ProtoMessage 

func (*CommandScheduleJob) ProtoMessage()

func (*CommandScheduleJob) ProtoReflect 

func (x *CommandScheduleJob) ProtoReflect() protoreflect.Message

func (*CommandScheduleJob) Reset 

func (x *CommandScheduleJob) Reset()

func (*CommandScheduleJob) String 

func (x *CommandScheduleJob) String() string

type CommandUpdateJob 

type CommandUpdateJob struct {
	PeerId  string                    `protobuf:"bytes,1,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	Patches []*CommandUpdateJob_Patch `protobuf:"bytes,2,rep,name=patches,proto3" json:"patches,omitempty"`
	// contains filtered or unexported fields
}

CommandUpdateJob will be sent to update the attributes of job which was previously scheduled for execution

func (*CommandUpdateJob) Descriptor deprecated 

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

Deprecated: Use CommandUpdateJob.ProtoReflect.Descriptor instead.

func (*CommandUpdateJob) GetPatches 

func (x *CommandUpdateJob) GetPatches() []*CommandUpdateJob_Patch

func (*CommandUpdateJob) GetPeerId 

func (x *CommandUpdateJob) GetPeerId() string

func (*CommandUpdateJob) ProtoMessage 

func (*CommandUpdateJob) ProtoMessage()

func (*CommandUpdateJob) ProtoReflect 

func (x *CommandUpdateJob) ProtoReflect() protoreflect.Message

func (*CommandUpdateJob) Reset 

func (x *CommandUpdateJob) Reset()

func (*CommandUpdateJob) String 

func (x *CommandUpdateJob) String() string

type CommandUpdateJob_Patch 

type CommandUpdateJob_Patch struct {
	RunId  string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandUpdateJob_Patch) Descriptor deprecated 

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

Deprecated: Use CommandUpdateJob_Patch.ProtoReflect.Descriptor instead.

func (*CommandUpdateJob_Patch) GetRunId 

func (x *CommandUpdateJob_Patch) GetRunId() string

func (*CommandUpdateJob_Patch) GetStatus 

func (x *CommandUpdateJob_Patch) GetStatus() string

func (*CommandUpdateJob_Patch) ProtoMessage 

func (*CommandUpdateJob_Patch) ProtoMessage()

func (*CommandUpdateJob_Patch) ProtoReflect 

func (x *CommandUpdateJob_Patch) ProtoReflect() protoreflect.Message

func (*CommandUpdateJob_Patch) Reset 

func (x *CommandUpdateJob_Patch) Reset()

func (*CommandUpdateJob_Patch) String 

func (x *CommandUpdateJob_Patch) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.