si

package
v0.0.0-...-da93802 Latest Latest
Warning

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

 Go to latest Published: Jan 9, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AffinityTargetExpression_AffinityTargetOperator_name = map[int32]string{
	0: "IN",
	1: "NOT_IN",
	2: "EXIST",
	3: "NOT_EXIST",
}
View Source 
var AffinityTargetExpression_AffinityTargetOperator_value = map[string]int32{
	"IN":        0,
	"NOT_IN":    1,
	"EXIST":     2,
	"NOT_EXIST": 3,
}
View Source 
var AllocationReleaseResponse_TerminationType_name = map[int32]string{
	0: "STOPPED_BY_RM",
	1: "TIMEOUT",
	2: "PREEMPTED_BY_SCHEDULER",
}
View Source 
var AllocationReleaseResponse_TerminationType_value = map[string]int32{
	"STOPPED_BY_RM":          0,
	"TIMEOUT":                1,
	"PREEMPTED_BY_SCHEDULER": 2,
}
View Source 
var E_SiSecret = &proto.ExtensionDesc{
	ExtendedType:  (*descriptor.FieldOptions)(nil),
	ExtensionType: (*bool)(nil),
	Field:         1059,
	Name:          "si.v1.si_secret",
	Tag:           "varint,1059,opt,name=si_secret",
	Filename:      "yunikorn-scheduler-interface/si.proto",
}
View Source 
var UpdateNodeInfo_ActionFromRM_name = map[int32]string{
	0: "NOOP",
	1: "DRAIN_NODE",
	2: "DECOMISSION",
	3: "DRAIN_TO_SCHEDULABLE",
}
View Source 
var UpdateNodeInfo_ActionFromRM_value = map[string]int32{
	"NOOP":                 0,
	"DRAIN_NODE":           1,
	"DECOMISSION":          2,
	"DRAIN_TO_SCHEDULABLE": 3,
}
View Source 
var UpdateResponse_ActionFromScheduler_name = map[int32]string{
	0: "NOACTION",
	1: "RESYNC",
}
View Source 
var UpdateResponse_ActionFromScheduler_value = map[string]int32{
	"NOACTION": 0,
	"RESYNC":   1,
}

Functions

func RegisterSchedulerServer 

func RegisterSchedulerServer(s *grpc.Server, 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AcceptedApplication) Descriptor 

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

func (*AcceptedApplication) GetApplicationID 

func (m *AcceptedApplication) GetApplicationID() string

func (*AcceptedApplication) ProtoMessage 

func (*AcceptedApplication) ProtoMessage()

func (*AcceptedApplication) Reset 

func (m *AcceptedApplication) Reset()

func (*AcceptedApplication) String 

func (m *AcceptedApplication) String() string

func (*AcceptedApplication) XXX_DiscardUnknown 

func (m *AcceptedApplication) XXX_DiscardUnknown()

func (*AcceptedApplication) XXX_Marshal 

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

func (*AcceptedApplication) XXX_Merge 

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

func (*AcceptedApplication) XXX_Size 

func (m *AcceptedApplication) XXX_Size() int

func (*AcceptedApplication) XXX_Unmarshal 

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

type AcceptedNode 

type AcceptedNode struct {
	// The node ID that was accepted
	NodeID               string   `protobuf:"bytes,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AcceptedNode) Descriptor 

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

func (*AcceptedNode) GetNodeID 

func (m *AcceptedNode) GetNodeID() string

func (*AcceptedNode) ProtoMessage 

func (*AcceptedNode) ProtoMessage()

func (*AcceptedNode) Reset 

func (m *AcceptedNode) Reset()

func (*AcceptedNode) String 

func (m *AcceptedNode) String() string

func (*AcceptedNode) XXX_DiscardUnknown 

func (m *AcceptedNode) XXX_DiscardUnknown()

func (*AcceptedNode) XXX_Marshal 

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

func (*AcceptedNode) XXX_Merge 

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

func (*AcceptedNode) XXX_Size 

func (m *AcceptedNode) XXX_Size() int

func (*AcceptedNode) XXX_Unmarshal 

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

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 inforamtion.
	// The tags are optional and are used in placing an appliction 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"`
	XXX_NoUnkeyedLiteral         struct{} `json:"-"`
	XXX_unrecognized             []byte   `json:"-"`
	XXX_sizecache                int32    `json:"-"`
}

func (*AddApplicationRequest) Descriptor 

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

func (*AddApplicationRequest) GetApplicationID 

func (m *AddApplicationRequest) GetApplicationID() string

func (*AddApplicationRequest) GetExecutionTimeoutMilliSeconds 

func (m *AddApplicationRequest) GetExecutionTimeoutMilliSeconds() int64

func (*AddApplicationRequest) GetPartitionName 

func (m *AddApplicationRequest) GetPartitionName() string

func (*AddApplicationRequest) GetQueueName 

func (m *AddApplicationRequest) GetQueueName() string

func (*AddApplicationRequest) GetTags 

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

func (*AddApplicationRequest) GetUgi 

func (m *AddApplicationRequest) GetUgi() *UserGroupInformation

func (*AddApplicationRequest) ProtoMessage 

func (*AddApplicationRequest) ProtoMessage()

func (*AddApplicationRequest) Reset 

func (m *AddApplicationRequest) Reset()

func (*AddApplicationRequest) String 

func (m *AddApplicationRequest) String() string

func (*AddApplicationRequest) XXX_DiscardUnknown 

func (m *AddApplicationRequest) XXX_DiscardUnknown()

func (*AddApplicationRequest) XXX_Marshal 

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

func (*AddApplicationRequest) XXX_Merge 

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

func (*AddApplicationRequest) XXX_Size 

func (m *AddApplicationRequest) XXX_Size() int

func (*AddApplicationRequest) XXX_Unmarshal 

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

type AffinityTargetExpression 

type AffinityTargetExpression struct {
	TargetOperator       *AffinityTargetExpression `protobuf:"bytes,1,opt,name=targetOperator,proto3" json:"targetOperator,omitempty"`
	TargetKey            string                    `protobuf:"bytes,2,opt,name=targetKey,proto3" json:"targetKey,omitempty"`
	TargetValues         []string                  `protobuf:"bytes,3,rep,name=targetValues,proto3" json:"targetValues,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*AffinityTargetExpression) Descriptor 

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

func (*AffinityTargetExpression) GetTargetKey 

func (m *AffinityTargetExpression) GetTargetKey() string

func (*AffinityTargetExpression) GetTargetOperator 

func (m *AffinityTargetExpression) GetTargetOperator() *AffinityTargetExpression

func (*AffinityTargetExpression) GetTargetValues 

func (m *AffinityTargetExpression) GetTargetValues() []string

func (*AffinityTargetExpression) ProtoMessage 

func (*AffinityTargetExpression) ProtoMessage()

func (*AffinityTargetExpression) Reset 

func (m *AffinityTargetExpression) Reset()

func (*AffinityTargetExpression) String 

func (m *AffinityTargetExpression) String() string

func (*AffinityTargetExpression) XXX_DiscardUnknown 

func (m *AffinityTargetExpression) XXX_DiscardUnknown()

func (*AffinityTargetExpression) XXX_Marshal 

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

func (*AffinityTargetExpression) XXX_Merge 

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

func (*AffinityTargetExpression) XXX_Size 

func (m *AffinityTargetExpression) XXX_Size() int

func (*AffinityTargetExpression) XXX_Unmarshal 

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

type AffinityTargetExpression_AffinityTargetOperator 

type AffinityTargetExpression_AffinityTargetOperator int32

Following 4 operators can be specified, by default is "IN". When EXIST/NOT_EXISTS specified, scheduler only check if given targetKey appears on node attribute or allocation tag. 

const (
	AffinityTargetExpression_IN        AffinityTargetExpression_AffinityTargetOperator = 0
	AffinityTargetExpression_NOT_IN    AffinityTargetExpression_AffinityTargetOperator = 1
	AffinityTargetExpression_EXIST     AffinityTargetExpression_AffinityTargetOperator = 2
	AffinityTargetExpression_NOT_EXIST AffinityTargetExpression_AffinityTargetOperator = 3
)

func (AffinityTargetExpression_AffinityTargetOperator) EnumDescriptor 

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

func (AffinityTargetExpression_AffinityTargetOperator) String 

func (x AffinityTargetExpression_AffinityTargetOperator) 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 */
	// UUID of the allocation
	UUID string `protobuf:"bytes,3,opt,name=UUID,proto3" json:"UUID,omitempty"`
	// Resource for each allocation
	ResourcePerAlloc *Resource `protobuf:"bytes,5,opt,name=resourcePerAlloc,proto3" json:"resourcePerAlloc,omitempty"`
	// Priority of ask
	Priority *Priority `protobuf:"bytes,6,opt,name=priority,proto3" json:"priority,omitempty"`
	// Queue which the allocation belongs to
	QueueName string `protobuf:"bytes,7,opt,name=queueName,proto3" json:"queueName,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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Allocation) Descriptor 

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

func (*Allocation) GetAllocationKey 

func (m *Allocation) GetAllocationKey() string

func (*Allocation) GetAllocationTags 

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

func (*Allocation) GetApplicationID 

func (m *Allocation) GetApplicationID() string

func (*Allocation) GetNodeID 

func (m *Allocation) GetNodeID() string

func (*Allocation) GetPartitionName 

func (m *Allocation) GetPartitionName() string

func (*Allocation) GetPriority 

func (m *Allocation) GetPriority() *Priority

func (*Allocation) GetQueueName 

func (m *Allocation) GetQueueName() string

func (*Allocation) GetResourcePerAlloc 

func (m *Allocation) GetResourcePerAlloc() *Resource

func (*Allocation) GetUUID 

func (m *Allocation) GetUUID() string

func (*Allocation) ProtoMessage 

func (*Allocation) ProtoMessage()

func (*Allocation) Reset 

func (m *Allocation) Reset()

func (*Allocation) String 

func (m *Allocation) String() string

func (*Allocation) XXX_DiscardUnknown 

func (m *Allocation) XXX_DiscardUnknown()

func (*Allocation) XXX_Marshal 

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

func (*Allocation) XXX_Merge 

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

func (*Allocation) XXX_Size 

func (m *Allocation) XXX_Size() int

func (*Allocation) XXX_Unmarshal 

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

type AllocationAffinityConstraints 

type AllocationAffinityConstraints struct {
	// Scope: scope is key of node attribute, which determines if >1 allocations
	// in the same group or not.
	// When allocations on node(s) which have same node attribute value
	// for given node attribute key == scope. They're in the same group.
	//
	// e.g. when user wants to do anti-affinity between allocation on node
	// basis, scope can be set to "hostname", max-cardinality = 1;
	Scope             string                      `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	TragetExpressions []*AffinityTargetExpression `protobuf:"bytes,2,rep,name=tragetExpressions,proto3" json:"tragetExpressions,omitempty"`
	MinCardinality    int32                       `protobuf:"varint,3,opt,name=minCardinality,proto3" json:"minCardinality,omitempty"`
	MaxCardinality    int32                       `protobuf:"varint,4,opt,name=maxCardinality,proto3" json:"maxCardinality,omitempty"`
	// Is this a required (hard) or preferred (soft) request.
	Required             bool     `protobuf:"varint,5,opt,name=required,proto3" json:"required,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Affinity to allocations (containers). Affinity is single-direction, which means if RM wants to do mutual affinity/ anti-affinity between allocations, same constraints need to be added to all allocation asks.

func (*AllocationAffinityConstraints) Descriptor 

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

func (*AllocationAffinityConstraints) GetMaxCardinality 

func (m *AllocationAffinityConstraints) GetMaxCardinality() int32

func (*AllocationAffinityConstraints) GetMinCardinality 

func (m *AllocationAffinityConstraints) GetMinCardinality() int32

func (*AllocationAffinityConstraints) GetRequired 

func (m *AllocationAffinityConstraints) GetRequired() bool

func (*AllocationAffinityConstraints) GetScope 

func (m *AllocationAffinityConstraints) GetScope() string

func (*AllocationAffinityConstraints) GetTragetExpressions 

func (m *AllocationAffinityConstraints) GetTragetExpressions() []*AffinityTargetExpression

func (*AllocationAffinityConstraints) ProtoMessage 

func (*AllocationAffinityConstraints) ProtoMessage()

func (*AllocationAffinityConstraints) Reset 

func (m *AllocationAffinityConstraints) Reset()

func (*AllocationAffinityConstraints) String 

func (m *AllocationAffinityConstraints) String() string

func (*AllocationAffinityConstraints) XXX_DiscardUnknown 

func (m *AllocationAffinityConstraints) XXX_DiscardUnknown()

func (*AllocationAffinityConstraints) XXX_Marshal 

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

func (*AllocationAffinityConstraints) XXX_Merge 

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

func (*AllocationAffinityConstraints) XXX_Size 

func (m *AllocationAffinityConstraints) XXX_Size() int

func (*AllocationAffinityConstraints) XXX_Unmarshal 

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

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 *Priority `protobuf:"bytes,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 */
	// Placement constraint defines how this allocation should be placed in the cluster.
	// if not set, no placement constraint will be applied.
	PlacementConstraint  *PlacementConstraint `protobuf:"bytes,9,opt,name=placementConstraint,proto3" json:"placementConstraint,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*AllocationAsk) Descriptor 

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

func (*AllocationAsk) GetAllocationKey 

func (m *AllocationAsk) GetAllocationKey() string

func (*AllocationAsk) GetApplicationID 

func (m *AllocationAsk) GetApplicationID() string

func (*AllocationAsk) GetExecutionTimeoutMilliSeconds 

func (m *AllocationAsk) GetExecutionTimeoutMilliSeconds() int64

func (*AllocationAsk) GetMaxAllocations 

func (m *AllocationAsk) GetMaxAllocations() int32

func (*AllocationAsk) GetPartitionName 

func (m *AllocationAsk) GetPartitionName() string

func (*AllocationAsk) GetPlacementConstraint 

func (m *AllocationAsk) GetPlacementConstraint() *PlacementConstraint

func (*AllocationAsk) GetPriority 

func (m *AllocationAsk) GetPriority() *Priority

func (*AllocationAsk) GetResourceAsk 

func (m *AllocationAsk) GetResourceAsk() *Resource

func (*AllocationAsk) GetTags 

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

func (*AllocationAsk) ProtoMessage 

func (*AllocationAsk) ProtoMessage()

func (*AllocationAsk) Reset 

func (m *AllocationAsk) Reset()

func (*AllocationAsk) String 

func (m *AllocationAsk) String() string

func (*AllocationAsk) XXX_DiscardUnknown 

func (m *AllocationAsk) XXX_DiscardUnknown()

func (*AllocationAsk) XXX_Marshal 

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

func (*AllocationAsk) XXX_Merge 

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

func (*AllocationAsk) XXX_Size 

func (m *AllocationAsk) XXX_Size() int

func (*AllocationAsk) XXX_Unmarshal 

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

type AllocationAskReleaseRequest 

type AllocationAskReleaseRequest 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"`
	// For human-readable message
	Message              string   `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Release ask

func (*AllocationAskReleaseRequest) Descriptor 

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

func (*AllocationAskReleaseRequest) GetAllocationkey 

func (m *AllocationAskReleaseRequest) GetAllocationkey() string

func (*AllocationAskReleaseRequest) GetApplicationID 

func (m *AllocationAskReleaseRequest) GetApplicationID() string

func (*AllocationAskReleaseRequest) GetMessage 

func (m *AllocationAskReleaseRequest) GetMessage() string

func (*AllocationAskReleaseRequest) GetPartitionName 

func (m *AllocationAskReleaseRequest) GetPartitionName() string

func (*AllocationAskReleaseRequest) ProtoMessage 

func (*AllocationAskReleaseRequest) ProtoMessage()

func (*AllocationAskReleaseRequest) Reset 

func (m *AllocationAskReleaseRequest) Reset()

func (*AllocationAskReleaseRequest) String 

func (m *AllocationAskReleaseRequest) String() string

func (*AllocationAskReleaseRequest) XXX_DiscardUnknown 

func (m *AllocationAskReleaseRequest) XXX_DiscardUnknown()

func (*AllocationAskReleaseRequest) XXX_Marshal 

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

func (*AllocationAskReleaseRequest) XXX_Merge 

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

func (*AllocationAskReleaseRequest) XXX_Size 

func (m *AllocationAskReleaseRequest) XXX_Size() int

func (*AllocationAskReleaseRequest) XXX_Unmarshal 

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

type AllocationReleaseRequest 

type AllocationReleaseRequest struct {
	// Which partition to release the allocation from, required.
	PartitionName string `protobuf:"bytes,1,opt,name=partitionName,proto3" json:"partitionName,omitempty"`
	// optional, when this is set, filter allocations by application id.
	// when application id is set and UUID is not set, release all allocations under the application id.
	ApplicationID string `protobuf:"bytes,2,opt,name=applicationID,proto3" json:"applicationID,omitempty"`
	// optional, when this is set, only release allocation by given UUID.
	UUID string `protobuf:"bytes,3,opt,name=UUID,proto3" json:"UUID,omitempty"`
	// For human-readable message
	Message              string   `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Release allocation

func (*AllocationReleaseRequest) Descriptor 

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

func (*AllocationReleaseRequest) GetApplicationID 

func (m *AllocationReleaseRequest) GetApplicationID() string

func (*AllocationReleaseRequest) GetMessage 

func (m *AllocationReleaseRequest) GetMessage() string

func (*AllocationReleaseRequest) GetPartitionName 

func (m *AllocationReleaseRequest) GetPartitionName() string

func (*AllocationReleaseRequest) GetUUID 

func (m *AllocationReleaseRequest) GetUUID() string

func (*AllocationReleaseRequest) ProtoMessage 

func (*AllocationReleaseRequest) ProtoMessage()

func (*AllocationReleaseRequest) Reset 

func (m *AllocationReleaseRequest) Reset()

func (*AllocationReleaseRequest) String 

func (m *AllocationReleaseRequest) String() string

func (*AllocationReleaseRequest) XXX_DiscardUnknown 

func (m *AllocationReleaseRequest) XXX_DiscardUnknown()

func (*AllocationReleaseRequest) XXX_Marshal 

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

func (*AllocationReleaseRequest) XXX_Merge 

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

func (*AllocationReleaseRequest) XXX_Size 

func (m *AllocationReleaseRequest) XXX_Size() int

func (*AllocationReleaseRequest) XXX_Unmarshal 

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

type AllocationReleaseResponse 

type AllocationReleaseResponse struct {
	// UUID of the allocation that is released
	UUID string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	// Termination type of the released allocation
	TerminationType AllocationReleaseResponse_TerminationType `` /* 137-byte string literal not displayed */
	// Any other human-readable message
	Message              string   `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

When allocation released, either by RM or preempted by scheduler. It will be sent back to RM.

func (*AllocationReleaseResponse) Descriptor 

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

func (*AllocationReleaseResponse) GetMessage 

func (m *AllocationReleaseResponse) GetMessage() string

func (*AllocationReleaseResponse) GetTerminationType 

func (m *AllocationReleaseResponse) GetTerminationType() AllocationReleaseResponse_TerminationType

func (*AllocationReleaseResponse) GetUUID 

func (m *AllocationReleaseResponse) GetUUID() string

func (*AllocationReleaseResponse) ProtoMessage 

func (*AllocationReleaseResponse) ProtoMessage()

func (*AllocationReleaseResponse) Reset 

func (m *AllocationReleaseResponse) Reset()

func (*AllocationReleaseResponse) String 

func (m *AllocationReleaseResponse) String() string

func (*AllocationReleaseResponse) XXX_DiscardUnknown 

func (m *AllocationReleaseResponse) XXX_DiscardUnknown()

func (*AllocationReleaseResponse) XXX_Marshal 

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

func (*AllocationReleaseResponse) XXX_Merge 

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

func (*AllocationReleaseResponse) XXX_Size 

func (m *AllocationReleaseResponse) XXX_Size() int

func (*AllocationReleaseResponse) XXX_Unmarshal 

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

type AllocationReleaseResponse_TerminationType 

type AllocationReleaseResponse_TerminationType int32
const (
	// STOPPED by ResourceManager.
	AllocationReleaseResponse_STOPPED_BY_RM AllocationReleaseResponse_TerminationType = 0
	// TIMEOUT based on the executionTimeoutMilliSeconds
	AllocationReleaseResponse_TIMEOUT AllocationReleaseResponse_TerminationType = 1
	// PREEMPTED by scheduler
	AllocationReleaseResponse_PREEMPTED_BY_SCHEDULER AllocationReleaseResponse_TerminationType = 2
)

func (AllocationReleaseResponse_TerminationType) EnumDescriptor 

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

func (AllocationReleaseResponse_TerminationType) String 

func (x AllocationReleaseResponse_TerminationType) String() string

type AllocationReleasesRequest 

type AllocationReleasesRequest struct {
	// The allocations to release
	AllocationsToRelease []*AllocationReleaseRequest `protobuf:"bytes,1,rep,name=allocationsToRelease,proto3" json:"allocationsToRelease,omitempty"`
	// The asks to release
	AllocationAsksToRelease []*AllocationAskReleaseRequest `protobuf:"bytes,2,rep,name=allocationAsksToRelease,proto3" json:"allocationAsksToRelease,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}                       `json:"-"`
	XXX_unrecognized        []byte                         `json:"-"`
	XXX_sizecache           int32                          `json:"-"`
}

func (*AllocationReleasesRequest) Descriptor 

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

func (*AllocationReleasesRequest) GetAllocationAsksToRelease 

func (m *AllocationReleasesRequest) GetAllocationAsksToRelease() []*AllocationAskReleaseRequest

func (*AllocationReleasesRequest) GetAllocationsToRelease 

func (m *AllocationReleasesRequest) GetAllocationsToRelease() []*AllocationReleaseRequest

func (*AllocationReleasesRequest) ProtoMessage 

func (*AllocationReleasesRequest) ProtoMessage()

func (*AllocationReleasesRequest) Reset 

func (m *AllocationReleasesRequest) Reset()

func (*AllocationReleasesRequest) String 

func (m *AllocationReleasesRequest) String() string

func (*AllocationReleasesRequest) XXX_DiscardUnknown 

func (m *AllocationReleasesRequest) XXX_DiscardUnknown()

func (*AllocationReleasesRequest) XXX_Marshal 

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

func (*AllocationReleasesRequest) XXX_Merge 

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

func (*AllocationReleasesRequest) XXX_Size 

func (m *AllocationReleasesRequest) XXX_Size() int

func (*AllocationReleasesRequest) XXX_Unmarshal 

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

type AssumedAllocation 

type AssumedAllocation struct {
	// allocation key used to identify a container.
	AllocationKey string `protobuf:"bytes,1,opt,name=allocationKey,proto3" json:"allocationKey,omitempty"`
	// the node ID the container is assumed to be allocated to, this info is stored in scheduler cache.
	NodeID               string   `protobuf:"bytes,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AssumedAllocation) Descriptor 

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

func (*AssumedAllocation) GetAllocationKey 

func (m *AssumedAllocation) GetAllocationKey() string

func (*AssumedAllocation) GetNodeID 

func (m *AssumedAllocation) GetNodeID() string

func (*AssumedAllocation) ProtoMessage 

func (*AssumedAllocation) ProtoMessage()

func (*AssumedAllocation) Reset 

func (m *AssumedAllocation) Reset()

func (*AssumedAllocation) String 

func (m *AssumedAllocation) String() string

func (*AssumedAllocation) XXX_DiscardUnknown 

func (m *AssumedAllocation) XXX_DiscardUnknown()

func (*AssumedAllocation) XXX_Marshal 

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

func (*AssumedAllocation) XXX_Merge 

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

func (*AssumedAllocation) XXX_Size 

func (m *AssumedAllocation) XXX_Size() int

func (*AssumedAllocation) XXX_Unmarshal 

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

type ForgotAllocation 

type ForgotAllocation struct {
	// allocation key used to identify a container.
	AllocationKey        string   `protobuf:"bytes,1,opt,name=allocationKey,proto3" json:"allocationKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ForgotAllocation) Descriptor 

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

func (*ForgotAllocation) GetAllocationKey 

func (m *ForgotAllocation) GetAllocationKey() string

func (*ForgotAllocation) ProtoMessage 

func (*ForgotAllocation) ProtoMessage()

func (*ForgotAllocation) Reset 

func (m *ForgotAllocation) Reset()

func (*ForgotAllocation) String 

func (m *ForgotAllocation) String() string

func (*ForgotAllocation) XXX_DiscardUnknown 

func (m *ForgotAllocation) XXX_DiscardUnknown()

func (*ForgotAllocation) XXX_Marshal 

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

func (*ForgotAllocation) XXX_Merge 

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

func (*ForgotAllocation) XXX_Size 

func (m *ForgotAllocation) XXX_Size() int

func (*ForgotAllocation) XXX_Unmarshal 

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

type NewNodeInfo 

type NewNodeInfo struct {
	// ID of node, must be unique
	NodeID string `protobuf:"bytes,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	// node attributes
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// Schedulable Resource
	SchedulableResource *Resource `protobuf:"bytes,3,opt,name=schedulableResource,proto3" json:"schedulableResource,omitempty"`
	// Allocated resources, this will be added when node registered to RM (recovery)
	ExistingAllocations  []*Allocation `protobuf:"bytes,4,rep,name=existingAllocations,proto3" json:"existingAllocations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*NewNodeInfo) Descriptor 

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

func (*NewNodeInfo) GetAttributes 

func (m *NewNodeInfo) GetAttributes() map[string]string

func (*NewNodeInfo) GetExistingAllocations 

func (m *NewNodeInfo) GetExistingAllocations() []*Allocation

func (*NewNodeInfo) GetNodeID 

func (m *NewNodeInfo) GetNodeID() string

func (*NewNodeInfo) GetSchedulableResource 

func (m *NewNodeInfo) GetSchedulableResource() *Resource

func (*NewNodeInfo) ProtoMessage 

func (*NewNodeInfo) ProtoMessage()

func (*NewNodeInfo) Reset 

func (m *NewNodeInfo) Reset()

func (*NewNodeInfo) String 

func (m *NewNodeInfo) String() string

func (*NewNodeInfo) XXX_DiscardUnknown 

func (m *NewNodeInfo) XXX_DiscardUnknown()

func (*NewNodeInfo) XXX_Marshal 

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

func (*NewNodeInfo) XXX_Merge 

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

func (*NewNodeInfo) XXX_Size 

func (m *NewNodeInfo) XXX_Size() int

func (*NewNodeInfo) XXX_Unmarshal 

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

type NodeAffinityConstraints 

type NodeAffinityConstraints struct {
	TargetExpressions    []*AffinityTargetExpression `protobuf:"bytes,2,rep,name=targetExpressions,proto3" json:"targetExpressions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

Affinity to node, multiple AffinityTargetExpression will be specified, They will be connected by AND.

func (*NodeAffinityConstraints) Descriptor 

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

func (*NodeAffinityConstraints) GetTargetExpressions 

func (m *NodeAffinityConstraints) GetTargetExpressions() []*AffinityTargetExpression

func (*NodeAffinityConstraints) ProtoMessage 

func (*NodeAffinityConstraints) ProtoMessage()

func (*NodeAffinityConstraints) Reset 

func (m *NodeAffinityConstraints) Reset()

func (*NodeAffinityConstraints) String 

func (m *NodeAffinityConstraints) String() string

func (*NodeAffinityConstraints) XXX_DiscardUnknown 

func (m *NodeAffinityConstraints) XXX_DiscardUnknown()

func (*NodeAffinityConstraints) XXX_Marshal 

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

func (*NodeAffinityConstraints) XXX_Merge 

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

func (*NodeAffinityConstraints) XXX_Size 

func (m *NodeAffinityConstraints) XXX_Size() int

func (*NodeAffinityConstraints) XXX_Unmarshal 

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

type NodeRecommendation 

type NodeRecommendation struct {
	RecommendedSchedulableResource *Resource `protobuf:"bytes,1,opt,name=recommendedSchedulableResource,proto3" json:"recommendedSchedulableResource,omitempty"`
	// Any other human-readable message
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeRecommendation) Descriptor 

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

func (*NodeRecommendation) GetMessage 

func (m *NodeRecommendation) GetMessage() string

func (*NodeRecommendation) GetRecommendedSchedulableResource 

func (m *NodeRecommendation) GetRecommendedSchedulableResource() *Resource

func (*NodeRecommendation) ProtoMessage 

func (*NodeRecommendation) ProtoMessage()

func (*NodeRecommendation) Reset 

func (m *NodeRecommendation) Reset()

func (*NodeRecommendation) String 

func (m *NodeRecommendation) String() string

func (*NodeRecommendation) XXX_DiscardUnknown 

func (m *NodeRecommendation) XXX_DiscardUnknown()

func (*NodeRecommendation) XXX_Marshal 

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

func (*NodeRecommendation) XXX_Merge 

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

func (*NodeRecommendation) XXX_Size 

func (m *NodeRecommendation) XXX_Size() int

func (*NodeRecommendation) XXX_Unmarshal 

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

type PlacementConstraint 

type PlacementConstraint struct {
	// Types that are valid to be assigned to Constraint:
	//	*PlacementConstraint_SimpleConstraint
	Constraint           isPlacementConstraint_Constraint `protobuf_oneof:"constraint"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

PlacementConstraint could have simplePlacementConstraint or CompositePlacementConstraint. One of them will be set.

func (*PlacementConstraint) Descriptor 

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

func (*PlacementConstraint) GetConstraint 

func (m *PlacementConstraint) GetConstraint() isPlacementConstraint_Constraint

func (*PlacementConstraint) GetSimpleConstraint 

func (m *PlacementConstraint) GetSimpleConstraint() *SimplePlacementConstraint

func (*PlacementConstraint) ProtoMessage 

func (*PlacementConstraint) ProtoMessage()

func (*PlacementConstraint) Reset 

func (m *PlacementConstraint) Reset()

func (*PlacementConstraint) String 

func (m *PlacementConstraint) String() string

func (*PlacementConstraint) XXX_DiscardUnknown 

func (m *PlacementConstraint) XXX_DiscardUnknown()

func (*PlacementConstraint) XXX_Marshal 

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

func (*PlacementConstraint) XXX_Merge 

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

func (*PlacementConstraint) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*PlacementConstraint) XXX_Size 

func (m *PlacementConstraint) XXX_Size() int

func (*PlacementConstraint) XXX_Unmarshal 

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

type PlacementConstraint_SimpleConstraint 

type PlacementConstraint_SimpleConstraint struct {
	SimpleConstraint *SimplePlacementConstraint `protobuf:"bytes,1,opt,name=simpleConstraint,proto3,oneof"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PredicatesArgs) Descriptor 

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

func (*PredicatesArgs) GetAllocationKey 

func (m *PredicatesArgs) GetAllocationKey() string

func (*PredicatesArgs) GetNodeID 

func (m *PredicatesArgs) GetNodeID() string

func (*PredicatesArgs) ProtoMessage 

func (*PredicatesArgs) ProtoMessage()

func (*PredicatesArgs) Reset 

func (m *PredicatesArgs) Reset()

func (*PredicatesArgs) String 

func (m *PredicatesArgs) String() string

func (*PredicatesArgs) XXX_DiscardUnknown 

func (m *PredicatesArgs) XXX_DiscardUnknown()

func (*PredicatesArgs) XXX_Marshal 

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

func (*PredicatesArgs) XXX_Merge 

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

func (*PredicatesArgs) XXX_Size 

func (m *PredicatesArgs) XXX_Size() int

func (*PredicatesArgs) XXX_Unmarshal 

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

type Priority 

type Priority struct {
	// Types that are valid to be assigned to Priority:
	//	*Priority_PriorityValue
	//	*Priority_PriorityClassName
	Priority             isPriority_Priority `protobuf_oneof:"priority"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*Priority) Descriptor 

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

func (*Priority) GetPriority 

func (m *Priority) GetPriority() isPriority_Priority

func (*Priority) GetPriorityClassName 

func (m *Priority) GetPriorityClassName() string

func (*Priority) GetPriorityValue 

func (m *Priority) GetPriorityValue() int32

func (*Priority) ProtoMessage 

func (*Priority) ProtoMessage()

func (*Priority) Reset 

func (m *Priority) Reset()

func (*Priority) String 

func (m *Priority) String() string

func (*Priority) XXX_DiscardUnknown 

func (m *Priority) XXX_DiscardUnknown()

func (*Priority) XXX_Marshal 

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

func (*Priority) XXX_Merge 

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

func (*Priority) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Priority) XXX_Size 

func (m *Priority) XXX_Size() int

func (*Priority) XXX_Unmarshal 

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

type Priority_PriorityClassName 

type Priority_PriorityClassName struct {
	PriorityClassName string `protobuf:"bytes,2,opt,name=priorityClassName,proto3,oneof"`
}

type Priority_PriorityValue 

type Priority_PriorityValue struct {
	PriorityValue int32 `protobuf:"varint,1,opt,name=priorityValue,proto3,oneof"`
}

type Quantity 

type Quantity struct {
	Value                int64    `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Quantity includes a single int64 value

func (*Quantity) Descriptor 

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

func (*Quantity) GetValue 

func (m *Quantity) GetValue() int64

func (*Quantity) ProtoMessage 

func (*Quantity) ProtoMessage()

func (*Quantity) Reset 

func (m *Quantity) Reset()

func (*Quantity) String 

func (m *Quantity) String() string

func (*Quantity) XXX_DiscardUnknown 

func (m *Quantity) XXX_DiscardUnknown()

func (*Quantity) XXX_Marshal 

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

func (*Quantity) XXX_Merge 

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

func (*Quantity) XXX_Size 

func (m *Quantity) XXX_Size() int

func (*Quantity) XXX_Unmarshal 

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

type ReSyncSchedulerCacheArgs 

type ReSyncSchedulerCacheArgs struct {
	// a list of assumed allocations, this will be sync'd to scheduler cache.
	AssumedAllocations []*AssumedAllocation `protobuf:"bytes,1,rep,name=assumedAllocations,proto3" json:"assumedAllocations,omitempty"`
	// a list of allocations to forget
	ForgetAllocations    []*ForgotAllocation `protobuf:"bytes,2,rep,name=forgetAllocations,proto3" json:"forgetAllocations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ReSyncSchedulerCacheArgs) Descriptor 

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

func (*ReSyncSchedulerCacheArgs) GetAssumedAllocations 

func (m *ReSyncSchedulerCacheArgs) GetAssumedAllocations() []*AssumedAllocation

func (*ReSyncSchedulerCacheArgs) GetForgetAllocations 

func (m *ReSyncSchedulerCacheArgs) GetForgetAllocations() []*ForgotAllocation

func (*ReSyncSchedulerCacheArgs) ProtoMessage 

func (*ReSyncSchedulerCacheArgs) ProtoMessage()

func (*ReSyncSchedulerCacheArgs) Reset 

func (m *ReSyncSchedulerCacheArgs) Reset()

func (*ReSyncSchedulerCacheArgs) String 

func (m *ReSyncSchedulerCacheArgs) String() string

func (*ReSyncSchedulerCacheArgs) XXX_DiscardUnknown 

func (m *ReSyncSchedulerCacheArgs) XXX_DiscardUnknown()

func (*ReSyncSchedulerCacheArgs) XXX_Marshal 

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

func (*ReSyncSchedulerCacheArgs) XXX_Merge 

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

func (*ReSyncSchedulerCacheArgs) XXX_Size 

func (m *ReSyncSchedulerCacheArgs) XXX_Size() int

func (*ReSyncSchedulerCacheArgs) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

service MetricsService { }

func (*RegisterResourceManagerRequest) Descriptor 

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

func (*RegisterResourceManagerRequest) GetPolicyGroup 

func (m *RegisterResourceManagerRequest) GetPolicyGroup() string

func (*RegisterResourceManagerRequest) GetRmID 

func (m *RegisterResourceManagerRequest) GetRmID() string

func (*RegisterResourceManagerRequest) GetVersion 

func (m *RegisterResourceManagerRequest) GetVersion() string

func (*RegisterResourceManagerRequest) ProtoMessage 

func (*RegisterResourceManagerRequest) ProtoMessage()

func (*RegisterResourceManagerRequest) Reset 

func (m *RegisterResourceManagerRequest) Reset()

func (*RegisterResourceManagerRequest) String 

func (m *RegisterResourceManagerRequest) String() string

func (*RegisterResourceManagerRequest) XXX_DiscardUnknown 

func (m *RegisterResourceManagerRequest) XXX_DiscardUnknown()

func (*RegisterResourceManagerRequest) XXX_Marshal 

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

func (*RegisterResourceManagerRequest) XXX_Merge 

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

func (*RegisterResourceManagerRequest) XXX_Size 

func (m *RegisterResourceManagerRequest) XXX_Size() int

func (*RegisterResourceManagerRequest) XXX_Unmarshal 

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

type RegisterResourceManagerResponse 

type RegisterResourceManagerResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*RegisterResourceManagerResponse) Descriptor 

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

func (*RegisterResourceManagerResponse) ProtoMessage 

func (*RegisterResourceManagerResponse) ProtoMessage()

func (*RegisterResourceManagerResponse) Reset 

func (m *RegisterResourceManagerResponse) Reset()

func (*RegisterResourceManagerResponse) String 

func (m *RegisterResourceManagerResponse) String() string

func (*RegisterResourceManagerResponse) XXX_DiscardUnknown 

func (m *RegisterResourceManagerResponse) XXX_DiscardUnknown()

func (*RegisterResourceManagerResponse) XXX_Marshal 

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

func (*RegisterResourceManagerResponse) XXX_Merge 

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

func (*RegisterResourceManagerResponse) XXX_Size 

func (m *RegisterResourceManagerResponse) XXX_Size() int

func (*RegisterResourceManagerResponse) XXX_Unmarshal 

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

type RejectedAllocationAsk 

type RejectedAllocationAsk struct {
	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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RejectedAllocationAsk) Descriptor 

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

func (*RejectedAllocationAsk) GetAllocationKey 

func (m *RejectedAllocationAsk) GetAllocationKey() string

func (*RejectedAllocationAsk) GetApplicationID 

func (m *RejectedAllocationAsk) GetApplicationID() string

func (*RejectedAllocationAsk) GetReason 

func (m *RejectedAllocationAsk) GetReason() string

func (*RejectedAllocationAsk) ProtoMessage 

func (*RejectedAllocationAsk) ProtoMessage()

func (*RejectedAllocationAsk) Reset 

func (m *RejectedAllocationAsk) Reset()

func (*RejectedAllocationAsk) String 

func (m *RejectedAllocationAsk) String() string

func (*RejectedAllocationAsk) XXX_DiscardUnknown 

func (m *RejectedAllocationAsk) XXX_DiscardUnknown()

func (*RejectedAllocationAsk) XXX_Marshal 

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

func (*RejectedAllocationAsk) XXX_Merge 

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

func (*RejectedAllocationAsk) XXX_Size 

func (m *RejectedAllocationAsk) XXX_Size() int

func (*RejectedAllocationAsk) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RejectedApplication) Descriptor 

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

func (*RejectedApplication) GetApplicationID 

func (m *RejectedApplication) GetApplicationID() string

func (*RejectedApplication) GetReason 

func (m *RejectedApplication) GetReason() string

func (*RejectedApplication) ProtoMessage 

func (*RejectedApplication) ProtoMessage()

func (*RejectedApplication) Reset 

func (m *RejectedApplication) Reset()

func (*RejectedApplication) String 

func (m *RejectedApplication) String() string

func (*RejectedApplication) XXX_DiscardUnknown 

func (m *RejectedApplication) XXX_DiscardUnknown()

func (*RejectedApplication) XXX_Marshal 

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

func (*RejectedApplication) XXX_Merge 

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

func (*RejectedApplication) XXX_Size 

func (m *RejectedApplication) XXX_Size() int

func (*RejectedApplication) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RejectedNode) Descriptor 

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

func (*RejectedNode) GetNodeID 

func (m *RejectedNode) GetNodeID() string

func (*RejectedNode) GetReason 

func (m *RejectedNode) GetReason() string

func (*RejectedNode) ProtoMessage 

func (*RejectedNode) ProtoMessage()

func (*RejectedNode) Reset 

func (m *RejectedNode) Reset()

func (*RejectedNode) String 

func (m *RejectedNode) String() string

func (*RejectedNode) XXX_DiscardUnknown 

func (m *RejectedNode) XXX_DiscardUnknown()

func (*RejectedNode) XXX_Marshal 

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

func (*RejectedNode) XXX_Merge 

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

func (*RejectedNode) XXX_Size 

func (m *RejectedNode) XXX_Size() int

func (*RejectedNode) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveApplicationRequest) Descriptor 

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

func (*RemoveApplicationRequest) GetApplicationID 

func (m *RemoveApplicationRequest) GetApplicationID() string

func (*RemoveApplicationRequest) GetPartitionName 

func (m *RemoveApplicationRequest) GetPartitionName() string

func (*RemoveApplicationRequest) ProtoMessage 

func (*RemoveApplicationRequest) ProtoMessage()

func (*RemoveApplicationRequest) Reset 

func (m *RemoveApplicationRequest) Reset()

func (*RemoveApplicationRequest) String 

func (m *RemoveApplicationRequest) String() string

func (*RemoveApplicationRequest) XXX_DiscardUnknown 

func (m *RemoveApplicationRequest) XXX_DiscardUnknown()

func (*RemoveApplicationRequest) XXX_Marshal 

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

func (*RemoveApplicationRequest) XXX_Merge 

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

func (*RemoveApplicationRequest) XXX_Size 

func (m *RemoveApplicationRequest) XXX_Size() int

func (*RemoveApplicationRequest) XXX_Unmarshal 

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

type Resource 

type Resource struct {
	Resources            map[string]*Quantity `` /* 159-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

A sparse map of resource to Quantity.

func (*Resource) Descriptor 

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

func (*Resource) GetResources 

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

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) Reset 

func (m *Resource) Reset()

func (*Resource) String 

func (m *Resource) String() string

func (*Resource) XXX_DiscardUnknown 

func (m *Resource) XXX_DiscardUnknown()

func (*Resource) XXX_Marshal 

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

func (*Resource) XXX_Merge 

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

func (*Resource) XXX_Size 

func (m *Resource) XXX_Size() int

func (*Resource) XXX_Unmarshal 

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

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(ctx context.Context, opts ...grpc.CallOption) (Scheduler_UpdateClient, error)
}

SchedulerClient is the client API for Scheduler service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSchedulerClient 

func NewSchedulerClient(cc *grpc.ClientConn) 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(Scheduler_UpdateServer) error
}

SchedulerServer is the server API for Scheduler service.

type Scheduler_UpdateClient 

type Scheduler_UpdateClient interface {
	Send(*UpdateRequest) error
	Recv() (*UpdateResponse, error)
	grpc.ClientStream
}

type Scheduler_UpdateServer 

type Scheduler_UpdateServer interface {
	Send(*UpdateResponse) error
	Recv() (*UpdateRequest, error)
	grpc.ServerStream
}

type SimplePlacementConstraint 

type SimplePlacementConstraint struct {
	// Constraint
	NodeAffinityConstraint      *NodeAffinityConstraints       `protobuf:"bytes,1,opt,name=nodeAffinityConstraint,proto3" json:"nodeAffinityConstraint,omitempty"`
	AllocationAffinityAttribute *AllocationAffinityConstraints `protobuf:"bytes,2,opt,name=allocationAffinityAttribute,proto3" json:"allocationAffinityAttribute,omitempty"`
	XXX_NoUnkeyedLiteral        struct{}                       `json:"-"`
	XXX_unrecognized            []byte                         `json:"-"`
	XXX_sizecache               int32                          `json:"-"`
}

Simple placement constraint represent constraint for affinity/anti-affinity to node attribute or allocation tags. When both of NodeAffinityConstraints and AllocationAffinityConstraints specified, both will be checked and verified while scheduling.

func (*SimplePlacementConstraint) Descriptor 

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

func (*SimplePlacementConstraint) GetAllocationAffinityAttribute 

func (m *SimplePlacementConstraint) GetAllocationAffinityAttribute() *AllocationAffinityConstraints

func (*SimplePlacementConstraint) GetNodeAffinityConstraint 

func (m *SimplePlacementConstraint) GetNodeAffinityConstraint() *NodeAffinityConstraints

func (*SimplePlacementConstraint) ProtoMessage 

func (*SimplePlacementConstraint) ProtoMessage()

func (*SimplePlacementConstraint) Reset 

func (m *SimplePlacementConstraint) Reset()

func (*SimplePlacementConstraint) String 

func (m *SimplePlacementConstraint) String() string

func (*SimplePlacementConstraint) XXX_DiscardUnknown 

func (m *SimplePlacementConstraint) XXX_DiscardUnknown()

func (*SimplePlacementConstraint) XXX_Marshal 

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

func (*SimplePlacementConstraint) XXX_Merge 

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

func (*SimplePlacementConstraint) XXX_Size 

func (m *SimplePlacementConstraint) XXX_Size() int

func (*SimplePlacementConstraint) XXX_Unmarshal 

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

type UpdateNodeInfo 

type UpdateNodeInfo struct {
	// ID of node, the node must exist to be updated
	NodeID string `protobuf:"bytes,1,opt,name=nodeID,proto3" json:"nodeID,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,3,opt,name=schedulableResource,proto3" json:"schedulableResource,omitempty"`
	// Action to perform by the scheduler
	Action               UpdateNodeInfo_ActionFromRM `protobuf:"varint,4,opt,name=action,proto3,enum=si.v1.UpdateNodeInfo_ActionFromRM" json:"action,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*UpdateNodeInfo) Descriptor 

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

func (*UpdateNodeInfo) GetAction 

func (m *UpdateNodeInfo) GetAction() UpdateNodeInfo_ActionFromRM

func (*UpdateNodeInfo) GetAttributes 

func (m *UpdateNodeInfo) GetAttributes() map[string]string

func (*UpdateNodeInfo) GetNodeID 

func (m *UpdateNodeInfo) GetNodeID() string

func (*UpdateNodeInfo) GetSchedulableResource 

func (m *UpdateNodeInfo) GetSchedulableResource() *Resource

func (*UpdateNodeInfo) ProtoMessage 

func (*UpdateNodeInfo) ProtoMessage()

func (*UpdateNodeInfo) Reset 

func (m *UpdateNodeInfo) Reset()

func (*UpdateNodeInfo) String 

func (m *UpdateNodeInfo) String() string

func (*UpdateNodeInfo) XXX_DiscardUnknown 

func (m *UpdateNodeInfo) XXX_DiscardUnknown()

func (*UpdateNodeInfo) XXX_Marshal 

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

func (*UpdateNodeInfo) XXX_Merge 

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

func (*UpdateNodeInfo) XXX_Size 

func (m *UpdateNodeInfo) XXX_Size() int

func (*UpdateNodeInfo) XXX_Unmarshal 

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

type UpdateNodeInfo_ActionFromRM 

type UpdateNodeInfo_ActionFromRM int32

Action from RM 

const (
	// Noop
	UpdateNodeInfo_NOOP UpdateNodeInfo_ActionFromRM = 0
	// Do not allocate new allocations on the node.
	UpdateNodeInfo_DRAIN_NODE UpdateNodeInfo_ActionFromRM = 1
	// Decomission node, it will immediately stop allocations on the node and
	// remove the node from schedulable lists.
	UpdateNodeInfo_DECOMISSION UpdateNodeInfo_ActionFromRM = 2
	// From Draining state to SCHEDULABLE state.
	// If node is not in draining state, error will be thrown
	UpdateNodeInfo_DRAIN_TO_SCHEDULABLE UpdateNodeInfo_ActionFromRM = 3
)

func (UpdateNodeInfo_ActionFromRM) EnumDescriptor 

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

func (UpdateNodeInfo_ActionFromRM) String 

func (x UpdateNodeInfo_ActionFromRM) String() string

type UpdateRequest 

type UpdateRequest 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"`
	// New node can be scheduled. If a node is notified to be "unscheduable", it needs to be part of this field as well.
	NewSchedulableNodes []*NewNodeInfo `protobuf:"bytes,3,rep,name=newSchedulableNodes,proto3" json:"newSchedulableNodes,omitempty"`
	// Update nodes for existing schedulable nodes.
	// May include:
	// - Node resource changes. (Like grows/shrinks node resource)
	// - Node attribute changes. (Including node-partition concept like YARN, and concept like "local images".
	//
	// Should not include:
	// - Allocation-related changes with the node.
	// - Realtime Utilizations.
	UpdatedNodes []*UpdateNodeInfo `protobuf:"bytes,4,rep,name=updatedNodes,proto3" json:"updatedNodes,omitempty"`
	// UtilizationReports for allocation and nodes.
	UtilizationReports []*UtilizationReport `protobuf:"bytes,5,rep,name=utilizationReports,proto3" json:"utilizationReports,omitempty"`
	// ID of RM, this will be used to identify which RM of the request comes from.
	RmID string `protobuf:"bytes,6,opt,name=rmID,proto3" json:"rmID,omitempty"`
	// 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)
	NewApplications []*AddApplicationRequest `protobuf:"bytes,8,rep,name=newApplications,proto3" json:"newApplications,omitempty"`
	// RM can also remove applications, all allocation/allocation requests associated with the application will be removed
	RemoveApplications   []*RemoveApplicationRequest `protobuf:"bytes,9,rep,name=removeApplications,proto3" json:"removeApplications,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*UpdateRequest) Descriptor 

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

func (*UpdateRequest) GetAsks 

func (m *UpdateRequest) GetAsks() []*AllocationAsk

func (*UpdateRequest) GetNewApplications 

func (m *UpdateRequest) GetNewApplications() []*AddApplicationRequest

func (*UpdateRequest) GetNewSchedulableNodes 

func (m *UpdateRequest) GetNewSchedulableNodes() []*NewNodeInfo

func (*UpdateRequest) GetReleases 

func (m *UpdateRequest) GetReleases() *AllocationReleasesRequest

func (*UpdateRequest) GetRemoveApplications 

func (m *UpdateRequest) GetRemoveApplications() []*RemoveApplicationRequest

func (*UpdateRequest) GetRmID 

func (m *UpdateRequest) GetRmID() string

func (*UpdateRequest) GetUpdatedNodes 

func (m *UpdateRequest) GetUpdatedNodes() []*UpdateNodeInfo

func (*UpdateRequest) GetUtilizationReports 

func (m *UpdateRequest) GetUtilizationReports() []*UtilizationReport

func (*UpdateRequest) ProtoMessage 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) Reset 

func (m *UpdateRequest) Reset()

func (*UpdateRequest) String 

func (m *UpdateRequest) String() string

func (*UpdateRequest) XXX_DiscardUnknown 

func (m *UpdateRequest) XXX_DiscardUnknown()

func (*UpdateRequest) XXX_Marshal 

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

func (*UpdateRequest) XXX_Merge 

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

func (*UpdateRequest) XXX_Size 

func (m *UpdateRequest) XXX_Size() int

func (*UpdateRequest) XXX_Unmarshal 

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

type UpdateResponse 

type UpdateResponse struct {
	// What RM needs to do, scheduler can send control code to RM when something goes wrong.
	// Don't use/expand this field for other general purposed actions. (Like kill a remote container process).
	Action UpdateResponse_ActionFromScheduler `protobuf:"varint,1,opt,name=action,proto3,enum=si.v1.UpdateResponse_ActionFromScheduler" json:"action,omitempty"`
	// New allocations
	NewAllocations []*Allocation `protobuf:"bytes,2,rep,name=newAllocations,proto3" json:"newAllocations,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).
	ReleasedAllocations []*AllocationReleaseResponse `protobuf:"bytes,3,rep,name=releasedAllocations,proto3" json:"releasedAllocations,omitempty"`
	// Rejected allocation requests
	RejectedAllocations []*RejectedAllocationAsk `protobuf:"bytes,4,rep,name=rejectedAllocations,proto3" json:"rejectedAllocations,omitempty"`
	// Suggested node update.
	// This could include:
	// 1) Schedulable resources on each node. This can be used when we want to run
	//    two resource management systems side-by-side. For example, YARN/K8s running side by side.
	//    and update YARN NodeManager / Kubelet resource dynamically.
	// 2) Other recommendations.
	NodeRecommendations []*NodeRecommendation `protobuf:"bytes,5,rep,name=nodeRecommendations,proto3" json:"nodeRecommendations,omitempty"`
	// Rejected Applications
	RejectedApplications []*RejectedApplication `protobuf:"bytes,6,rep,name=rejectedApplications,proto3" json:"rejectedApplications,omitempty"`
	// Accepted Applications
	AcceptedApplications []*AcceptedApplication `protobuf:"bytes,7,rep,name=acceptedApplications,proto3" json:"acceptedApplications,omitempty"`
	// Rejected Node Registrations
	RejectedNodes []*RejectedNode `protobuf:"bytes,8,rep,name=rejectedNodes,proto3" json:"rejectedNodes,omitempty"`
	// Accepted Node Registrations
	AcceptedNodes        []*AcceptedNode `protobuf:"bytes,9,rep,name=acceptedNodes,proto3" json:"acceptedNodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*UpdateResponse) Descriptor 

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

func (*UpdateResponse) GetAcceptedApplications 

func (m *UpdateResponse) GetAcceptedApplications() []*AcceptedApplication

func (*UpdateResponse) GetAcceptedNodes 

func (m *UpdateResponse) GetAcceptedNodes() []*AcceptedNode

func (*UpdateResponse) GetAction 

func (m *UpdateResponse) GetAction() UpdateResponse_ActionFromScheduler

func (*UpdateResponse) GetNewAllocations 

func (m *UpdateResponse) GetNewAllocations() []*Allocation

func (*UpdateResponse) GetNodeRecommendations 

func (m *UpdateResponse) GetNodeRecommendations() []*NodeRecommendation

func (*UpdateResponse) GetRejectedAllocations 

func (m *UpdateResponse) GetRejectedAllocations() []*RejectedAllocationAsk

func (*UpdateResponse) GetRejectedApplications 

func (m *UpdateResponse) GetRejectedApplications() []*RejectedApplication

func (*UpdateResponse) GetRejectedNodes 

func (m *UpdateResponse) GetRejectedNodes() []*RejectedNode

func (*UpdateResponse) GetReleasedAllocations 

func (m *UpdateResponse) GetReleasedAllocations() []*AllocationReleaseResponse

func (*UpdateResponse) ProtoMessage 

func (*UpdateResponse) ProtoMessage()

func (*UpdateResponse) Reset 

func (m *UpdateResponse) Reset()

func (*UpdateResponse) String 

func (m *UpdateResponse) String() string

func (*UpdateResponse) XXX_DiscardUnknown 

func (m *UpdateResponse) XXX_DiscardUnknown()

func (*UpdateResponse) XXX_Marshal 

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

func (*UpdateResponse) XXX_Merge 

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

func (*UpdateResponse) XXX_Size 

func (m *UpdateResponse) XXX_Size() int

func (*UpdateResponse) XXX_Unmarshal 

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

type UpdateResponse_ActionFromScheduler 

type UpdateResponse_ActionFromScheduler int32

Scheduler can send action to RM. 

const (
	// Nothing needs to do
	UpdateResponse_NOACTION UpdateResponse_ActionFromScheduler = 0
	// Something is wrong, RM needs to stop the RM, and re-register with scheduler.
	UpdateResponse_RESYNC UpdateResponse_ActionFromScheduler = 1
)

func (UpdateResponse_ActionFromScheduler) EnumDescriptor 

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

func (UpdateResponse_ActionFromScheduler) String 

func (x UpdateResponse_ActionFromScheduler) 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UserGroupInformation) Descriptor 

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

func (*UserGroupInformation) GetGroups 

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

func (*UserGroupInformation) GetUser 

func (m *UserGroupInformation) GetUser() string

func (*UserGroupInformation) ProtoMessage 

func (*UserGroupInformation) ProtoMessage()

func (*UserGroupInformation) Reset 

func (m *UserGroupInformation) Reset()

func (*UserGroupInformation) String 

func (m *UserGroupInformation) String() string

func (*UserGroupInformation) XXX_DiscardUnknown 

func (m *UserGroupInformation) XXX_DiscardUnknown()

func (*UserGroupInformation) XXX_Marshal 

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

func (*UserGroupInformation) XXX_Merge 

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

func (*UserGroupInformation) XXX_Size 

func (m *UserGroupInformation) XXX_Size() int

func (*UserGroupInformation) XXX_Unmarshal 

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

type UtilizationReport 

type UtilizationReport struct {
	// it could be either node id or allocation UUID.
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// Actual used resource
	ActualUsedResource   *Resource `protobuf:"bytes,2,opt,name=actualUsedResource,proto3" json:"actualUsedResource,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*UtilizationReport) Descriptor 

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

func (*UtilizationReport) GetActualUsedResource 

func (m *UtilizationReport) GetActualUsedResource() *Resource

func (*UtilizationReport) GetID 

func (m *UtilizationReport) GetID() string

func (*UtilizationReport) ProtoMessage 

func (*UtilizationReport) ProtoMessage()

func (*UtilizationReport) Reset 

func (m *UtilizationReport) Reset()

func (*UtilizationReport) String 

func (m *UtilizationReport) String() string

func (*UtilizationReport) XXX_DiscardUnknown 

func (m *UtilizationReport) XXX_DiscardUnknown()

func (*UtilizationReport) XXX_Marshal 

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

func (*UtilizationReport) XXX_Merge 

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

func (*UtilizationReport) XXX_Size 

func (m *UtilizationReport) XXX_Size() int

func (*UtilizationReport) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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