si

package

Go to main page

Versions in this module

v1

v1.6.0

Aug 27, 2024

v1.6.0-2

Aug 27, 2024

v1.6.0-1

Aug 27, 2024

v1.5.2

May 3, 2024

v1.5.2-1

May 3, 2024

v1.5.1

May 3, 2024

v1.5.1-1

May 3, 2024

v1.5.0

Feb 22, 2024

Changes in this version

type Allocation

+ AllocationID string

+ Originator bool

+ PreemptionPolicy *PreemptionPolicy

+ func (x *Allocation) GetAllocationID() string

+ func (x *Allocation) GetOriginator() bool

+ func (x *Allocation) GetPreemptionPolicy() *PreemptionPolicy

type AllocationRelease

+ AllocationID string

+ func (x *AllocationRelease) GetAllocationID() string

type EventRecord_ChangeDetail

+ const EventRecord_APP_CANNOTRUN_QUEUE

+ const EventRecord_APP_CANNOTRUN_QUOTA

+ const EventRecord_APP_RUNNABLE_QUEUE

+ const EventRecord_APP_RUNNABLE_QUOTA

+ const EventRecord_UG_APP_LINK

+ const EventRecord_UG_GROUP_LIMIT

+ const EventRecord_UG_GROUP_RESOURCE

+ const EventRecord_UG_USER_LIMIT

+ const EventRecord_UG_USER_RESOURCE

type EventRecord_Type

+ const EventRecord_USERGROUP

v1.5.0-1

Feb 22, 2024

v1.4.0

Nov 13, 2023

Changes in this version

+ const Scheduler_RegisterResourceManager_FullMethodName

+ const Scheduler_UpdateAllocation_FullMethodName

+ const Scheduler_UpdateApplication_FullMethodName

+ const Scheduler_UpdateNode_FullMethodName

+ var EventRecord_ChangeDetail_name = map[int32]string

+ var EventRecord_ChangeDetail_value = map[string]int32

+ var EventRecord_ChangeType_name = map[int32]string

+ var EventRecord_ChangeType_value = map[string]int32

+ var File_yunikorn_scheduler_interface_si_proto protoreflect.FileDescriptor

+ var Scheduler_ServiceDesc = grpc.ServiceDesc

type AcceptedApplication

+ func (x *AcceptedApplication) ProtoReflect() protoreflect.Message

type AcceptedNode

+ func (x *AcceptedNode) ProtoReflect() protoreflect.Message

type AddApplicationRequest

+ func (x *AddApplicationRequest) ProtoReflect() protoreflect.Message

type Allocation

+ func (x *Allocation) ProtoReflect() protoreflect.Message

type AllocationAsk

+ func (x *AllocationAsk) ProtoReflect() protoreflect.Message

type AllocationAskRelease

+ func (x *AllocationAskRelease) ProtoReflect() protoreflect.Message

type AllocationRelease

+ func (x *AllocationRelease) ProtoReflect() protoreflect.Message

type AllocationReleasesRequest

+ func (x *AllocationReleasesRequest) ProtoReflect() protoreflect.Message

type AllocationRequest

+ Allocations []*Allocation

+ func (x *AllocationRequest) GetAllocations() []*Allocation

+ func (x *AllocationRequest) ProtoReflect() protoreflect.Message

type AllocationResponse

+ RejectedAllocations []*RejectedAllocation

+ func (x *AllocationResponse) GetRejectedAllocations() []*RejectedAllocation

+ func (x *AllocationResponse) ProtoReflect() protoreflect.Message

type ApplicationRequest

+ func (x *ApplicationRequest) ProtoReflect() protoreflect.Message

type ApplicationResponse

+ func (x *ApplicationResponse) ProtoReflect() protoreflect.Message

type EventRecord

+ EventChangeDetail EventRecord_ChangeDetail

+ EventChangeType EventRecord_ChangeType

+ ReferenceID string

+ Resource *Resource

+ func (x *EventRecord) GetEventChangeDetail() EventRecord_ChangeDetail

+ func (x *EventRecord) GetEventChangeType() EventRecord_ChangeType

+ func (x *EventRecord) GetReferenceID() string

+ func (x *EventRecord) GetResource() *Resource

+ func (x *EventRecord) ProtoReflect() protoreflect.Message

+ type EventRecord_ChangeDetail int32

+ const EventRecord_ALLOC_CANCEL

+ const EventRecord_ALLOC_NODEREMOVED

+ const EventRecord_ALLOC_PREEMPT

+ const EventRecord_ALLOC_REPLACED

+ const EventRecord_ALLOC_TIMEOUT

+ const EventRecord_APP_ACCEPTED

+ const EventRecord_APP_ALLOC

+ const EventRecord_APP_COMPLETED

+ const EventRecord_APP_COMPLETING

+ const EventRecord_APP_EXPIRED

+ const EventRecord_APP_FAILED

+ const EventRecord_APP_FAILING

+ const EventRecord_APP_NEW

+ const EventRecord_APP_REJECT

+ const EventRecord_APP_REQUEST

+ const EventRecord_APP_RESUMING

+ const EventRecord_APP_RUNNING

+ const EventRecord_APP_STARTING

+ const EventRecord_DETAILS_NONE

+ const EventRecord_NODE_ALLOC

+ const EventRecord_NODE_CAPACITY

+ const EventRecord_NODE_DECOMISSION

+ const EventRecord_NODE_OCCUPIED

+ const EventRecord_NODE_READY

+ const EventRecord_NODE_RESERVATION

+ const EventRecord_NODE_SCHEDULABLE

+ const EventRecord_QUEUE_ALLOC

+ const EventRecord_QUEUE_APP

+ const EventRecord_QUEUE_CONFIG

+ const EventRecord_QUEUE_DYNAMIC

+ const EventRecord_QUEUE_GUARANTEED

+ const EventRecord_QUEUE_MAX

+ const EventRecord_QUEUE_TYPE

+ const EventRecord_REQUEST_ALLOC

+ const EventRecord_REQUEST_CANCEL

+ const EventRecord_REQUEST_TIMEOUT

+ func (EventRecord_ChangeDetail) Descriptor() protoreflect.EnumDescriptor

+ func (EventRecord_ChangeDetail) EnumDescriptor() ([]byte, []int)

+ func (EventRecord_ChangeDetail) Type() protoreflect.EnumType

+ func (x EventRecord_ChangeDetail) Enum() *EventRecord_ChangeDetail

+ func (x EventRecord_ChangeDetail) Number() protoreflect.EnumNumber

+ func (x EventRecord_ChangeDetail) String() string

+ type EventRecord_ChangeType int32

+ const EventRecord_ADD

+ const EventRecord_NONE

+ const EventRecord_REMOVE

+ const EventRecord_SET

+ func (EventRecord_ChangeType) Descriptor() protoreflect.EnumDescriptor

+ func (EventRecord_ChangeType) EnumDescriptor() ([]byte, []int)

+ func (EventRecord_ChangeType) Type() protoreflect.EnumType

+ func (x EventRecord_ChangeType) Enum() *EventRecord_ChangeType

+ func (x EventRecord_ChangeType) Number() protoreflect.EnumNumber

+ func (x EventRecord_ChangeType) String() string

type EventRecord_Type

+ func (EventRecord_Type) Descriptor() protoreflect.EnumDescriptor

+ func (EventRecord_Type) Type() protoreflect.EnumType

+ func (x EventRecord_Type) Enum() *EventRecord_Type

+ func (x EventRecord_Type) Number() protoreflect.EnumNumber

type NodeInfo

+ func (x *NodeInfo) ProtoReflect() protoreflect.Message

type NodeInfo_ActionFromRM

+ const NodeInfo_CREATE_DRAIN

+ func (NodeInfo_ActionFromRM) Descriptor() protoreflect.EnumDescriptor

+ func (NodeInfo_ActionFromRM) Type() protoreflect.EnumType

+ func (x NodeInfo_ActionFromRM) Enum() *NodeInfo_ActionFromRM

+ func (x NodeInfo_ActionFromRM) Number() protoreflect.EnumNumber

type NodeRequest

+ func (x *NodeRequest) ProtoReflect() protoreflect.Message

type NodeResponse

+ func (x *NodeResponse) ProtoReflect() protoreflect.Message

type PredicatesArgs

+ func (x *PredicatesArgs) ProtoReflect() protoreflect.Message

type PreemptionPolicy

+ func (x *PreemptionPolicy) ProtoReflect() protoreflect.Message

type PreemptionPredicatesArgs

+ func (x *PreemptionPredicatesArgs) ProtoReflect() protoreflect.Message

type PreemptionPredicatesResponse

+ func (x *PreemptionPredicatesResponse) ProtoReflect() protoreflect.Message

type Quantity

+ func (x *Quantity) ProtoReflect() protoreflect.Message

type RegisterResourceManagerRequest

+ func (x *RegisterResourceManagerRequest) ProtoReflect() protoreflect.Message

type RegisterResourceManagerResponse

+ func (x *RegisterResourceManagerResponse) ProtoReflect() protoreflect.Message

+ type RejectedAllocation struct

+ AllocationKey string

+ ApplicationID string

+ Reason string

+ func (*RejectedAllocation) Descriptor() ([]byte, []int)

+ func (*RejectedAllocation) ProtoMessage()

+ func (x *RejectedAllocation) GetAllocationKey() string

+ func (x *RejectedAllocation) GetApplicationID() string

+ func (x *RejectedAllocation) GetReason() string

+ func (x *RejectedAllocation) ProtoReflect() protoreflect.Message

+ func (x *RejectedAllocation) Reset()

+ func (x *RejectedAllocation) String() string

type RejectedAllocationAsk

+ func (x *RejectedAllocationAsk) ProtoReflect() protoreflect.Message

type RejectedApplication

+ func (x *RejectedApplication) ProtoReflect() protoreflect.Message

type RejectedNode

+ func (x *RejectedNode) ProtoReflect() protoreflect.Message

type RemoveApplicationRequest

+ func (x *RemoveApplicationRequest) ProtoReflect() protoreflect.Message

type Resource

+ func (x *Resource) ProtoReflect() protoreflect.Message

type TerminationType

+ func (TerminationType) Descriptor() protoreflect.EnumDescriptor

+ func (TerminationType) Type() protoreflect.EnumType

+ func (x TerminationType) Enum() *TerminationType

+ func (x TerminationType) Number() protoreflect.EnumNumber

+ type UnimplementedSchedulerServer struct

+ func (UnimplementedSchedulerServer) RegisterResourceManager(context.Context, *RegisterResourceManagerRequest) (*RegisterResourceManagerResponse, error)

+ func (UnimplementedSchedulerServer) UpdateAllocation(Scheduler_UpdateAllocationServer) error

+ func (UnimplementedSchedulerServer) UpdateApplication(Scheduler_UpdateApplicationServer) error

+ func (UnimplementedSchedulerServer) UpdateNode(Scheduler_UpdateNodeServer) error

+ type UnsafeSchedulerServer interface

type UpdateConfigurationRequest

+ func (x *UpdateConfigurationRequest) ProtoReflect() protoreflect.Message

type UpdateContainerSchedulingStateRequest

+ ApplicationID string

+ func (x *UpdateContainerSchedulingStateRequest) GetApplicationID() string

+ func (x *UpdateContainerSchedulingStateRequest) ProtoReflect() protoreflect.Message

type UpdateContainerSchedulingStateRequest_SchedulingState

+ func (UpdateContainerSchedulingStateRequest_SchedulingState) Descriptor() protoreflect.EnumDescriptor

+ func (UpdateContainerSchedulingStateRequest_SchedulingState) Type() protoreflect.EnumType

+ func (x UpdateContainerSchedulingStateRequest_SchedulingState) Enum() *UpdateContainerSchedulingStateRequest_SchedulingState

+ func (x UpdateContainerSchedulingStateRequest_SchedulingState) Number() protoreflect.EnumNumber

type UpdatedApplication

+ func (x *UpdatedApplication) ProtoReflect() protoreflect.Message

type UserGroupInformation

+ func (x *UserGroupInformation) ProtoReflect() protoreflect.Message

v1.4.0-1

Nov 13, 2023

v1.3.0

May 17, 2023

Changes in this version

+ type PreemptionPredicatesArgs struct

+ AllocationKey string

+ NodeID string

+ PreemptAllocationKeys []string

+ StartIndex int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PreemptionPredicatesArgs) Descriptor() ([]byte, []int)

+ func (*PreemptionPredicatesArgs) ProtoMessage()

+ func (dst *PreemptionPredicatesArgs) XXX_Merge(src proto.Message)

+ func (m *PreemptionPredicatesArgs) GetAllocationKey() string

+ func (m *PreemptionPredicatesArgs) GetNodeID() string

+ func (m *PreemptionPredicatesArgs) GetPreemptAllocationKeys() []string

+ func (m *PreemptionPredicatesArgs) GetStartIndex() int32

+ func (m *PreemptionPredicatesArgs) Reset()

+ func (m *PreemptionPredicatesArgs) String() string

+ func (m *PreemptionPredicatesArgs) XXX_DiscardUnknown()

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

+ func (m *PreemptionPredicatesArgs) XXX_Size() int

+ func (m *PreemptionPredicatesArgs) XXX_Unmarshal(b []byte) error

+ type PreemptionPredicatesResponse struct

+ Index int32

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PreemptionPredicatesResponse) Descriptor() ([]byte, []int)

+ func (*PreemptionPredicatesResponse) ProtoMessage()

+ func (dst *PreemptionPredicatesResponse) XXX_Merge(src proto.Message)

+ func (m *PreemptionPredicatesResponse) GetIndex() int32

+ func (m *PreemptionPredicatesResponse) GetSuccess() bool

+ func (m *PreemptionPredicatesResponse) Reset()

+ func (m *PreemptionPredicatesResponse) String() string

+ func (m *PreemptionPredicatesResponse) XXX_DiscardUnknown()

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

+ func (m *PreemptionPredicatesResponse) XXX_Size() int

+ func (m *PreemptionPredicatesResponse) XXX_Unmarshal(b []byte) error

v1.3.0-1

May 17, 2023

v1.2.0

Jan 15, 2023

Changes in this version

type AllocationAsk

+ PreemptionPolicy *PreemptionPolicy

+ func (m *AllocationAsk) GetPreemptionPolicy() *PreemptionPolicy

+ type PreemptionPolicy struct

+ AllowPreemptOther bool

+ AllowPreemptSelf bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PreemptionPolicy) Descriptor() ([]byte, []int)

+ func (*PreemptionPolicy) ProtoMessage()

+ func (dst *PreemptionPolicy) XXX_Merge(src proto.Message)

+ func (m *PreemptionPolicy) GetAllowPreemptOther() bool

+ func (m *PreemptionPolicy) GetAllowPreemptSelf() bool

+ func (m *PreemptionPolicy) Reset()

+ func (m *PreemptionPolicy) String() string

+ func (m *PreemptionPolicy) XXX_DiscardUnknown()

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

+ func (m *PreemptionPolicy) XXX_Size() int

+ func (m *PreemptionPolicy) XXX_Unmarshal(b []byte) error

type RegisterResourceManagerRequest

+ Config string

+ ExtraConfig map[string]string

+ func (m *RegisterResourceManagerRequest) GetConfig() string

+ func (m *RegisterResourceManagerRequest) GetExtraConfig() map[string]string

type UpdateConfigurationRequest

+ Config string

+ ExtraConfig map[string]string

+ PolicyGroup string

+ RmID string

+ func (m *UpdateConfigurationRequest) GetConfig() string

+ func (m *UpdateConfigurationRequest) GetExtraConfig() map[string]string

+ func (m *UpdateConfigurationRequest) GetPolicyGroup() string

+ func (m *UpdateConfigurationRequest) GetRmID() string

v1.2.0-1

Jan 15, 2023

v1.1.0

Aug 26, 2022

Changes in this version

type AllocationAsk

+ Originator bool

+ func (m *AllocationAsk) GetOriginator() bool

v1.1.0-1

Aug 26, 2022

v1.0.0

Apr 13, 2022

Changes in this version

+ var E_SiSecret = &proto.ExtensionDesc

+ var EventRecord_Type_name = map[int32]string

+ var EventRecord_Type_value = map[string]int32

+ var NodeInfo_ActionFromRM_name = map[int32]string

+ var NodeInfo_ActionFromRM_value = map[string]int32

+ var TerminationType_name = map[int32]string

+ var TerminationType_value = map[string]int32

+ var UpdateContainerSchedulingStateRequest_SchedulingState_name = map[int32]string

+ var UpdateContainerSchedulingStateRequest_SchedulingState_value = map[string]int32

+ func RegisterSchedulerServer(s *grpc.Server, srv SchedulerServer)

+ type AcceptedApplication struct

+ ApplicationID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AcceptedApplication) Descriptor() ([]byte, []int)

+ func (*AcceptedApplication) ProtoMessage()

+ func (dst *AcceptedApplication) XXX_Merge(src proto.Message)

+ func (m *AcceptedApplication) GetApplicationID() string

+ func (m *AcceptedApplication) Reset()

+ func (m *AcceptedApplication) String() string

+ func (m *AcceptedApplication) XXX_DiscardUnknown()

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

+ func (m *AcceptedApplication) XXX_Size() int

+ func (m *AcceptedApplication) XXX_Unmarshal(b []byte) error

+ type AcceptedNode struct

+ NodeID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AcceptedNode) Descriptor() ([]byte, []int)

+ func (*AcceptedNode) ProtoMessage()

+ func (dst *AcceptedNode) XXX_Merge(src proto.Message)

+ func (m *AcceptedNode) GetNodeID() string

+ func (m *AcceptedNode) Reset()

+ func (m *AcceptedNode) String() string

+ func (m *AcceptedNode) XXX_DiscardUnknown()

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

+ func (m *AcceptedNode) XXX_Size() int

+ func (m *AcceptedNode) XXX_Unmarshal(b []byte) error

+ type AddApplicationRequest struct

+ ApplicationID string

+ ExecutionTimeoutMilliSeconds int64

+ GangSchedulingStyle string

+ PartitionName string

+ PlaceholderAsk *Resource

+ QueueName string

+ Tags map[string]string

+ Ugi *UserGroupInformation

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AddApplicationRequest) Descriptor() ([]byte, []int)

+ func (*AddApplicationRequest) ProtoMessage()

+ func (dst *AddApplicationRequest) XXX_Merge(src proto.Message)

+ func (m *AddApplicationRequest) GetApplicationID() string

+ func (m *AddApplicationRequest) GetExecutionTimeoutMilliSeconds() int64

+ func (m *AddApplicationRequest) GetGangSchedulingStyle() string

+ func (m *AddApplicationRequest) GetPartitionName() string

+ func (m *AddApplicationRequest) GetPlaceholderAsk() *Resource

+ func (m *AddApplicationRequest) GetQueueName() string

+ func (m *AddApplicationRequest) GetTags() map[string]string

+ func (m *AddApplicationRequest) GetUgi() *UserGroupInformation

+ func (m *AddApplicationRequest) Reset()

+ func (m *AddApplicationRequest) String() string

+ func (m *AddApplicationRequest) XXX_DiscardUnknown()

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

+ func (m *AddApplicationRequest) XXX_Size() int

+ func (m *AddApplicationRequest) XXX_Unmarshal(b []byte) error

+ type Allocation struct

+ AllocationKey string

+ AllocationTags map[string]string

+ ApplicationID string

+ NodeID string

+ PartitionName string

+ Placeholder bool

+ Priority *Priority

+ QueueName string

+ ResourcePerAlloc *Resource

+ TaskGroupName string

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Allocation) Descriptor() ([]byte, []int)

+ func (*Allocation) ProtoMessage()

+ func (dst *Allocation) XXX_Merge(src proto.Message)

+ func (m *Allocation) GetAllocationKey() string

+ func (m *Allocation) GetAllocationTags() map[string]string

+ func (m *Allocation) GetApplicationID() string

+ func (m *Allocation) GetNodeID() string

+ func (m *Allocation) GetPartitionName() string

+ func (m *Allocation) GetPlaceholder() bool

+ func (m *Allocation) GetPriority() *Priority

+ func (m *Allocation) GetQueueName() string

+ func (m *Allocation) GetResourcePerAlloc() *Resource

+ func (m *Allocation) GetTaskGroupName() string

+ func (m *Allocation) GetUUID() string

+ func (m *Allocation) Reset()

+ func (m *Allocation) String() string

+ func (m *Allocation) XXX_DiscardUnknown()

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

+ func (m *Allocation) XXX_Size() int

+ func (m *Allocation) XXX_Unmarshal(b []byte) error

+ type AllocationAsk struct

+ AllocationKey string

+ ApplicationID string

+ ExecutionTimeoutMilliSeconds int64

+ MaxAllocations int32

+ PartitionName string

+ Placeholder bool

+ Priority *Priority

+ ResourceAsk *Resource

+ Tags map[string]string

+ TaskGroupName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AllocationAsk) Descriptor() ([]byte, []int)

+ func (*AllocationAsk) ProtoMessage()

+ func (dst *AllocationAsk) XXX_Merge(src proto.Message)

+ func (m *AllocationAsk) GetAllocationKey() string

+ func (m *AllocationAsk) GetApplicationID() string

+ func (m *AllocationAsk) GetExecutionTimeoutMilliSeconds() int64

+ func (m *AllocationAsk) GetMaxAllocations() int32

+ func (m *AllocationAsk) GetPartitionName() string

+ func (m *AllocationAsk) GetPlaceholder() bool

+ func (m *AllocationAsk) GetPriority() *Priority

+ func (m *AllocationAsk) GetResourceAsk() *Resource

+ func (m *AllocationAsk) GetTags() map[string]string

+ func (m *AllocationAsk) GetTaskGroupName() string

+ func (m *AllocationAsk) Reset()

+ func (m *AllocationAsk) String() string

+ func (m *AllocationAsk) XXX_DiscardUnknown()

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

+ func (m *AllocationAsk) XXX_Size() int

+ func (m *AllocationAsk) XXX_Unmarshal(b []byte) error

+ type AllocationAskRelease struct

+ AllocationKey string

+ ApplicationID string

+ Message string

+ PartitionName string

+ TerminationType TerminationType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AllocationAskRelease) Descriptor() ([]byte, []int)

+ func (*AllocationAskRelease) ProtoMessage()

+ func (dst *AllocationAskRelease) XXX_Merge(src proto.Message)

+ func (m *AllocationAskRelease) GetAllocationKey() string

+ func (m *AllocationAskRelease) GetApplicationID() string

+ func (m *AllocationAskRelease) GetMessage() string

+ func (m *AllocationAskRelease) GetPartitionName() string

+ func (m *AllocationAskRelease) GetTerminationType() TerminationType

+ func (m *AllocationAskRelease) Reset()

+ func (m *AllocationAskRelease) String() string

+ func (m *AllocationAskRelease) XXX_DiscardUnknown()

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

+ func (m *AllocationAskRelease) XXX_Size() int

+ func (m *AllocationAskRelease) XXX_Unmarshal(b []byte) error

+ type AllocationRelease struct

+ AllocationKey string

+ ApplicationID string

+ Message string

+ PartitionName string

+ TerminationType TerminationType

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AllocationRelease) Descriptor() ([]byte, []int)

+ func (*AllocationRelease) ProtoMessage()

+ func (dst *AllocationRelease) XXX_Merge(src proto.Message)

+ func (m *AllocationRelease) GetAllocationKey() string

+ func (m *AllocationRelease) GetApplicationID() string

+ func (m *AllocationRelease) GetMessage() string

+ func (m *AllocationRelease) GetPartitionName() string

+ func (m *AllocationRelease) GetTerminationType() TerminationType

+ func (m *AllocationRelease) GetUUID() string

+ func (m *AllocationRelease) Reset()

+ func (m *AllocationRelease) String() string

+ func (m *AllocationRelease) XXX_DiscardUnknown()

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

+ func (m *AllocationRelease) XXX_Size() int

+ func (m *AllocationRelease) XXX_Unmarshal(b []byte) error

+ type AllocationReleasesRequest struct

+ AllocationAsksToRelease []*AllocationAskRelease

+ AllocationsToRelease []*AllocationRelease

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AllocationReleasesRequest) Descriptor() ([]byte, []int)

+ func (*AllocationReleasesRequest) ProtoMessage()

+ func (dst *AllocationReleasesRequest) XXX_Merge(src proto.Message)

+ func (m *AllocationReleasesRequest) GetAllocationAsksToRelease() []*AllocationAskRelease

+ func (m *AllocationReleasesRequest) GetAllocationsToRelease() []*AllocationRelease

+ func (m *AllocationReleasesRequest) Reset()

+ func (m *AllocationReleasesRequest) String() string

+ func (m *AllocationReleasesRequest) XXX_DiscardUnknown()

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

+ func (m *AllocationReleasesRequest) XXX_Size() int

+ func (m *AllocationReleasesRequest) XXX_Unmarshal(b []byte) error

+ type AllocationRequest struct

+ Asks []*AllocationAsk

+ Releases *AllocationReleasesRequest

+ RmID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AllocationRequest) Descriptor() ([]byte, []int)

+ func (*AllocationRequest) ProtoMessage()

+ func (dst *AllocationRequest) XXX_Merge(src proto.Message)

+ func (m *AllocationRequest) GetAsks() []*AllocationAsk

+ func (m *AllocationRequest) GetReleases() *AllocationReleasesRequest

+ func (m *AllocationRequest) GetRmID() string

+ func (m *AllocationRequest) Reset()

+ func (m *AllocationRequest) String() string

+ func (m *AllocationRequest) XXX_DiscardUnknown()

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

+ func (m *AllocationRequest) XXX_Size() int

+ func (m *AllocationRequest) XXX_Unmarshal(b []byte) error

+ type AllocationResponse struct

+ New []*Allocation

+ Rejected []*RejectedAllocationAsk

+ Released []*AllocationRelease

+ ReleasedAsks []*AllocationAskRelease

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AllocationResponse) Descriptor() ([]byte, []int)

+ func (*AllocationResponse) ProtoMessage()

+ func (dst *AllocationResponse) XXX_Merge(src proto.Message)

+ func (m *AllocationResponse) GetNew() []*Allocation

+ func (m *AllocationResponse) GetRejected() []*RejectedAllocationAsk

+ func (m *AllocationResponse) GetReleased() []*AllocationRelease

+ func (m *AllocationResponse) GetReleasedAsks() []*AllocationAskRelease

+ func (m *AllocationResponse) Reset()

+ func (m *AllocationResponse) String() string

+ func (m *AllocationResponse) XXX_DiscardUnknown()

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

+ func (m *AllocationResponse) XXX_Size() int

+ func (m *AllocationResponse) XXX_Unmarshal(b []byte) error

+ type ApplicationRequest struct

+ New []*AddApplicationRequest

+ Remove []*RemoveApplicationRequest

+ RmID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ApplicationRequest) Descriptor() ([]byte, []int)

+ func (*ApplicationRequest) ProtoMessage()

+ func (dst *ApplicationRequest) XXX_Merge(src proto.Message)

+ func (m *ApplicationRequest) GetNew() []*AddApplicationRequest

+ func (m *ApplicationRequest) GetRemove() []*RemoveApplicationRequest

+ func (m *ApplicationRequest) GetRmID() string

+ func (m *ApplicationRequest) Reset()

+ func (m *ApplicationRequest) String() string

+ func (m *ApplicationRequest) XXX_DiscardUnknown()

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

+ func (m *ApplicationRequest) XXX_Size() int

+ func (m *ApplicationRequest) XXX_Unmarshal(b []byte) error

+ type ApplicationResponse struct

+ Accepted []*AcceptedApplication

+ Rejected []*RejectedApplication

+ Updated []*UpdatedApplication

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ApplicationResponse) Descriptor() ([]byte, []int)

+ func (*ApplicationResponse) ProtoMessage()

+ func (dst *ApplicationResponse) XXX_Merge(src proto.Message)

+ func (m *ApplicationResponse) GetAccepted() []*AcceptedApplication

+ func (m *ApplicationResponse) GetRejected() []*RejectedApplication

+ func (m *ApplicationResponse) GetUpdated() []*UpdatedApplication

+ func (m *ApplicationResponse) Reset()

+ func (m *ApplicationResponse) String() string

+ func (m *ApplicationResponse) XXX_DiscardUnknown()

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

+ func (m *ApplicationResponse) XXX_Size() int

+ func (m *ApplicationResponse) XXX_Unmarshal(b []byte) error

+ type EventRecord struct

+ GroupID string

+ Message string

+ ObjectID string

+ Reason string

+ TimestampNano int64

+ Type EventRecord_Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*EventRecord) Descriptor() ([]byte, []int)

+ func (*EventRecord) ProtoMessage()

+ func (dst *EventRecord) XXX_Merge(src proto.Message)

+ func (m *EventRecord) GetGroupID() string

+ func (m *EventRecord) GetMessage() string

+ func (m *EventRecord) GetObjectID() string

+ func (m *EventRecord) GetReason() string

+ func (m *EventRecord) GetTimestampNano() int64

+ func (m *EventRecord) GetType() EventRecord_Type

+ func (m *EventRecord) Reset()

+ func (m *EventRecord) String() string

+ func (m *EventRecord) XXX_DiscardUnknown()

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

+ func (m *EventRecord) XXX_Size() int

+ func (m *EventRecord) XXX_Unmarshal(b []byte) error

+ type EventRecord_Type int32

+ const EventRecord_APP

+ const EventRecord_NODE

+ const EventRecord_QUEUE

+ const EventRecord_REQUEST

+ const EventRecord_UNKNOWN_EVENTRECORD_TYPE

+ func (EventRecord_Type) EnumDescriptor() ([]byte, []int)

+ func (x EventRecord_Type) String() string

+ type NodeInfo struct

+ Action NodeInfo_ActionFromRM

+ Attributes map[string]string

+ ExistingAllocations []*Allocation

+ NodeID string

+ OccupiedResource *Resource

+ SchedulableResource *Resource

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeInfo) Descriptor() ([]byte, []int)

+ func (*NodeInfo) ProtoMessage()

+ func (dst *NodeInfo) XXX_Merge(src proto.Message)

+ func (m *NodeInfo) GetAction() NodeInfo_ActionFromRM

+ func (m *NodeInfo) GetAttributes() map[string]string

+ func (m *NodeInfo) GetExistingAllocations() []*Allocation

+ func (m *NodeInfo) GetNodeID() string

+ func (m *NodeInfo) GetOccupiedResource() *Resource

+ func (m *NodeInfo) GetSchedulableResource() *Resource

+ func (m *NodeInfo) Reset()

+ func (m *NodeInfo) String() string

+ func (m *NodeInfo) XXX_DiscardUnknown()

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

+ func (m *NodeInfo) XXX_Size() int

+ func (m *NodeInfo) XXX_Unmarshal(b []byte) error

+ type NodeInfo_ActionFromRM int32

+ const NodeInfo_CREATE

+ const NodeInfo_DECOMISSION

+ const NodeInfo_DRAIN_NODE

+ const NodeInfo_DRAIN_TO_SCHEDULABLE

+ const NodeInfo_UNKNOWN_ACTION_FROM_RM

+ const NodeInfo_UPDATE

+ func (NodeInfo_ActionFromRM) EnumDescriptor() ([]byte, []int)

+ func (x NodeInfo_ActionFromRM) String() string

+ type NodeRequest struct

+ Nodes []*NodeInfo

+ RmID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeRequest) Descriptor() ([]byte, []int)

+ func (*NodeRequest) ProtoMessage()

+ func (dst *NodeRequest) XXX_Merge(src proto.Message)

+ func (m *NodeRequest) GetNodes() []*NodeInfo

+ func (m *NodeRequest) GetRmID() string

+ func (m *NodeRequest) Reset()

+ func (m *NodeRequest) String() string

+ func (m *NodeRequest) XXX_DiscardUnknown()

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

+ func (m *NodeRequest) XXX_Size() int

+ func (m *NodeRequest) XXX_Unmarshal(b []byte) error

+ type NodeResponse struct

+ Accepted []*AcceptedNode

+ Rejected []*RejectedNode

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeResponse) Descriptor() ([]byte, []int)

+ func (*NodeResponse) ProtoMessage()

+ func (dst *NodeResponse) XXX_Merge(src proto.Message)

+ func (m *NodeResponse) GetAccepted() []*AcceptedNode

+ func (m *NodeResponse) GetRejected() []*RejectedNode

+ func (m *NodeResponse) Reset()

+ func (m *NodeResponse) String() string

+ func (m *NodeResponse) XXX_DiscardUnknown()

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

+ func (m *NodeResponse) XXX_Size() int

+ func (m *NodeResponse) XXX_Unmarshal(b []byte) error

+ type PredicatesArgs struct

+ Allocate bool

+ AllocationKey string

+ NodeID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PredicatesArgs) Descriptor() ([]byte, []int)

+ func (*PredicatesArgs) ProtoMessage()

+ func (dst *PredicatesArgs) XXX_Merge(src proto.Message)

+ func (m *PredicatesArgs) GetAllocate() bool

+ func (m *PredicatesArgs) GetAllocationKey() string

+ func (m *PredicatesArgs) GetNodeID() string

+ func (m *PredicatesArgs) Reset()

+ func (m *PredicatesArgs) String() string

+ func (m *PredicatesArgs) XXX_DiscardUnknown()

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

+ func (m *PredicatesArgs) XXX_Size() int

+ func (m *PredicatesArgs) XXX_Unmarshal(b []byte) error

+ type Priority struct

+ Priority isPriority_Priority

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Priority) Descriptor() ([]byte, []int)

+ func (*Priority) ProtoMessage()

+ func (*Priority) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *Priority) XXX_Merge(src proto.Message)

+ func (m *Priority) GetPriority() isPriority_Priority

+ func (m *Priority) GetPriorityClassName() string

+ func (m *Priority) GetPriorityValue() int32

+ func (m *Priority) Reset()

+ func (m *Priority) String() string

+ func (m *Priority) XXX_DiscardUnknown()

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

+ func (m *Priority) XXX_Size() int

+ func (m *Priority) XXX_Unmarshal(b []byte) error

+ type Priority_PriorityClassName struct

+ PriorityClassName string

+ type Priority_PriorityValue struct

+ PriorityValue int32

+ type Quantity struct

+ Value int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Quantity) Descriptor() ([]byte, []int)

+ func (*Quantity) ProtoMessage()

+ func (dst *Quantity) XXX_Merge(src proto.Message)

+ func (m *Quantity) GetValue() int64

+ func (m *Quantity) Reset()

+ func (m *Quantity) String() string

+ func (m *Quantity) XXX_DiscardUnknown()

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

+ func (m *Quantity) XXX_Size() int

+ func (m *Quantity) XXX_Unmarshal(b []byte) error

+ type RegisterResourceManagerRequest struct

+ BuildInfo map[string]string

+ PolicyGroup string

+ RmID string

+ Version string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RegisterResourceManagerRequest) Descriptor() ([]byte, []int)

+ func (*RegisterResourceManagerRequest) ProtoMessage()

+ func (dst *RegisterResourceManagerRequest) XXX_Merge(src proto.Message)

+ func (m *RegisterResourceManagerRequest) GetBuildInfo() map[string]string

+ func (m *RegisterResourceManagerRequest) GetPolicyGroup() string

+ func (m *RegisterResourceManagerRequest) GetRmID() string

+ func (m *RegisterResourceManagerRequest) GetVersion() string

+ func (m *RegisterResourceManagerRequest) Reset()

+ func (m *RegisterResourceManagerRequest) String() string

+ func (m *RegisterResourceManagerRequest) XXX_DiscardUnknown()

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

+ func (m *RegisterResourceManagerRequest) XXX_Size() int

+ func (m *RegisterResourceManagerRequest) XXX_Unmarshal(b []byte) error

+ type RegisterResourceManagerResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RegisterResourceManagerResponse) Descriptor() ([]byte, []int)

+ func (*RegisterResourceManagerResponse) ProtoMessage()

+ func (dst *RegisterResourceManagerResponse) XXX_Merge(src proto.Message)

+ func (m *RegisterResourceManagerResponse) Reset()

+ func (m *RegisterResourceManagerResponse) String() string

+ func (m *RegisterResourceManagerResponse) XXX_DiscardUnknown()

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

+ func (m *RegisterResourceManagerResponse) XXX_Size() int

+ func (m *RegisterResourceManagerResponse) XXX_Unmarshal(b []byte) error

+ type RejectedAllocationAsk struct

+ AllocationKey string

+ ApplicationID string

+ Reason string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RejectedAllocationAsk) Descriptor() ([]byte, []int)

+ func (*RejectedAllocationAsk) ProtoMessage()

+ func (dst *RejectedAllocationAsk) XXX_Merge(src proto.Message)

+ func (m *RejectedAllocationAsk) GetAllocationKey() string

+ func (m *RejectedAllocationAsk) GetApplicationID() string

+ func (m *RejectedAllocationAsk) GetReason() string

+ func (m *RejectedAllocationAsk) Reset()

+ func (m *RejectedAllocationAsk) String() string

+ func (m *RejectedAllocationAsk) XXX_DiscardUnknown()

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

+ func (m *RejectedAllocationAsk) XXX_Size() int

+ func (m *RejectedAllocationAsk) XXX_Unmarshal(b []byte) error

+ type RejectedApplication struct

+ ApplicationID string

+ Reason string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RejectedApplication) Descriptor() ([]byte, []int)

+ func (*RejectedApplication) ProtoMessage()

+ func (dst *RejectedApplication) XXX_Merge(src proto.Message)

+ func (m *RejectedApplication) GetApplicationID() string

+ func (m *RejectedApplication) GetReason() string

+ func (m *RejectedApplication) Reset()

+ func (m *RejectedApplication) String() string

+ func (m *RejectedApplication) XXX_DiscardUnknown()

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

+ func (m *RejectedApplication) XXX_Size() int

+ func (m *RejectedApplication) XXX_Unmarshal(b []byte) error

+ type RejectedNode struct

+ NodeID string

+ Reason string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RejectedNode) Descriptor() ([]byte, []int)

+ func (*RejectedNode) ProtoMessage()

+ func (dst *RejectedNode) XXX_Merge(src proto.Message)

+ func (m *RejectedNode) GetNodeID() string

+ func (m *RejectedNode) GetReason() string

+ func (m *RejectedNode) Reset()

+ func (m *RejectedNode) String() string

+ func (m *RejectedNode) XXX_DiscardUnknown()

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

+ func (m *RejectedNode) XXX_Size() int

+ func (m *RejectedNode) XXX_Unmarshal(b []byte) error

+ type RemoveApplicationRequest struct

+ ApplicationID string

+ PartitionName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RemoveApplicationRequest) Descriptor() ([]byte, []int)

+ func (*RemoveApplicationRequest) ProtoMessage()

+ func (dst *RemoveApplicationRequest) XXX_Merge(src proto.Message)

+ func (m *RemoveApplicationRequest) GetApplicationID() string

+ func (m *RemoveApplicationRequest) GetPartitionName() string

+ func (m *RemoveApplicationRequest) Reset()

+ func (m *RemoveApplicationRequest) String() string

+ func (m *RemoveApplicationRequest) XXX_DiscardUnknown()

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

+ func (m *RemoveApplicationRequest) XXX_Size() int

+ func (m *RemoveApplicationRequest) XXX_Unmarshal(b []byte) error

+ type Resource struct

+ Resources map[string]*Quantity

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Resource) Descriptor() ([]byte, []int)

+ func (*Resource) ProtoMessage()

+ func (dst *Resource) XXX_Merge(src proto.Message)

+ func (m *Resource) GetResources() map[string]*Quantity

+ func (m *Resource) Reset()

+ func (m *Resource) String() string

+ func (m *Resource) XXX_DiscardUnknown()

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

+ func (m *Resource) XXX_Size() int

+ func (m *Resource) XXX_Unmarshal(b []byte) error

+ type SchedulerClient interface

+ RegisterResourceManager func(ctx context.Context, in *RegisterResourceManagerRequest, ...) (*RegisterResourceManagerResponse, error)

+ UpdateAllocation func(ctx context.Context, opts ...grpc.CallOption) (Scheduler_UpdateAllocationClient, error)

+ UpdateApplication func(ctx context.Context, opts ...grpc.CallOption) (Scheduler_UpdateApplicationClient, error)

+ UpdateNode func(ctx context.Context, opts ...grpc.CallOption) (Scheduler_UpdateNodeClient, error)

+ func NewSchedulerClient(cc *grpc.ClientConn) SchedulerClient

+ type SchedulerServer interface

+ RegisterResourceManager func(context.Context, *RegisterResourceManagerRequest) (*RegisterResourceManagerResponse, error)

+ UpdateAllocation func(Scheduler_UpdateAllocationServer) error

+ UpdateApplication func(Scheduler_UpdateApplicationServer) error

+ UpdateNode func(Scheduler_UpdateNodeServer) error

+ type Scheduler_UpdateAllocationClient interface

+ Recv func() (*AllocationResponse, error)

+ Send func(*AllocationRequest) error

+ type Scheduler_UpdateAllocationServer interface

+ Recv func() (*AllocationRequest, error)

+ Send func(*AllocationResponse) error

+ type Scheduler_UpdateApplicationClient interface

+ Recv func() (*ApplicationResponse, error)

+ Send func(*ApplicationRequest) error

+ type Scheduler_UpdateApplicationServer interface

+ Recv func() (*ApplicationRequest, error)

+ Send func(*ApplicationResponse) error

+ type Scheduler_UpdateNodeClient interface

+ Recv func() (*NodeResponse, error)

+ Send func(*NodeRequest) error

+ type Scheduler_UpdateNodeServer interface

+ Recv func() (*NodeRequest, error)

+ Send func(*NodeResponse) error

+ type TerminationType int32

+ const TerminationType_PLACEHOLDER_REPLACED

+ const TerminationType_PREEMPTED_BY_SCHEDULER

+ const TerminationType_STOPPED_BY_RM

+ const TerminationType_TIMEOUT

+ const TerminationType_UNKNOWN_TERMINATION_TYPE

+ func (TerminationType) EnumDescriptor() ([]byte, []int)

+ func (x TerminationType) String() string

+ type UpdateConfigurationRequest struct

+ Configs string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*UpdateConfigurationRequest) Descriptor() ([]byte, []int)

+ func (*UpdateConfigurationRequest) ProtoMessage()

+ func (dst *UpdateConfigurationRequest) XXX_Merge(src proto.Message)

+ func (m *UpdateConfigurationRequest) GetConfigs() string

+ func (m *UpdateConfigurationRequest) Reset()

+ func (m *UpdateConfigurationRequest) String() string

+ func (m *UpdateConfigurationRequest) XXX_DiscardUnknown()

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

+ func (m *UpdateConfigurationRequest) XXX_Size() int

+ func (m *UpdateConfigurationRequest) XXX_Unmarshal(b []byte) error

+ type UpdateConfigurationResponse struct

+ OldConfig string

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*UpdateConfigurationResponse) Descriptor() ([]byte, []int)

+ func (*UpdateConfigurationResponse) ProtoMessage()

+ func (dst *UpdateConfigurationResponse) XXX_Merge(src proto.Message)

+ func (m *UpdateConfigurationResponse) GetOldConfig() string

+ func (m *UpdateConfigurationResponse) GetReason() string

+ func (m *UpdateConfigurationResponse) GetSuccess() bool

+ func (m *UpdateConfigurationResponse) Reset()

+ func (m *UpdateConfigurationResponse) String() string

+ func (m *UpdateConfigurationResponse) XXX_DiscardUnknown()

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

+ func (m *UpdateConfigurationResponse) XXX_Size() int

+ func (m *UpdateConfigurationResponse) XXX_Unmarshal(b []byte) error

+ type UpdateContainerSchedulingStateRequest struct

+ AllocationKey string

+ ApplicartionID string

+ Reason string

+ State UpdateContainerSchedulingStateRequest_SchedulingState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*UpdateContainerSchedulingStateRequest) Descriptor() ([]byte, []int)

+ func (*UpdateContainerSchedulingStateRequest) ProtoMessage()

+ func (dst *UpdateContainerSchedulingStateRequest) XXX_Merge(src proto.Message)

+ func (m *UpdateContainerSchedulingStateRequest) GetAllocationKey() string

+ func (m *UpdateContainerSchedulingStateRequest) GetApplicartionID() string

+ func (m *UpdateContainerSchedulingStateRequest) GetReason() string

+ func (m *UpdateContainerSchedulingStateRequest) GetState() UpdateContainerSchedulingStateRequest_SchedulingState

+ func (m *UpdateContainerSchedulingStateRequest) Reset()

+ func (m *UpdateContainerSchedulingStateRequest) String() string

+ func (m *UpdateContainerSchedulingStateRequest) XXX_DiscardUnknown()

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

+ func (m *UpdateContainerSchedulingStateRequest) XXX_Size() int

+ func (m *UpdateContainerSchedulingStateRequest) XXX_Unmarshal(b []byte) error

+ type UpdateContainerSchedulingStateRequest_SchedulingState int32

+ const UpdateContainerSchedulingStateRequest_FAILED

+ const UpdateContainerSchedulingStateRequest_RESERVED

+ const UpdateContainerSchedulingStateRequest_SCHEDULED

+ const UpdateContainerSchedulingStateRequest_SKIPPED

+ const UpdateContainerSchedulingStateRequest_UNKNOWN_SCHEDULING_STATE

+ func (UpdateContainerSchedulingStateRequest_SchedulingState) EnumDescriptor() ([]byte, []int)

+ func (x UpdateContainerSchedulingStateRequest_SchedulingState) String() string

+ type UpdatedApplication struct

+ ApplicationID string

+ Message string

+ State string

+ StateTransitionTimestamp int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*UpdatedApplication) Descriptor() ([]byte, []int)

+ func (*UpdatedApplication) ProtoMessage()

+ func (dst *UpdatedApplication) XXX_Merge(src proto.Message)

+ func (m *UpdatedApplication) GetApplicationID() string

+ func (m *UpdatedApplication) GetMessage() string

+ func (m *UpdatedApplication) GetState() string

+ func (m *UpdatedApplication) GetStateTransitionTimestamp() int64

+ func (m *UpdatedApplication) Reset()

+ func (m *UpdatedApplication) String() string

+ func (m *UpdatedApplication) XXX_DiscardUnknown()

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

+ func (m *UpdatedApplication) XXX_Size() int

+ func (m *UpdatedApplication) XXX_Unmarshal(b []byte) error

+ type UserGroupInformation struct

+ Groups []string

+ User string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*UserGroupInformation) Descriptor() ([]byte, []int)

+ func (*UserGroupInformation) ProtoMessage()

+ func (dst *UserGroupInformation) XXX_Merge(src proto.Message)

+ func (m *UserGroupInformation) GetGroups() []string

+ func (m *UserGroupInformation) GetUser() string

+ func (m *UserGroupInformation) Reset()

+ func (m *UserGroupInformation) String() string

+ func (m *UserGroupInformation) XXX_DiscardUnknown()

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

+ func (m *UserGroupInformation) XXX_Size() int

+ func (m *UserGroupInformation) XXX_Unmarshal(b []byte) error

v1.0.0-1

Apr 13, 2022

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL