controlplaneevents

package
v0.20.34 Latest Latest
Warning

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

 Go to latest Published: Feb 26, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ActiveJobState_name = map[int32]string{
	0: "UNKNOWN",
	1: "QUEUED",
	2: "LEASED",
	3: "PENDING",
	4: "RUNNING",
}
View Source 
var ActiveJobState_value = map[string]int32{
	"UNKNOWN": 0,
	"QUEUED":  1,
	"LEASED":  2,
	"PENDING": 3,
	"RUNNING": 4,
}

Functions

This section is empty.

Types

type ActiveJobState added in v0.15.4 

type ActiveJobState int32

A subset of JobState including only non-terminal states 

const (
	ActiveJobState_UNKNOWN ActiveJobState = 0
	ActiveJobState_QUEUED  ActiveJobState = 1
	ActiveJobState_LEASED  ActiveJobState = 2
	ActiveJobState_PENDING ActiveJobState = 3
	ActiveJobState_RUNNING ActiveJobState = 4
)

func (ActiveJobState) EnumDescriptor added in v0.15.4 

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

func (ActiveJobState) String added in v0.15.4 

func (x ActiveJobState) String() string

type CancelOnExecutor added in v0.15.4 

type CancelOnExecutor struct {
	Name            string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Queues          []string `protobuf:"bytes,2,rep,name=queues,proto3" json:"queues,omitempty"`
	PriorityClasses []string `protobuf:"bytes,3,rep,name=priorityClasses,proto3" json:"priorityClasses,omitempty"`
	// If empty, jobs on all pools will be cancelled
	Pools []string `protobuf:"bytes,4,rep,name=pools,proto3" json:"pools,omitempty"`
}

func (*CancelOnExecutor) Descriptor added in v0.15.4 

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

func (*CancelOnExecutor) GetName added in v0.15.4 

func (m *CancelOnExecutor) GetName() string

func (*CancelOnExecutor) GetPools added in v0.20.29 

func (m *CancelOnExecutor) GetPools() []string

func (*CancelOnExecutor) GetPriorityClasses added in v0.15.4 

func (m *CancelOnExecutor) GetPriorityClasses() []string

func (*CancelOnExecutor) GetQueues added in v0.15.4 

func (m *CancelOnExecutor) GetQueues() []string

func (*CancelOnExecutor) Marshal added in v0.15.4 

func (m *CancelOnExecutor) Marshal() (dAtA []byte, err error)

func (*CancelOnExecutor) MarshalTo added in v0.15.4 

func (m *CancelOnExecutor) MarshalTo(dAtA []byte) (int, error)

func (*CancelOnExecutor) MarshalToSizedBuffer added in v0.15.4 

func (m *CancelOnExecutor) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CancelOnExecutor) ProtoMessage added in v0.15.4 

func (*CancelOnExecutor) ProtoMessage()

func (*CancelOnExecutor) Reset added in v0.15.4 

func (m *CancelOnExecutor) Reset()

func (*CancelOnExecutor) Size added in v0.15.4 

func (m *CancelOnExecutor) Size() (n int)

func (*CancelOnExecutor) String added in v0.15.4 

func (m *CancelOnExecutor) String() string

func (*CancelOnExecutor) Unmarshal added in v0.15.4 

func (m *CancelOnExecutor) Unmarshal(dAtA []byte) error

func (*CancelOnExecutor) XXX_DiscardUnknown added in v0.15.4 

func (m *CancelOnExecutor) XXX_DiscardUnknown()

func (*CancelOnExecutor) XXX_Marshal added in v0.15.4 

func (m *CancelOnExecutor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CancelOnExecutor) XXX_Merge added in v0.15.4 

func (m *CancelOnExecutor) XXX_Merge(src proto.Message)

func (*CancelOnExecutor) XXX_Size added in v0.15.4 

func (m *CancelOnExecutor) XXX_Size() int

func (*CancelOnExecutor) XXX_Unmarshal added in v0.15.4 

func (m *CancelOnExecutor) XXX_Unmarshal(b []byte) error

type CancelOnNode added in v0.20.29 

type CancelOnNode struct {
	Name            string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Executor        string   `protobuf:"bytes,2,opt,name=executor,proto3" json:"executor,omitempty"`
	Queues          []string `protobuf:"bytes,3,rep,name=queues,proto3" json:"queues,omitempty"`
	PriorityClasses []string `protobuf:"bytes,4,rep,name=priorityClasses,proto3" json:"priorityClasses,omitempty"`
}

func (*CancelOnNode) Descriptor added in v0.20.29 

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

func (*CancelOnNode) GetExecutor added in v0.20.29 

func (m *CancelOnNode) GetExecutor() string

func (*CancelOnNode) GetName added in v0.20.29 

func (m *CancelOnNode) GetName() string

func (*CancelOnNode) GetPriorityClasses added in v0.20.29 

func (m *CancelOnNode) GetPriorityClasses() []string

func (*CancelOnNode) GetQueues added in v0.20.29 

func (m *CancelOnNode) GetQueues() []string

func (*CancelOnNode) Marshal added in v0.20.29 

func (m *CancelOnNode) Marshal() (dAtA []byte, err error)

func (*CancelOnNode) MarshalTo added in v0.20.29 

func (m *CancelOnNode) MarshalTo(dAtA []byte) (int, error)

func (*CancelOnNode) MarshalToSizedBuffer added in v0.20.29 

func (m *CancelOnNode) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CancelOnNode) ProtoMessage added in v0.20.29 

func (*CancelOnNode) ProtoMessage()

func (*CancelOnNode) Reset added in v0.20.29 

func (m *CancelOnNode) Reset()

func (*CancelOnNode) Size added in v0.20.29 

func (m *CancelOnNode) Size() (n int)

func (*CancelOnNode) String added in v0.20.29 

func (m *CancelOnNode) String() string

func (*CancelOnNode) Unmarshal added in v0.20.29 

func (m *CancelOnNode) Unmarshal(dAtA []byte) error

func (*CancelOnNode) XXX_DiscardUnknown added in v0.20.29 

func (m *CancelOnNode) XXX_DiscardUnknown()

func (*CancelOnNode) XXX_Marshal added in v0.20.29 

func (m *CancelOnNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CancelOnNode) XXX_Merge added in v0.20.29 

func (m *CancelOnNode) XXX_Merge(src proto.Message)

func (*CancelOnNode) XXX_Size added in v0.20.29 

func (m *CancelOnNode) XXX_Size() int

func (*CancelOnNode) XXX_Unmarshal added in v0.20.29 

func (m *CancelOnNode) XXX_Unmarshal(b []byte) error

type CancelOnQueue added in v0.15.4 

type CancelOnQueue struct {
	Name            string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	PriorityClasses []string         `protobuf:"bytes,2,rep,name=priorityClasses,proto3" json:"priorityClasses,omitempty"`
	JobStates       []ActiveJobState `protobuf:"varint,3,rep,packed,name=jobStates,proto3,enum=controlplaneevents.ActiveJobState" json:"jobStates,omitempty"`
	// If empty, jobs on all pools will be cancelled
	Pools []string `protobuf:"bytes,4,rep,name=pools,proto3" json:"pools,omitempty"`
}

func (*CancelOnQueue) Descriptor added in v0.15.4 

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

func (*CancelOnQueue) GetJobStates added in v0.15.4 

func (m *CancelOnQueue) GetJobStates() []ActiveJobState

func (*CancelOnQueue) GetName added in v0.15.4 

func (m *CancelOnQueue) GetName() string

func (*CancelOnQueue) GetPools added in v0.20.29 

func (m *CancelOnQueue) GetPools() []string

func (*CancelOnQueue) GetPriorityClasses added in v0.15.4 

func (m *CancelOnQueue) GetPriorityClasses() []string

func (*CancelOnQueue) Marshal added in v0.15.4 

func (m *CancelOnQueue) Marshal() (dAtA []byte, err error)

func (*CancelOnQueue) MarshalTo added in v0.15.4 

func (m *CancelOnQueue) MarshalTo(dAtA []byte) (int, error)

func (*CancelOnQueue) MarshalToSizedBuffer added in v0.15.4 

func (m *CancelOnQueue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CancelOnQueue) ProtoMessage added in v0.15.4 

func (*CancelOnQueue) ProtoMessage()

func (*CancelOnQueue) Reset added in v0.15.4 

func (m *CancelOnQueue) Reset()

func (*CancelOnQueue) Size added in v0.15.4 

func (m *CancelOnQueue) Size() (n int)

func (*CancelOnQueue) String added in v0.15.4 

func (m *CancelOnQueue) String() string

func (*CancelOnQueue) Unmarshal added in v0.15.4 

func (m *CancelOnQueue) Unmarshal(dAtA []byte) error

func (*CancelOnQueue) XXX_DiscardUnknown added in v0.15.4 

func (m *CancelOnQueue) XXX_DiscardUnknown()

func (*CancelOnQueue) XXX_Marshal added in v0.15.4 

func (m *CancelOnQueue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CancelOnQueue) XXX_Merge added in v0.15.4 

func (m *CancelOnQueue) XXX_Merge(src proto.Message)

func (*CancelOnQueue) XXX_Size added in v0.15.4 

func (m *CancelOnQueue) XXX_Size() int

func (*CancelOnQueue) XXX_Unmarshal added in v0.15.4 

func (m *CancelOnQueue) XXX_Unmarshal(b []byte) error

type Event 

type Event struct {
	Created *types.Timestamp `protobuf:"bytes,1,opt,name=created,proto3" json:"created,omitempty"`
	// Types that are valid to be assigned to Event:
	//	*Event_ExecutorSettingsUpsert
	//	*Event_ExecutorSettingsDelete
	//	*Event_PreemptOnExecutor
	//	*Event_CancelOnExecutor
	//	*Event_PreemptOnQueue
	//	*Event_CancelOnQueue
	//	*Event_PreemptOnNode
	//	*Event_CancelOnNode
	Event isEvent_Event `protobuf_oneof:"event"`
}

func (*Event) Descriptor 

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

func (*Event) GetCancelOnExecutor added in v0.15.4 

func (m *Event) GetCancelOnExecutor() *CancelOnExecutor

func (*Event) GetCancelOnNode added in v0.20.29 

func (m *Event) GetCancelOnNode() *CancelOnNode

func (*Event) GetCancelOnQueue added in v0.15.4 

func (m *Event) GetCancelOnQueue() *CancelOnQueue

func (*Event) GetCreated 

func (m *Event) GetCreated() *types.Timestamp

func (*Event) GetEvent 

func (m *Event) GetEvent() isEvent_Event

func (*Event) GetEventName 

func (ev *Event) GetEventName() string

func (*Event) GetExecutorSettingsDelete 

func (m *Event) GetExecutorSettingsDelete() *ExecutorSettingsDelete

func (*Event) GetExecutorSettingsUpsert 

func (m *Event) GetExecutorSettingsUpsert() *ExecutorSettingsUpsert

func (*Event) GetPreemptOnExecutor added in v0.15.4 

func (m *Event) GetPreemptOnExecutor() *PreemptOnExecutor

func (*Event) GetPreemptOnNode added in v0.20.29 

func (m *Event) GetPreemptOnNode() *PreemptOnNode

func (*Event) GetPreemptOnQueue added in v0.15.4 

func (m *Event) GetPreemptOnQueue() *PreemptOnQueue

func (*Event) Marshal 

func (m *Event) Marshal() (dAtA []byte, err error)

func (*Event) MarshalTo 

func (m *Event) MarshalTo(dAtA []byte) (int, error)

func (*Event) MarshalToSizedBuffer 

func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

func (m *Event) Size() (n int)

func (*Event) String 

func (m *Event) String() string

func (*Event) Unmarshal 

func (m *Event) Unmarshal(dAtA []byte) error

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_OneofWrappers 

func (*Event) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

type Event_CancelOnExecutor added in v0.15.4 

type Event_CancelOnExecutor struct {
	CancelOnExecutor *CancelOnExecutor `protobuf:"bytes,5,opt,name=cancelOnExecutor,proto3,oneof" json:"cancelOnExecutor,omitempty"`
}

func (*Event_CancelOnExecutor) MarshalTo added in v0.15.4 

func (m *Event_CancelOnExecutor) MarshalTo(dAtA []byte) (int, error)

func (*Event_CancelOnExecutor) MarshalToSizedBuffer added in v0.15.4 

func (m *Event_CancelOnExecutor) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_CancelOnExecutor) Size added in v0.15.4 

func (m *Event_CancelOnExecutor) Size() (n int)

type Event_CancelOnNode added in v0.20.29 

type Event_CancelOnNode struct {
	CancelOnNode *CancelOnNode `protobuf:"bytes,9,opt,name=cancelOnNode,proto3,oneof" json:"cancelOnNode,omitempty"`
}

func (*Event_CancelOnNode) MarshalTo added in v0.20.29 

func (m *Event_CancelOnNode) MarshalTo(dAtA []byte) (int, error)

func (*Event_CancelOnNode) MarshalToSizedBuffer added in v0.20.29 

func (m *Event_CancelOnNode) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_CancelOnNode) Size added in v0.20.29 

func (m *Event_CancelOnNode) Size() (n int)

type Event_CancelOnQueue added in v0.15.4 

type Event_CancelOnQueue struct {
	CancelOnQueue *CancelOnQueue `protobuf:"bytes,7,opt,name=cancelOnQueue,proto3,oneof" json:"cancelOnQueue,omitempty"`
}

func (*Event_CancelOnQueue) MarshalTo added in v0.15.4 

func (m *Event_CancelOnQueue) MarshalTo(dAtA []byte) (int, error)

func (*Event_CancelOnQueue) MarshalToSizedBuffer added in v0.15.4 

func (m *Event_CancelOnQueue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_CancelOnQueue) Size added in v0.15.4 

func (m *Event_CancelOnQueue) Size() (n int)

type Event_ExecutorSettingsDelete 

type Event_ExecutorSettingsDelete struct {
	ExecutorSettingsDelete *ExecutorSettingsDelete `protobuf:"bytes,3,opt,name=executorSettingsDelete,proto3,oneof" json:"executorSettingsDelete,omitempty"`
}

func (*Event_ExecutorSettingsDelete) MarshalTo 

func (m *Event_ExecutorSettingsDelete) MarshalTo(dAtA []byte) (int, error)

func (*Event_ExecutorSettingsDelete) MarshalToSizedBuffer 

func (m *Event_ExecutorSettingsDelete) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_ExecutorSettingsDelete) Size 

func (m *Event_ExecutorSettingsDelete) Size() (n int)

type Event_ExecutorSettingsUpsert 

type Event_ExecutorSettingsUpsert struct {
	ExecutorSettingsUpsert *ExecutorSettingsUpsert `protobuf:"bytes,2,opt,name=executorSettingsUpsert,proto3,oneof" json:"executorSettingsUpsert,omitempty"`
}

func (*Event_ExecutorSettingsUpsert) MarshalTo 

func (m *Event_ExecutorSettingsUpsert) MarshalTo(dAtA []byte) (int, error)

func (*Event_ExecutorSettingsUpsert) MarshalToSizedBuffer 

func (m *Event_ExecutorSettingsUpsert) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_ExecutorSettingsUpsert) Size 

func (m *Event_ExecutorSettingsUpsert) Size() (n int)

type Event_PreemptOnExecutor added in v0.15.4 

type Event_PreemptOnExecutor struct {
	PreemptOnExecutor *PreemptOnExecutor `protobuf:"bytes,4,opt,name=preemptOnExecutor,proto3,oneof" json:"preemptOnExecutor,omitempty"`
}

func (*Event_PreemptOnExecutor) MarshalTo added in v0.15.4 

func (m *Event_PreemptOnExecutor) MarshalTo(dAtA []byte) (int, error)

func (*Event_PreemptOnExecutor) MarshalToSizedBuffer added in v0.15.4 

func (m *Event_PreemptOnExecutor) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_PreemptOnExecutor) Size added in v0.15.4 

func (m *Event_PreemptOnExecutor) Size() (n int)

type Event_PreemptOnNode added in v0.20.29 

type Event_PreemptOnNode struct {
	PreemptOnNode *PreemptOnNode `protobuf:"bytes,8,opt,name=preemptOnNode,proto3,oneof" json:"preemptOnNode,omitempty"`
}

func (*Event_PreemptOnNode) MarshalTo added in v0.20.29 

func (m *Event_PreemptOnNode) MarshalTo(dAtA []byte) (int, error)

func (*Event_PreemptOnNode) MarshalToSizedBuffer added in v0.20.29 

func (m *Event_PreemptOnNode) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_PreemptOnNode) Size added in v0.20.29 

func (m *Event_PreemptOnNode) Size() (n int)

type Event_PreemptOnQueue added in v0.15.4 

type Event_PreemptOnQueue struct {
	PreemptOnQueue *PreemptOnQueue `protobuf:"bytes,6,opt,name=preemptOnQueue,proto3,oneof" json:"preemptOnQueue,omitempty"`
}

func (*Event_PreemptOnQueue) MarshalTo added in v0.15.4 

func (m *Event_PreemptOnQueue) MarshalTo(dAtA []byte) (int, error)

func (*Event_PreemptOnQueue) MarshalToSizedBuffer added in v0.15.4 

func (m *Event_PreemptOnQueue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_PreemptOnQueue) Size added in v0.15.4 

func (m *Event_PreemptOnQueue) Size() (n int)

type ExecutorSettingsDelete 

type ExecutorSettingsDelete struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*ExecutorSettingsDelete) Descriptor 

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

func (*ExecutorSettingsDelete) GetName 

func (m *ExecutorSettingsDelete) GetName() string

func (*ExecutorSettingsDelete) Marshal 

func (m *ExecutorSettingsDelete) Marshal() (dAtA []byte, err error)

func (*ExecutorSettingsDelete) MarshalTo 

func (m *ExecutorSettingsDelete) MarshalTo(dAtA []byte) (int, error)

func (*ExecutorSettingsDelete) MarshalToSizedBuffer 

func (m *ExecutorSettingsDelete) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExecutorSettingsDelete) ProtoMessage 

func (*ExecutorSettingsDelete) ProtoMessage()

func (*ExecutorSettingsDelete) Reset 

func (m *ExecutorSettingsDelete) Reset()

func (*ExecutorSettingsDelete) Size 

func (m *ExecutorSettingsDelete) Size() (n int)

func (*ExecutorSettingsDelete) String 

func (m *ExecutorSettingsDelete) String() string

func (*ExecutorSettingsDelete) Unmarshal 

func (m *ExecutorSettingsDelete) Unmarshal(dAtA []byte) error

func (*ExecutorSettingsDelete) XXX_DiscardUnknown 

func (m *ExecutorSettingsDelete) XXX_DiscardUnknown()

func (*ExecutorSettingsDelete) XXX_Marshal 

func (m *ExecutorSettingsDelete) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecutorSettingsDelete) XXX_Merge 

func (m *ExecutorSettingsDelete) XXX_Merge(src proto.Message)

func (*ExecutorSettingsDelete) XXX_Size 

func (m *ExecutorSettingsDelete) XXX_Size() int

func (*ExecutorSettingsDelete) XXX_Unmarshal 

func (m *ExecutorSettingsDelete) XXX_Unmarshal(b []byte) error

type ExecutorSettingsUpsert 

type ExecutorSettingsUpsert struct {
	Name         string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Cordoned     bool   `protobuf:"varint,2,opt,name=cordoned,proto3" json:"cordoned,omitempty"`
	CordonReason string `protobuf:"bytes,3,opt,name=cordonReason,proto3" json:"cordonReason,omitempty"`
	SetByUser    string `protobuf:"bytes,4,opt,name=setByUser,proto3" json:"setByUser,omitempty"`
}

func (*ExecutorSettingsUpsert) Descriptor 

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

func (*ExecutorSettingsUpsert) GetCordonReason 

func (m *ExecutorSettingsUpsert) GetCordonReason() string

func (*ExecutorSettingsUpsert) GetCordoned 

func (m *ExecutorSettingsUpsert) GetCordoned() bool

func (*ExecutorSettingsUpsert) GetName 

func (m *ExecutorSettingsUpsert) GetName() string

func (*ExecutorSettingsUpsert) GetSetByUser added in v0.15.3 

func (m *ExecutorSettingsUpsert) GetSetByUser() string

func (*ExecutorSettingsUpsert) Marshal 

func (m *ExecutorSettingsUpsert) Marshal() (dAtA []byte, err error)

func (*ExecutorSettingsUpsert) MarshalTo 

func (m *ExecutorSettingsUpsert) MarshalTo(dAtA []byte) (int, error)

func (*ExecutorSettingsUpsert) MarshalToSizedBuffer 

func (m *ExecutorSettingsUpsert) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExecutorSettingsUpsert) ProtoMessage 

func (*ExecutorSettingsUpsert) ProtoMessage()

func (*ExecutorSettingsUpsert) Reset 

func (m *ExecutorSettingsUpsert) Reset()

func (*ExecutorSettingsUpsert) Size 

func (m *ExecutorSettingsUpsert) Size() (n int)

func (*ExecutorSettingsUpsert) String 

func (m *ExecutorSettingsUpsert) String() string

func (*ExecutorSettingsUpsert) Unmarshal 

func (m *ExecutorSettingsUpsert) Unmarshal(dAtA []byte) error

func (*ExecutorSettingsUpsert) XXX_DiscardUnknown 

func (m *ExecutorSettingsUpsert) XXX_DiscardUnknown()

func (*ExecutorSettingsUpsert) XXX_Marshal 

func (m *ExecutorSettingsUpsert) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecutorSettingsUpsert) XXX_Merge 

func (m *ExecutorSettingsUpsert) XXX_Merge(src proto.Message)

func (*ExecutorSettingsUpsert) XXX_Size 

func (m *ExecutorSettingsUpsert) XXX_Size() int

func (*ExecutorSettingsUpsert) XXX_Unmarshal 

func (m *ExecutorSettingsUpsert) XXX_Unmarshal(b []byte) error

type PreemptOnExecutor added in v0.15.4 

type PreemptOnExecutor struct {
	Name            string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Queues          []string `protobuf:"bytes,2,rep,name=queues,proto3" json:"queues,omitempty"`
	PriorityClasses []string `protobuf:"bytes,3,rep,name=priorityClasses,proto3" json:"priorityClasses,omitempty"`
	// If empty, jobs on all pools will be preempted
	Pools []string `protobuf:"bytes,4,rep,name=pools,proto3" json:"pools,omitempty"`
}

func (*PreemptOnExecutor) Descriptor added in v0.15.4 

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

func (*PreemptOnExecutor) GetName added in v0.15.4 

func (m *PreemptOnExecutor) GetName() string

func (*PreemptOnExecutor) GetPools added in v0.20.29 

func (m *PreemptOnExecutor) GetPools() []string

func (*PreemptOnExecutor) GetPriorityClasses added in v0.15.4 

func (m *PreemptOnExecutor) GetPriorityClasses() []string

func (*PreemptOnExecutor) GetQueues added in v0.15.4 

func (m *PreemptOnExecutor) GetQueues() []string

func (*PreemptOnExecutor) Marshal added in v0.15.4 

func (m *PreemptOnExecutor) Marshal() (dAtA []byte, err error)

func (*PreemptOnExecutor) MarshalTo added in v0.15.4 

func (m *PreemptOnExecutor) MarshalTo(dAtA []byte) (int, error)

func (*PreemptOnExecutor) MarshalToSizedBuffer added in v0.15.4 

func (m *PreemptOnExecutor) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PreemptOnExecutor) ProtoMessage added in v0.15.4 

func (*PreemptOnExecutor) ProtoMessage()

func (*PreemptOnExecutor) Reset added in v0.15.4 

func (m *PreemptOnExecutor) Reset()

func (*PreemptOnExecutor) Size added in v0.15.4 

func (m *PreemptOnExecutor) Size() (n int)

func (*PreemptOnExecutor) String added in v0.15.4 

func (m *PreemptOnExecutor) String() string

func (*PreemptOnExecutor) Unmarshal added in v0.15.4 

func (m *PreemptOnExecutor) Unmarshal(dAtA []byte) error

func (*PreemptOnExecutor) XXX_DiscardUnknown added in v0.15.4 

func (m *PreemptOnExecutor) XXX_DiscardUnknown()

func (*PreemptOnExecutor) XXX_Marshal added in v0.15.4 

func (m *PreemptOnExecutor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PreemptOnExecutor) XXX_Merge added in v0.15.4 

func (m *PreemptOnExecutor) XXX_Merge(src proto.Message)

func (*PreemptOnExecutor) XXX_Size added in v0.15.4 

func (m *PreemptOnExecutor) XXX_Size() int

func (*PreemptOnExecutor) XXX_Unmarshal added in v0.15.4 

func (m *PreemptOnExecutor) XXX_Unmarshal(b []byte) error

type PreemptOnNode added in v0.20.29 

type PreemptOnNode struct {
	Name            string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Executor        string   `protobuf:"bytes,2,opt,name=executor,proto3" json:"executor,omitempty"`
	Queues          []string `protobuf:"bytes,3,rep,name=queues,proto3" json:"queues,omitempty"`
	PriorityClasses []string `protobuf:"bytes,4,rep,name=priorityClasses,proto3" json:"priorityClasses,omitempty"`
}

func (*PreemptOnNode) Descriptor added in v0.20.29 

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

func (*PreemptOnNode) GetExecutor added in v0.20.29 

func (m *PreemptOnNode) GetExecutor() string

func (*PreemptOnNode) GetName added in v0.20.29 

func (m *PreemptOnNode) GetName() string

func (*PreemptOnNode) GetPriorityClasses added in v0.20.29 

func (m *PreemptOnNode) GetPriorityClasses() []string

func (*PreemptOnNode) GetQueues added in v0.20.29 

func (m *PreemptOnNode) GetQueues() []string

func (*PreemptOnNode) Marshal added in v0.20.29 

func (m *PreemptOnNode) Marshal() (dAtA []byte, err error)

func (*PreemptOnNode) MarshalTo added in v0.20.29 

func (m *PreemptOnNode) MarshalTo(dAtA []byte) (int, error)

func (*PreemptOnNode) MarshalToSizedBuffer added in v0.20.29 

func (m *PreemptOnNode) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PreemptOnNode) ProtoMessage added in v0.20.29 

func (*PreemptOnNode) ProtoMessage()

func (*PreemptOnNode) Reset added in v0.20.29 

func (m *PreemptOnNode) Reset()

func (*PreemptOnNode) Size added in v0.20.29 

func (m *PreemptOnNode) Size() (n int)

func (*PreemptOnNode) String added in v0.20.29 

func (m *PreemptOnNode) String() string

func (*PreemptOnNode) Unmarshal added in v0.20.29 

func (m *PreemptOnNode) Unmarshal(dAtA []byte) error

func (*PreemptOnNode) XXX_DiscardUnknown added in v0.20.29 

func (m *PreemptOnNode) XXX_DiscardUnknown()

func (*PreemptOnNode) XXX_Marshal added in v0.20.29 

func (m *PreemptOnNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PreemptOnNode) XXX_Merge added in v0.20.29 

func (m *PreemptOnNode) XXX_Merge(src proto.Message)

func (*PreemptOnNode) XXX_Size added in v0.20.29 

func (m *PreemptOnNode) XXX_Size() int

func (*PreemptOnNode) XXX_Unmarshal added in v0.20.29 

func (m *PreemptOnNode) XXX_Unmarshal(b []byte) error

type PreemptOnQueue added in v0.15.4 

type PreemptOnQueue struct {
	Name            string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	PriorityClasses []string `protobuf:"bytes,2,rep,name=priorityClasses,proto3" json:"priorityClasses,omitempty"`
	// If empty, jobs on all pools will be preempted
	Pools []string `protobuf:"bytes,3,rep,name=pools,proto3" json:"pools,omitempty"`
}

func (*PreemptOnQueue) Descriptor added in v0.15.4 

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

func (*PreemptOnQueue) GetName added in v0.15.4 

func (m *PreemptOnQueue) GetName() string

func (*PreemptOnQueue) GetPools added in v0.20.29 

func (m *PreemptOnQueue) GetPools() []string

func (*PreemptOnQueue) GetPriorityClasses added in v0.15.4 

func (m *PreemptOnQueue) GetPriorityClasses() []string

func (*PreemptOnQueue) Marshal added in v0.15.4 

func (m *PreemptOnQueue) Marshal() (dAtA []byte, err error)

func (*PreemptOnQueue) MarshalTo added in v0.15.4 

func (m *PreemptOnQueue) MarshalTo(dAtA []byte) (int, error)

func (*PreemptOnQueue) MarshalToSizedBuffer added in v0.15.4 

func (m *PreemptOnQueue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PreemptOnQueue) ProtoMessage added in v0.15.4 

func (*PreemptOnQueue) ProtoMessage()

func (*PreemptOnQueue) Reset added in v0.15.4 

func (m *PreemptOnQueue) Reset()

func (*PreemptOnQueue) Size added in v0.15.4 

func (m *PreemptOnQueue) Size() (n int)

func (*PreemptOnQueue) String added in v0.15.4 

func (m *PreemptOnQueue) String() string

func (*PreemptOnQueue) Unmarshal added in v0.15.4 

func (m *PreemptOnQueue) Unmarshal(dAtA []byte) error

func (*PreemptOnQueue) XXX_DiscardUnknown added in v0.15.4 

func (m *PreemptOnQueue) XXX_DiscardUnknown()

func (*PreemptOnQueue) XXX_Marshal added in v0.15.4 

func (m *PreemptOnQueue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PreemptOnQueue) XXX_Merge added in v0.15.4 

func (m *PreemptOnQueue) XXX_Merge(src proto.Message)

func (*PreemptOnQueue) XXX_Size added in v0.15.4 

func (m *PreemptOnQueue) XXX_Size() int

func (*PreemptOnQueue) XXX_Unmarshal added in v0.15.4 

func (m *PreemptOnQueue) XXX_Unmarshal(b []byte) error

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.