si

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: May 17, 2023 License: Apache-2.0 Imports: 6 Imported by: 24

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var E_SiSecret = &proto.ExtensionDesc{
	ExtendedType:  (*descriptorpb.FieldOptions)(nil),
	ExtensionType: (*bool)(nil),
	Field:         1059,
	Name:          "si.v1.si_secret",
	Tag:           "varint,1059,opt,name=si_secret,json=siSecret",
	Filename:      "yunikorn-scheduler-interface/si.proto",
}
View Source 
var EventRecord_Type_name = map[int32]string{
	0: "UNKNOWN_EVENTRECORD_TYPE",
	1: "REQUEST",
	2: "APP",
	3: "NODE",
	4: "QUEUE",
}
View Source 
var EventRecord_Type_value = map[string]int32{
	"UNKNOWN_EVENTRECORD_TYPE": 0,
	"REQUEST":                  1,
	"APP":                      2,
	"NODE":                     3,
	"QUEUE":                    4,
}
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",
}
View Source 
var NodeInfo_ActionFromRM_value = map[string]int32{
	"UNKNOWN_ACTION_FROM_RM": 0,
	"CREATE":                 1,
	"UPDATE":                 2,
	"DRAIN_NODE":             3,
	"DECOMISSION":            4,
	"DRAIN_TO_SCHEDULABLE":   5,
}
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",
}
View Source 
var TerminationType_value = map[string]int32{
	"UNKNOWN_TERMINATION_TYPE": 0,
	"STOPPED_BY_RM":            1,
	"TIMEOUT":                  2,
	"PREEMPTED_BY_SCHEDULER":   3,
	"PLACEHOLDER_REPLACED":     4,
}
View Source 
var UpdateContainerSchedulingStateRequest_SchedulingState_name = map[int32]string{
	0: "UNKNOWN_SCHEDULING_STATE",
	1: "SKIPPED",
	2: "SCHEDULED",
	3: "RESERVED",
	4: "FAILED",
}
View Source 
var UpdateContainerSchedulingStateRequest_SchedulingState_value = map[string]int32{
	"UNKNOWN_SCHEDULING_STATE": 0,
	"SKIPPED":                  1,
	"SCHEDULED":                2,
	"RESERVED":                 3,
	"FAILED":                   4,
}

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 (dst *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 (dst *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"`
	// 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"`
	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) GetGangSchedulingStyle 

func (m *AddApplicationRequest) GetGangSchedulingStyle() string

func (*AddApplicationRequest) GetPartitionName 

func (m *AddApplicationRequest) GetPartitionName() string

func (*AddApplicationRequest) GetPlaceholderAsk 

func (m *AddApplicationRequest) GetPlaceholderAsk() *Resource

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 (dst *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 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 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"`
	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) GetPlaceholder 

func (m *Allocation) GetPlaceholder() bool

func (*Allocation) GetPriority 

func (m *Allocation) GetPriority() int32

func (*Allocation) GetResourcePerAlloc 

func (m *Allocation) GetResourcePerAlloc() *Resource

func (*Allocation) GetTaskGroupName 

func (m *Allocation) GetTaskGroupName() string

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 (dst *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 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"`
	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) GetOriginator added in v1.1.0 

func (m *AllocationAsk) GetOriginator() bool

func (*AllocationAsk) GetPartitionName 

func (m *AllocationAsk) GetPartitionName() string

func (*AllocationAsk) GetPlaceholder 

func (m *AllocationAsk) GetPlaceholder() bool

func (*AllocationAsk) GetPreemptionPolicy added in v1.2.0 

func (m *AllocationAsk) GetPreemptionPolicy() *PreemptionPolicy

func (*AllocationAsk) GetPriority 

func (m *AllocationAsk) GetPriority() int32

func (*AllocationAsk) GetResourceAsk 

func (m *AllocationAsk) GetResourceAsk() *Resource

func (*AllocationAsk) GetTags 

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

func (*AllocationAsk) GetTaskGroupName 

func (m *AllocationAsk) GetTaskGroupName() 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 (dst *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 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Release ask

func (*AllocationAskRelease) Descriptor 

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

func (*AllocationAskRelease) GetAllocationKey 

func (m *AllocationAskRelease) GetAllocationKey() string

func (*AllocationAskRelease) GetApplicationID 

func (m *AllocationAskRelease) GetApplicationID() string

func (*AllocationAskRelease) GetMessage 

func (m *AllocationAskRelease) GetMessage() string

func (*AllocationAskRelease) GetPartitionName 

func (m *AllocationAskRelease) GetPartitionName() string

func (*AllocationAskRelease) GetTerminationType 

func (m *AllocationAskRelease) GetTerminationType() TerminationType

func (*AllocationAskRelease) ProtoMessage 

func (*AllocationAskRelease) ProtoMessage()

func (*AllocationAskRelease) Reset 

func (m *AllocationAskRelease) Reset()

func (*AllocationAskRelease) String 

func (m *AllocationAskRelease) String() string

func (*AllocationAskRelease) XXX_DiscardUnknown 

func (m *AllocationAskRelease) XXX_DiscardUnknown()

func (*AllocationAskRelease) XXX_Marshal 

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

func (*AllocationAskRelease) XXX_Merge 

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

func (*AllocationAskRelease) XXX_Size 

func (m *AllocationAskRelease) XXX_Size() int

func (*AllocationAskRelease) XXX_Unmarshal 

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

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"`
	// The UUID of the allocation to release, if not set all allocations are released for
	// the applicationID
	UUID string `protobuf:"bytes,3,opt,name=UUID,proto3" json:"UUID,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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

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

func (*AllocationRelease) GetAllocationKey 

func (m *AllocationRelease) GetAllocationKey() string

func (*AllocationRelease) GetApplicationID 

func (m *AllocationRelease) GetApplicationID() string

func (*AllocationRelease) GetMessage 

func (m *AllocationRelease) GetMessage() string

func (*AllocationRelease) GetPartitionName 

func (m *AllocationRelease) GetPartitionName() string

func (*AllocationRelease) GetTerminationType 

func (m *AllocationRelease) GetTerminationType() TerminationType

func (*AllocationRelease) GetUUID 

func (m *AllocationRelease) GetUUID() string

func (*AllocationRelease) ProtoMessage 

func (*AllocationRelease) ProtoMessage()

func (*AllocationRelease) Reset 

func (m *AllocationRelease) Reset()

func (*AllocationRelease) String 

func (m *AllocationRelease) String() string

func (*AllocationRelease) XXX_DiscardUnknown 

func (m *AllocationRelease) XXX_DiscardUnknown()

func (*AllocationRelease) XXX_Marshal 

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

func (*AllocationRelease) XXX_Merge 

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

func (*AllocationRelease) XXX_Size 

func (m *AllocationRelease) XXX_Size() int

func (*AllocationRelease) XXX_Unmarshal 

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

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"`
	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() []*AllocationAskRelease

func (*AllocationReleasesRequest) GetAllocationsToRelease 

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

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

func (*AllocationRequest) Descriptor 

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

func (*AllocationRequest) GetAsks 

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

func (*AllocationRequest) GetReleases 

func (m *AllocationRequest) GetReleases() *AllocationReleasesRequest

func (*AllocationRequest) GetRmID 

func (m *AllocationRequest) GetRmID() string

func (*AllocationRequest) ProtoMessage 

func (*AllocationRequest) ProtoMessage()

func (*AllocationRequest) Reset 

func (m *AllocationRequest) Reset()

func (*AllocationRequest) String 

func (m *AllocationRequest) String() string

func (*AllocationRequest) XXX_DiscardUnknown 

func (m *AllocationRequest) XXX_DiscardUnknown()

func (*AllocationRequest) XXX_Marshal 

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

func (*AllocationRequest) XXX_Merge 

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

func (*AllocationRequest) XXX_Size 

func (m *AllocationRequest) XXX_Size() int

func (*AllocationRequest) XXX_Unmarshal 

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

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

func (*AllocationResponse) Descriptor 

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

func (*AllocationResponse) GetNew 

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

func (*AllocationResponse) GetRejected 

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

func (*AllocationResponse) GetReleased 

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

func (*AllocationResponse) GetReleasedAsks 

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

func (*AllocationResponse) ProtoMessage 

func (*AllocationResponse) ProtoMessage()

func (*AllocationResponse) Reset 

func (m *AllocationResponse) Reset()

func (*AllocationResponse) String 

func (m *AllocationResponse) String() string

func (*AllocationResponse) XXX_DiscardUnknown 

func (m *AllocationResponse) XXX_DiscardUnknown()

func (*AllocationResponse) XXX_Marshal 

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

func (*AllocationResponse) XXX_Merge 

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

func (*AllocationResponse) XXX_Size 

func (m *AllocationResponse) XXX_Size() int

func (*AllocationResponse) XXX_Unmarshal 

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

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

func (*ApplicationRequest) Descriptor 

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

func (*ApplicationRequest) GetNew 

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

func (*ApplicationRequest) GetRemove 

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

func (*ApplicationRequest) GetRmID 

func (m *ApplicationRequest) GetRmID() string

func (*ApplicationRequest) ProtoMessage 

func (*ApplicationRequest) ProtoMessage()

func (*ApplicationRequest) Reset 

func (m *ApplicationRequest) Reset()

func (*ApplicationRequest) String 

func (m *ApplicationRequest) String() string

func (*ApplicationRequest) XXX_DiscardUnknown 

func (m *ApplicationRequest) XXX_DiscardUnknown()

func (*ApplicationRequest) XXX_Marshal 

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

func (*ApplicationRequest) XXX_Merge 

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

func (*ApplicationRequest) XXX_Size 

func (m *ApplicationRequest) XXX_Size() int

func (*ApplicationRequest) XXX_Unmarshal 

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

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

func (*ApplicationResponse) Descriptor 

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

func (*ApplicationResponse) GetAccepted 

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

func (*ApplicationResponse) GetRejected 

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

func (*ApplicationResponse) GetUpdated 

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

func (*ApplicationResponse) ProtoMessage 

func (*ApplicationResponse) ProtoMessage()

func (*ApplicationResponse) Reset 

func (m *ApplicationResponse) Reset()

func (*ApplicationResponse) String 

func (m *ApplicationResponse) String() string

func (*ApplicationResponse) XXX_DiscardUnknown 

func (m *ApplicationResponse) XXX_DiscardUnknown()

func (*ApplicationResponse) XXX_Marshal 

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

func (*ApplicationResponse) XXX_Merge 

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

func (*ApplicationResponse) XXX_Size 

func (m *ApplicationResponse) XXX_Size() int

func (*ApplicationResponse) XXX_Unmarshal 

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

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 group this object belongs to
	// it specifies the application ID for allocations and the queue for applications
	GroupID string `protobuf:"bytes,3,opt,name=groupID,proto3" json:"groupID,omitempty"`
	// the reason of this event
	Reason string `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventRecord) Descriptor 

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

func (*EventRecord) GetGroupID 

func (m *EventRecord) GetGroupID() string

func (*EventRecord) GetMessage 

func (m *EventRecord) GetMessage() string

func (*EventRecord) GetObjectID 

func (m *EventRecord) GetObjectID() string

func (*EventRecord) GetReason 

func (m *EventRecord) GetReason() string

func (*EventRecord) GetTimestampNano 

func (m *EventRecord) GetTimestampNano() int64

func (*EventRecord) GetType 

func (m *EventRecord) GetType() EventRecord_Type

func (*EventRecord) ProtoMessage 

func (*EventRecord) ProtoMessage()

func (*EventRecord) Reset 

func (m *EventRecord) Reset()

func (*EventRecord) String 

func (m *EventRecord) String() string

func (*EventRecord) XXX_DiscardUnknown 

func (m *EventRecord) XXX_DiscardUnknown()

func (*EventRecord) XXX_Marshal 

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

func (*EventRecord) XXX_Merge 

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

func (*EventRecord) XXX_Size 

func (m *EventRecord) XXX_Size() int

func (*EventRecord) XXX_Unmarshal 

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

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
)

func (EventRecord_Type) EnumDescriptor 

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

func (EventRecord_Type) String 

func (x EventRecord_Type) String() string

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

func (*NodeInfo) Descriptor 

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

func (*NodeInfo) GetAction 

func (m *NodeInfo) GetAction() NodeInfo_ActionFromRM

func (*NodeInfo) GetAttributes 

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

func (*NodeInfo) GetExistingAllocations 

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

func (*NodeInfo) GetNodeID 

func (m *NodeInfo) GetNodeID() string

func (*NodeInfo) GetOccupiedResource 

func (m *NodeInfo) GetOccupiedResource() *Resource

func (*NodeInfo) GetSchedulableResource 

func (m *NodeInfo) GetSchedulableResource() *Resource

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset 

func (m *NodeInfo) Reset()

func (*NodeInfo) String 

func (m *NodeInfo) String() string

func (*NodeInfo) XXX_DiscardUnknown 

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal 

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

func (*NodeInfo) XXX_Merge 

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

func (*NodeInfo) XXX_Size 

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal 

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

type NodeInfo_ActionFromRM 

type NodeInfo_ActionFromRM int32

Action from RM 

const (
	// ActionFromRM not set
	NodeInfo_UNKNOWN_ACTION_FROM_RM NodeInfo_ActionFromRM = 0
	// Create Node
	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
)

func (NodeInfo_ActionFromRM) EnumDescriptor 

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

func (NodeInfo_ActionFromRM) String 

func (x NodeInfo_ActionFromRM) String() string

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

func (*NodeRequest) Descriptor 

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

func (*NodeRequest) GetNodes 

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

func (*NodeRequest) GetRmID 

func (m *NodeRequest) GetRmID() string

func (*NodeRequest) ProtoMessage 

func (*NodeRequest) ProtoMessage()

func (*NodeRequest) Reset 

func (m *NodeRequest) Reset()

func (*NodeRequest) String 

func (m *NodeRequest) String() string

func (*NodeRequest) XXX_DiscardUnknown 

func (m *NodeRequest) XXX_DiscardUnknown()

func (*NodeRequest) XXX_Marshal 

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

func (*NodeRequest) XXX_Merge 

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

func (*NodeRequest) XXX_Size 

func (m *NodeRequest) XXX_Size() int

func (*NodeRequest) XXX_Unmarshal 

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

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

func (*NodeResponse) Descriptor 

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

func (*NodeResponse) GetAccepted 

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

func (*NodeResponse) GetRejected 

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

func (*NodeResponse) ProtoMessage 

func (*NodeResponse) ProtoMessage()

func (*NodeResponse) Reset 

func (m *NodeResponse) Reset()

func (*NodeResponse) String 

func (m *NodeResponse) String() string

func (*NodeResponse) XXX_DiscardUnknown 

func (m *NodeResponse) XXX_DiscardUnknown()

func (*NodeResponse) XXX_Marshal 

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

func (*NodeResponse) XXX_Merge 

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

func (*NodeResponse) XXX_Size 

func (m *NodeResponse) XXX_Size() int

func (*NodeResponse) XXX_Unmarshal 

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

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

func (*PredicatesArgs) Descriptor 

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

func (*PredicatesArgs) GetAllocate 

func (m *PredicatesArgs) GetAllocate() bool

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

func (*PreemptionPolicy) Descriptor added in v1.2.0 

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

func (*PreemptionPolicy) GetAllowPreemptOther added in v1.2.0 

func (m *PreemptionPolicy) GetAllowPreemptOther() bool

func (*PreemptionPolicy) GetAllowPreemptSelf added in v1.2.0 

func (m *PreemptionPolicy) GetAllowPreemptSelf() bool

func (*PreemptionPolicy) ProtoMessage added in v1.2.0 

func (*PreemptionPolicy) ProtoMessage()

func (*PreemptionPolicy) Reset added in v1.2.0 

func (m *PreemptionPolicy) Reset()

func (*PreemptionPolicy) String added in v1.2.0 

func (m *PreemptionPolicy) String() string

func (*PreemptionPolicy) XXX_DiscardUnknown added in v1.2.0 

func (m *PreemptionPolicy) XXX_DiscardUnknown()

func (*PreemptionPolicy) XXX_Marshal added in v1.2.0 

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

func (*PreemptionPolicy) XXX_Merge added in v1.2.0 

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

func (*PreemptionPolicy) XXX_Size added in v1.2.0 

func (m *PreemptionPolicy) XXX_Size() int

func (*PreemptionPolicy) XXX_Unmarshal added in v1.2.0 

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

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

func (*PreemptionPredicatesArgs) Descriptor added in v1.3.0 

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

func (*PreemptionPredicatesArgs) GetAllocationKey added in v1.3.0 

func (m *PreemptionPredicatesArgs) GetAllocationKey() string

func (*PreemptionPredicatesArgs) GetNodeID added in v1.3.0 

func (m *PreemptionPredicatesArgs) GetNodeID() string

func (*PreemptionPredicatesArgs) GetPreemptAllocationKeys added in v1.3.0 

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

func (*PreemptionPredicatesArgs) GetStartIndex added in v1.3.0 

func (m *PreemptionPredicatesArgs) GetStartIndex() int32

func (*PreemptionPredicatesArgs) ProtoMessage added in v1.3.0 

func (*PreemptionPredicatesArgs) ProtoMessage()

func (*PreemptionPredicatesArgs) Reset added in v1.3.0 

func (m *PreemptionPredicatesArgs) Reset()

func (*PreemptionPredicatesArgs) String added in v1.3.0 

func (m *PreemptionPredicatesArgs) String() string

func (*PreemptionPredicatesArgs) XXX_DiscardUnknown added in v1.3.0 

func (m *PreemptionPredicatesArgs) XXX_DiscardUnknown()

func (*PreemptionPredicatesArgs) XXX_Marshal added in v1.3.0 

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

func (*PreemptionPredicatesArgs) XXX_Merge added in v1.3.0 

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

func (*PreemptionPredicatesArgs) XXX_Size added in v1.3.0 

func (m *PreemptionPredicatesArgs) XXX_Size() int

func (*PreemptionPredicatesArgs) XXX_Unmarshal added in v1.3.0 

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

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

func (*PreemptionPredicatesResponse) Descriptor added in v1.3.0 

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

func (*PreemptionPredicatesResponse) GetIndex added in v1.3.0 

func (m *PreemptionPredicatesResponse) GetIndex() int32

func (*PreemptionPredicatesResponse) GetSuccess added in v1.3.0 

func (m *PreemptionPredicatesResponse) GetSuccess() bool

func (*PreemptionPredicatesResponse) ProtoMessage added in v1.3.0 

func (*PreemptionPredicatesResponse) ProtoMessage()

func (*PreemptionPredicatesResponse) Reset added in v1.3.0 

func (m *PreemptionPredicatesResponse) Reset()

func (*PreemptionPredicatesResponse) String added in v1.3.0 

func (m *PreemptionPredicatesResponse) String() string

func (*PreemptionPredicatesResponse) XXX_DiscardUnknown added in v1.3.0 

func (m *PreemptionPredicatesResponse) XXX_DiscardUnknown()

func (*PreemptionPredicatesResponse) XXX_Marshal added in v1.3.0 

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

func (*PreemptionPredicatesResponse) XXX_Merge added in v1.3.0 

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

func (*PreemptionPredicatesResponse) XXX_Size added in v1.3.0 

func (m *PreemptionPredicatesResponse) XXX_Size() int

func (*PreemptionPredicatesResponse) XXX_Unmarshal added in v1.3.0 

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

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

func (*RegisterResourceManagerRequest) Descriptor 

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

func (*RegisterResourceManagerRequest) GetBuildInfo 

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

func (*RegisterResourceManagerRequest) GetConfig added in v1.2.0 

func (m *RegisterResourceManagerRequest) GetConfig() string

func (*RegisterResourceManagerRequest) GetExtraConfig added in v1.2.0 

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

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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 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://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 allocation request
	UpdateAllocation(Scheduler_UpdateAllocationServer) error
	// Update application request
	UpdateApplication(Scheduler_UpdateApplicationServer) error
	// Update node info
	UpdateNode(Scheduler_UpdateNodeServer) error
}

SchedulerServer is the server API for Scheduler service.

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_STOPPED_BY_RM            TerminationType = 1
	TerminationType_TIMEOUT                  TerminationType = 2
	TerminationType_PREEMPTED_BY_SCHEDULER   TerminationType = 3
	TerminationType_PLACEHOLDER_REPLACED     TerminationType = 4
)

func (TerminationType) EnumDescriptor 

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

func (TerminationType) String 

func (x TerminationType) String() string

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

func (*UpdateConfigurationRequest) Descriptor 

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

func (*UpdateConfigurationRequest) GetConfig added in v1.2.0 

func (m *UpdateConfigurationRequest) GetConfig() string

func (*UpdateConfigurationRequest) GetExtraConfig added in v1.2.0 

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

func (*UpdateConfigurationRequest) GetPolicyGroup added in v1.2.0 

func (m *UpdateConfigurationRequest) GetPolicyGroup() string

func (*UpdateConfigurationRequest) GetRmID added in v1.2.0 

func (m *UpdateConfigurationRequest) GetRmID() string

func (*UpdateConfigurationRequest) ProtoMessage 

func (*UpdateConfigurationRequest) ProtoMessage()

func (*UpdateConfigurationRequest) Reset 

func (m *UpdateConfigurationRequest) Reset()

func (*UpdateConfigurationRequest) String 

func (m *UpdateConfigurationRequest) String() string

func (*UpdateConfigurationRequest) XXX_DiscardUnknown 

func (m *UpdateConfigurationRequest) XXX_DiscardUnknown()

func (*UpdateConfigurationRequest) XXX_Marshal 

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

func (*UpdateConfigurationRequest) XXX_Merge 

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

func (*UpdateConfigurationRequest) XXX_Size 

func (m *UpdateConfigurationRequest) XXX_Size() int

func (*UpdateConfigurationRequest) XXX_Unmarshal 

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

type UpdateContainerSchedulingStateRequest 

type UpdateContainerSchedulingStateRequest struct {
	// application ID
	ApplicartionID string `protobuf:"bytes,1,opt,name=applicartionID,proto3" json:"applicartionID,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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateContainerSchedulingStateRequest) Descriptor 

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

func (*UpdateContainerSchedulingStateRequest) GetAllocationKey 

func (m *UpdateContainerSchedulingStateRequest) GetAllocationKey() string

func (*UpdateContainerSchedulingStateRequest) GetApplicartionID 

func (m *UpdateContainerSchedulingStateRequest) GetApplicartionID() string

func (*UpdateContainerSchedulingStateRequest) GetReason 

func (m *UpdateContainerSchedulingStateRequest) GetReason() string

func (*UpdateContainerSchedulingStateRequest) GetState 

func (m *UpdateContainerSchedulingStateRequest) GetState() UpdateContainerSchedulingStateRequest_SchedulingState

func (*UpdateContainerSchedulingStateRequest) ProtoMessage 

func (*UpdateContainerSchedulingStateRequest) ProtoMessage()

func (*UpdateContainerSchedulingStateRequest) Reset 

func (m *UpdateContainerSchedulingStateRequest) Reset()

func (*UpdateContainerSchedulingStateRequest) String 

func (m *UpdateContainerSchedulingStateRequest) String() string

func (*UpdateContainerSchedulingStateRequest) XXX_DiscardUnknown 

func (m *UpdateContainerSchedulingStateRequest) XXX_DiscardUnknown()

func (*UpdateContainerSchedulingStateRequest) XXX_Marshal 

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

func (*UpdateContainerSchedulingStateRequest) XXX_Merge 

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

func (*UpdateContainerSchedulingStateRequest) XXX_Size 

func (m *UpdateContainerSchedulingStateRequest) XXX_Size() int

func (*UpdateContainerSchedulingStateRequest) XXX_Unmarshal 

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

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) EnumDescriptor 

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

func (UpdateContainerSchedulingStateRequest_SchedulingState) String 

func (x UpdateContainerSchedulingStateRequest_SchedulingState) String() string

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

func (*UpdatedApplication) Descriptor 

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

func (*UpdatedApplication) GetApplicationID 

func (m *UpdatedApplication) GetApplicationID() string

func (*UpdatedApplication) GetMessage 

func (m *UpdatedApplication) GetMessage() string

func (*UpdatedApplication) GetState 

func (m *UpdatedApplication) GetState() string

func (*UpdatedApplication) GetStateTransitionTimestamp 

func (m *UpdatedApplication) GetStateTransitionTimestamp() int64

func (*UpdatedApplication) ProtoMessage 

func (*UpdatedApplication) ProtoMessage()

func (*UpdatedApplication) Reset 

func (m *UpdatedApplication) Reset()

func (*UpdatedApplication) String 

func (m *UpdatedApplication) String() string

func (*UpdatedApplication) XXX_DiscardUnknown 

func (m *UpdatedApplication) XXX_DiscardUnknown()

func (*UpdatedApplication) XXX_Marshal 

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

func (*UpdatedApplication) XXX_Merge 

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

func (*UpdatedApplication) XXX_Size 

func (m *UpdatedApplication) XXX_Size() int

func (*UpdatedApplication) XXX_Unmarshal 

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

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 (dst *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

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.