Documentation ¶
Index ¶
- Variables
- type ActiveJobState
- type CancelOnExecutor
- func (*CancelOnExecutor) Descriptor() ([]byte, []int)
- func (m *CancelOnExecutor) GetName() string
- func (m *CancelOnExecutor) GetPriorityClasses() []string
- func (m *CancelOnExecutor) GetQueues() []string
- func (m *CancelOnExecutor) Marshal() (dAtA []byte, err error)
- func (m *CancelOnExecutor) MarshalTo(dAtA []byte) (int, error)
- func (m *CancelOnExecutor) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CancelOnExecutor) ProtoMessage()
- func (m *CancelOnExecutor) Reset()
- func (m *CancelOnExecutor) Size() (n int)
- func (m *CancelOnExecutor) String() string
- func (m *CancelOnExecutor) Unmarshal(dAtA []byte) error
- func (m *CancelOnExecutor) XXX_DiscardUnknown()
- func (m *CancelOnExecutor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CancelOnExecutor) XXX_Merge(src proto.Message)
- func (m *CancelOnExecutor) XXX_Size() int
- func (m *CancelOnExecutor) XXX_Unmarshal(b []byte) error
- type CancelOnQueue
- func (*CancelOnQueue) Descriptor() ([]byte, []int)
- func (m *CancelOnQueue) GetJobStates() []ActiveJobState
- func (m *CancelOnQueue) GetName() string
- func (m *CancelOnQueue) GetPriorityClasses() []string
- func (m *CancelOnQueue) Marshal() (dAtA []byte, err error)
- func (m *CancelOnQueue) MarshalTo(dAtA []byte) (int, error)
- func (m *CancelOnQueue) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CancelOnQueue) ProtoMessage()
- func (m *CancelOnQueue) Reset()
- func (m *CancelOnQueue) Size() (n int)
- func (m *CancelOnQueue) String() string
- func (m *CancelOnQueue) Unmarshal(dAtA []byte) error
- func (m *CancelOnQueue) XXX_DiscardUnknown()
- func (m *CancelOnQueue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CancelOnQueue) XXX_Merge(src proto.Message)
- func (m *CancelOnQueue) XXX_Size() int
- func (m *CancelOnQueue) XXX_Unmarshal(b []byte) error
- type Event
- func (*Event) Descriptor() ([]byte, []int)
- func (m *Event) GetCancelOnExecutor() *CancelOnExecutor
- func (m *Event) GetCancelOnQueue() *CancelOnQueue
- func (m *Event) GetCreated() *types.Timestamp
- func (m *Event) GetEvent() isEvent_Event
- func (ev *Event) GetEventName() string
- func (m *Event) GetExecutorSettingsDelete() *ExecutorSettingsDelete
- func (m *Event) GetExecutorSettingsUpsert() *ExecutorSettingsUpsert
- func (m *Event) GetPreemptOnExecutor() *PreemptOnExecutor
- func (m *Event) GetPreemptOnQueue() *PreemptOnQueue
- func (m *Event) Marshal() (dAtA []byte, err error)
- func (m *Event) MarshalTo(dAtA []byte) (int, error)
- func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Event) ProtoMessage()
- func (m *Event) Reset()
- func (m *Event) Size() (n int)
- func (m *Event) String() string
- func (m *Event) Unmarshal(dAtA []byte) error
- func (m *Event) XXX_DiscardUnknown()
- func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event) XXX_Merge(src proto.Message)
- func (*Event) XXX_OneofWrappers() []interface{}
- func (m *Event) XXX_Size() int
- func (m *Event) XXX_Unmarshal(b []byte) error
- type Event_CancelOnExecutor
- type Event_CancelOnQueue
- type Event_ExecutorSettingsDelete
- type Event_ExecutorSettingsUpsert
- type Event_PreemptOnExecutor
- type Event_PreemptOnQueue
- type ExecutorSettingsDelete
- func (*ExecutorSettingsDelete) Descriptor() ([]byte, []int)
- func (m *ExecutorSettingsDelete) GetName() string
- func (m *ExecutorSettingsDelete) Marshal() (dAtA []byte, err error)
- func (m *ExecutorSettingsDelete) MarshalTo(dAtA []byte) (int, error)
- func (m *ExecutorSettingsDelete) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExecutorSettingsDelete) ProtoMessage()
- func (m *ExecutorSettingsDelete) Reset()
- func (m *ExecutorSettingsDelete) Size() (n int)
- func (m *ExecutorSettingsDelete) String() string
- func (m *ExecutorSettingsDelete) Unmarshal(dAtA []byte) error
- func (m *ExecutorSettingsDelete) XXX_DiscardUnknown()
- func (m *ExecutorSettingsDelete) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecutorSettingsDelete) XXX_Merge(src proto.Message)
- func (m *ExecutorSettingsDelete) XXX_Size() int
- func (m *ExecutorSettingsDelete) XXX_Unmarshal(b []byte) error
- type ExecutorSettingsUpsert
- func (*ExecutorSettingsUpsert) Descriptor() ([]byte, []int)
- func (m *ExecutorSettingsUpsert) GetCordonReason() string
- func (m *ExecutorSettingsUpsert) GetCordoned() bool
- func (m *ExecutorSettingsUpsert) GetName() string
- func (m *ExecutorSettingsUpsert) GetSetByUser() string
- func (m *ExecutorSettingsUpsert) Marshal() (dAtA []byte, err error)
- func (m *ExecutorSettingsUpsert) MarshalTo(dAtA []byte) (int, error)
- func (m *ExecutorSettingsUpsert) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExecutorSettingsUpsert) ProtoMessage()
- func (m *ExecutorSettingsUpsert) Reset()
- func (m *ExecutorSettingsUpsert) Size() (n int)
- func (m *ExecutorSettingsUpsert) String() string
- func (m *ExecutorSettingsUpsert) Unmarshal(dAtA []byte) error
- func (m *ExecutorSettingsUpsert) XXX_DiscardUnknown()
- func (m *ExecutorSettingsUpsert) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecutorSettingsUpsert) XXX_Merge(src proto.Message)
- func (m *ExecutorSettingsUpsert) XXX_Size() int
- func (m *ExecutorSettingsUpsert) XXX_Unmarshal(b []byte) error
- type PreemptOnExecutor
- func (*PreemptOnExecutor) Descriptor() ([]byte, []int)
- func (m *PreemptOnExecutor) GetName() string
- func (m *PreemptOnExecutor) GetPriorityClasses() []string
- func (m *PreemptOnExecutor) GetQueues() []string
- func (m *PreemptOnExecutor) Marshal() (dAtA []byte, err error)
- func (m *PreemptOnExecutor) MarshalTo(dAtA []byte) (int, error)
- func (m *PreemptOnExecutor) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PreemptOnExecutor) ProtoMessage()
- func (m *PreemptOnExecutor) Reset()
- func (m *PreemptOnExecutor) Size() (n int)
- func (m *PreemptOnExecutor) String() string
- func (m *PreemptOnExecutor) Unmarshal(dAtA []byte) error
- func (m *PreemptOnExecutor) XXX_DiscardUnknown()
- func (m *PreemptOnExecutor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PreemptOnExecutor) XXX_Merge(src proto.Message)
- func (m *PreemptOnExecutor) XXX_Size() int
- func (m *PreemptOnExecutor) XXX_Unmarshal(b []byte) error
- type PreemptOnQueue
- func (*PreemptOnQueue) Descriptor() ([]byte, []int)
- func (m *PreemptOnQueue) GetName() string
- func (m *PreemptOnQueue) GetPriorityClasses() []string
- func (m *PreemptOnQueue) Marshal() (dAtA []byte, err error)
- func (m *PreemptOnQueue) MarshalTo(dAtA []byte) (int, error)
- func (m *PreemptOnQueue) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PreemptOnQueue) ProtoMessage()
- func (m *PreemptOnQueue) Reset()
- func (m *PreemptOnQueue) Size() (n int)
- func (m *PreemptOnQueue) String() string
- func (m *PreemptOnQueue) Unmarshal(dAtA []byte) error
- func (m *PreemptOnQueue) XXX_DiscardUnknown()
- func (m *PreemptOnQueue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PreemptOnQueue) XXX_Merge(src proto.Message)
- func (m *PreemptOnQueue) XXX_Size() int
- func (m *PreemptOnQueue) XXX_Unmarshal(b []byte) error
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"` }
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) 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 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"` }
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) 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 isEvent_Event `protobuf_oneof:"event"` }
func (*Event) Descriptor ¶
func (*Event) GetCancelOnExecutor ¶ added in v0.15.4
func (m *Event) GetCancelOnExecutor() *CancelOnExecutor
func (*Event) GetCancelOnQueue ¶ added in v0.15.4
func (m *Event) GetCancelOnQueue() *CancelOnQueue
func (*Event) GetCreated ¶
func (*Event) GetEventName ¶
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) GetPreemptOnQueue ¶ added in v0.15.4
func (m *Event) GetPreemptOnQueue() *PreemptOnQueue
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) XXX_DiscardUnknown ¶
func (m *Event) XXX_DiscardUnknown()
func (*Event) XXX_Marshal ¶
func (*Event) XXX_OneofWrappers ¶
func (*Event) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*Event) XXX_Unmarshal ¶
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_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_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"` }
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) 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 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"` }
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) 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
Click to show internal directories.
Click to hide internal directories.