si

package
v1.5.0 Latest Latest
Warning

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

 Go to latest Published: Feb 22, 2024 License: Apache-2.0 Imports: 9 Imported by: 23

Documentation

Index

Constants

View Source 
const (
	Scheduler_RegisterResourceManager_FullMethodName = "/si.v1.Scheduler/RegisterResourceManager"
	Scheduler_UpdateAllocation_FullMethodName        = "/si.v1.Scheduler/UpdateAllocation"
	Scheduler_UpdateApplication_FullMethodName       = "/si.v1.Scheduler/UpdateApplication"
	Scheduler_UpdateNode_FullMethodName              = "/si.v1.Scheduler/UpdateNode"
)

Variables

View Source 
var (
	TerminationType_name = map[int32]string{
		0: "UNKNOWN_TERMINATION_TYPE",
		1: "STOPPED_BY_RM",
		2: "TIMEOUT",
		3: "PREEMPTED_BY_SCHEDULER",
		4: "PLACEHOLDER_REPLACED",
	}
	TerminationType_value = map[string]int32{
		"UNKNOWN_TERMINATION_TYPE": 0,
		"STOPPED_BY_RM":            1,
		"TIMEOUT":                  2,
		"PREEMPTED_BY_SCHEDULER":   3,
		"PLACEHOLDER_REPLACED":     4,
	}
)

Enum value maps for TerminationType.

View Source 
var (
	NodeInfo_ActionFromRM_name = map[int32]string{
		0: "UNKNOWN_ACTION_FROM_RM",
		1: "CREATE",
		2: "UPDATE",
		3: "DRAIN_NODE",
		4: "DECOMISSION",
		5: "DRAIN_TO_SCHEDULABLE",
		6: "CREATE_DRAIN",
	}
	NodeInfo_ActionFromRM_value = map[string]int32{
		"UNKNOWN_ACTION_FROM_RM": 0,
		"CREATE":                 1,
		"UPDATE":                 2,
		"DRAIN_NODE":             3,
		"DECOMISSION":            4,
		"DRAIN_TO_SCHEDULABLE":   5,
		"CREATE_DRAIN":           6,
	}
)

Enum value maps for NodeInfo_ActionFromRM.

View Source 
var (
	UpdateContainerSchedulingStateRequest_SchedulingState_name = map[int32]string{
		0: "UNKNOWN_SCHEDULING_STATE",
		1: "SKIPPED",
		2: "SCHEDULED",
		3: "RESERVED",
		4: "FAILED",
	}
	UpdateContainerSchedulingStateRequest_SchedulingState_value = map[string]int32{
		"UNKNOWN_SCHEDULING_STATE": 0,
		"SKIPPED":                  1,
		"SCHEDULED":                2,
		"RESERVED":                 3,
		"FAILED":                   4,
	}
)

Enum value maps for UpdateContainerSchedulingStateRequest_SchedulingState.

View Source 
var (
	EventRecord_Type_name = map[int32]string{
		0: "UNKNOWN_EVENTRECORD_TYPE",
		1: "REQUEST",
		2: "APP",
		3: "NODE",
		4: "QUEUE",
		5: "USERGROUP",
	}
	EventRecord_Type_value = map[string]int32{
		"UNKNOWN_EVENTRECORD_TYPE": 0,
		"REQUEST":                  1,
		"APP":                      2,
		"NODE":                     3,
		"QUEUE":                    4,
		"USERGROUP":                5,
	}
)

Enum value maps for EventRecord_Type.

View Source 
var (
	EventRecord_ChangeType_name = map[int32]string{
		0: "NONE",
		1: "SET",
		2: "ADD",
		3: "REMOVE",
	}
	EventRecord_ChangeType_value = map[string]int32{
		"NONE":   0,
		"SET":    1,
		"ADD":    2,
		"REMOVE": 3,
	}
)

Enum value maps for EventRecord_ChangeType.

View Source 
var (
	EventRecord_ChangeDetail_name = map[int32]string{
		0:   "DETAILS_NONE",
		100: "REQUEST_CANCEL",
		101: "REQUEST_ALLOC",
		102: "REQUEST_TIMEOUT",
		200: "APP_ALLOC",
		201: "APP_REQUEST",
		202: "APP_REJECT",
		203: "APP_NEW",
		204: "APP_ACCEPTED",
		205: "APP_STARTING",
		206: "APP_RUNNING",
		207: "APP_COMPLETING",
		208: "APP_COMPLETED",
		209: "APP_FAILING",
		210: "APP_FAILED",
		211: "APP_RESUMING",
		212: "APP_EXPIRED",
		213: "APP_CANNOTRUN_QUEUE",
		214: "APP_RUNNABLE_QUEUE",
		215: "APP_CANNOTRUN_QUOTA",
		216: "APP_RUNNABLE_QUOTA",
		300: "NODE_DECOMISSION",
		301: "NODE_READY",
		302: "NODE_SCHEDULABLE",
		303: "NODE_ALLOC",
		304: "NODE_CAPACITY",
		305: "NODE_OCCUPIED",
		306: "NODE_RESERVATION",
		400: "QUEUE_CONFIG",
		401: "QUEUE_DYNAMIC",
		402: "QUEUE_TYPE",
		403: "QUEUE_MAX",
		404: "QUEUE_GUARANTEED",
		405: "QUEUE_APP",
		406: "QUEUE_ALLOC",
		500: "ALLOC_CANCEL",
		501: "ALLOC_PREEMPT",
		502: "ALLOC_TIMEOUT",
		503: "ALLOC_REPLACED",
		504: "ALLOC_NODEREMOVED",
		600: "UG_USER_LIMIT",
		601: "UG_GROUP_LIMIT",
		602: "UG_APP_LINK",
		603: "UG_USER_RESOURCE",
		604: "UG_GROUP_RESOURCE",
	}
	EventRecord_ChangeDetail_value = map[string]int32{
		"DETAILS_NONE":        0,
		"REQUEST_CANCEL":      100,
		"REQUEST_ALLOC":       101,
		"REQUEST_TIMEOUT":     102,
		"APP_ALLOC":           200,
		"APP_REQUEST":         201,
		"APP_REJECT":          202,
		"APP_NEW":             203,
		"APP_ACCEPTED":        204,
		"APP_STARTING":        205,
		"APP_RUNNING":         206,
		"APP_COMPLETING":      207,
		"APP_COMPLETED":       208,
		"APP_FAILING":         209,
		"APP_FAILED":          210,
		"APP_RESUMING":        211,
		"APP_EXPIRED":         212,
		"APP_CANNOTRUN_QUEUE": 213,
		"APP_RUNNABLE_QUEUE":  214,
		"APP_CANNOTRUN_QUOTA": 215,
		"APP_RUNNABLE_QUOTA":  216,
		"NODE_DECOMISSION":    300,
		"NODE_READY":          301,
		"NODE_SCHEDULABLE":    302,
		"NODE_ALLOC":          303,
		"NODE_CAPACITY":       304,
		"NODE_OCCUPIED":       305,
		"NODE_RESERVATION":    306,
		"QUEUE_CONFIG":        400,
		"QUEUE_DYNAMIC":       401,
		"QUEUE_TYPE":          402,
		"QUEUE_MAX":           403,
		"QUEUE_GUARANTEED":    404,
		"QUEUE_APP":           405,
		"QUEUE_ALLOC":         406,
		"ALLOC_CANCEL":        500,
		"ALLOC_PREEMPT":       501,
		"ALLOC_TIMEOUT":       502,
		"ALLOC_REPLACED":      503,
		"ALLOC_NODEREMOVED":   504,
		"UG_USER_LIMIT":       600,
		"UG_GROUP_LIMIT":      601,
		"UG_APP_LINK":         602,
		"UG_USER_RESOURCE":    603,
		"UG_GROUP_RESOURCE":   604,
	}
)

Enum value maps for EventRecord_ChangeDetail.

View Source 
var (
	// Indicates that a field MAY contain information that is sensitive
	// and MUST be treated as such (e.g. not logged).
	//
	// optional bool si_secret = 1059;
	E_SiSecret = &file_yunikorn_scheduler_interface_si_proto_extTypes[0]
)

Extension fields to descriptorpb.FieldOptions.

View Source 
var File_yunikorn_scheduler_interface_si_proto protoreflect.FileDescriptor
View Source 
var Scheduler_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "si.v1.Scheduler",
	HandlerType: (*SchedulerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterResourceManager",
			Handler:    _Scheduler_RegisterResourceManager_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "UpdateAllocation",
			Handler:       _Scheduler_UpdateAllocation_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "UpdateApplication",
			Handler:       _Scheduler_UpdateApplication_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "UpdateNode",
			Handler:       _Scheduler_UpdateNode_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "yunikorn-scheduler-interface/si.proto",
}

Scheduler_ServiceDesc is the grpc.ServiceDesc for Scheduler service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterSchedulerServer 

func RegisterSchedulerServer(s grpc.ServiceRegistrar, srv SchedulerServer)

Types

type AcceptedApplication 

type AcceptedApplication struct {

	// The application ID that was accepted
	ApplicationID string `protobuf:"bytes,1,opt,name=applicationID,proto3" json:"applicationID,omitempty"`
	// contains filtered or unexported fields
}

func (*AcceptedApplication) Descriptor deprecated 

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

Deprecated: Use AcceptedApplication.ProtoReflect.Descriptor instead.

func (*AcceptedApplication) GetApplicationID 

func (x *AcceptedApplication) GetApplicationID() string

func (*AcceptedApplication) ProtoMessage 

func (*AcceptedApplication) ProtoMessage()

func (*AcceptedApplication) ProtoReflect added in v1.4.0 

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

func (*AcceptedApplication) Reset 

func (x *AcceptedApplication) Reset()

func (*AcceptedApplication) String 

func (x *AcceptedApplication) String() string

type AcceptedNode 

type AcceptedNode struct {

	// The node ID that was accepted
	NodeID string `protobuf:"bytes,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	// contains filtered or unexported fields
}

func (*AcceptedNode) Descriptor deprecated 

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

Deprecated: Use AcceptedNode.ProtoReflect.Descriptor instead.

func (*AcceptedNode) GetNodeID 

func (x *AcceptedNode) GetNodeID() string

func (*AcceptedNode) ProtoMessage 

func (*AcceptedNode) ProtoMessage()

func (*AcceptedNode) ProtoReflect added in v1.4.0 

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

func (*AcceptedNode) Reset 

func (x *AcceptedNode) Reset()

func (*AcceptedNode) String 

func (x *AcceptedNode) String() string

type AddApplicationRequest 

type AddApplicationRequest struct {

	// The ID of the application, must be unique
	ApplicationID string `protobuf:"bytes,1,opt,name=applicationID,proto3" json:"applicationID,omitempty"`
	// The queue this application is requesting. The scheduler will place the application into a
	// queue according to policy, taking into account the requested queue as per the policy.
	QueueName string `protobuf:"bytes,2,opt,name=queueName,proto3" json:"queueName,omitempty"`
	// The partition the application belongs to
	PartitionName string `protobuf:"bytes,3,opt,name=partitionName,proto3" json:"partitionName,omitempty"`
	// The user group information of the application owner
	Ugi *UserGroupInformation `protobuf:"bytes,4,opt,name=ugi,proto3" json:"ugi,omitempty"`
	// A set of tags for the application. These tags provide application level generic information.
	// The tags are optional and are used in placing an application or scheduling.
	// Application tags are not considered when processing AllocationAsks.
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// Execution timeout: How long this application can be in a running state
	// 0 or negative value means never expire.
	ExecutionTimeoutMilliSeconds int64 `protobuf:"varint,6,opt,name=executionTimeoutMilliSeconds,proto3" json:"executionTimeoutMilliSeconds,omitempty"`
	// The total amount of resources gang placeholders will request
	PlaceholderAsk *Resource `protobuf:"bytes,7,opt,name=placeholderAsk,proto3" json:"placeholderAsk,omitempty"`
	// Gang scheduling style can be hard (the application will fail after placeholder timeout)
	// or soft (after the timeout the application will be scheduled as a normal application)
	GangSchedulingStyle string `protobuf:"bytes,8,opt,name=gangSchedulingStyle,proto3" json:"gangSchedulingStyle,omitempty"`
	// contains filtered or unexported fields
}

func (*AddApplicationRequest) Descriptor deprecated 

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

Deprecated: Use AddApplicationRequest.ProtoReflect.Descriptor instead.

func (*AddApplicationRequest) GetApplicationID 

func (x *AddApplicationRequest) GetApplicationID() string

func (*AddApplicationRequest) GetExecutionTimeoutMilliSeconds 

func (x *AddApplicationRequest) GetExecutionTimeoutMilliSeconds() int64

func (*AddApplicationRequest) GetGangSchedulingStyle 

func (x *AddApplicationRequest) GetGangSchedulingStyle() string

func (*AddApplicationRequest) GetPartitionName 

func (x *AddApplicationRequest) GetPartitionName() string

func (*AddApplicationRequest) GetPlaceholderAsk 

func (x *AddApplicationRequest) GetPlaceholderAsk() *Resource

func (*AddApplicationRequest) GetQueueName 

func (x *AddApplicationRequest) GetQueueName() string

func (*AddApplicationRequest) GetTags 

func (x *AddApplicationRequest) GetTags() map[string]string

func (*AddApplicationRequest) GetUgi 

func (x *AddApplicationRequest) GetUgi() *UserGroupInformation

func (*AddApplicationRequest) ProtoMessage 

func (*AddApplicationRequest) ProtoMessage()

func (*AddApplicationRequest) ProtoReflect added in v1.4.0 

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

func (*AddApplicationRequest) Reset 

func (x *AddApplicationRequest) Reset()

func (*AddApplicationRequest) String 

func (x *AddApplicationRequest) String() string

type Allocation 

type Allocation struct {

	// AllocationKey from AllocationAsk
	AllocationKey string `protobuf:"bytes,1,opt,name=allocationKey,proto3" json:"allocationKey,omitempty"`
	// Allocation tags from AllocationAsk
	AllocationTags map[string]string `` /* 169-byte string literal not displayed */
	// Resource for each allocation
	ResourcePerAlloc *Resource `protobuf:"bytes,5,opt,name=resourcePerAlloc,proto3" json:"resourcePerAlloc,omitempty"`
	// Priority of ask
	Priority int32 `protobuf:"varint,6,opt,name=priority,proto3" json:"priority,omitempty"`
	// Node which the allocation belongs to
	NodeID string `protobuf:"bytes,8,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	// The ID of the application
	ApplicationID string `protobuf:"bytes,9,opt,name=applicationID,proto3" json:"applicationID,omitempty"`
	// Partition of the allocation
	PartitionName string `protobuf:"bytes,10,opt,name=partitionName,proto3" json:"partitionName,omitempty"`
	// The name of the TaskGroup this allocation belongs to
	TaskGroupName string `protobuf:"bytes,11,opt,name=taskGroupName,proto3" json:"taskGroupName,omitempty"`
	// Is this a placeholder allocation (true) or a real allocation (false), defaults to false
	// ignored if the taskGroupName is not set
	Placeholder bool `protobuf:"varint,12,opt,name=placeholder,proto3" json:"placeholder,omitempty"`
	// AllocationID of the allocation
	AllocationID string `protobuf:"bytes,13,opt,name=allocationID,proto3" json:"allocationID,omitempty"`
	// Whether this allocation was the originator of this app
	Originator bool `protobuf:"varint,14,opt,name=originator,proto3" json:"originator,omitempty"`
	// The preemption policy for this allocation
	PreemptionPolicy *PreemptionPolicy `protobuf:"bytes,15,opt,name=preemptionPolicy,proto3" json:"preemptionPolicy,omitempty"`
	// contains filtered or unexported fields
}

func (*Allocation) Descriptor deprecated 

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

Deprecated: Use Allocation.ProtoReflect.Descriptor instead.

func (*Allocation) GetAllocationID added in v1.5.0 

func (x *Allocation) GetAllocationID() string

func (*Allocation) GetAllocationKey 

func (x *Allocation) GetAllocationKey() string

func (*Allocation) GetAllocationTags 

func (x *Allocation) GetAllocationTags() map[string]string

func (*Allocation) GetApplicationID 

func (x *Allocation) GetApplicationID() string

func (*Allocation) GetNodeID 

func (x *Allocation) GetNodeID() string

func (*Allocation) GetOriginator added in v1.5.0 

func (x *Allocation) GetOriginator() bool

func (*Allocation) GetPartitionName 

func (x *Allocation) GetPartitionName() string

func (*Allocation) GetPlaceholder 

func (x *Allocation) GetPlaceholder() bool

func (*Allocation) GetPreemptionPolicy added in v1.5.0 

func (x *Allocation) GetPreemptionPolicy() *PreemptionPolicy

func (*Allocation) GetPriority 

func (x *Allocation) GetPriority() int32

func (*Allocation) GetResourcePerAlloc 

func (x *Allocation) GetResourcePerAlloc() *Resource

func (*Allocation) GetTaskGroupName 

func (x *Allocation) GetTaskGroupName() string

func (*Allocation) ProtoMessage 

func (*Allocation) ProtoMessage()

func (*Allocation) ProtoReflect added in v1.4.0 

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

func (*Allocation) Reset 

func (x *Allocation) Reset()

func (*Allocation) String 

func (x *Allocation) String() string

type AllocationAsk 

type AllocationAsk struct {

	// Allocation key is used by both of scheduler and RM to track allocations.
	// It doesn't have to be same as RM's internal allocation id (such as Pod name of K8s or ContainerID of YARN).
	// Allocations from the same AllocationAsk which are returned to the RM at the same time will have the same allocationKey.
	// The request is considered an update of the existing AllocationAsk if an AllocationAsk with the same allocationKey
	// already exists.
	AllocationKey string `protobuf:"bytes,1,opt,name=allocationKey,proto3" json:"allocationKey,omitempty"`
	// The application ID this allocation ask belongs to
	ApplicationID string `protobuf:"bytes,2,opt,name=applicationID,proto3" json:"applicationID,omitempty"`
	// The partition the application belongs to
	PartitionName string `protobuf:"bytes,3,opt,name=partitionName,proto3" json:"partitionName,omitempty"`
	// The amount of resources per ask
	ResourceAsk *Resource `protobuf:"bytes,4,opt,name=resourceAsk,proto3" json:"resourceAsk,omitempty"`
	// Maximum number of allocations
	MaxAllocations int32 `protobuf:"varint,5,opt,name=maxAllocations,proto3" json:"maxAllocations,omitempty"`
	// Priority of ask
	Priority int32 `protobuf:"varint,6,opt,name=priority,proto3" json:"priority,omitempty"`
	// Execution timeout: How long this allocation will be terminated (by scheduler)
	// once allocated by scheduler, 0 or negative value means never expire.
	ExecutionTimeoutMilliSeconds int64 `protobuf:"varint,7,opt,name=executionTimeoutMilliSeconds,proto3" json:"executionTimeoutMilliSeconds,omitempty"`
	// A set of tags for this spscific AllocationAsk. Allocation level tags are used in placing this specific
	// ask on nodes in the cluster. These tags are used in the PlacementConstraints.
	// These tags are optional.
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// The name of the TaskGroup this ask belongs to
	TaskGroupName string `protobuf:"bytes,9,opt,name=taskGroupName,proto3" json:"taskGroupName,omitempty"`
	// Is this a placeholder ask (true) or a real ask (false), defaults to false
	// ignored if the taskGroupName is not set
	Placeholder bool `protobuf:"varint,10,opt,name=placeholder,proto3" json:"placeholder,omitempty"`
	// Is this ask the originator of the application?
	Originator bool `protobuf:"varint,11,opt,name=Originator,proto3" json:"Originator,omitempty"`
	// The preemption policy for this ask
	PreemptionPolicy *PreemptionPolicy `protobuf:"bytes,12,opt,name=preemptionPolicy,proto3" json:"preemptionPolicy,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocationAsk) Descriptor deprecated 

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

Deprecated: Use AllocationAsk.ProtoReflect.Descriptor instead.

func (*AllocationAsk) GetAllocationKey 

func (x *AllocationAsk) GetAllocationKey() string

func (*AllocationAsk) GetApplicationID 

func (x *AllocationAsk) GetApplicationID() string

func (*AllocationAsk) GetExecutionTimeoutMilliSeconds 

func (x *AllocationAsk) GetExecutionTimeoutMilliSeconds() int64

func (*AllocationAsk) GetMaxAllocations 

func (x *AllocationAsk) GetMaxAllocations() int32

func (*AllocationAsk) GetOriginator added in v1.1.0 

func (x *AllocationAsk) GetOriginator() bool

func (*AllocationAsk) GetPartitionName 

func (x *AllocationAsk) GetPartitionName() string

func (*AllocationAsk) GetPlaceholder 

func (x *AllocationAsk) GetPlaceholder() bool

func (*AllocationAsk) GetPreemptionPolicy added in v1.2.0 

func (x *AllocationAsk) GetPreemptionPolicy() *PreemptionPolicy

func (*AllocationAsk) GetPriority 

func (x *AllocationAsk) GetPriority() int32

func (*AllocationAsk) GetResourceAsk 

func (x *AllocationAsk) GetResourceAsk() *Resource

func (*AllocationAsk) GetTags 

func (x *AllocationAsk) GetTags() map[string]string

func (*AllocationAsk) GetTaskGroupName 

func (x *AllocationAsk) GetTaskGroupName() string

func (*AllocationAsk) ProtoMessage 

func (*AllocationAsk) ProtoMessage()

func (*AllocationAsk) ProtoReflect added in v1.4.0 

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

func (*AllocationAsk) Reset 

func (x *AllocationAsk) Reset()

func (*AllocationAsk) String 

func (x *AllocationAsk) String() string

type AllocationAskRelease 

type AllocationAskRelease struct {

	// Which partition to release the ask from, required.
	PartitionName string `protobuf:"bytes,1,opt,name=partitionName,proto3" json:"partitionName,omitempty"`
	// optional, when this is set, filter allocation key by application id.
	// when application id is set and allocationKey is not set, release all allocations key under the application id.
	ApplicationID string `protobuf:"bytes,2,opt,name=applicationID,proto3" json:"applicationID,omitempty"`
	// optional, when this is set, only release allocation ask by specified
	AllocationKey string `protobuf:"bytes,3,opt,name=allocationKey,proto3" json:"allocationKey,omitempty"`
	// Termination type of the released allocation ask
	TerminationType TerminationType `protobuf:"varint,4,opt,name=terminationType,proto3,enum=si.v1.TerminationType" json:"terminationType,omitempty"`
	// For human-readable message
	Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

Release ask

func (*AllocationAskRelease) Descriptor deprecated 

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

Deprecated: Use AllocationAskRelease.ProtoReflect.Descriptor instead.

func (*AllocationAskRelease) GetAllocationKey 

func (x *AllocationAskRelease) GetAllocationKey() string

func (*AllocationAskRelease) GetApplicationID 

func (x *AllocationAskRelease) GetApplicationID() string

func (*AllocationAskRelease) GetMessage 

func (x *AllocationAskRelease) GetMessage() string

func (*AllocationAskRelease) GetPartitionName 

func (x *AllocationAskRelease) GetPartitionName() string

func (*AllocationAskRelease) GetTerminationType 

func (x *AllocationAskRelease) GetTerminationType() TerminationType

func (*AllocationAskRelease) ProtoMessage 

func (*AllocationAskRelease) ProtoMessage()

func (*AllocationAskRelease) ProtoReflect added in v1.4.0 

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

func (*AllocationAskRelease) Reset 

func (x *AllocationAskRelease) Reset()

func (*AllocationAskRelease) String 

func (x *AllocationAskRelease) String() string

type AllocationRelease 

type AllocationRelease struct {

	// The name of the partition the allocation belongs to
	PartitionName string `protobuf:"bytes,1,opt,name=partitionName,proto3" json:"partitionName,omitempty"`
	// The application the allocation belongs to
	ApplicationID string `protobuf:"bytes,2,opt,name=applicationID,proto3" json:"applicationID,omitempty"`
	// Termination type of the released allocation
	TerminationType TerminationType `protobuf:"varint,4,opt,name=terminationType,proto3,enum=si.v1.TerminationType" json:"terminationType,omitempty"`
	// human-readable message
	Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	// AllocationKey from AllocationAsk
	AllocationKey string `protobuf:"bytes,6,opt,name=allocationKey,proto3" json:"allocationKey,omitempty"`
	// AllocationID of the allocation to release, if not set all allocations are released for
	// the applicationID
	AllocationID string `protobuf:"bytes,7,opt,name=allocationID,proto3" json:"allocationID,omitempty"`
	// contains filtered or unexported fields
}

Release allocation: this is a bidirectional message. The Terminationtype defines the origin, or creator, as per the comment. The confirmation or response from the receiver is the same message with the same termination type set.

func (*AllocationRelease) Descriptor deprecated 

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

Deprecated: Use AllocationRelease.ProtoReflect.Descriptor instead.

func (*AllocationRelease) GetAllocationID added in v1.5.0 

func (x *AllocationRelease) GetAllocationID() string

func (*AllocationRelease) GetAllocationKey 

func (x *AllocationRelease) GetAllocationKey() string

func (*AllocationRelease) GetApplicationID 

func (x *AllocationRelease) GetApplicationID() string

func (*AllocationRelease) GetMessage 

func (x *AllocationRelease) GetMessage() string

func (*AllocationRelease) GetPartitionName 

func (x *AllocationRelease) GetPartitionName() string

func (*AllocationRelease) GetTerminationType 

func (x *AllocationRelease) GetTerminationType() TerminationType

func (*AllocationRelease) ProtoMessage 

func (*AllocationRelease) ProtoMessage()

func (*AllocationRelease) ProtoReflect added in v1.4.0 

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

func (*AllocationRelease) Reset 

func (x *AllocationRelease) Reset()

func (*AllocationRelease) String 

func (x *AllocationRelease) String() string

type AllocationReleasesRequest 

type AllocationReleasesRequest struct {

	// The allocations to release
	AllocationsToRelease []*AllocationRelease `protobuf:"bytes,1,rep,name=allocationsToRelease,proto3" json:"allocationsToRelease,omitempty"`
	// The asks to release
	AllocationAsksToRelease []*AllocationAskRelease `protobuf:"bytes,2,rep,name=allocationAsksToRelease,proto3" json:"allocationAsksToRelease,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocationReleasesRequest) Descriptor deprecated 

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

Deprecated: Use AllocationReleasesRequest.ProtoReflect.Descriptor instead.

func (*AllocationReleasesRequest) GetAllocationAsksToRelease 

func (x *AllocationReleasesRequest) GetAllocationAsksToRelease() []*AllocationAskRelease

func (*AllocationReleasesRequest) GetAllocationsToRelease 

func (x *AllocationReleasesRequest) GetAllocationsToRelease() []*AllocationRelease

func (*AllocationReleasesRequest) ProtoMessage 

func (*AllocationReleasesRequest) ProtoMessage()

func (*AllocationReleasesRequest) ProtoReflect added in v1.4.0 

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

func (*AllocationReleasesRequest) Reset 

func (x *AllocationReleasesRequest) Reset()

func (*AllocationReleasesRequest) String 

func (x *AllocationReleasesRequest) String() string

type AllocationRequest 

type AllocationRequest struct {

	// New allocation requests or replace existing allocation request (if allocationID is same)
	Asks []*AllocationAsk `protobuf:"bytes,1,rep,name=asks,proto3" json:"asks,omitempty"`
	// Allocations can be released.
	Releases *AllocationReleasesRequest `protobuf:"bytes,2,opt,name=releases,proto3" json:"releases,omitempty"`
	// ID of RM, this will be used to identify which RM of the request comes from.
	RmID string `protobuf:"bytes,3,opt,name=rmID,proto3" json:"rmID,omitempty"`
	// Existing allocations to be added.
	Allocations []*Allocation `protobuf:"bytes,4,rep,name=allocations,proto3" json:"allocations,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocationRequest) Descriptor deprecated 

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

Deprecated: Use AllocationRequest.ProtoReflect.Descriptor instead.

func (*AllocationRequest) GetAllocations added in v1.4.0 

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

func (*AllocationRequest) GetAsks 

func (x *AllocationRequest) GetAsks() []*AllocationAsk

func (*AllocationRequest) GetReleases 

func (x *AllocationRequest) GetReleases() *AllocationReleasesRequest

func (*AllocationRequest) GetRmID 

func (x *AllocationRequest) GetRmID() string

func (*AllocationRequest) ProtoMessage 

func (*AllocationRequest) ProtoMessage()

func (*AllocationRequest) ProtoReflect added in v1.4.0 

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

func (*AllocationRequest) Reset 

func (x *AllocationRequest) Reset()

func (*AllocationRequest) String 

func (x *AllocationRequest) String() string

type AllocationResponse 

type AllocationResponse struct {

	// New allocations
	New []*Allocation `protobuf:"bytes,1,rep,name=new,proto3" json:"new,omitempty"`
	// Released allocations, this could be either ack from scheduler when RM asks to terminate some allocations.
	// Or it could be decision made by scheduler (such as preemption or timeout).
	Released []*AllocationRelease `protobuf:"bytes,2,rep,name=released,proto3" json:"released,omitempty"`
	// Released allocation asks(placeholder), when the placeholder allocation times out
	ReleasedAsks []*AllocationAskRelease `protobuf:"bytes,3,rep,name=releasedAsks,proto3" json:"releasedAsks,omitempty"`
	// Rejected allocation requests
	Rejected []*RejectedAllocationAsk `protobuf:"bytes,4,rep,name=rejected,proto3" json:"rejected,omitempty"`
	// Rejected allocations
	RejectedAllocations []*RejectedAllocation `protobuf:"bytes,5,rep,name=rejectedAllocations,proto3" json:"rejectedAllocations,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocationResponse) Descriptor deprecated 

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

Deprecated: Use AllocationResponse.ProtoReflect.Descriptor instead.

func (*AllocationResponse) GetNew 

func (x *AllocationResponse) GetNew() []*Allocation

func (*AllocationResponse) GetRejected 

func (x *AllocationResponse) GetRejected() []*RejectedAllocationAsk

func (*AllocationResponse) GetRejectedAllocations added in v1.4.0 

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

func (*AllocationResponse) GetReleased 

func (x *AllocationResponse) GetReleased() []*AllocationRelease

func (*AllocationResponse) GetReleasedAsks 

func (x *AllocationResponse) GetReleasedAsks() []*AllocationAskRelease

func (*AllocationResponse) ProtoMessage 

func (*AllocationResponse) ProtoMessage()

func (*AllocationResponse) ProtoReflect added in v1.4.0 

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

func (*AllocationResponse) Reset 

func (x *AllocationResponse) Reset()

func (*AllocationResponse) String 

func (x *AllocationResponse) String() string

type ApplicationRequest 

type ApplicationRequest struct {

	// RM should explicitly add application when allocation request also explictly belongs to application.
	// This is optional if allocation request doesn't belong to a application. (Independent allocation)
	New []*AddApplicationRequest `protobuf:"bytes,1,rep,name=new,proto3" json:"new,omitempty"`
	// RM can also remove applications, all allocation/allocation requests associated with the application will be removed
	Remove []*RemoveApplicationRequest `protobuf:"bytes,2,rep,name=remove,proto3" json:"remove,omitempty"`
	// ID of RM, this will be used to identify which RM of the request comes from.
	RmID string `protobuf:"bytes,3,opt,name=rmID,proto3" json:"rmID,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplicationRequest) Descriptor deprecated 

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

Deprecated: Use ApplicationRequest.ProtoReflect.Descriptor instead.

func (*ApplicationRequest) GetNew 

func (x *ApplicationRequest) GetNew() []*AddApplicationRequest

func (*ApplicationRequest) GetRemove 

func (x *ApplicationRequest) GetRemove() []*RemoveApplicationRequest

func (*ApplicationRequest) GetRmID 

func (x *ApplicationRequest) GetRmID() string

func (*ApplicationRequest) ProtoMessage 

func (*ApplicationRequest) ProtoMessage()

func (*ApplicationRequest) ProtoReflect added in v1.4.0 

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

func (*ApplicationRequest) Reset 

func (x *ApplicationRequest) Reset()

func (*ApplicationRequest) String 

func (x *ApplicationRequest) String() string

type ApplicationResponse 

type ApplicationResponse struct {

	// Rejected Applications
	Rejected []*RejectedApplication `protobuf:"bytes,1,rep,name=rejected,proto3" json:"rejected,omitempty"`
	// Accepted Applications
	Accepted []*AcceptedApplication `protobuf:"bytes,2,rep,name=accepted,proto3" json:"accepted,omitempty"`
	// Updated Applications
	Updated []*UpdatedApplication `protobuf:"bytes,3,rep,name=updated,proto3" json:"updated,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplicationResponse) Descriptor deprecated 

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

Deprecated: Use ApplicationResponse.ProtoReflect.Descriptor instead.

func (*ApplicationResponse) GetAccepted 

func (x *ApplicationResponse) GetAccepted() []*AcceptedApplication

func (*ApplicationResponse) GetRejected 

func (x *ApplicationResponse) GetRejected() []*RejectedApplication

func (*ApplicationResponse) GetUpdated 

func (x *ApplicationResponse) GetUpdated() []*UpdatedApplication

func (*ApplicationResponse) ProtoMessage 

func (*ApplicationResponse) ProtoMessage()

func (*ApplicationResponse) ProtoReflect added in v1.4.0 

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

func (*ApplicationResponse) Reset 

func (x *ApplicationResponse) Reset()

func (*ApplicationResponse) String 

func (x *ApplicationResponse) String() string

type EventRecord 

type EventRecord struct {

	// the type of the object associated with the event
	Type EventRecord_Type `protobuf:"varint,1,opt,name=type,proto3,enum=si.v1.EventRecord_Type" json:"type,omitempty"`
	// ID of the object associated with the event
	ObjectID string `protobuf:"bytes,2,opt,name=objectID,proto3" json:"objectID,omitempty"`
	// the detailed message as string
	Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	// timestamp of the event
	TimestampNano int64 `protobuf:"varint,6,opt,name=timestampNano,proto3" json:"timestampNano,omitempty"`
	// the type of the change
	EventChangeType EventRecord_ChangeType `protobuf:"varint,7,opt,name=eventChangeType,proto3,enum=si.v1.EventRecord_ChangeType" json:"eventChangeType,omitempty"`
	// details about the change
	EventChangeDetail EventRecord_ChangeDetail `protobuf:"varint,8,opt,name=eventChangeDetail,proto3,enum=si.v1.EventRecord_ChangeDetail" json:"eventChangeDetail,omitempty"`
	// the secondary object in the event (eg. allocation ID, request ID)
	ReferenceID string `protobuf:"bytes,9,opt,name=referenceID,proto3" json:"referenceID,omitempty"`
	// the resource value if the change involves setting/modifying a resource
	Resource *Resource `protobuf:"bytes,10,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

func (*EventRecord) Descriptor deprecated 

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

Deprecated: Use EventRecord.ProtoReflect.Descriptor instead.

func (*EventRecord) GetEventChangeDetail added in v1.4.0 

func (x *EventRecord) GetEventChangeDetail() EventRecord_ChangeDetail

func (*EventRecord) GetEventChangeType added in v1.4.0 

func (x *EventRecord) GetEventChangeType() EventRecord_ChangeType

func (*EventRecord) GetMessage 

func (x *EventRecord) GetMessage() string

func (*EventRecord) GetObjectID 

func (x *EventRecord) GetObjectID() string

func (*EventRecord) GetReferenceID added in v1.4.0 

func (x *EventRecord) GetReferenceID() string

func (*EventRecord) GetResource added in v1.4.0 

func (x *EventRecord) GetResource() *Resource

func (*EventRecord) GetTimestampNano 

func (x *EventRecord) GetTimestampNano() int64

func (*EventRecord) GetType 

func (x *EventRecord) GetType() EventRecord_Type

func (*EventRecord) ProtoMessage 

func (*EventRecord) ProtoMessage()

func (*EventRecord) ProtoReflect added in v1.4.0 

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

func (*EventRecord) Reset 

func (x *EventRecord) Reset()

func (*EventRecord) String 

func (x *EventRecord) String() string

type EventRecord_ChangeDetail added in v1.4.0 

type EventRecord_ChangeDetail int32
const (
	EventRecord_DETAILS_NONE        EventRecord_ChangeDetail = 0
	EventRecord_REQUEST_CANCEL      EventRecord_ChangeDetail = 100 // Request cancelled by the RM
	EventRecord_REQUEST_ALLOC       EventRecord_ChangeDetail = 101 // Request allocated
	EventRecord_REQUEST_TIMEOUT     EventRecord_ChangeDetail = 102 // Request cancelled due to timeout
	EventRecord_APP_ALLOC           EventRecord_ChangeDetail = 200 // Allocation changed
	EventRecord_APP_REQUEST         EventRecord_ChangeDetail = 201 // Request changed
	EventRecord_APP_REJECT          EventRecord_ChangeDetail = 202 // Application rejected on create
	EventRecord_APP_NEW             EventRecord_ChangeDetail = 203 // Application added with state new
	EventRecord_APP_ACCEPTED        EventRecord_ChangeDetail = 204 // State change to accepted
	EventRecord_APP_STARTING        EventRecord_ChangeDetail = 205 // State change to starting
	EventRecord_APP_RUNNING         EventRecord_ChangeDetail = 206 // State change to running
	EventRecord_APP_COMPLETING      EventRecord_ChangeDetail = 207 // State change to completing
	EventRecord_APP_COMPLETED       EventRecord_ChangeDetail = 208 // State change to completed
	EventRecord_APP_FAILING         EventRecord_ChangeDetail = 209 // State change to failing
	EventRecord_APP_FAILED          EventRecord_ChangeDetail = 210 // State change to failed
	EventRecord_APP_RESUMING        EventRecord_ChangeDetail = 211 // State change to resuming
	EventRecord_APP_EXPIRED         EventRecord_ChangeDetail = 212 // State change to expired
	EventRecord_APP_CANNOTRUN_QUEUE EventRecord_ChangeDetail = 213 // Application cannot run in the queue (maxApplications hit)
	EventRecord_APP_RUNNABLE_QUEUE  EventRecord_ChangeDetail = 214 // Application is allowed to run (after maxApplications limit hit)
	EventRecord_APP_CANNOTRUN_QUOTA EventRecord_ChangeDetail = 215 // Application cannot run due to user/group quota (maxApplications hit)
	EventRecord_APP_RUNNABLE_QUOTA  EventRecord_ChangeDetail = 216 // Application is allowed to run based on user/group quota (after maxApplications limit hit)
	EventRecord_NODE_DECOMISSION    EventRecord_ChangeDetail = 300 // Node removal
	EventRecord_NODE_READY          EventRecord_ChangeDetail = 301 // Node ready state change
	EventRecord_NODE_SCHEDULABLE    EventRecord_ChangeDetail = 302 // Node schedulable state change (cordon)
	EventRecord_NODE_ALLOC          EventRecord_ChangeDetail = 303 // Allocation changed
	EventRecord_NODE_CAPACITY       EventRecord_ChangeDetail = 304 // Capacity changed
	EventRecord_NODE_OCCUPIED       EventRecord_ChangeDetail = 305 // Occupied resource changed
	EventRecord_NODE_RESERVATION    EventRecord_ChangeDetail = 306 // Reservation/unreservation occurred
	EventRecord_QUEUE_CONFIG        EventRecord_ChangeDetail = 400 // Managed queue update or removal
	EventRecord_QUEUE_DYNAMIC       EventRecord_ChangeDetail = 401 // Dynamic queue update or removal
	EventRecord_QUEUE_TYPE          EventRecord_ChangeDetail = 402 // Queue type change
	EventRecord_QUEUE_MAX           EventRecord_ChangeDetail = 403 // Max resource changed
	EventRecord_QUEUE_GUARANTEED    EventRecord_ChangeDetail = 404 // Guaranteed resource changed
	EventRecord_QUEUE_APP           EventRecord_ChangeDetail = 405 // Application changed
	EventRecord_QUEUE_ALLOC         EventRecord_ChangeDetail = 406 // Allocation changed
	EventRecord_ALLOC_CANCEL        EventRecord_ChangeDetail = 500 // Allocation cancelled by the RM
	EventRecord_ALLOC_PREEMPT       EventRecord_ChangeDetail = 501 // Allocation preempted by the core
	EventRecord_ALLOC_TIMEOUT       EventRecord_ChangeDetail = 502 // Allocation cancelled due to timeout
	EventRecord_ALLOC_REPLACED      EventRecord_ChangeDetail = 503 // Allocation replacement (placeholder)
	EventRecord_ALLOC_NODEREMOVED   EventRecord_ChangeDetail = 504 // Allocation cancelled, node removal
	EventRecord_UG_USER_LIMIT       EventRecord_ChangeDetail = 600 // Limit is changed (set/unset) for a given user
	EventRecord_UG_GROUP_LIMIT      EventRecord_ChangeDetail = 601 // Limit is changed (set/unset) for a given group
	EventRecord_UG_APP_LINK         EventRecord_ChangeDetail = 602 // Linkage is changed (created/removed) between an application and a group
	EventRecord_UG_USER_RESOURCE    EventRecord_ChangeDetail = 603 // Resource usage updated for a user
	EventRecord_UG_GROUP_RESOURCE   EventRecord_ChangeDetail = 604 // Resource usage updated for a group
)

func (EventRecord_ChangeDetail) Descriptor added in v1.4.0 

func (EventRecord_ChangeDetail) Descriptor() protoreflect.EnumDescriptor

func (EventRecord_ChangeDetail) Enum added in v1.4.0 

func (x EventRecord_ChangeDetail) Enum() *EventRecord_ChangeDetail

func (EventRecord_ChangeDetail) EnumDescriptor deprecated added in v1.4.0 

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

Deprecated: Use EventRecord_ChangeDetail.Descriptor instead.

func (EventRecord_ChangeDetail) Number added in v1.4.0 

func (x EventRecord_ChangeDetail) Number() protoreflect.EnumNumber

func (EventRecord_ChangeDetail) String added in v1.4.0 

func (x EventRecord_ChangeDetail) String() string

func (EventRecord_ChangeDetail) Type added in v1.4.0 

func (EventRecord_ChangeDetail) Type() protoreflect.EnumType

type EventRecord_ChangeType added in v1.4.0 

type EventRecord_ChangeType int32
const (
	EventRecord_NONE   EventRecord_ChangeType = 0
	EventRecord_SET    EventRecord_ChangeType = 1
	EventRecord_ADD    EventRecord_ChangeType = 2
	EventRecord_REMOVE EventRecord_ChangeType = 3
)

func (EventRecord_ChangeType) Descriptor added in v1.4.0 

func (EventRecord_ChangeType) Descriptor() protoreflect.EnumDescriptor

func (EventRecord_ChangeType) Enum added in v1.4.0 

func (x EventRecord_ChangeType) Enum() *EventRecord_ChangeType

func (EventRecord_ChangeType) EnumDescriptor deprecated added in v1.4.0 

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

Deprecated: Use EventRecord_ChangeType.Descriptor instead.

func (EventRecord_ChangeType) Number added in v1.4.0 

func (x EventRecord_ChangeType) Number() protoreflect.EnumNumber

func (EventRecord_ChangeType) String added in v1.4.0 

func (x EventRecord_ChangeType) String() string

func (EventRecord_ChangeType) Type added in v1.4.0 

func (EventRecord_ChangeType) Type() protoreflect.EnumType

type EventRecord_Type 

type EventRecord_Type int32
const (
	// EventRecord Type not set
	EventRecord_UNKNOWN_EVENTRECORD_TYPE EventRecord_Type = 0
	EventRecord_REQUEST                  EventRecord_Type = 1
	EventRecord_APP                      EventRecord_Type = 2
	EventRecord_NODE                     EventRecord_Type = 3
	EventRecord_QUEUE                    EventRecord_Type = 4
	EventRecord_USERGROUP                EventRecord_Type = 5
)

func (EventRecord_Type) Descriptor added in v1.4.0 

func (EventRecord_Type) Descriptor() protoreflect.EnumDescriptor

func (EventRecord_Type) Enum added in v1.4.0 

func (x EventRecord_Type) Enum() *EventRecord_Type

func (EventRecord_Type) EnumDescriptor deprecated 

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

Deprecated: Use EventRecord_Type.Descriptor instead.

func (EventRecord_Type) Number added in v1.4.0 

func (x EventRecord_Type) Number() protoreflect.EnumNumber

func (EventRecord_Type) String 

func (x EventRecord_Type) String() string

func (EventRecord_Type) Type added in v1.4.0 

func (EventRecord_Type) Type() protoreflect.EnumType

type NodeInfo 

type NodeInfo struct {

	// ID of node, the node must exist to be updated
	NodeID string `protobuf:"bytes,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	// Action to perform by the scheduler
	Action NodeInfo_ActionFromRM `protobuf:"varint,2,opt,name=action,proto3,enum=si.v1.NodeInfo_ActionFromRM" json:"action,omitempty"`
	// New attributes of node, which will replace previously reported attribute.
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// new schedulable resource, scheduler may preempt allocations on the
	// node or schedule more allocations accordingly.
	SchedulableResource *Resource `protobuf:"bytes,4,opt,name=schedulableResource,proto3" json:"schedulableResource,omitempty"`
	// when the scheduler is co-exist with some other schedulers, some node
	// resources might be occupied (allocated) by other schedulers.
	OccupiedResource *Resource `protobuf:"bytes,5,opt,name=occupiedResource,proto3" json:"occupiedResource,omitempty"`
	// Allocated resources, this will be added when node registered to RM (recovery)
	ExistingAllocations []*Allocation `protobuf:"bytes,6,rep,name=existingAllocations,proto3" json:"existingAllocations,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfo) Descriptor deprecated 

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

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetAction 

func (x *NodeInfo) GetAction() NodeInfo_ActionFromRM

func (*NodeInfo) GetAttributes 

func (x *NodeInfo) GetAttributes() map[string]string

func (*NodeInfo) GetExistingAllocations 

func (x *NodeInfo) GetExistingAllocations() []*Allocation

func (*NodeInfo) GetNodeID 

func (x *NodeInfo) GetNodeID() string

func (*NodeInfo) GetOccupiedResource 

func (x *NodeInfo) GetOccupiedResource() *Resource

func (*NodeInfo) GetSchedulableResource 

func (x *NodeInfo) GetSchedulableResource() *Resource

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect added in v1.4.0 

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

func (*NodeInfo) Reset 

func (x *NodeInfo) Reset()

func (*NodeInfo) String 

func (x *NodeInfo) String() string

type NodeInfo_ActionFromRM 

type NodeInfo_ActionFromRM int32

Action from RM 

const (
	// ActionFromRM not set
	NodeInfo_UNKNOWN_ACTION_FROM_RM NodeInfo_ActionFromRM = 0
	// Create Node as initially schedulable.
	NodeInfo_CREATE NodeInfo_ActionFromRM = 1
	// Update node resources, attributes.
	NodeInfo_UPDATE NodeInfo_ActionFromRM = 2
	// Do not allocate new allocations on the node.
	NodeInfo_DRAIN_NODE NodeInfo_ActionFromRM = 3
	// Decomission node, it will immediately stop allocations on the node and
	// remove the node from schedulable lists.
	NodeInfo_DECOMISSION NodeInfo_ActionFromRM = 4
	// From Draining state to SCHEDULABLE state.
	// If node is not in draining state, error will be thrown
	NodeInfo_DRAIN_TO_SCHEDULABLE NodeInfo_ActionFromRM = 5
	// Create Node as initially draining (i.e. unschedulable). Before scheduling can proceed,
	// DRAIN_TO_SCHEDULABLE must be called.
	NodeInfo_CREATE_DRAIN NodeInfo_ActionFromRM = 6
)

func (NodeInfo_ActionFromRM) Descriptor added in v1.4.0 

func (NodeInfo_ActionFromRM) Descriptor() protoreflect.EnumDescriptor

func (NodeInfo_ActionFromRM) Enum added in v1.4.0 

func (x NodeInfo_ActionFromRM) Enum() *NodeInfo_ActionFromRM

func (NodeInfo_ActionFromRM) EnumDescriptor deprecated 

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

Deprecated: Use NodeInfo_ActionFromRM.Descriptor instead.

func (NodeInfo_ActionFromRM) Number added in v1.4.0 

func (x NodeInfo_ActionFromRM) Number() protoreflect.EnumNumber

func (NodeInfo_ActionFromRM) String 

func (x NodeInfo_ActionFromRM) String() string

func (NodeInfo_ActionFromRM) Type added in v1.4.0 

func (NodeInfo_ActionFromRM) Type() protoreflect.EnumType

type NodeRequest 

type NodeRequest struct {

	// New node can be scheduled. If a node is notified to be "unscheduable", it needs to be part of this field as well.
	Nodes []*NodeInfo `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// ID of RM, this will be used to identify which RM of the request comes from.
	RmID string `protobuf:"bytes,2,opt,name=rmID,proto3" json:"rmID,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeRequest) Descriptor deprecated 

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

Deprecated: Use NodeRequest.ProtoReflect.Descriptor instead.

func (*NodeRequest) GetNodes 

func (x *NodeRequest) GetNodes() []*NodeInfo

func (*NodeRequest) GetRmID 

func (x *NodeRequest) GetRmID() string

func (*NodeRequest) ProtoMessage 

func (*NodeRequest) ProtoMessage()

func (*NodeRequest) ProtoReflect added in v1.4.0 

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

func (*NodeRequest) Reset 

func (x *NodeRequest) Reset()

func (*NodeRequest) String 

func (x *NodeRequest) String() string

type NodeResponse 

type NodeResponse struct {

	// Rejected Node Registrations
	Rejected []*RejectedNode `protobuf:"bytes,1,rep,name=rejected,proto3" json:"rejected,omitempty"`
	// Accepted Node Registrations
	Accepted []*AcceptedNode `protobuf:"bytes,2,rep,name=accepted,proto3" json:"accepted,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeResponse) Descriptor deprecated 

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

Deprecated: Use NodeResponse.ProtoReflect.Descriptor instead.

func (*NodeResponse) GetAccepted 

func (x *NodeResponse) GetAccepted() []*AcceptedNode

func (*NodeResponse) GetRejected 

func (x *NodeResponse) GetRejected() []*RejectedNode

func (*NodeResponse) ProtoMessage 

func (*NodeResponse) ProtoMessage()

func (*NodeResponse) ProtoReflect added in v1.4.0 

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

func (*NodeResponse) Reset 

func (x *NodeResponse) Reset()

func (*NodeResponse) String 

func (x *NodeResponse) String() string

type PredicatesArgs 

type PredicatesArgs struct {

	// allocation key identifies a container, the predicates function is going to check
	// if this container is eligible to be placed ont to a node.
	AllocationKey string `protobuf:"bytes,1,opt,name=allocationKey,proto3" json:"allocationKey,omitempty"`
	// the node ID the container is assigned to.
	NodeID string `protobuf:"bytes,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	// run the predicates for alloactions (true) or reservations (false)
	Allocate bool `protobuf:"varint,3,opt,name=allocate,proto3" json:"allocate,omitempty"`
	// contains filtered or unexported fields
}

func (*PredicatesArgs) Descriptor deprecated 

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

Deprecated: Use PredicatesArgs.ProtoReflect.Descriptor instead.

func (*PredicatesArgs) GetAllocate 

func (x *PredicatesArgs) GetAllocate() bool

func (*PredicatesArgs) GetAllocationKey 

func (x *PredicatesArgs) GetAllocationKey() string

func (*PredicatesArgs) GetNodeID 

func (x *PredicatesArgs) GetNodeID() string

func (*PredicatesArgs) ProtoMessage 

func (*PredicatesArgs) ProtoMessage()

func (*PredicatesArgs) ProtoReflect added in v1.4.0 

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

func (*PredicatesArgs) Reset 

func (x *PredicatesArgs) Reset()

func (*PredicatesArgs) String 

func (x *PredicatesArgs) String() string

type PreemptionPolicy added in v1.2.0 

type PreemptionPolicy struct {

	// Opt-out from preemption
	AllowPreemptSelf bool `protobuf:"varint,1,opt,name=allowPreemptSelf,proto3" json:"allowPreemptSelf,omitempty"`
	// Allow preemption of other tasks with same or lower priority
	AllowPreemptOther bool `protobuf:"varint,2,opt,name=allowPreemptOther,proto3" json:"allowPreemptOther,omitempty"`
	// contains filtered or unexported fields
}

func (*PreemptionPolicy) Descriptor deprecated added in v1.2.0 

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

Deprecated: Use PreemptionPolicy.ProtoReflect.Descriptor instead.

func (*PreemptionPolicy) GetAllowPreemptOther added in v1.2.0 

func (x *PreemptionPolicy) GetAllowPreemptOther() bool

func (*PreemptionPolicy) GetAllowPreemptSelf added in v1.2.0 

func (x *PreemptionPolicy) GetAllowPreemptSelf() bool

func (*PreemptionPolicy) ProtoMessage added in v1.2.0 

func (*PreemptionPolicy) ProtoMessage()

func (*PreemptionPolicy) ProtoReflect added in v1.4.0 

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

func (*PreemptionPolicy) Reset added in v1.2.0 

func (x *PreemptionPolicy) Reset()

func (*PreemptionPolicy) String added in v1.2.0 

func (x *PreemptionPolicy) String() string

type PreemptionPredicatesArgs added in v1.3.0 

type PreemptionPredicatesArgs struct {

	// the allocation key of the container to check
	AllocationKey string `protobuf:"bytes,1,opt,name=allocationKey,proto3" json:"allocationKey,omitempty"`
	// the node ID the container should be attempted to be scheduled on
	NodeID string `protobuf:"bytes,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	// a list of existing allocations that should be tentatively removed before checking
	PreemptAllocationKeys []string `protobuf:"bytes,3,rep,name=preemptAllocationKeys,proto3" json:"preemptAllocationKeys,omitempty"`
	// index of last allocation in starting attempt (first attempt should be 0..startIndex)
	StartIndex int32 `protobuf:"varint,4,opt,name=startIndex,proto3" json:"startIndex,omitempty"`
	// contains filtered or unexported fields
}

func (*PreemptionPredicatesArgs) Descriptor deprecated added in v1.3.0 

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

Deprecated: Use PreemptionPredicatesArgs.ProtoReflect.Descriptor instead.

func (*PreemptionPredicatesArgs) GetAllocationKey added in v1.3.0 

func (x *PreemptionPredicatesArgs) GetAllocationKey() string

func (*PreemptionPredicatesArgs) GetNodeID added in v1.3.0 

func (x *PreemptionPredicatesArgs) GetNodeID() string

func (*PreemptionPredicatesArgs) GetPreemptAllocationKeys added in v1.3.0 

func (x *PreemptionPredicatesArgs) GetPreemptAllocationKeys() []string

func (*PreemptionPredicatesArgs) GetStartIndex added in v1.3.0 

func (x *PreemptionPredicatesArgs) GetStartIndex() int32

func (*PreemptionPredicatesArgs) ProtoMessage added in v1.3.0 

func (*PreemptionPredicatesArgs) ProtoMessage()

func (*PreemptionPredicatesArgs) ProtoReflect added in v1.4.0 

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

func (*PreemptionPredicatesArgs) Reset added in v1.3.0 

func (x *PreemptionPredicatesArgs) Reset()

func (*PreemptionPredicatesArgs) String added in v1.3.0 

func (x *PreemptionPredicatesArgs) String() string

type PreemptionPredicatesResponse added in v1.3.0 

type PreemptionPredicatesResponse struct {

	// whether or not container will schedule on the node
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// index of last allocation which was removed before success (ignored during failure)
	Index int32 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

func (*PreemptionPredicatesResponse) Descriptor deprecated added in v1.3.0 

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

Deprecated: Use PreemptionPredicatesResponse.ProtoReflect.Descriptor instead.

func (*PreemptionPredicatesResponse) GetIndex added in v1.3.0 

func (x *PreemptionPredicatesResponse) GetIndex() int32

func (*PreemptionPredicatesResponse) GetSuccess added in v1.3.0 

func (x *PreemptionPredicatesResponse) GetSuccess() bool

func (*PreemptionPredicatesResponse) ProtoMessage added in v1.3.0 

func (*PreemptionPredicatesResponse) ProtoMessage()

func (*PreemptionPredicatesResponse) ProtoReflect added in v1.4.0 

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

func (*PreemptionPredicatesResponse) Reset added in v1.3.0 

func (x *PreemptionPredicatesResponse) Reset()

func (*PreemptionPredicatesResponse) String added in v1.3.0 

func (x *PreemptionPredicatesResponse) String() string

type Quantity 

type Quantity struct {
	Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Quantity includes a single int64 value

func (*Quantity) Descriptor deprecated 

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

Deprecated: Use Quantity.ProtoReflect.Descriptor instead.

func (*Quantity) GetValue 

func (x *Quantity) GetValue() int64

func (*Quantity) ProtoMessage 

func (*Quantity) ProtoMessage()

func (*Quantity) ProtoReflect added in v1.4.0 

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

func (*Quantity) Reset 

func (x *Quantity) Reset()

func (*Quantity) String 

func (x *Quantity) String() string

type RegisterResourceManagerRequest 

type RegisterResourceManagerRequest struct {

	// An ID which can uniquely identify a RM **cluster**. (For example, if a RM cluster has multiple manager instances for HA purpose, they should use the same information when do registration).
	// If RM register with the same ID, all previous scheduling state in memory will be cleaned up, and expect RM report full scheduling state after registration.
	RmID string `protobuf:"bytes,1,opt,name=rmID,proto3" json:"rmID,omitempty"`
	// Version of RM scheduler interface client.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// Policy group name:
	// This defines which policy to use. Policy should be statically configured. (Think about network security group concept of ec2).
	// Different RMs can refer to the same policyGroup if their static configuration is identical.
	PolicyGroup string `protobuf:"bytes,3,opt,name=policyGroup,proto3" json:"policyGroup,omitempty"`
	// Pass the build information of k8shim to core.
	BuildInfo map[string]string `` /* 159-byte string literal not displayed */
	// Pass the serialized configuration for this policyGroup to core.
	Config string `protobuf:"bytes,5,opt,name=config,proto3" json:"config,omitempty"`
	// Additional configuration key/value pairs for configuration not related to the policyGroup.
	ExtraConfig map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RegisterResourceManagerRequest) Descriptor deprecated 

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

Deprecated: Use RegisterResourceManagerRequest.ProtoReflect.Descriptor instead.

func (*RegisterResourceManagerRequest) GetBuildInfo 

func (x *RegisterResourceManagerRequest) GetBuildInfo() map[string]string

func (*RegisterResourceManagerRequest) GetConfig added in v1.2.0 

func (x *RegisterResourceManagerRequest) GetConfig() string

func (*RegisterResourceManagerRequest) GetExtraConfig added in v1.2.0 

func (x *RegisterResourceManagerRequest) GetExtraConfig() map[string]string

func (*RegisterResourceManagerRequest) GetPolicyGroup 

func (x *RegisterResourceManagerRequest) GetPolicyGroup() string

func (*RegisterResourceManagerRequest) GetRmID 

func (x *RegisterResourceManagerRequest) GetRmID() string

func (*RegisterResourceManagerRequest) GetVersion 

func (x *RegisterResourceManagerRequest) GetVersion() string

func (*RegisterResourceManagerRequest) ProtoMessage 

func (*RegisterResourceManagerRequest) ProtoMessage()

func (*RegisterResourceManagerRequest) ProtoReflect added in v1.4.0 

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

func (*RegisterResourceManagerRequest) Reset 

func (x *RegisterResourceManagerRequest) Reset()

func (*RegisterResourceManagerRequest) String 

func (x *RegisterResourceManagerRequest) String() string

type RegisterResourceManagerResponse 

type RegisterResourceManagerResponse struct {
	// contains filtered or unexported fields
}

Upon success, scheduler returns RegisterResourceManagerResponse to RM, otherwise RM receives exception.

func (*RegisterResourceManagerResponse) Descriptor deprecated 

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

Deprecated: Use RegisterResourceManagerResponse.ProtoReflect.Descriptor instead.

func (*RegisterResourceManagerResponse) ProtoMessage 

func (*RegisterResourceManagerResponse) ProtoMessage()

func (*RegisterResourceManagerResponse) ProtoReflect added in v1.4.0 

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

func (*RegisterResourceManagerResponse) Reset 

func (x *RegisterResourceManagerResponse) Reset()

func (*RegisterResourceManagerResponse) String 

func (x *RegisterResourceManagerResponse) String() string

type RejectedAllocation added in v1.4.0 

type RejectedAllocation struct {

	// the ID of the allocation
	AllocationKey string `protobuf:"bytes,1,opt,name=allocationKey,proto3" json:"allocationKey,omitempty"`
	// The ID of the application
	ApplicationID string `protobuf:"bytes,2,opt,name=applicationID,proto3" json:"applicationID,omitempty"`
	// A human-readable reason message
	Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*RejectedAllocation) Descriptor deprecated added in v1.4.0 

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

Deprecated: Use RejectedAllocation.ProtoReflect.Descriptor instead.

func (*RejectedAllocation) GetAllocationKey added in v1.4.0 

func (x *RejectedAllocation) GetAllocationKey() string

func (*RejectedAllocation) GetApplicationID added in v1.4.0 

func (x *RejectedAllocation) GetApplicationID() string

func (*RejectedAllocation) GetReason added in v1.4.0 

func (x *RejectedAllocation) GetReason() string

func (*RejectedAllocation) ProtoMessage added in v1.4.0 

func (*RejectedAllocation) ProtoMessage()

func (*RejectedAllocation) ProtoReflect added in v1.4.0 

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

func (*RejectedAllocation) Reset added in v1.4.0 

func (x *RejectedAllocation) Reset()

func (*RejectedAllocation) String added in v1.4.0 

func (x *RejectedAllocation) String() string

type RejectedAllocationAsk 

type RejectedAllocationAsk struct {

	// the ID of the allocation ask
	AllocationKey string `protobuf:"bytes,1,opt,name=allocationKey,proto3" json:"allocationKey,omitempty"`
	// The ID of the application
	ApplicationID string `protobuf:"bytes,2,opt,name=applicationID,proto3" json:"applicationID,omitempty"`
	// A human-readable reason message
	Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*RejectedAllocationAsk) Descriptor deprecated 

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

Deprecated: Use RejectedAllocationAsk.ProtoReflect.Descriptor instead.

func (*RejectedAllocationAsk) GetAllocationKey 

func (x *RejectedAllocationAsk) GetAllocationKey() string

func (*RejectedAllocationAsk) GetApplicationID 

func (x *RejectedAllocationAsk) GetApplicationID() string

func (*RejectedAllocationAsk) GetReason 

func (x *RejectedAllocationAsk) GetReason() string

func (*RejectedAllocationAsk) ProtoMessage 

func (*RejectedAllocationAsk) ProtoMessage()

func (*RejectedAllocationAsk) ProtoReflect added in v1.4.0 

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

func (*RejectedAllocationAsk) Reset 

func (x *RejectedAllocationAsk) Reset()

func (*RejectedAllocationAsk) String 

func (x *RejectedAllocationAsk) String() string

type RejectedApplication 

type RejectedApplication struct {

	// The application ID that was rejected
	ApplicationID string `protobuf:"bytes,1,opt,name=applicationID,proto3" json:"applicationID,omitempty"`
	// A human-readable reason message
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*RejectedApplication) Descriptor deprecated 

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

Deprecated: Use RejectedApplication.ProtoReflect.Descriptor instead.

func (*RejectedApplication) GetApplicationID 

func (x *RejectedApplication) GetApplicationID() string

func (*RejectedApplication) GetReason 

func (x *RejectedApplication) GetReason() string

func (*RejectedApplication) ProtoMessage 

func (*RejectedApplication) ProtoMessage()

func (*RejectedApplication) ProtoReflect added in v1.4.0 

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

func (*RejectedApplication) Reset 

func (x *RejectedApplication) Reset()

func (*RejectedApplication) String 

func (x *RejectedApplication) String() string

type RejectedNode 

type RejectedNode struct {

	// The node ID that was rejected
	NodeID string `protobuf:"bytes,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	// A human-readable reason message
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*RejectedNode) Descriptor deprecated 

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

Deprecated: Use RejectedNode.ProtoReflect.Descriptor instead.

func (*RejectedNode) GetNodeID 

func (x *RejectedNode) GetNodeID() string

func (*RejectedNode) GetReason 

func (x *RejectedNode) GetReason() string

func (*RejectedNode) ProtoMessage 

func (*RejectedNode) ProtoMessage()

func (*RejectedNode) ProtoReflect added in v1.4.0 

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

func (*RejectedNode) Reset 

func (x *RejectedNode) Reset()

func (*RejectedNode) String 

func (x *RejectedNode) String() string

type RemoveApplicationRequest 

type RemoveApplicationRequest struct {

	// The ID of the application to remove
	ApplicationID string `protobuf:"bytes,1,opt,name=applicationID,proto3" json:"applicationID,omitempty"`
	// The partition the application belongs to
	PartitionName string `protobuf:"bytes,2,opt,name=partitionName,proto3" json:"partitionName,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveApplicationRequest) Descriptor deprecated 

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

Deprecated: Use RemoveApplicationRequest.ProtoReflect.Descriptor instead.

func (*RemoveApplicationRequest) GetApplicationID 

func (x *RemoveApplicationRequest) GetApplicationID() string

func (*RemoveApplicationRequest) GetPartitionName 

func (x *RemoveApplicationRequest) GetPartitionName() string

func (*RemoveApplicationRequest) ProtoMessage 

func (*RemoveApplicationRequest) ProtoMessage()

func (*RemoveApplicationRequest) ProtoReflect added in v1.4.0 

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

func (*RemoveApplicationRequest) Reset 

func (x *RemoveApplicationRequest) Reset()

func (*RemoveApplicationRequest) String 

func (x *RemoveApplicationRequest) String() string

type Resource 

type Resource struct {
	Resources map[string]*Quantity `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

A sparse map of resource to Quantity.

func (*Resource) Descriptor deprecated 

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

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetResources 

func (x *Resource) GetResources() map[string]*Quantity

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect added in v1.4.0 

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

func (*Resource) Reset 

func (x *Resource) Reset()

func (*Resource) String 

func (x *Resource) String() string

type SchedulerClient 

type SchedulerClient interface {
	// Register a RM, if it is a reconnect from previous RM the call will
	// trigger a cleanup of all in-memory data and resync with RM.
	RegisterResourceManager(ctx context.Context, in *RegisterResourceManagerRequest, opts ...grpc.CallOption) (*RegisterResourceManagerResponse, error)
	// Update Scheduler status (this includes node status update, allocation request
	// updates, etc. And receive updates from scheduler for allocation changes,
	// any required status changes, etc.
	// Update allocation request
	UpdateAllocation(ctx context.Context, opts ...grpc.CallOption) (Scheduler_UpdateAllocationClient, error)
	// Update application request
	UpdateApplication(ctx context.Context, opts ...grpc.CallOption) (Scheduler_UpdateApplicationClient, error)
	// Update node info
	UpdateNode(ctx context.Context, opts ...grpc.CallOption) (Scheduler_UpdateNodeClient, error)
}

SchedulerClient is the client API for Scheduler service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSchedulerClient 

func NewSchedulerClient(cc grpc.ClientConnInterface) SchedulerClient

type SchedulerServer 

type SchedulerServer interface {
	// Register a RM, if it is a reconnect from previous RM the call will
	// trigger a cleanup of all in-memory data and resync with RM.
	RegisterResourceManager(context.Context, *RegisterResourceManagerRequest) (*RegisterResourceManagerResponse, error)
	// Update Scheduler status (this includes node status update, allocation request
	// updates, etc. And receive updates from scheduler for allocation changes,
	// any required status changes, etc.
	// Update allocation request
	UpdateAllocation(Scheduler_UpdateAllocationServer) error
	// Update application request
	UpdateApplication(Scheduler_UpdateApplicationServer) error
	// Update node info
	UpdateNode(Scheduler_UpdateNodeServer) error
	// contains filtered or unexported methods
}

SchedulerServer is the server API for Scheduler service. All implementations must embed UnimplementedSchedulerServer for forward compatibility

type Scheduler_UpdateAllocationClient 

type Scheduler_UpdateAllocationClient interface {
	Send(*AllocationRequest) error
	Recv() (*AllocationResponse, error)
	grpc.ClientStream
}

type Scheduler_UpdateAllocationServer 

type Scheduler_UpdateAllocationServer interface {
	Send(*AllocationResponse) error
	Recv() (*AllocationRequest, error)
	grpc.ServerStream
}

type Scheduler_UpdateApplicationClient 

type Scheduler_UpdateApplicationClient interface {
	Send(*ApplicationRequest) error
	Recv() (*ApplicationResponse, error)
	grpc.ClientStream
}

type Scheduler_UpdateApplicationServer 

type Scheduler_UpdateApplicationServer interface {
	Send(*ApplicationResponse) error
	Recv() (*ApplicationRequest, error)
	grpc.ServerStream
}

type Scheduler_UpdateNodeClient 

type Scheduler_UpdateNodeClient interface {
	Send(*NodeRequest) error
	Recv() (*NodeResponse, error)
	grpc.ClientStream
}

type Scheduler_UpdateNodeServer 

type Scheduler_UpdateNodeServer interface {
	Send(*NodeResponse) error
	Recv() (*NodeRequest, error)
	grpc.ServerStream
}

type TerminationType 

type TerminationType int32
const (
	TerminationType_UNKNOWN_TERMINATION_TYPE TerminationType = 0 //TerminationType not set
	TerminationType_STOPPED_BY_RM            TerminationType = 1 // Stopped or killed by ResourceManager (created by RM)
	TerminationType_TIMEOUT                  TerminationType = 2 // Timed out based on the executionTimeoutMilliSeconds (created by core)
	TerminationType_PREEMPTED_BY_SCHEDULER   TerminationType = 3 // Preempted allocation by scheduler (created by core)
	TerminationType_PLACEHOLDER_REPLACED     TerminationType = 4 // Placeholder allocation replaced by real allocation (created by core)
)

func (TerminationType) Descriptor added in v1.4.0 

func (TerminationType) Descriptor() protoreflect.EnumDescriptor

func (TerminationType) Enum added in v1.4.0 

func (x TerminationType) Enum() *TerminationType

func (TerminationType) EnumDescriptor deprecated 

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

Deprecated: Use TerminationType.Descriptor instead.

func (TerminationType) Number added in v1.4.0 

func (x TerminationType) Number() protoreflect.EnumNumber

func (TerminationType) String 

func (x TerminationType) String() string

func (TerminationType) Type added in v1.4.0 

func (TerminationType) Type() protoreflect.EnumType

type UnimplementedSchedulerServer added in v1.4.0 

type UnimplementedSchedulerServer struct {
}

UnimplementedSchedulerServer must be embedded to have forward compatible implementations.

func (UnimplementedSchedulerServer) RegisterResourceManager added in v1.4.0 

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

func (UnimplementedSchedulerServer) UpdateAllocation added in v1.4.0 

func (UnimplementedSchedulerServer) UpdateAllocation(Scheduler_UpdateAllocationServer) error

func (UnimplementedSchedulerServer) UpdateApplication added in v1.4.0 

func (UnimplementedSchedulerServer) UpdateApplication(Scheduler_UpdateApplicationServer) error

func (UnimplementedSchedulerServer) UpdateNode added in v1.4.0 

func (UnimplementedSchedulerServer) UpdateNode(Scheduler_UpdateNodeServer) error

type UnsafeSchedulerServer added in v1.4.0 

type UnsafeSchedulerServer interface {
	// contains filtered or unexported methods
}

UnsafeSchedulerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SchedulerServer will result in compilation errors.

type UpdateConfigurationRequest 

type UpdateConfigurationRequest struct {

	// RM ID to update
	RmID string `protobuf:"bytes,2,opt,name=rmID,proto3" json:"rmID,omitempty"`
	// PolicyGroup to update
	PolicyGroup string `protobuf:"bytes,3,opt,name=policyGroup,proto3" json:"policyGroup,omitempty"`
	// New configuration to update
	Config string `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	// Additional configuration key/value pairs for configuration not related to the policyGroup.
	ExtraConfig map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateConfigurationRequest) Descriptor deprecated 

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

Deprecated: Use UpdateConfigurationRequest.ProtoReflect.Descriptor instead.

func (*UpdateConfigurationRequest) GetConfig added in v1.2.0 

func (x *UpdateConfigurationRequest) GetConfig() string

func (*UpdateConfigurationRequest) GetExtraConfig added in v1.2.0 

func (x *UpdateConfigurationRequest) GetExtraConfig() map[string]string

func (*UpdateConfigurationRequest) GetPolicyGroup added in v1.2.0 

func (x *UpdateConfigurationRequest) GetPolicyGroup() string

func (*UpdateConfigurationRequest) GetRmID added in v1.2.0 

func (x *UpdateConfigurationRequest) GetRmID() string

func (*UpdateConfigurationRequest) ProtoMessage 

func (*UpdateConfigurationRequest) ProtoMessage()

func (*UpdateConfigurationRequest) ProtoReflect added in v1.4.0 

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

func (*UpdateConfigurationRequest) Reset 

func (x *UpdateConfigurationRequest) Reset()

func (*UpdateConfigurationRequest) String 

func (x *UpdateConfigurationRequest) String() string

type UpdateContainerSchedulingStateRequest 

type UpdateContainerSchedulingStateRequest struct {

	// application ID
	ApplicationID string `protobuf:"bytes,1,opt,name=applicationID,proto3" json:"applicationID,omitempty"`
	// allocation key used to identify a container.
	AllocationKey string `protobuf:"bytes,2,opt,name=allocationKey,proto3" json:"allocationKey,omitempty"`
	// container scheduling state
	State UpdateContainerSchedulingStateRequest_SchedulingState `` /* 129-byte string literal not displayed */
	// an optional plain message to explain why it is in such state
	Reason string `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateContainerSchedulingStateRequest) Descriptor deprecated 

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

Deprecated: Use UpdateContainerSchedulingStateRequest.ProtoReflect.Descriptor instead.

func (*UpdateContainerSchedulingStateRequest) GetAllocationKey 

func (x *UpdateContainerSchedulingStateRequest) GetAllocationKey() string

func (*UpdateContainerSchedulingStateRequest) GetApplicationID added in v1.4.0 

func (x *UpdateContainerSchedulingStateRequest) GetApplicationID() string

func (*UpdateContainerSchedulingStateRequest) GetReason 

func (x *UpdateContainerSchedulingStateRequest) GetReason() string

func (*UpdateContainerSchedulingStateRequest) GetState 

func (x *UpdateContainerSchedulingStateRequest) GetState() UpdateContainerSchedulingStateRequest_SchedulingState

func (*UpdateContainerSchedulingStateRequest) ProtoMessage 

func (*UpdateContainerSchedulingStateRequest) ProtoMessage()

func (*UpdateContainerSchedulingStateRequest) ProtoReflect added in v1.4.0 

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

func (*UpdateContainerSchedulingStateRequest) Reset 

func (x *UpdateContainerSchedulingStateRequest) Reset()

func (*UpdateContainerSchedulingStateRequest) String 

func (x *UpdateContainerSchedulingStateRequest) String() string

type UpdateContainerSchedulingStateRequest_SchedulingState 

type UpdateContainerSchedulingStateRequest_SchedulingState int32

container scheduling states 

const (
	// SchedulingState not set
	UpdateContainerSchedulingStateRequest_UNKNOWN_SCHEDULING_STATE UpdateContainerSchedulingStateRequest_SchedulingState = 0
	// the container is being skipped by the scheduler
	UpdateContainerSchedulingStateRequest_SKIPPED UpdateContainerSchedulingStateRequest_SchedulingState = 1
	// the container is scheduled and it has been assigned to a node
	UpdateContainerSchedulingStateRequest_SCHEDULED UpdateContainerSchedulingStateRequest_SchedulingState = 2
	// the container is reserved on some node, but not yet assigned
	UpdateContainerSchedulingStateRequest_RESERVED UpdateContainerSchedulingStateRequest_SchedulingState = 3
	// scheduler has visited all candidate nodes for this container
	// but non of them could satisfy this container's requirement
	UpdateContainerSchedulingStateRequest_FAILED UpdateContainerSchedulingStateRequest_SchedulingState = 4
)

func (UpdateContainerSchedulingStateRequest_SchedulingState) Descriptor added in v1.4.0 

func (UpdateContainerSchedulingStateRequest_SchedulingState) Descriptor() protoreflect.EnumDescriptor

func (UpdateContainerSchedulingStateRequest_SchedulingState) Enum added in v1.4.0 

func (x UpdateContainerSchedulingStateRequest_SchedulingState) Enum() *UpdateContainerSchedulingStateRequest_SchedulingState

func (UpdateContainerSchedulingStateRequest_SchedulingState) EnumDescriptor deprecated 

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

Deprecated: Use UpdateContainerSchedulingStateRequest_SchedulingState.Descriptor instead.

func (UpdateContainerSchedulingStateRequest_SchedulingState) Number added in v1.4.0 

func (x UpdateContainerSchedulingStateRequest_SchedulingState) Number() protoreflect.EnumNumber

func (UpdateContainerSchedulingStateRequest_SchedulingState) String 

func (x UpdateContainerSchedulingStateRequest_SchedulingState) String() string

func (UpdateContainerSchedulingStateRequest_SchedulingState) Type added in v1.4.0 

func (UpdateContainerSchedulingStateRequest_SchedulingState) Type() protoreflect.EnumType

type UpdatedApplication 

type UpdatedApplication struct {

	// The application ID that was updated
	ApplicationID string `protobuf:"bytes,1,opt,name=applicationID,proto3" json:"applicationID,omitempty"`
	// State of the application
	State string `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	// Timestamp of the state transition
	StateTransitionTimestamp int64 `protobuf:"varint,3,opt,name=stateTransitionTimestamp,proto3" json:"stateTransitionTimestamp,omitempty"`
	// Detailed message
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdatedApplication) Descriptor deprecated 

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

Deprecated: Use UpdatedApplication.ProtoReflect.Descriptor instead.

func (*UpdatedApplication) GetApplicationID 

func (x *UpdatedApplication) GetApplicationID() string

func (*UpdatedApplication) GetMessage 

func (x *UpdatedApplication) GetMessage() string

func (*UpdatedApplication) GetState 

func (x *UpdatedApplication) GetState() string

func (*UpdatedApplication) GetStateTransitionTimestamp 

func (x *UpdatedApplication) GetStateTransitionTimestamp() int64

func (*UpdatedApplication) ProtoMessage 

func (*UpdatedApplication) ProtoMessage()

func (*UpdatedApplication) ProtoReflect added in v1.4.0 

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

func (*UpdatedApplication) Reset 

func (x *UpdatedApplication) Reset()

func (*UpdatedApplication) String 

func (x *UpdatedApplication) String() string

type UserGroupInformation 

type UserGroupInformation struct {

	// the user name
	User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// the list of groups of the user, can be empty
	Groups []string `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups,omitempty"`
	// contains filtered or unexported fields
}

func (*UserGroupInformation) Descriptor deprecated 

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

Deprecated: Use UserGroupInformation.ProtoReflect.Descriptor instead.

func (*UserGroupInformation) GetGroups 

func (x *UserGroupInformation) GetGroups() []string

func (*UserGroupInformation) GetUser 

func (x *UserGroupInformation) GetUser() string

func (*UserGroupInformation) ProtoMessage 

func (*UserGroupInformation) ProtoMessage()

func (*UserGroupInformation) ProtoReflect added in v1.4.0 

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

func (*UserGroupInformation) Reset 

func (x *UserGroupInformation) Reset()

func (*UserGroupInformation) String 

func (x *UserGroupInformation) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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