firmament

package
v0.0.0-...-2c9fce1 Latest Latest
Warning

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

 Go to latest Published: Jul 19, 2021 License: Apache-2.0, Apache-2.0 Imports: 9 Imported by: 12

Documentation

Overview

Package firmament is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var JobDescriptor_JobState_name = map[int32]string{
	0: "NEW",
	1: "CREATED",
	2: "RUNNING",
	3: "COMPLETED",
	4: "FAILED",
	5: "ABORTED",
	6: "UNKNOWN",
}
View Source 
var JobDescriptor_JobState_value = map[string]int32{
	"NEW":       0,
	"CREATED":   1,
	"RUNNING":   2,
	"COMPLETED": 3,
	"FAILED":    4,
	"ABORTED":   5,
	"UNKNOWN":   6,
}
View Source 
var LabelSelector_SelectorType_name = map[int32]string{
	0: "IN_SET",
	1: "NOT_IN_SET",
	2: "EXISTS_KEY",
	3: "NOT_EXISTS_KEY",
	4: "GREATER_THAN",
	5: "LESSER_THAN",
}
View Source 
var LabelSelector_SelectorType_value = map[string]int32{
	"IN_SET":         0,
	"NOT_IN_SET":     1,
	"EXISTS_KEY":     2,
	"NOT_EXISTS_KEY": 3,
	"GREATER_THAN":   4,
	"LESSER_THAN":    5,
}
View Source 
var NodeReplyType_name = map[int32]string{
	0: "NODE_ADDED_OK",
	1: "NODE_FAILED_OK",
	2: "NODE_REMOVED_OK",
	3: "NODE_UPDATED_OK",
	4: "NODE_NOT_FOUND",
	5: "NODE_ALREADY_EXISTS",
}
View Source 
var NodeReplyType_value = map[string]int32{
	"NODE_ADDED_OK":       0,
	"NODE_FAILED_OK":      1,
	"NODE_REMOVED_OK":     2,
	"NODE_UPDATED_OK":     3,
	"NODE_NOT_FOUND":      4,
	"NODE_ALREADY_EXISTS": 5,
}
View Source 
var ReferenceDescriptor_ReferenceScope_name = map[int32]string{
	0: "PUBLIC",
	1: "PRIVATE",
}
View Source 
var ReferenceDescriptor_ReferenceScope_value = map[string]int32{
	"PUBLIC":  0,
	"PRIVATE": 1,
}
View Source 
var ReferenceDescriptor_ReferenceType_name = map[int32]string{
	0: "TOMBSTONE",
	1: "FUTURE",
	2: "CONCRETE",
	3: "STREAM",
	4: "VALUE",
	5: "ERROR",
}
View Source 
var ReferenceDescriptor_ReferenceType_value = map[string]int32{
	"TOMBSTONE": 0,
	"FUTURE":    1,
	"CONCRETE":  2,
	"STREAM":    3,
	"VALUE":     4,
	"ERROR":     5,
}
View Source 
var ResourceDescriptor_ResourceState_name = map[int32]string{
	0: "RESOURCE_UNKNOWN",
	1: "RESOURCE_IDLE",
	2: "RESOURCE_BUSY",
	3: "RESOURCE_LOST",
}
View Source 
var ResourceDescriptor_ResourceState_value = map[string]int32{
	"RESOURCE_UNKNOWN": 0,
	"RESOURCE_IDLE":    1,
	"RESOURCE_BUSY":    2,
	"RESOURCE_LOST":    3,
}
View Source 
var ResourceDescriptor_ResourceType_name = map[int32]string{
	0:  "RESOURCE_PU",
	1:  "RESOURCE_CORE",
	2:  "RESOURCE_CACHE",
	3:  "RESOURCE_NIC",
	4:  "RESOURCE_DISK",
	5:  "RESOURCE_SSD",
	6:  "RESOURCE_MACHINE",
	7:  "RESOURCE_LOGICAL",
	8:  "RESOURCE_NUMA_NODE",
	9:  "RESOURCE_SOCKET",
	10: "RESOURCE_COORDINATOR",
}
View Source 
var ResourceDescriptor_ResourceType_value = map[string]int32{
	"RESOURCE_PU":          0,
	"RESOURCE_CORE":        1,
	"RESOURCE_CACHE":       2,
	"RESOURCE_NIC":         3,
	"RESOURCE_DISK":        4,
	"RESOURCE_SSD":         5,
	"RESOURCE_MACHINE":     6,
	"RESOURCE_LOGICAL":     7,
	"RESOURCE_NUMA_NODE":   8,
	"RESOURCE_SOCKET":      9,
	"RESOURCE_COORDINATOR": 10,
}
View Source 
var SchedulingDelta_ChangeType_name = map[int32]string{
	0: "NOOP",
	1: "PLACE",
	2: "PREEMPT",
	3: "MIGRATE",
}
View Source 
var SchedulingDelta_ChangeType_value = map[string]int32{
	"NOOP":    0,
	"PLACE":   1,
	"PREEMPT": 2,
	"MIGRATE": 3,
}
View Source 
var ServingStatus_name = map[int32]string{
	0: "UNKNOWN",
	1: "SERVING",
	2: "NOT_SERVING",
}
View Source 
var ServingStatus_value = map[string]int32{
	"UNKNOWN":     0,
	"SERVING":     1,
	"NOT_SERVING": 2,
}
View Source 
var TaskDescriptor_TaskState_name = map[int32]string{
	0: "CREATED",
	1: "BLOCKING",
	2: "RUNNABLE",
	3: "ASSIGNED",
	4: "RUNNING",
	5: "COMPLETED",
	6: "FAILED",
	7: "ABORTED",
	8: "DELEGATED",
	9: "UNKNOWN",
}
View Source 
var TaskDescriptor_TaskState_value = map[string]int32{
	"CREATED":   0,
	"BLOCKING":  1,
	"RUNNABLE":  2,
	"ASSIGNED":  3,
	"RUNNING":   4,
	"COMPLETED": 5,
	"FAILED":    6,
	"ABORTED":   7,
	"DELEGATED": 8,
	"UNKNOWN":   9,
}
View Source 
var TaskDescriptor_TaskType_name = map[int32]string{
	0: "SHEEP",
	1: "RABBIT",
	2: "DEVIL",
	3: "TURTLE",
}
View Source 
var TaskDescriptor_TaskType_value = map[string]int32{
	"SHEEP":  0,
	"RABBIT": 1,
	"DEVIL":  2,
	"TURTLE": 3,
}
View Source 
var TaskInfoReplyType_name = map[int32]string{
	0: "TASKINFO_SUBMITTED_OK",
	2: "TASKINFO_REMOVED_OK",
	3: "TASKINFO_SUBMIT_FAILED",
	4: "TASKINFO_REMOVE_FAILED",
}
View Source 
var TaskInfoReplyType_value = map[string]int32{
	"TASKINFO_SUBMITTED_OK":  0,
	"TASKINFO_REMOVED_OK":    2,
	"TASKINFO_SUBMIT_FAILED": 3,
	"TASKINFO_REMOVE_FAILED": 4,
}
View Source 
var TaskInfoType_name = map[int32]string{
	0: "TASKINFO_ADD",
	1: "TASKINFO_REMOVE",
}
View Source 
var TaskInfoType_value = map[string]int32{
	"TASKINFO_ADD":    0,
	"TASKINFO_REMOVE": 1,
}
View Source 
var TaskReplyType_name = map[int32]string{
	0: "TASK_COMPLETED_OK",
	1: "TASK_SUBMITTED_OK",
	2: "TASK_REMOVED_OK",
	3: "TASK_FAILED_OK",
	4: "TASK_UPDATED_OK",
	5: "TASK_NOT_FOUND",
	6: "TASK_JOB_NOT_FOUND",
	7: "TASK_ALREADY_SUBMITTED",
	8: "TASK_STATE_NOT_CREATED",
}
View Source 
var TaskReplyType_value = map[string]int32{
	"TASK_COMPLETED_OK":      0,
	"TASK_SUBMITTED_OK":      1,
	"TASK_REMOVED_OK":        2,
	"TASK_FAILED_OK":         3,
	"TASK_UPDATED_OK":        4,
	"TASK_NOT_FOUND":         5,
	"TASK_JOB_NOT_FOUND":     6,
	"TASK_ALREADY_SUBMITTED": 7,
	"TASK_STATE_NOT_CREATED": 8,
}

Functions

func AddNodeStats 

func AddNodeStats(client FirmamentSchedulerClient, rs *ResourceStats)

AddNodeStats sends node status to firmament server.

func AddTaskInfo 

func AddTaskInfo(client FirmamentSchedulerClient, ts *TaskInfo)

AddTaskStats sends task status to firmament server.

func AddTaskStats 

func AddTaskStats(client FirmamentSchedulerClient, ts *TaskStats)

AddTaskStats sends task status to firmament server.

func Check 

func Check(client FirmamentSchedulerClient, req_service *HealthCheckRequest) (bool, error)

Check tests if firmament server is health

func NodeAdded 

func NodeAdded(client FirmamentSchedulerClient, rtnd *ResourceTopologyNodeDescriptor)

NodeAdded tells firmament server the given node is added.

func NodeFailed 

func NodeFailed(client FirmamentSchedulerClient, ruid *ResourceUID)

NodeFailed tells firmament server the given node is failed.

func NodeRemoved 

func NodeRemoved(client FirmamentSchedulerClient, ruid *ResourceUID)

NodeRemoved tells firmament server the given node is removed.

func NodeUpdated 

func NodeUpdated(client FirmamentSchedulerClient, rtnd *ResourceTopologyNodeDescriptor)

NodeUpdated tells firmament server the given node is updated.

func RegisterFirmamentSchedulerServer 

func RegisterFirmamentSchedulerServer(s *grpc.Server, srv FirmamentSchedulerServer)

func TaskCompleted 

func TaskCompleted(client FirmamentSchedulerClient, tuid *TaskUID)

TaskCompleted tells firmament server the given task is completed.

func TaskFailed 

func TaskFailed(client FirmamentSchedulerClient, tuid *TaskUID)

TaskFailed tells firmament server the given task is failed.

func TaskRemoved 

func TaskRemoved(client FirmamentSchedulerClient, tuid *TaskUID)

TaskRemoved tells firmament server the given task is removed.

func TaskSubmitted 

func TaskSubmitted(client FirmamentSchedulerClient, td *TaskDescription)

TaskSubmitted tells firmament server the given task is submitted.

func TaskUpdated 

func TaskUpdated(client FirmamentSchedulerClient, td *TaskDescription)

TaskUpdated tells firmament server the given task is updated.

Types

type Affinity 

type Affinity struct {
	NodeAffinity         *NodeAffinity    `protobuf:"bytes,1,opt,name=node_affinity,json=nodeAffinity,proto3" json:"node_affinity,omitempty"`
	PodAffinity          *PodAffinity     `protobuf:"bytes,2,opt,name=pod_affinity,json=podAffinity,proto3" json:"pod_affinity,omitempty"`
	PodAntiAffinity      *PodAntiAffinity `protobuf:"bytes,3,opt,name=pod_anti_affinity,json=podAntiAffinity,proto3" json:"pod_anti_affinity,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*Affinity) Descriptor 

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

func (*Affinity) GetNodeAffinity 

func (m *Affinity) GetNodeAffinity() *NodeAffinity

func (*Affinity) GetPodAffinity 

func (m *Affinity) GetPodAffinity() *PodAffinity

func (*Affinity) GetPodAntiAffinity 

func (m *Affinity) GetPodAntiAffinity() *PodAntiAffinity

func (*Affinity) ProtoMessage 

func (*Affinity) ProtoMessage()

func (*Affinity) Reset 

func (m *Affinity) Reset()

func (*Affinity) String 

func (m *Affinity) String() string

func (*Affinity) XXX_DiscardUnknown 

func (m *Affinity) XXX_DiscardUnknown()

func (*Affinity) XXX_Marshal 

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

func (*Affinity) XXX_Merge 

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

func (*Affinity) XXX_Size 

func (m *Affinity) XXX_Size() int

func (*Affinity) XXX_Unmarshal 

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

type AvoidPodsAnnotation 

type AvoidPodsAnnotation struct {
	Kind                 string   `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	Uid                  string   `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AvoidPodsAnnotation) Descriptor 

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

func (*AvoidPodsAnnotation) GetKind 

func (m *AvoidPodsAnnotation) GetKind() string

func (*AvoidPodsAnnotation) GetUid 

func (m *AvoidPodsAnnotation) GetUid() string

func (*AvoidPodsAnnotation) ProtoMessage 

func (*AvoidPodsAnnotation) ProtoMessage()

func (*AvoidPodsAnnotation) Reset 

func (m *AvoidPodsAnnotation) Reset()

func (*AvoidPodsAnnotation) String 

func (m *AvoidPodsAnnotation) String() string

func (*AvoidPodsAnnotation) XXX_DiscardUnknown 

func (m *AvoidPodsAnnotation) XXX_DiscardUnknown()

func (*AvoidPodsAnnotation) XXX_Marshal 

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

func (*AvoidPodsAnnotation) XXX_Merge 

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

func (*AvoidPodsAnnotation) XXX_Size 

func (m *AvoidPodsAnnotation) XXX_Size() int

func (*AvoidPodsAnnotation) XXX_Unmarshal 

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

type CoCoInterferenceScores 

type CoCoInterferenceScores struct {
	DevilPenalty         uint32   `protobuf:"varint,1,opt,name=devil_penalty,json=devilPenalty,proto3" json:"devil_penalty,omitempty"`
	RabbitPenalty        uint32   `protobuf:"varint,2,opt,name=rabbit_penalty,json=rabbitPenalty,proto3" json:"rabbit_penalty,omitempty"`
	SheepPenalty         uint32   `protobuf:"varint,3,opt,name=sheep_penalty,json=sheepPenalty,proto3" json:"sheep_penalty,omitempty"`
	TurtlePenalty        uint32   `protobuf:"varint,4,opt,name=turtle_penalty,json=turtlePenalty,proto3" json:"turtle_penalty,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Co-ordinated co-location cost model.

func (*CoCoInterferenceScores) Descriptor 

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

func (*CoCoInterferenceScores) GetDevilPenalty 

func (m *CoCoInterferenceScores) GetDevilPenalty() uint32

func (*CoCoInterferenceScores) GetRabbitPenalty 

func (m *CoCoInterferenceScores) GetRabbitPenalty() uint32

func (*CoCoInterferenceScores) GetSheepPenalty 

func (m *CoCoInterferenceScores) GetSheepPenalty() uint32

func (*CoCoInterferenceScores) GetTurtlePenalty 

func (m *CoCoInterferenceScores) GetTurtlePenalty() uint32

func (*CoCoInterferenceScores) ProtoMessage 

func (*CoCoInterferenceScores) ProtoMessage()

func (*CoCoInterferenceScores) Reset 

func (m *CoCoInterferenceScores) Reset()

func (*CoCoInterferenceScores) String 

func (m *CoCoInterferenceScores) String() string

func (*CoCoInterferenceScores) XXX_DiscardUnknown 

func (m *CoCoInterferenceScores) XXX_DiscardUnknown()

func (*CoCoInterferenceScores) XXX_Marshal 

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

func (*CoCoInterferenceScores) XXX_Merge 

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

func (*CoCoInterferenceScores) XXX_Size 

func (m *CoCoInterferenceScores) XXX_Size() int

func (*CoCoInterferenceScores) XXX_Unmarshal 

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

type CpuStats 

type CpuStats struct {
	// CPU stats in millicores.
	// cpu_allocatable is allocatable CPU millicores of node.
	CpuAllocatable int64 `protobuf:"varint,1,opt,name=cpu_allocatable,json=cpuAllocatable,proto3" json:"cpu_allocatable,omitempty"`
	// cpu_capacity is the CPU capacity millicores of node.
	CpuCapacity int64 `protobuf:"varint,2,opt,name=cpu_capacity,json=cpuCapacity,proto3" json:"cpu_capacity,omitempty"`
	// CPU stats (fraction of total).
	// cpu_reservation is the fraction of cpu millicores reserved.
	CpuReservation float64 `protobuf:"fixed64,3,opt,name=cpu_reservation,json=cpuReservation,proto3" json:"cpu_reservation,omitempty"`
	// cpu_utilization is the fraction of cpu millicores used.
	CpuUtilization       float64  `protobuf:"fixed64,4,opt,name=cpu_utilization,json=cpuUtilization,proto3" json:"cpu_utilization,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CpuStats) Descriptor 

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

func (*CpuStats) GetCpuAllocatable 

func (m *CpuStats) GetCpuAllocatable() int64

func (*CpuStats) GetCpuCapacity 

func (m *CpuStats) GetCpuCapacity() int64

func (*CpuStats) GetCpuReservation 

func (m *CpuStats) GetCpuReservation() float64

func (*CpuStats) GetCpuUtilization 

func (m *CpuStats) GetCpuUtilization() float64

func (*CpuStats) ProtoMessage 

func (*CpuStats) ProtoMessage()

func (*CpuStats) Reset 

func (m *CpuStats) Reset()

func (*CpuStats) String 

func (m *CpuStats) String() string

func (*CpuStats) XXX_DiscardUnknown 

func (m *CpuStats) XXX_DiscardUnknown()

func (*CpuStats) XXX_Marshal 

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

func (*CpuStats) XXX_Merge 

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

func (*CpuStats) XXX_Size 

func (m *CpuStats) XXX_Size() int

func (*CpuStats) XXX_Unmarshal 

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

type FirmamentSchedulerClient 

type FirmamentSchedulerClient interface {
	// Schedule sends a schedule request to firmament server.
	Schedule(ctx context.Context, in *ScheduleRequest, opts ...grpc.CallOption) (*SchedulingDeltas, error)
	// TaskCompleted notifies firmament server the given task is completed.
	TaskCompleted(ctx context.Context, in *TaskUID, opts ...grpc.CallOption) (*TaskCompletedResponse, error)
	// TaskFailed notifies firmament server the given task is failed.
	TaskFailed(ctx context.Context, in *TaskUID, opts ...grpc.CallOption) (*TaskFailedResponse, error)
	// TaskRemoved notifies firmament server the given task is removed.
	TaskRemoved(ctx context.Context, in *TaskUID, opts ...grpc.CallOption) (*TaskRemovedResponse, error)
	// TaskSubmitted notifies firmament server the given task is submitted.
	TaskSubmitted(ctx context.Context, in *TaskDescription, opts ...grpc.CallOption) (*TaskSubmittedResponse, error)
	// TaskUpdated notifies firmament server the given task is updated.
	TaskUpdated(ctx context.Context, in *TaskDescription, opts ...grpc.CallOption) (*TaskUpdatedResponse, error)
	// NodeAdded notifies firmament server the given node is added.
	NodeAdded(ctx context.Context, in *ResourceTopologyNodeDescriptor, opts ...grpc.CallOption) (*NodeAddedResponse, error)
	// NodeFailed notifies firmament server the given node is failed.
	NodeFailed(ctx context.Context, in *ResourceUID, opts ...grpc.CallOption) (*NodeFailedResponse, error)
	// NodeRemoved notifies firmament server the given node is removed.
	NodeRemoved(ctx context.Context, in *ResourceUID, opts ...grpc.CallOption) (*NodeRemovedResponse, error)
	// NodeUpdated notifies firmament server the given node is updated.
	NodeUpdated(ctx context.Context, in *ResourceTopologyNodeDescriptor, opts ...grpc.CallOption) (*NodeUpdatedResponse, error)
	// AddTaskStats sends task status to firmament server.
	AddTaskStats(ctx context.Context, in *TaskStats, opts ...grpc.CallOption) (*TaskStatsResponse, error)
	// AddNodeStats sends node status to firmament server.
	AddNodeStats(ctx context.Context, in *ResourceStats, opts ...grpc.CallOption) (*ResourceStatsResponse, error)
	Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	// AddTaskInfo sends task status to firmament server.
	AddTaskInfo(ctx context.Context, in *TaskInfo, opts ...grpc.CallOption) (*TaskInfoResponse, error)
}

FirmamentSchedulerClient is the client API for FirmamentScheduler service.

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

func New 

func New(address string) (FirmamentSchedulerClient, *grpc.ClientConn, error)

New creates a firmament scheduler client by a remote server address. NOTE: it's an insecure connection.

func NewFirmamentSchedulerClient 

func NewFirmamentSchedulerClient(cc *grpc.ClientConn) FirmamentSchedulerClient

type FirmamentSchedulerServer 

type FirmamentSchedulerServer interface {
	// Schedule sends a schedule request to firmament server.
	Schedule(context.Context, *ScheduleRequest) (*SchedulingDeltas, error)
	// TaskCompleted notifies firmament server the given task is completed.
	TaskCompleted(context.Context, *TaskUID) (*TaskCompletedResponse, error)
	// TaskFailed notifies firmament server the given task is failed.
	TaskFailed(context.Context, *TaskUID) (*TaskFailedResponse, error)
	// TaskRemoved notifies firmament server the given task is removed.
	TaskRemoved(context.Context, *TaskUID) (*TaskRemovedResponse, error)
	// TaskSubmitted notifies firmament server the given task is submitted.
	TaskSubmitted(context.Context, *TaskDescription) (*TaskSubmittedResponse, error)
	// TaskUpdated notifies firmament server the given task is updated.
	TaskUpdated(context.Context, *TaskDescription) (*TaskUpdatedResponse, error)
	// NodeAdded notifies firmament server the given node is added.
	NodeAdded(context.Context, *ResourceTopologyNodeDescriptor) (*NodeAddedResponse, error)
	// NodeFailed notifies firmament server the given node is failed.
	NodeFailed(context.Context, *ResourceUID) (*NodeFailedResponse, error)
	// NodeRemoved notifies firmament server the given node is removed.
	NodeRemoved(context.Context, *ResourceUID) (*NodeRemovedResponse, error)
	// NodeUpdated notifies firmament server the given node is updated.
	NodeUpdated(context.Context, *ResourceTopologyNodeDescriptor) (*NodeUpdatedResponse, error)
	// AddTaskStats sends task status to firmament server.
	AddTaskStats(context.Context, *TaskStats) (*TaskStatsResponse, error)
	// AddNodeStats sends node status to firmament server.
	AddNodeStats(context.Context, *ResourceStats) (*ResourceStatsResponse, error)
	Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	// AddTaskInfo sends task status to firmament server.
	AddTaskInfo(context.Context, *TaskInfo) (*TaskInfoResponse, error)
}

FirmamentSchedulerServer is the server API for FirmamentScheduler service.

type HealthCheckRequest 

type HealthCheckRequest struct {
	GrpcService          string   `protobuf:"bytes,1,opt,name=grpc_service,json=grpcService,proto3" json:"grpc_service,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HealthCheckRequest) Descriptor 

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

func (*HealthCheckRequest) GetGrpcService 

func (m *HealthCheckRequest) GetGrpcService() string

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) Reset 

func (m *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String 

func (m *HealthCheckRequest) String() string

func (*HealthCheckRequest) XXX_DiscardUnknown 

func (m *HealthCheckRequest) XXX_DiscardUnknown()

func (*HealthCheckRequest) XXX_Marshal 

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

func (*HealthCheckRequest) XXX_Merge 

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

func (*HealthCheckRequest) XXX_Size 

func (m *HealthCheckRequest) XXX_Size() int

func (*HealthCheckRequest) XXX_Unmarshal 

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

type HealthCheckResponse 

type HealthCheckResponse struct {
	Status               ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=firmament.ServingStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*HealthCheckResponse) Descriptor 

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

func (*HealthCheckResponse) GetStatus 

func (m *HealthCheckResponse) GetStatus() ServingStatus

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) Reset 

func (m *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String 

func (m *HealthCheckResponse) String() string

func (*HealthCheckResponse) XXX_DiscardUnknown 

func (m *HealthCheckResponse) XXX_DiscardUnknown()

func (*HealthCheckResponse) XXX_Marshal 

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

func (*HealthCheckResponse) XXX_Merge 

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

func (*HealthCheckResponse) XXX_Size 

func (m *HealthCheckResponse) XXX_Size() int

func (*HealthCheckResponse) XXX_Unmarshal 

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

type JobDescriptor 

type JobDescriptor struct {
	Uuid      string                 `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Name      string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	State     JobDescriptor_JobState `protobuf:"varint,3,opt,name=state,proto3,enum=firmament.JobDescriptor_JobState" json:"state,omitempty"`
	RootTask  *TaskDescriptor        `protobuf:"bytes,4,opt,name=root_task,json=rootTask,proto3" json:"root_task,omitempty"`
	OutputIds [][]byte               `protobuf:"bytes,5,rep,name=output_ids,json=outputIds,proto3" json:"output_ids,omitempty"`
	// For gang scheduling jobs.
	MinNumberOfTasks     uint64   `protobuf:"varint,6,opt,name=min_number_of_tasks,json=minNumberOfTasks,proto3" json:"min_number_of_tasks,omitempty"`
	ScheduledTasksCount  uint64   `protobuf:"varint,7,opt,name=scheduled_tasks_count,json=scheduledTasksCount,proto3" json:"scheduled_tasks_count,omitempty"`
	IsGangSchedulingJob  bool     `protobuf:"varint,8,opt,name=is_gang_scheduling_job,json=isGangSchedulingJob,proto3" json:"is_gang_scheduling_job,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobDescriptor) Descriptor 

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

func (*JobDescriptor) GetIsGangSchedulingJob 

func (m *JobDescriptor) GetIsGangSchedulingJob() bool

func (*JobDescriptor) GetMinNumberOfTasks 

func (m *JobDescriptor) GetMinNumberOfTasks() uint64

func (*JobDescriptor) GetName 

func (m *JobDescriptor) GetName() string

func (*JobDescriptor) GetOutputIds 

func (m *JobDescriptor) GetOutputIds() [][]byte

func (*JobDescriptor) GetRootTask 

func (m *JobDescriptor) GetRootTask() *TaskDescriptor

func (*JobDescriptor) GetScheduledTasksCount 

func (m *JobDescriptor) GetScheduledTasksCount() uint64

func (*JobDescriptor) GetState 

func (m *JobDescriptor) GetState() JobDescriptor_JobState

func (*JobDescriptor) GetUuid 

func (m *JobDescriptor) GetUuid() string

func (*JobDescriptor) ProtoMessage 

func (*JobDescriptor) ProtoMessage()

func (*JobDescriptor) Reset 

func (m *JobDescriptor) Reset()

func (*JobDescriptor) String 

func (m *JobDescriptor) String() string

func (*JobDescriptor) XXX_DiscardUnknown 

func (m *JobDescriptor) XXX_DiscardUnknown()

func (*JobDescriptor) XXX_Marshal 

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

func (*JobDescriptor) XXX_Merge 

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

func (*JobDescriptor) XXX_Size 

func (m *JobDescriptor) XXX_Size() int

func (*JobDescriptor) XXX_Unmarshal 

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

type JobDescriptor_JobState 

type JobDescriptor_JobState int32
const (
	JobDescriptor_NEW       JobDescriptor_JobState = 0
	JobDescriptor_CREATED   JobDescriptor_JobState = 1
	JobDescriptor_RUNNING   JobDescriptor_JobState = 2
	JobDescriptor_COMPLETED JobDescriptor_JobState = 3
	JobDescriptor_FAILED    JobDescriptor_JobState = 4
	JobDescriptor_ABORTED   JobDescriptor_JobState = 5
	JobDescriptor_UNKNOWN   JobDescriptor_JobState = 6
)

func (JobDescriptor_JobState) EnumDescriptor 

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

func (JobDescriptor_JobState) String 

func (x JobDescriptor_JobState) String() string

type Label 

type Label struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Labels are key/value pairs that are attached to firmament resousces.It can be used to organize and to select subsets of objects.

func (*Label) Descriptor 

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

func (*Label) GetKey 

func (m *Label) GetKey() string

func (*Label) GetValue 

func (m *Label) GetValue() string

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) Reset 

func (m *Label) Reset()

func (*Label) String 

func (m *Label) String() string

func (*Label) XXX_DiscardUnknown 

func (m *Label) XXX_DiscardUnknown()

func (*Label) XXX_Marshal 

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

func (*Label) XXX_Merge 

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

func (*Label) XXX_Size 

func (m *Label) XXX_Size() int

func (*Label) XXX_Unmarshal 

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

type LabelSelector 

type LabelSelector struct {
	Type                 LabelSelector_SelectorType `protobuf:"varint,1,opt,name=type,proto3,enum=firmament.LabelSelector_SelectorType" json:"type,omitempty"`
	Key                  string                     `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Values               []string                   `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

LabelSelector can be used by client/user to identify a set of objects if their Labels match the LabelSelector. Set-based label requirements allow filtering keys according to a set of values. Four kinds of operators are supported: in, notin, exists (only the key identifier) and notexist.

func (*LabelSelector) Descriptor 

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

func (*LabelSelector) GetKey 

func (m *LabelSelector) GetKey() string

func (*LabelSelector) GetType 

func (m *LabelSelector) GetType() LabelSelector_SelectorType

func (*LabelSelector) GetValues 

func (m *LabelSelector) GetValues() []string

func (*LabelSelector) ProtoMessage 

func (*LabelSelector) ProtoMessage()

func (*LabelSelector) Reset 

func (m *LabelSelector) Reset()

func (*LabelSelector) String 

func (m *LabelSelector) String() string

func (*LabelSelector) XXX_DiscardUnknown 

func (m *LabelSelector) XXX_DiscardUnknown()

func (*LabelSelector) XXX_Marshal 

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

func (*LabelSelector) XXX_Merge 

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

func (*LabelSelector) XXX_Size 

func (m *LabelSelector) XXX_Size() int

func (*LabelSelector) XXX_Unmarshal 

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

type LabelSelectorAntiAff 

type LabelSelectorAntiAff struct {
	MatchLabels          *MatchLabelsAntiAff                `protobuf:"bytes,1,opt,name=matchLabels,proto3" json:"matchLabels,omitempty"`
	MatchExpressions     []*LabelSelectorRequirementAntiAff `protobuf:"bytes,2,rep,name=matchExpressions,proto3" json:"matchExpressions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*LabelSelectorAntiAff) Descriptor 

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

func (*LabelSelectorAntiAff) GetMatchExpressions 

func (m *LabelSelectorAntiAff) GetMatchExpressions() []*LabelSelectorRequirementAntiAff

func (*LabelSelectorAntiAff) GetMatchLabels 

func (m *LabelSelectorAntiAff) GetMatchLabels() *MatchLabelsAntiAff

func (*LabelSelectorAntiAff) ProtoMessage 

func (*LabelSelectorAntiAff) ProtoMessage()

func (*LabelSelectorAntiAff) Reset 

func (m *LabelSelectorAntiAff) Reset()

func (*LabelSelectorAntiAff) String 

func (m *LabelSelectorAntiAff) String() string

func (*LabelSelectorAntiAff) XXX_DiscardUnknown 

func (m *LabelSelectorAntiAff) XXX_DiscardUnknown()

func (*LabelSelectorAntiAff) XXX_Marshal 

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

func (*LabelSelectorAntiAff) XXX_Merge 

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

func (*LabelSelectorAntiAff) XXX_Size 

func (m *LabelSelectorAntiAff) XXX_Size() int

func (*LabelSelectorAntiAff) XXX_Unmarshal 

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

type LabelSelectorRequirement 

type LabelSelectorRequirement struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Operator             string   `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"`
	Values               []string `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LabelSelectorRequirement) Descriptor 

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

func (*LabelSelectorRequirement) GetKey 

func (m *LabelSelectorRequirement) GetKey() string

func (*LabelSelectorRequirement) GetOperator 

func (m *LabelSelectorRequirement) GetOperator() string

func (*LabelSelectorRequirement) GetValues 

func (m *LabelSelectorRequirement) GetValues() []string

func (*LabelSelectorRequirement) ProtoMessage 

func (*LabelSelectorRequirement) ProtoMessage()

func (*LabelSelectorRequirement) Reset 

func (m *LabelSelectorRequirement) Reset()

func (*LabelSelectorRequirement) String 

func (m *LabelSelectorRequirement) String() string

func (*LabelSelectorRequirement) XXX_DiscardUnknown 

func (m *LabelSelectorRequirement) XXX_DiscardUnknown()

func (*LabelSelectorRequirement) XXX_Marshal 

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

func (*LabelSelectorRequirement) XXX_Merge 

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

func (*LabelSelectorRequirement) XXX_Size 

func (m *LabelSelectorRequirement) XXX_Size() int

func (*LabelSelectorRequirement) XXX_Unmarshal 

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

type LabelSelectorRequirementAntiAff 

type LabelSelectorRequirementAntiAff struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Operator             string   `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"`
	Values               []string `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LabelSelectorRequirementAntiAff) Descriptor 

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

func (*LabelSelectorRequirementAntiAff) GetKey 

func (m *LabelSelectorRequirementAntiAff) GetKey() string

func (*LabelSelectorRequirementAntiAff) GetOperator 

func (m *LabelSelectorRequirementAntiAff) GetOperator() string

func (*LabelSelectorRequirementAntiAff) GetValues 

func (m *LabelSelectorRequirementAntiAff) GetValues() []string

func (*LabelSelectorRequirementAntiAff) ProtoMessage 

func (*LabelSelectorRequirementAntiAff) ProtoMessage()

func (*LabelSelectorRequirementAntiAff) Reset 

func (m *LabelSelectorRequirementAntiAff) Reset()

func (*LabelSelectorRequirementAntiAff) String 

func (m *LabelSelectorRequirementAntiAff) String() string

func (*LabelSelectorRequirementAntiAff) XXX_DiscardUnknown 

func (m *LabelSelectorRequirementAntiAff) XXX_DiscardUnknown()

func (*LabelSelectorRequirementAntiAff) XXX_Marshal 

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

func (*LabelSelectorRequirementAntiAff) XXX_Merge 

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

func (*LabelSelectorRequirementAntiAff) XXX_Size 

func (m *LabelSelectorRequirementAntiAff) XXX_Size() int

func (*LabelSelectorRequirementAntiAff) XXX_Unmarshal 

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

type LabelSelector_SelectorType 

type LabelSelector_SelectorType int32
const (
	LabelSelector_IN_SET         LabelSelector_SelectorType = 0
	LabelSelector_NOT_IN_SET     LabelSelector_SelectorType = 1
	LabelSelector_EXISTS_KEY     LabelSelector_SelectorType = 2
	LabelSelector_NOT_EXISTS_KEY LabelSelector_SelectorType = 3
	LabelSelector_GREATER_THAN   LabelSelector_SelectorType = 4
	LabelSelector_LESSER_THAN    LabelSelector_SelectorType = 5
)

func (LabelSelector_SelectorType) EnumDescriptor 

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

func (LabelSelector_SelectorType) String 

func (x LabelSelector_SelectorType) String() string

type MatchLabels 

type MatchLabels struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MatchLabels) Descriptor 

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

func (*MatchLabels) GetKey 

func (m *MatchLabels) GetKey() string

func (*MatchLabels) GetValue 

func (m *MatchLabels) GetValue() string

func (*MatchLabels) ProtoMessage 

func (*MatchLabels) ProtoMessage()

func (*MatchLabels) Reset 

func (m *MatchLabels) Reset()

func (*MatchLabels) String 

func (m *MatchLabels) String() string

func (*MatchLabels) XXX_DiscardUnknown 

func (m *MatchLabels) XXX_DiscardUnknown()

func (*MatchLabels) XXX_Marshal 

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

func (*MatchLabels) XXX_Merge 

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

func (*MatchLabels) XXX_Size 

func (m *MatchLabels) XXX_Size() int

func (*MatchLabels) XXX_Unmarshal 

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

type MatchLabelsAntiAff 

type MatchLabelsAntiAff struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MatchLabelsAntiAff) Descriptor 

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

func (*MatchLabelsAntiAff) GetKey 

func (m *MatchLabelsAntiAff) GetKey() string

func (*MatchLabelsAntiAff) GetValue 

func (m *MatchLabelsAntiAff) GetValue() string

func (*MatchLabelsAntiAff) ProtoMessage 

func (*MatchLabelsAntiAff) ProtoMessage()

func (*MatchLabelsAntiAff) Reset 

func (m *MatchLabelsAntiAff) Reset()

func (*MatchLabelsAntiAff) String 

func (m *MatchLabelsAntiAff) String() string

func (*MatchLabelsAntiAff) XXX_DiscardUnknown 

func (m *MatchLabelsAntiAff) XXX_DiscardUnknown()

func (*MatchLabelsAntiAff) XXX_Marshal 

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

func (*MatchLabelsAntiAff) XXX_Merge 

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

func (*MatchLabelsAntiAff) XXX_Size 

func (m *MatchLabelsAntiAff) XXX_Size() int

func (*MatchLabelsAntiAff) XXX_Unmarshal 

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

type MockFirmamentSchedulerClient 

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

MockFirmamentSchedulerClient is a mock of FirmamentSchedulerClient interface

func NewMockFirmamentSchedulerClient 

func NewMockFirmamentSchedulerClient(ctrl *gomock.Controller) *MockFirmamentSchedulerClient

NewMockFirmamentSchedulerClient creates a new mock instance

func (*MockFirmamentSchedulerClient) AddNodeStats 

func (m *MockFirmamentSchedulerClient) AddNodeStats(ctx context.Context, in *ResourceStats, opts ...grpc.CallOption) (*ResourceStatsResponse, error)

AddNodeStats mocks base method

func (*MockFirmamentSchedulerClient) AddTaskInfo 

func (m *MockFirmamentSchedulerClient) AddTaskInfo(ctx context.Context, in *TaskInfo, opts ...grpc.CallOption) (*TaskInfoResponse, error)

AddTaskInfo mocks base method

func (*MockFirmamentSchedulerClient) AddTaskStats 

func (m *MockFirmamentSchedulerClient) AddTaskStats(ctx context.Context, in *TaskStats, opts ...grpc.CallOption) (*TaskStatsResponse, error)

AddTaskStats mocks base method

func (*MockFirmamentSchedulerClient) Check 

func (m *MockFirmamentSchedulerClient) Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)

Check mocks base method

func (*MockFirmamentSchedulerClient) EXPECT 

func (m *MockFirmamentSchedulerClient) EXPECT() *MockFirmamentSchedulerClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockFirmamentSchedulerClient) NodeAdded 

func (m *MockFirmamentSchedulerClient) NodeAdded(ctx context.Context, in *ResourceTopologyNodeDescriptor, opts ...grpc.CallOption) (*NodeAddedResponse, error)

NodeAdded mocks base method

func (*MockFirmamentSchedulerClient) NodeFailed 

func (m *MockFirmamentSchedulerClient) NodeFailed(ctx context.Context, in *ResourceUID, opts ...grpc.CallOption) (*NodeFailedResponse, error)

NodeFailed mocks base method

func (*MockFirmamentSchedulerClient) NodeRemoved 

func (m *MockFirmamentSchedulerClient) NodeRemoved(ctx context.Context, in *ResourceUID, opts ...grpc.CallOption) (*NodeRemovedResponse, error)

NodeRemoved mocks base method

func (*MockFirmamentSchedulerClient) NodeUpdated 

func (m *MockFirmamentSchedulerClient) NodeUpdated(ctx context.Context, in *ResourceTopologyNodeDescriptor, opts ...grpc.CallOption) (*NodeUpdatedResponse, error)

NodeUpdated mocks base method

func (*MockFirmamentSchedulerClient) Schedule 

func (m *MockFirmamentSchedulerClient) Schedule(ctx context.Context, in *ScheduleRequest, opts ...grpc.CallOption) (*SchedulingDeltas, error)

Schedule mocks base method

func (*MockFirmamentSchedulerClient) TaskCompleted 

func (m *MockFirmamentSchedulerClient) TaskCompleted(ctx context.Context, in *TaskUID, opts ...grpc.CallOption) (*TaskCompletedResponse, error)

TaskCompleted mocks base method

func (*MockFirmamentSchedulerClient) TaskFailed 

func (m *MockFirmamentSchedulerClient) TaskFailed(ctx context.Context, in *TaskUID, opts ...grpc.CallOption) (*TaskFailedResponse, error)

TaskFailed mocks base method

func (*MockFirmamentSchedulerClient) TaskRemoved 

func (m *MockFirmamentSchedulerClient) TaskRemoved(ctx context.Context, in *TaskUID, opts ...grpc.CallOption) (*TaskRemovedResponse, error)

TaskRemoved mocks base method

func (*MockFirmamentSchedulerClient) TaskSubmitted 

func (m *MockFirmamentSchedulerClient) TaskSubmitted(ctx context.Context, in *TaskDescription, opts ...grpc.CallOption) (*TaskSubmittedResponse, error)

TaskSubmitted mocks base method

func (*MockFirmamentSchedulerClient) TaskUpdated 

func (m *MockFirmamentSchedulerClient) TaskUpdated(ctx context.Context, in *TaskDescription, opts ...grpc.CallOption) (*TaskUpdatedResponse, error)

TaskUpdated mocks base method

type MockFirmamentSchedulerClientMockRecorder 

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

MockFirmamentSchedulerClientMockRecorder is the mock recorder for MockFirmamentSchedulerClient

func (*MockFirmamentSchedulerClientMockRecorder) AddNodeStats 

func (mr *MockFirmamentSchedulerClientMockRecorder) AddNodeStats(ctx, in interface{}, opts ...interface{}) *gomock.Call

AddNodeStats indicates an expected call of AddNodeStats

func (*MockFirmamentSchedulerClientMockRecorder) AddTaskInfo 

func (mr *MockFirmamentSchedulerClientMockRecorder) AddTaskInfo(ctx, in interface{}, opts ...interface{}) *gomock.Call

AddTaskInfo indicates an expected call of AddTaskInfo

func (*MockFirmamentSchedulerClientMockRecorder) AddTaskStats 

func (mr *MockFirmamentSchedulerClientMockRecorder) AddTaskStats(ctx, in interface{}, opts ...interface{}) *gomock.Call

AddTaskStats indicates an expected call of AddTaskStats

func (*MockFirmamentSchedulerClientMockRecorder) Check 

func (mr *MockFirmamentSchedulerClientMockRecorder) Check(ctx, in interface{}, opts ...interface{}) *gomock.Call

Check indicates an expected call of Check

func (*MockFirmamentSchedulerClientMockRecorder) NodeAdded 

func (mr *MockFirmamentSchedulerClientMockRecorder) NodeAdded(ctx, in interface{}, opts ...interface{}) *gomock.Call

NodeAdded indicates an expected call of NodeAdded

func (*MockFirmamentSchedulerClientMockRecorder) NodeFailed 

func (mr *MockFirmamentSchedulerClientMockRecorder) NodeFailed(ctx, in interface{}, opts ...interface{}) *gomock.Call

NodeFailed indicates an expected call of NodeFailed

func (*MockFirmamentSchedulerClientMockRecorder) NodeRemoved 

func (mr *MockFirmamentSchedulerClientMockRecorder) NodeRemoved(ctx, in interface{}, opts ...interface{}) *gomock.Call

NodeRemoved indicates an expected call of NodeRemoved

func (*MockFirmamentSchedulerClientMockRecorder) NodeUpdated 

func (mr *MockFirmamentSchedulerClientMockRecorder) NodeUpdated(ctx, in interface{}, opts ...interface{}) *gomock.Call

NodeUpdated indicates an expected call of NodeUpdated

func (*MockFirmamentSchedulerClientMockRecorder) Schedule 

func (mr *MockFirmamentSchedulerClientMockRecorder) Schedule(ctx, in interface{}, opts ...interface{}) *gomock.Call

Schedule indicates an expected call of Schedule

func (*MockFirmamentSchedulerClientMockRecorder) TaskCompleted 

func (mr *MockFirmamentSchedulerClientMockRecorder) TaskCompleted(ctx, in interface{}, opts ...interface{}) *gomock.Call

TaskCompleted indicates an expected call of TaskCompleted

func (*MockFirmamentSchedulerClientMockRecorder) TaskFailed 

func (mr *MockFirmamentSchedulerClientMockRecorder) TaskFailed(ctx, in interface{}, opts ...interface{}) *gomock.Call

TaskFailed indicates an expected call of TaskFailed

func (*MockFirmamentSchedulerClientMockRecorder) TaskRemoved 

func (mr *MockFirmamentSchedulerClientMockRecorder) TaskRemoved(ctx, in interface{}, opts ...interface{}) *gomock.Call

TaskRemoved indicates an expected call of TaskRemoved

func (*MockFirmamentSchedulerClientMockRecorder) TaskSubmitted 

func (mr *MockFirmamentSchedulerClientMockRecorder) TaskSubmitted(ctx, in interface{}, opts ...interface{}) *gomock.Call

TaskSubmitted indicates an expected call of TaskSubmitted

func (*MockFirmamentSchedulerClientMockRecorder) TaskUpdated 

func (mr *MockFirmamentSchedulerClientMockRecorder) TaskUpdated(ctx, in interface{}, opts ...interface{}) *gomock.Call

TaskUpdated indicates an expected call of TaskUpdated

type MockFirmamentSchedulerServer 

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

MockFirmamentSchedulerServer is a mock of FirmamentSchedulerServer interface

func NewMockFirmamentSchedulerServer 

func NewMockFirmamentSchedulerServer(ctrl *gomock.Controller) *MockFirmamentSchedulerServer

NewMockFirmamentSchedulerServer creates a new mock instance

func (*MockFirmamentSchedulerServer) AddNodeStats 

func (m *MockFirmamentSchedulerServer) AddNodeStats(arg0 context.Context, arg1 *ResourceStats) (*ResourceStatsResponse, error)

AddNodeStats mocks base method

func (*MockFirmamentSchedulerServer) AddTaskInfo 

func (m *MockFirmamentSchedulerServer) AddTaskInfo(arg0 context.Context, arg1 *TaskInfo) (*TaskInfoResponse, error)

AddTaskInfo mocks base method

func (*MockFirmamentSchedulerServer) AddTaskStats 

func (m *MockFirmamentSchedulerServer) AddTaskStats(arg0 context.Context, arg1 *TaskStats) (*TaskStatsResponse, error)

AddTaskStats mocks base method

func (*MockFirmamentSchedulerServer) Check 

func (m *MockFirmamentSchedulerServer) Check(arg0 context.Context, arg1 *HealthCheckRequest) (*HealthCheckResponse, error)

Check mocks base method

func (*MockFirmamentSchedulerServer) EXPECT 

func (m *MockFirmamentSchedulerServer) EXPECT() *MockFirmamentSchedulerServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockFirmamentSchedulerServer) NodeAdded 

func (m *MockFirmamentSchedulerServer) NodeAdded(arg0 context.Context, arg1 *ResourceTopologyNodeDescriptor) (*NodeAddedResponse, error)

NodeAdded mocks base method

func (*MockFirmamentSchedulerServer) NodeFailed 

func (m *MockFirmamentSchedulerServer) NodeFailed(arg0 context.Context, arg1 *ResourceUID) (*NodeFailedResponse, error)

NodeFailed mocks base method

func (*MockFirmamentSchedulerServer) NodeRemoved 

func (m *MockFirmamentSchedulerServer) NodeRemoved(arg0 context.Context, arg1 *ResourceUID) (*NodeRemovedResponse, error)

NodeRemoved mocks base method

func (*MockFirmamentSchedulerServer) NodeUpdated 

func (m *MockFirmamentSchedulerServer) NodeUpdated(arg0 context.Context, arg1 *ResourceTopologyNodeDescriptor) (*NodeUpdatedResponse, error)

NodeUpdated mocks base method

func (*MockFirmamentSchedulerServer) Schedule 

func (m *MockFirmamentSchedulerServer) Schedule(arg0 context.Context, arg1 *ScheduleRequest) (*SchedulingDeltas, error)

Schedule mocks base method

func (*MockFirmamentSchedulerServer) TaskCompleted 

func (m *MockFirmamentSchedulerServer) TaskCompleted(arg0 context.Context, arg1 *TaskUID) (*TaskCompletedResponse, error)

TaskCompleted mocks base method

func (*MockFirmamentSchedulerServer) TaskFailed 

func (m *MockFirmamentSchedulerServer) TaskFailed(arg0 context.Context, arg1 *TaskUID) (*TaskFailedResponse, error)

TaskFailed mocks base method

func (*MockFirmamentSchedulerServer) TaskRemoved 

func (m *MockFirmamentSchedulerServer) TaskRemoved(arg0 context.Context, arg1 *TaskUID) (*TaskRemovedResponse, error)

TaskRemoved mocks base method

func (*MockFirmamentSchedulerServer) TaskSubmitted 

func (m *MockFirmamentSchedulerServer) TaskSubmitted(arg0 context.Context, arg1 *TaskDescription) (*TaskSubmittedResponse, error)

TaskSubmitted mocks base method

func (*MockFirmamentSchedulerServer) TaskUpdated 

func (m *MockFirmamentSchedulerServer) TaskUpdated(arg0 context.Context, arg1 *TaskDescription) (*TaskUpdatedResponse, error)

TaskUpdated mocks base method

type MockFirmamentSchedulerServerMockRecorder 

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

MockFirmamentSchedulerServerMockRecorder is the mock recorder for MockFirmamentSchedulerServer

func (*MockFirmamentSchedulerServerMockRecorder) AddNodeStats 

func (mr *MockFirmamentSchedulerServerMockRecorder) AddNodeStats(arg0, arg1 interface{}) *gomock.Call

AddNodeStats indicates an expected call of AddNodeStats

func (*MockFirmamentSchedulerServerMockRecorder) AddTaskInfo 

func (mr *MockFirmamentSchedulerServerMockRecorder) AddTaskInfo(arg0, arg1 interface{}) *gomock.Call

AddTaskInfo indicates an expected call of AddTaskInfo

func (*MockFirmamentSchedulerServerMockRecorder) AddTaskStats 

func (mr *MockFirmamentSchedulerServerMockRecorder) AddTaskStats(arg0, arg1 interface{}) *gomock.Call

AddTaskStats indicates an expected call of AddTaskStats

func (*MockFirmamentSchedulerServerMockRecorder) Check 

func (mr *MockFirmamentSchedulerServerMockRecorder) Check(arg0, arg1 interface{}) *gomock.Call

Check indicates an expected call of Check

func (*MockFirmamentSchedulerServerMockRecorder) NodeAdded 

func (mr *MockFirmamentSchedulerServerMockRecorder) NodeAdded(arg0, arg1 interface{}) *gomock.Call

NodeAdded indicates an expected call of NodeAdded

func (*MockFirmamentSchedulerServerMockRecorder) NodeFailed 

func (mr *MockFirmamentSchedulerServerMockRecorder) NodeFailed(arg0, arg1 interface{}) *gomock.Call

NodeFailed indicates an expected call of NodeFailed

func (*MockFirmamentSchedulerServerMockRecorder) NodeRemoved 

func (mr *MockFirmamentSchedulerServerMockRecorder) NodeRemoved(arg0, arg1 interface{}) *gomock.Call

NodeRemoved indicates an expected call of NodeRemoved

func (*MockFirmamentSchedulerServerMockRecorder) NodeUpdated 

func (mr *MockFirmamentSchedulerServerMockRecorder) NodeUpdated(arg0, arg1 interface{}) *gomock.Call

NodeUpdated indicates an expected call of NodeUpdated

func (*MockFirmamentSchedulerServerMockRecorder) Schedule 

func (mr *MockFirmamentSchedulerServerMockRecorder) Schedule(arg0, arg1 interface{}) *gomock.Call

Schedule indicates an expected call of Schedule

func (*MockFirmamentSchedulerServerMockRecorder) TaskCompleted 

func (mr *MockFirmamentSchedulerServerMockRecorder) TaskCompleted(arg0, arg1 interface{}) *gomock.Call

TaskCompleted indicates an expected call of TaskCompleted

func (*MockFirmamentSchedulerServerMockRecorder) TaskFailed 

func (mr *MockFirmamentSchedulerServerMockRecorder) TaskFailed(arg0, arg1 interface{}) *gomock.Call

TaskFailed indicates an expected call of TaskFailed

func (*MockFirmamentSchedulerServerMockRecorder) TaskRemoved 

func (mr *MockFirmamentSchedulerServerMockRecorder) TaskRemoved(arg0, arg1 interface{}) *gomock.Call

TaskRemoved indicates an expected call of TaskRemoved

func (*MockFirmamentSchedulerServerMockRecorder) TaskSubmitted 

func (mr *MockFirmamentSchedulerServerMockRecorder) TaskSubmitted(arg0, arg1 interface{}) *gomock.Call

TaskSubmitted indicates an expected call of TaskSubmitted

func (*MockFirmamentSchedulerServerMockRecorder) TaskUpdated 

func (mr *MockFirmamentSchedulerServerMockRecorder) TaskUpdated(arg0, arg1 interface{}) *gomock.Call

TaskUpdated indicates an expected call of TaskUpdated

type NodeAddedResponse 

type NodeAddedResponse struct {
	Type                 NodeReplyType `protobuf:"varint,1,opt,name=type,proto3,enum=firmament.NodeReplyType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*NodeAddedResponse) Descriptor 

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

func (*NodeAddedResponse) GetType 

func (m *NodeAddedResponse) GetType() NodeReplyType

func (*NodeAddedResponse) ProtoMessage 

func (*NodeAddedResponse) ProtoMessage()

func (*NodeAddedResponse) Reset 

func (m *NodeAddedResponse) Reset()

func (*NodeAddedResponse) String 

func (m *NodeAddedResponse) String() string

func (*NodeAddedResponse) XXX_DiscardUnknown 

func (m *NodeAddedResponse) XXX_DiscardUnknown()

func (*NodeAddedResponse) XXX_Marshal 

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

func (*NodeAddedResponse) XXX_Merge 

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

func (*NodeAddedResponse) XXX_Size 

func (m *NodeAddedResponse) XXX_Size() int

func (*NodeAddedResponse) XXX_Unmarshal 

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

type NodeAffinity 

type NodeAffinity struct {
	RequiredDuringSchedulingIgnoredDuringExecution  *NodeSelector              `` /* 145-byte string literal not displayed */
	PreferredDuringSchedulingIgnoredDuringExecution []*PreferredSchedulingTerm `` /* 147-byte string literal not displayed */
	XXX_NoUnkeyedLiteral                            struct{}                   `json:"-"`
	XXX_unrecognized                                []byte                     `json:"-"`
	XXX_sizecache                                   int32                      `json:"-"`
}

func (*NodeAffinity) Descriptor 

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

func (*NodeAffinity) GetPreferredDuringSchedulingIgnoredDuringExecution 

func (m *NodeAffinity) GetPreferredDuringSchedulingIgnoredDuringExecution() []*PreferredSchedulingTerm

func (*NodeAffinity) GetRequiredDuringSchedulingIgnoredDuringExecution 

func (m *NodeAffinity) GetRequiredDuringSchedulingIgnoredDuringExecution() *NodeSelector

func (*NodeAffinity) ProtoMessage 

func (*NodeAffinity) ProtoMessage()

func (*NodeAffinity) Reset 

func (m *NodeAffinity) Reset()

func (*NodeAffinity) String 

func (m *NodeAffinity) String() string

func (*NodeAffinity) XXX_DiscardUnknown 

func (m *NodeAffinity) XXX_DiscardUnknown()

func (*NodeAffinity) XXX_Marshal 

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

func (*NodeAffinity) XXX_Merge 

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

func (*NodeAffinity) XXX_Size 

func (m *NodeAffinity) XXX_Size() int

func (*NodeAffinity) XXX_Unmarshal 

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

type NodeFailedResponse 

type NodeFailedResponse struct {
	Type                 NodeReplyType `protobuf:"varint,1,opt,name=type,proto3,enum=firmament.NodeReplyType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*NodeFailedResponse) Descriptor 

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

func (*NodeFailedResponse) GetType 

func (m *NodeFailedResponse) GetType() NodeReplyType

func (*NodeFailedResponse) ProtoMessage 

func (*NodeFailedResponse) ProtoMessage()

func (*NodeFailedResponse) Reset 

func (m *NodeFailedResponse) Reset()

func (*NodeFailedResponse) String 

func (m *NodeFailedResponse) String() string

func (*NodeFailedResponse) XXX_DiscardUnknown 

func (m *NodeFailedResponse) XXX_DiscardUnknown()

func (*NodeFailedResponse) XXX_Marshal 

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

func (*NodeFailedResponse) XXX_Merge 

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

func (*NodeFailedResponse) XXX_Size 

func (m *NodeFailedResponse) XXX_Size() int

func (*NodeFailedResponse) XXX_Unmarshal 

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

type NodeRemovedResponse 

type NodeRemovedResponse struct {
	Type                 NodeReplyType `protobuf:"varint,1,opt,name=type,proto3,enum=firmament.NodeReplyType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*NodeRemovedResponse) Descriptor 

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

func (*NodeRemovedResponse) GetType 

func (m *NodeRemovedResponse) GetType() NodeReplyType

func (*NodeRemovedResponse) ProtoMessage 

func (*NodeRemovedResponse) ProtoMessage()

func (*NodeRemovedResponse) Reset 

func (m *NodeRemovedResponse) Reset()

func (*NodeRemovedResponse) String 

func (m *NodeRemovedResponse) String() string

func (*NodeRemovedResponse) XXX_DiscardUnknown 

func (m *NodeRemovedResponse) XXX_DiscardUnknown()

func (*NodeRemovedResponse) XXX_Marshal 

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

func (*NodeRemovedResponse) XXX_Merge 

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

func (*NodeRemovedResponse) XXX_Size 

func (m *NodeRemovedResponse) XXX_Size() int

func (*NodeRemovedResponse) XXX_Unmarshal 

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

type NodeReplyType 

type NodeReplyType int32
const (
	NodeReplyType_NODE_ADDED_OK       NodeReplyType = 0
	NodeReplyType_NODE_FAILED_OK      NodeReplyType = 1
	NodeReplyType_NODE_REMOVED_OK     NodeReplyType = 2
	NodeReplyType_NODE_UPDATED_OK     NodeReplyType = 3
	NodeReplyType_NODE_NOT_FOUND      NodeReplyType = 4
	NodeReplyType_NODE_ALREADY_EXISTS NodeReplyType = 5
)

func (NodeReplyType) EnumDescriptor 

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

func (NodeReplyType) String 

func (x NodeReplyType) String() string

type NodeSelector 

type NodeSelector struct {
	// Required. A list of node selector terms. The terms are ORed.
	NodeSelectorTerms    []*NodeSelectorTerm `protobuf:"bytes,1,rep,name=nodeSelectorTerms,proto3" json:"nodeSelectorTerms,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*NodeSelector) Descriptor 

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

func (*NodeSelector) GetNodeSelectorTerms 

func (m *NodeSelector) GetNodeSelectorTerms() []*NodeSelectorTerm

func (*NodeSelector) ProtoMessage 

func (*NodeSelector) ProtoMessage()

func (*NodeSelector) Reset 

func (m *NodeSelector) Reset()

func (*NodeSelector) String 

func (m *NodeSelector) String() string

func (*NodeSelector) XXX_DiscardUnknown 

func (m *NodeSelector) XXX_DiscardUnknown()

func (*NodeSelector) XXX_Marshal 

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

func (*NodeSelector) XXX_Merge 

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

func (*NodeSelector) XXX_Size 

func (m *NodeSelector) XXX_Size() int

func (*NodeSelector) XXX_Unmarshal 

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

type NodeSelectorRequirement 

type NodeSelectorRequirement struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Operator             string   `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"`
	Values               []string `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeSelectorRequirement) Descriptor 

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

func (*NodeSelectorRequirement) GetKey 

func (m *NodeSelectorRequirement) GetKey() string

func (*NodeSelectorRequirement) GetOperator 

func (m *NodeSelectorRequirement) GetOperator() string

func (*NodeSelectorRequirement) GetValues 

func (m *NodeSelectorRequirement) GetValues() []string

func (*NodeSelectorRequirement) ProtoMessage 

func (*NodeSelectorRequirement) ProtoMessage()

func (*NodeSelectorRequirement) Reset 

func (m *NodeSelectorRequirement) Reset()

func (*NodeSelectorRequirement) String 

func (m *NodeSelectorRequirement) String() string

func (*NodeSelectorRequirement) XXX_DiscardUnknown 

func (m *NodeSelectorRequirement) XXX_DiscardUnknown()

func (*NodeSelectorRequirement) XXX_Marshal 

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

func (*NodeSelectorRequirement) XXX_Merge 

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

func (*NodeSelectorRequirement) XXX_Size 

func (m *NodeSelectorRequirement) XXX_Size() int

func (*NodeSelectorRequirement) XXX_Unmarshal 

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

type NodeSelectorTerm 

type NodeSelectorTerm struct {
	// A list of node selector requirements by node's labels.
	// +optional
	MatchExpressions     []*NodeSelectorRequirement `protobuf:"bytes,1,rep,name=matchExpressions,proto3" json:"matchExpressions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*NodeSelectorTerm) Descriptor 

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

func (*NodeSelectorTerm) GetMatchExpressions 

func (m *NodeSelectorTerm) GetMatchExpressions() []*NodeSelectorRequirement

func (*NodeSelectorTerm) ProtoMessage 

func (*NodeSelectorTerm) ProtoMessage()

func (*NodeSelectorTerm) Reset 

func (m *NodeSelectorTerm) Reset()

func (*NodeSelectorTerm) String 

func (m *NodeSelectorTerm) String() string

func (*NodeSelectorTerm) XXX_DiscardUnknown 

func (m *NodeSelectorTerm) XXX_DiscardUnknown()

func (*NodeSelectorTerm) XXX_Marshal 

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

func (*NodeSelectorTerm) XXX_Merge 

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

func (*NodeSelectorTerm) XXX_Size 

func (m *NodeSelectorTerm) XXX_Size() int

func (*NodeSelectorTerm) XXX_Unmarshal 

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

type NodeUpdatedResponse 

type NodeUpdatedResponse struct {
	Type                 NodeReplyType `protobuf:"varint,1,opt,name=type,proto3,enum=firmament.NodeReplyType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*NodeUpdatedResponse) Descriptor 

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

func (*NodeUpdatedResponse) GetType 

func (m *NodeUpdatedResponse) GetType() NodeReplyType

func (*NodeUpdatedResponse) ProtoMessage 

func (*NodeUpdatedResponse) ProtoMessage()

func (*NodeUpdatedResponse) Reset 

func (m *NodeUpdatedResponse) Reset()

func (*NodeUpdatedResponse) String 

func (m *NodeUpdatedResponse) String() string

func (*NodeUpdatedResponse) XXX_DiscardUnknown 

func (m *NodeUpdatedResponse) XXX_DiscardUnknown()

func (*NodeUpdatedResponse) XXX_Marshal 

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

func (*NodeUpdatedResponse) XXX_Merge 

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

func (*NodeUpdatedResponse) XXX_Size 

func (m *NodeUpdatedResponse) XXX_Size() int

func (*NodeUpdatedResponse) XXX_Unmarshal 

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

type PodAffinity 

type PodAffinity struct {
	RequiredDuringSchedulingIgnoredDuringExecution  []*PodAffinityTerm         `` /* 145-byte string literal not displayed */
	PreferredDuringSchedulingIgnoredDuringExecution []*WeightedPodAffinityTerm `` /* 147-byte string literal not displayed */
	XXX_NoUnkeyedLiteral                            struct{}                   `json:"-"`
	XXX_unrecognized                                []byte                     `json:"-"`
	XXX_sizecache                                   int32                      `json:"-"`
}

func (*PodAffinity) Descriptor 

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

func (*PodAffinity) GetPreferredDuringSchedulingIgnoredDuringExecution 

func (m *PodAffinity) GetPreferredDuringSchedulingIgnoredDuringExecution() []*WeightedPodAffinityTerm

func (*PodAffinity) GetRequiredDuringSchedulingIgnoredDuringExecution 

func (m *PodAffinity) GetRequiredDuringSchedulingIgnoredDuringExecution() []*PodAffinityTerm

func (*PodAffinity) ProtoMessage 

func (*PodAffinity) ProtoMessage()

func (*PodAffinity) Reset 

func (m *PodAffinity) Reset()

func (*PodAffinity) String 

func (m *PodAffinity) String() string

func (*PodAffinity) XXX_DiscardUnknown 

func (m *PodAffinity) XXX_DiscardUnknown()

func (*PodAffinity) XXX_Marshal 

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

func (*PodAffinity) XXX_Merge 

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

func (*PodAffinity) XXX_Size 

func (m *PodAffinity) XXX_Size() int

func (*PodAffinity) XXX_Unmarshal 

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

type PodAffinityTerm 

type PodAffinityTerm struct {
	LabelSelector *PodLabelSelector `protobuf:"bytes,1,opt,name=labelSelector,proto3" json:"labelSelector,omitempty"`
	Namespaces    []string          `protobuf:"bytes,2,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// Empty topologyKey is not allowed.
	TopologyKey          string   `protobuf:"bytes,3,opt,name=topologyKey,proto3" json:"topologyKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PodAffinityTerm) Descriptor 

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

func (*PodAffinityTerm) GetLabelSelector 

func (m *PodAffinityTerm) GetLabelSelector() *PodLabelSelector

func (*PodAffinityTerm) GetNamespaces 

func (m *PodAffinityTerm) GetNamespaces() []string

func (*PodAffinityTerm) GetTopologyKey 

func (m *PodAffinityTerm) GetTopologyKey() string

func (*PodAffinityTerm) ProtoMessage 

func (*PodAffinityTerm) ProtoMessage()

func (*PodAffinityTerm) Reset 

func (m *PodAffinityTerm) Reset()

func (*PodAffinityTerm) String 

func (m *PodAffinityTerm) String() string

func (*PodAffinityTerm) XXX_DiscardUnknown 

func (m *PodAffinityTerm) XXX_DiscardUnknown()

func (*PodAffinityTerm) XXX_Marshal 

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

func (*PodAffinityTerm) XXX_Merge 

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

func (*PodAffinityTerm) XXX_Size 

func (m *PodAffinityTerm) XXX_Size() int

func (*PodAffinityTerm) XXX_Unmarshal 

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

type PodAffinityTermAntiAff 

type PodAffinityTermAntiAff struct {
	LabelSelector *LabelSelectorAntiAff `protobuf:"bytes,1,opt,name=labelSelector,proto3" json:"labelSelector,omitempty"`
	Namespaces    []string              `protobuf:"bytes,2,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// Empty topologyKey is not allowed.
	TopologyKey          string   `protobuf:"bytes,3,opt,name=topologyKey,proto3" json:"topologyKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PodAffinityTermAntiAff) Descriptor 

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

func (*PodAffinityTermAntiAff) GetLabelSelector 

func (m *PodAffinityTermAntiAff) GetLabelSelector() *LabelSelectorAntiAff

func (*PodAffinityTermAntiAff) GetNamespaces 

func (m *PodAffinityTermAntiAff) GetNamespaces() []string

func (*PodAffinityTermAntiAff) GetTopologyKey 

func (m *PodAffinityTermAntiAff) GetTopologyKey() string

func (*PodAffinityTermAntiAff) ProtoMessage 

func (*PodAffinityTermAntiAff) ProtoMessage()

func (*PodAffinityTermAntiAff) Reset 

func (m *PodAffinityTermAntiAff) Reset()

func (*PodAffinityTermAntiAff) String 

func (m *PodAffinityTermAntiAff) String() string

func (*PodAffinityTermAntiAff) XXX_DiscardUnknown 

func (m *PodAffinityTermAntiAff) XXX_DiscardUnknown()

func (*PodAffinityTermAntiAff) XXX_Marshal 

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

func (*PodAffinityTermAntiAff) XXX_Merge 

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

func (*PodAffinityTermAntiAff) XXX_Size 

func (m *PodAffinityTermAntiAff) XXX_Size() int

func (*PodAffinityTermAntiAff) XXX_Unmarshal 

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

type PodAntiAffinity 

type PodAntiAffinity struct {
	RequiredDuringSchedulingIgnoredDuringExecution  []*PodAffinityTermAntiAff         `` /* 145-byte string literal not displayed */
	PreferredDuringSchedulingIgnoredDuringExecution []*WeightedPodAffinityTermAntiAff `` /* 147-byte string literal not displayed */
	XXX_NoUnkeyedLiteral                            struct{}                          `json:"-"`
	XXX_unrecognized                                []byte                            `json:"-"`
	XXX_sizecache                                   int32                             `json:"-"`
}

func (*PodAntiAffinity) Descriptor 

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

func (*PodAntiAffinity) GetPreferredDuringSchedulingIgnoredDuringExecution 

func (m *PodAntiAffinity) GetPreferredDuringSchedulingIgnoredDuringExecution() []*WeightedPodAffinityTermAntiAff

func (*PodAntiAffinity) GetRequiredDuringSchedulingIgnoredDuringExecution 

func (m *PodAntiAffinity) GetRequiredDuringSchedulingIgnoredDuringExecution() []*PodAffinityTermAntiAff

func (*PodAntiAffinity) ProtoMessage 

func (*PodAntiAffinity) ProtoMessage()

func (*PodAntiAffinity) Reset 

func (m *PodAntiAffinity) Reset()

func (*PodAntiAffinity) String 

func (m *PodAntiAffinity) String() string

func (*PodAntiAffinity) XXX_DiscardUnknown 

func (m *PodAntiAffinity) XXX_DiscardUnknown()

func (*PodAntiAffinity) XXX_Marshal 

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

func (*PodAntiAffinity) XXX_Merge 

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

func (*PodAntiAffinity) XXX_Size 

func (m *PodAntiAffinity) XXX_Size() int

func (*PodAntiAffinity) XXX_Unmarshal 

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

type PodLabelSelector 

type PodLabelSelector struct {
	MatchLabels          *MatchLabels                `protobuf:"bytes,1,opt,name=matchLabels,proto3" json:"matchLabels,omitempty"`
	MatchExpressions     []*LabelSelectorRequirement `protobuf:"bytes,2,rep,name=matchExpressions,proto3" json:"matchExpressions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*PodLabelSelector) Descriptor 

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

func (*PodLabelSelector) GetMatchExpressions 

func (m *PodLabelSelector) GetMatchExpressions() []*LabelSelectorRequirement

func (*PodLabelSelector) GetMatchLabels 

func (m *PodLabelSelector) GetMatchLabels() *MatchLabels

func (*PodLabelSelector) ProtoMessage 

func (*PodLabelSelector) ProtoMessage()

func (*PodLabelSelector) Reset 

func (m *PodLabelSelector) Reset()

func (*PodLabelSelector) String 

func (m *PodLabelSelector) String() string

func (*PodLabelSelector) XXX_DiscardUnknown 

func (m *PodLabelSelector) XXX_DiscardUnknown()

func (*PodLabelSelector) XXX_Marshal 

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

func (*PodLabelSelector) XXX_Merge 

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

func (*PodLabelSelector) XXX_Size 

func (m *PodLabelSelector) XXX_Size() int

func (*PodLabelSelector) XXX_Unmarshal 

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

type PreferredSchedulingTerm 

type PreferredSchedulingTerm struct {
	// Weight associated with matching the corresponding nodeSelectorTerm, in the range 1-100.
	Weight int32 `protobuf:"varint,1,opt,name=weight,proto3" json:"weight,omitempty"`
	// A node selector term, associated with the corresponding weight.
	Preference           *NodeSelectorTerm `protobuf:"bytes,2,opt,name=preference,proto3" json:"preference,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*PreferredSchedulingTerm) Descriptor 

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

func (*PreferredSchedulingTerm) GetPreference 

func (m *PreferredSchedulingTerm) GetPreference() *NodeSelectorTerm

func (*PreferredSchedulingTerm) GetWeight 

func (m *PreferredSchedulingTerm) GetWeight() int32

func (*PreferredSchedulingTerm) ProtoMessage 

func (*PreferredSchedulingTerm) ProtoMessage()

func (*PreferredSchedulingTerm) Reset 

func (m *PreferredSchedulingTerm) Reset()

func (*PreferredSchedulingTerm) String 

func (m *PreferredSchedulingTerm) String() string

func (*PreferredSchedulingTerm) XXX_DiscardUnknown 

func (m *PreferredSchedulingTerm) XXX_DiscardUnknown()

func (*PreferredSchedulingTerm) XXX_Marshal 

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

func (*PreferredSchedulingTerm) XXX_Merge 

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

func (*PreferredSchedulingTerm) XXX_Size 

func (m *PreferredSchedulingTerm) XXX_Size() int

func (*PreferredSchedulingTerm) XXX_Unmarshal 

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

type ReferenceDescriptor 

type ReferenceDescriptor struct {
	Id                   []byte                             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type                 ReferenceDescriptor_ReferenceType  `protobuf:"varint,2,opt,name=type,proto3,enum=firmament.ReferenceDescriptor_ReferenceType" json:"type,omitempty"`
	Scope                ReferenceDescriptor_ReferenceScope `protobuf:"varint,3,opt,name=scope,proto3,enum=firmament.ReferenceDescriptor_ReferenceScope" json:"scope,omitempty"`
	NonDeterministic     bool                               `protobuf:"varint,4,opt,name=non_deterministic,json=nonDeterministic,proto3" json:"non_deterministic,omitempty"`
	Size                 uint64                             `protobuf:"varint,5,opt,name=size,proto3" json:"size,omitempty"`
	Location             string                             `protobuf:"bytes,6,opt,name=location,proto3" json:"location,omitempty"`
	InlineData           []byte                             `protobuf:"bytes,7,opt,name=inline_data,json=inlineData,proto3" json:"inline_data,omitempty"`
	ProducingTask        uint64                             `protobuf:"varint,8,opt,name=producing_task,json=producingTask,proto3" json:"producing_task,omitempty"`
	TimeToCompute        uint64                             `protobuf:"varint,9,opt,name=time_to_compute,json=timeToCompute,proto3" json:"time_to_compute,omitempty"`
	Version              uint64                             `protobuf:"varint,10,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*ReferenceDescriptor) Descriptor 

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

func (*ReferenceDescriptor) GetId 

func (m *ReferenceDescriptor) GetId() []byte

func (*ReferenceDescriptor) GetInlineData 

func (m *ReferenceDescriptor) GetInlineData() []byte

func (*ReferenceDescriptor) GetLocation 

func (m *ReferenceDescriptor) GetLocation() string

func (*ReferenceDescriptor) GetNonDeterministic 

func (m *ReferenceDescriptor) GetNonDeterministic() bool

func (*ReferenceDescriptor) GetProducingTask 

func (m *ReferenceDescriptor) GetProducingTask() uint64

func (*ReferenceDescriptor) GetScope 

func (m *ReferenceDescriptor) GetScope() ReferenceDescriptor_ReferenceScope

func (*ReferenceDescriptor) GetSize 

func (m *ReferenceDescriptor) GetSize() uint64

func (*ReferenceDescriptor) GetTimeToCompute 

func (m *ReferenceDescriptor) GetTimeToCompute() uint64

func (*ReferenceDescriptor) GetType 

func (m *ReferenceDescriptor) GetType() ReferenceDescriptor_ReferenceType

func (*ReferenceDescriptor) GetVersion 

func (m *ReferenceDescriptor) GetVersion() uint64

func (*ReferenceDescriptor) ProtoMessage 

func (*ReferenceDescriptor) ProtoMessage()

func (*ReferenceDescriptor) Reset 

func (m *ReferenceDescriptor) Reset()

func (*ReferenceDescriptor) String 

func (m *ReferenceDescriptor) String() string

func (*ReferenceDescriptor) XXX_DiscardUnknown 

func (m *ReferenceDescriptor) XXX_DiscardUnknown()

func (*ReferenceDescriptor) XXX_Marshal 

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

func (*ReferenceDescriptor) XXX_Merge 

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

func (*ReferenceDescriptor) XXX_Size 

func (m *ReferenceDescriptor) XXX_Size() int

func (*ReferenceDescriptor) XXX_Unmarshal 

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

type ReferenceDescriptor_ReferenceScope 

type ReferenceDescriptor_ReferenceScope int32
const (
	// TODO(malte): really encode like this?
	ReferenceDescriptor_PUBLIC  ReferenceDescriptor_ReferenceScope = 0
	ReferenceDescriptor_PRIVATE ReferenceDescriptor_ReferenceScope = 1
)

func (ReferenceDescriptor_ReferenceScope) EnumDescriptor 

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

func (ReferenceDescriptor_ReferenceScope) String 

func (x ReferenceDescriptor_ReferenceScope) String() string

type ReferenceDescriptor_ReferenceType 

type ReferenceDescriptor_ReferenceType int32
const (
	ReferenceDescriptor_TOMBSTONE ReferenceDescriptor_ReferenceType = 0
	ReferenceDescriptor_FUTURE    ReferenceDescriptor_ReferenceType = 1
	ReferenceDescriptor_CONCRETE  ReferenceDescriptor_ReferenceType = 2
	ReferenceDescriptor_STREAM    ReferenceDescriptor_ReferenceType = 3
	ReferenceDescriptor_VALUE     ReferenceDescriptor_ReferenceType = 4
	ReferenceDescriptor_ERROR     ReferenceDescriptor_ReferenceType = 5
)

func (ReferenceDescriptor_ReferenceType) EnumDescriptor 

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

func (ReferenceDescriptor_ReferenceType) String 

func (x ReferenceDescriptor_ReferenceType) String() string

type ResourceDescriptor 

type ResourceDescriptor struct {
	Uuid            string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	FriendlyName    string `protobuf:"bytes,2,opt,name=friendly_name,json=friendlyName,proto3" json:"friendly_name,omitempty"`
	DescriptiveName string `protobuf:"bytes,3,opt,name=descriptive_name,json=descriptiveName,proto3" json:"descriptive_name,omitempty"`
	// state is the state of resource.
	State ResourceDescriptor_ResourceState `protobuf:"varint,4,opt,name=state,proto3,enum=firmament.ResourceDescriptor_ResourceState" json:"state,omitempty"`
	// task_capacity is the max number of tasks that can be scheduled on the resource.
	TaskCapacity uint64 `protobuf:"varint,5,opt,name=task_capacity,json=taskCapacity,proto3" json:"task_capacity,omitempty"`
	// last heartbeat of the resource, e.g. node.
	LastHeartbeat uint64 `protobuf:"varint,6,opt,name=last_heartbeat,json=lastHeartbeat,proto3" json:"last_heartbeat,omitempty"`
	// Type of the resource
	Type ResourceDescriptor_ResourceType `protobuf:"varint,7,opt,name=type,proto3,enum=firmament.ResourceDescriptor_ResourceType" json:"type,omitempty"`
	// schedulable indicates if the resource, e.g. node is able to schedule tasks.
	Schedulable bool `protobuf:"varint,8,opt,name=schedulable,proto3" json:"schedulable,omitempty"`
	// current_running_tasks stores all the running tasks on the resource, e.g. node.
	CurrentRunningTasks []uint64 `` /* 128-byte string literal not displayed */
	// num_running_tasks_below stores the number of running tasks on the resources that are below this node.
	NumRunningTasksBelow uint64 `` /* 127-byte string literal not displayed */
	NumSlotsBelow        uint64 `protobuf:"varint,11,opt,name=num_slots_below,json=numSlotsBelow,proto3" json:"num_slots_below,omitempty"`
	// Resource capacity and load tracking
	AvailableResources          *ResourceVector `protobuf:"bytes,12,opt,name=available_resources,json=availableResources,proto3" json:"available_resources,omitempty"`
	ReservedResources           *ResourceVector `protobuf:"bytes,13,opt,name=reserved_resources,json=reservedResources,proto3" json:"reserved_resources,omitempty"`
	MinAvailableResourcesBelow  *ResourceVector `` /* 144-byte string literal not displayed */
	MaxAvailableResourcesBelow  *ResourceVector `` /* 144-byte string literal not displayed */
	MinUnreservedResourcesBelow *ResourceVector `` /* 147-byte string literal not displayed */
	MaxUnreservedResourcesBelow *ResourceVector `` /* 147-byte string literal not displayed */
	ResourceCapacity            *ResourceVector `protobuf:"bytes,18,opt,name=resource_capacity,json=resourceCapacity,proto3" json:"resource_capacity,omitempty"`
	// Cost-model-specific statistics
	WhareMapStats          *WhareMapStats          `protobuf:"bytes,19,opt,name=whare_map_stats,json=whareMapStats,proto3" json:"whare_map_stats,omitempty"`
	CocoInterferenceScores *CoCoInterferenceScores `` /* 130-byte string literal not displayed */
	// Simulation related fields
	TraceMachineId uint64 `protobuf:"varint,21,opt,name=trace_machine_id,json=traceMachineId,proto3" json:"trace_machine_id,omitempty"`
	// Resource labels
	Labels []*Label `protobuf:"bytes,32,rep,name=labels,proto3" json:"labels,omitempty"`
	// Taints
	Taints []*Taint `protobuf:"bytes,33,rep,name=taints,proto3" json:"taints,omitempty"`
	// Avoid pods annotations
	Avoids []*AvoidPodsAnnotation `protobuf:"bytes,34,rep,name=avoids,proto3" json:"avoids,omitempty"`
	// Max pods allowed per node
	MaxPods              uint64   `protobuf:"varint,35,opt,name=max_pods,json=maxPods,proto3" json:"max_pods,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResourceDescriptor) Descriptor 

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

func (*ResourceDescriptor) GetAvailableResources 

func (m *ResourceDescriptor) GetAvailableResources() *ResourceVector

func (*ResourceDescriptor) GetAvoids 

func (m *ResourceDescriptor) GetAvoids() []*AvoidPodsAnnotation

func (*ResourceDescriptor) GetCocoInterferenceScores 

func (m *ResourceDescriptor) GetCocoInterferenceScores() *CoCoInterferenceScores

func (*ResourceDescriptor) GetCurrentRunningTasks 

func (m *ResourceDescriptor) GetCurrentRunningTasks() []uint64

func (*ResourceDescriptor) GetDescriptiveName 

func (m *ResourceDescriptor) GetDescriptiveName() string

func (*ResourceDescriptor) GetFriendlyName 

func (m *ResourceDescriptor) GetFriendlyName() string

func (*ResourceDescriptor) GetLabels 

func (m *ResourceDescriptor) GetLabels() []*Label

func (*ResourceDescriptor) GetLastHeartbeat 

func (m *ResourceDescriptor) GetLastHeartbeat() uint64

func (*ResourceDescriptor) GetMaxAvailableResourcesBelow 

func (m *ResourceDescriptor) GetMaxAvailableResourcesBelow() *ResourceVector

func (*ResourceDescriptor) GetMaxPods 

func (m *ResourceDescriptor) GetMaxPods() uint64

func (*ResourceDescriptor) GetMaxUnreservedResourcesBelow 

func (m *ResourceDescriptor) GetMaxUnreservedResourcesBelow() *ResourceVector

func (*ResourceDescriptor) GetMinAvailableResourcesBelow 

func (m *ResourceDescriptor) GetMinAvailableResourcesBelow() *ResourceVector

func (*ResourceDescriptor) GetMinUnreservedResourcesBelow 

func (m *ResourceDescriptor) GetMinUnreservedResourcesBelow() *ResourceVector

func (*ResourceDescriptor) GetNumRunningTasksBelow 

func (m *ResourceDescriptor) GetNumRunningTasksBelow() uint64

func (*ResourceDescriptor) GetNumSlotsBelow 

func (m *ResourceDescriptor) GetNumSlotsBelow() uint64

func (*ResourceDescriptor) GetReservedResources 

func (m *ResourceDescriptor) GetReservedResources() *ResourceVector

func (*ResourceDescriptor) GetResourceCapacity 

func (m *ResourceDescriptor) GetResourceCapacity() *ResourceVector

func (*ResourceDescriptor) GetSchedulable 

func (m *ResourceDescriptor) GetSchedulable() bool

func (*ResourceDescriptor) GetState 

func (m *ResourceDescriptor) GetState() ResourceDescriptor_ResourceState

func (*ResourceDescriptor) GetTaints 

func (m *ResourceDescriptor) GetTaints() []*Taint

func (*ResourceDescriptor) GetTaskCapacity 

func (m *ResourceDescriptor) GetTaskCapacity() uint64

func (*ResourceDescriptor) GetTraceMachineId 

func (m *ResourceDescriptor) GetTraceMachineId() uint64

func (*ResourceDescriptor) GetType 

func (m *ResourceDescriptor) GetType() ResourceDescriptor_ResourceType

func (*ResourceDescriptor) GetUuid 

func (m *ResourceDescriptor) GetUuid() string

func (*ResourceDescriptor) GetWhareMapStats 

func (m *ResourceDescriptor) GetWhareMapStats() *WhareMapStats

func (*ResourceDescriptor) ProtoMessage 

func (*ResourceDescriptor) ProtoMessage()

func (*ResourceDescriptor) Reset 

func (m *ResourceDescriptor) Reset()

func (*ResourceDescriptor) String 

func (m *ResourceDescriptor) String() string

func (*ResourceDescriptor) XXX_DiscardUnknown 

func (m *ResourceDescriptor) XXX_DiscardUnknown()

func (*ResourceDescriptor) XXX_Marshal 

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

func (*ResourceDescriptor) XXX_Merge 

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

func (*ResourceDescriptor) XXX_Size 

func (m *ResourceDescriptor) XXX_Size() int

func (*ResourceDescriptor) XXX_Unmarshal 

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

type ResourceDescriptor_ResourceState 

type ResourceDescriptor_ResourceState int32
const (
	ResourceDescriptor_RESOURCE_UNKNOWN ResourceDescriptor_ResourceState = 0
	ResourceDescriptor_RESOURCE_IDLE    ResourceDescriptor_ResourceState = 1
	ResourceDescriptor_RESOURCE_BUSY    ResourceDescriptor_ResourceState = 2
	ResourceDescriptor_RESOURCE_LOST    ResourceDescriptor_ResourceState = 3
)

func (ResourceDescriptor_ResourceState) EnumDescriptor 

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

func (ResourceDescriptor_ResourceState) String 

func (x ResourceDescriptor_ResourceState) String() string

type ResourceDescriptor_ResourceType 

type ResourceDescriptor_ResourceType int32
const (
	ResourceDescriptor_RESOURCE_PU          ResourceDescriptor_ResourceType = 0
	ResourceDescriptor_RESOURCE_CORE        ResourceDescriptor_ResourceType = 1
	ResourceDescriptor_RESOURCE_CACHE       ResourceDescriptor_ResourceType = 2
	ResourceDescriptor_RESOURCE_NIC         ResourceDescriptor_ResourceType = 3
	ResourceDescriptor_RESOURCE_DISK        ResourceDescriptor_ResourceType = 4
	ResourceDescriptor_RESOURCE_SSD         ResourceDescriptor_ResourceType = 5
	ResourceDescriptor_RESOURCE_MACHINE     ResourceDescriptor_ResourceType = 6
	ResourceDescriptor_RESOURCE_LOGICAL     ResourceDescriptor_ResourceType = 7
	ResourceDescriptor_RESOURCE_NUMA_NODE   ResourceDescriptor_ResourceType = 8
	ResourceDescriptor_RESOURCE_SOCKET      ResourceDescriptor_ResourceType = 9
	ResourceDescriptor_RESOURCE_COORDINATOR ResourceDescriptor_ResourceType = 10
)

func (ResourceDescriptor_ResourceType) EnumDescriptor 

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

func (ResourceDescriptor_ResourceType) String 

func (x ResourceDescriptor_ResourceType) String() string

type ResourceStats 

type ResourceStats struct {
	// resource_id is used to uniquely identify a resource.
	ResourceId string `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	Timestamp  uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// cpus_stats stores the stats of each CPU.
	// The first entry is the cpu usage of cpu0 and so on.
	CpusStats []*CpuStats `protobuf:"bytes,3,rep,name=cpus_stats,json=cpusStats,proto3" json:"cpus_stats,omitempty"`
	// Below are the Memory status (in KB) of node.
	// mem_allocatable is the allocatable memory resource of node.
	MemAllocatable int64 `protobuf:"varint,4,opt,name=mem_allocatable,json=memAllocatable,proto3" json:"mem_allocatable,omitempty"`
	// mem_capacity is the capacity of memory of node.
	MemCapacity int64 `protobuf:"varint,5,opt,name=mem_capacity,json=memCapacity,proto3" json:"mem_capacity,omitempty"`
	// Memory stats (fraction of total).
	// mem_reservation is the fraction of memory reserved.
	MemReservation float64 `protobuf:"fixed64,6,opt,name=mem_reservation,json=memReservation,proto3" json:"mem_reservation,omitempty"`
	// mem_utilization is the fraction of memory used.
	MemUtilization float64 `protobuf:"fixed64,7,opt,name=mem_utilization,json=memUtilization,proto3" json:"mem_utilization,omitempty"`
	// Disk stats in KB.
	DiskBw int64 `protobuf:"varint,8,opt,name=disk_bw,json=diskBw,proto3" json:"disk_bw,omitempty"`
	// Network stats in KB.
	// net_rx_bw is received network packets in KB.
	NetRxBw int64 `protobuf:"varint,9,opt,name=net_rx_bw,json=netRxBw,proto3" json:"net_rx_bw,omitempty"`
	// net_tx_bw is transmit network packets in KB.
	NetTxBw              int64    `protobuf:"varint,10,opt,name=net_tx_bw,json=netTxBw,proto3" json:"net_tx_bw,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResourceStats) Descriptor 

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

func (*ResourceStats) GetCpusStats 

func (m *ResourceStats) GetCpusStats() []*CpuStats

func (*ResourceStats) GetDiskBw 

func (m *ResourceStats) GetDiskBw() int64

func (*ResourceStats) GetMemAllocatable 

func (m *ResourceStats) GetMemAllocatable() int64

func (*ResourceStats) GetMemCapacity 

func (m *ResourceStats) GetMemCapacity() int64

func (*ResourceStats) GetMemReservation 

func (m *ResourceStats) GetMemReservation() float64

func (*ResourceStats) GetMemUtilization 

func (m *ResourceStats) GetMemUtilization() float64

func (*ResourceStats) GetNetRxBw 

func (m *ResourceStats) GetNetRxBw() int64

func (*ResourceStats) GetNetTxBw 

func (m *ResourceStats) GetNetTxBw() int64

func (*ResourceStats) GetResourceId 

func (m *ResourceStats) GetResourceId() string

func (*ResourceStats) GetTimestamp 

func (m *ResourceStats) GetTimestamp() uint64

func (*ResourceStats) ProtoMessage 

func (*ResourceStats) ProtoMessage()

func (*ResourceStats) Reset 

func (m *ResourceStats) Reset()

func (*ResourceStats) String 

func (m *ResourceStats) String() string

func (*ResourceStats) XXX_DiscardUnknown 

func (m *ResourceStats) XXX_DiscardUnknown()

func (*ResourceStats) XXX_Marshal 

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

func (*ResourceStats) XXX_Merge 

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

func (*ResourceStats) XXX_Size 

func (m *ResourceStats) XXX_Size() int

func (*ResourceStats) XXX_Unmarshal 

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

type ResourceStatsResponse 

type ResourceStatsResponse struct {
	Type                 NodeReplyType `protobuf:"varint,1,opt,name=type,proto3,enum=firmament.NodeReplyType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ResourceStatsResponse) Descriptor 

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

func (*ResourceStatsResponse) GetType 

func (m *ResourceStatsResponse) GetType() NodeReplyType

func (*ResourceStatsResponse) ProtoMessage 

func (*ResourceStatsResponse) ProtoMessage()

func (*ResourceStatsResponse) Reset 

func (m *ResourceStatsResponse) Reset()

func (*ResourceStatsResponse) String 

func (m *ResourceStatsResponse) String() string

func (*ResourceStatsResponse) XXX_DiscardUnknown 

func (m *ResourceStatsResponse) XXX_DiscardUnknown()

func (*ResourceStatsResponse) XXX_Marshal 

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

func (*ResourceStatsResponse) XXX_Merge 

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

func (*ResourceStatsResponse) XXX_Size 

func (m *ResourceStatsResponse) XXX_Size() int

func (*ResourceStatsResponse) XXX_Unmarshal 

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

type ResourceTopologyNodeDescriptor 

type ResourceTopologyNodeDescriptor struct {
	ResourceDesc *ResourceDescriptor `protobuf:"bytes,1,opt,name=resource_desc,json=resourceDesc,proto3" json:"resource_desc,omitempty"`
	// children stores the children nodes.
	Children []*ResourceTopologyNodeDescriptor `protobuf:"bytes,2,rep,name=children,proto3" json:"children,omitempty"`
	// parent_id is the id of its parent topology node.
	ParentId             string   `protobuf:"bytes,3,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ResourceTopologyNodeDescriptor describe a node resource topology information.

func (*ResourceTopologyNodeDescriptor) Descriptor 

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

func (*ResourceTopologyNodeDescriptor) GetChildren 

func (m *ResourceTopologyNodeDescriptor) GetChildren() []*ResourceTopologyNodeDescriptor

func (*ResourceTopologyNodeDescriptor) GetParentId 

func (m *ResourceTopologyNodeDescriptor) GetParentId() string

func (*ResourceTopologyNodeDescriptor) GetResourceDesc 

func (m *ResourceTopologyNodeDescriptor) GetResourceDesc() *ResourceDescriptor

func (*ResourceTopologyNodeDescriptor) ProtoMessage 

func (*ResourceTopologyNodeDescriptor) ProtoMessage()

func (*ResourceTopologyNodeDescriptor) Reset 

func (m *ResourceTopologyNodeDescriptor) Reset()

func (*ResourceTopologyNodeDescriptor) String 

func (m *ResourceTopologyNodeDescriptor) String() string

func (*ResourceTopologyNodeDescriptor) XXX_DiscardUnknown 

func (m *ResourceTopologyNodeDescriptor) XXX_DiscardUnknown()

func (*ResourceTopologyNodeDescriptor) XXX_Marshal 

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

func (*ResourceTopologyNodeDescriptor) XXX_Merge 

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

func (*ResourceTopologyNodeDescriptor) XXX_Size 

func (m *ResourceTopologyNodeDescriptor) XXX_Size() int

func (*ResourceTopologyNodeDescriptor) XXX_Unmarshal 

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

type ResourceUID 

type ResourceUID struct {
	ResourceUid          string   `protobuf:"bytes,1,opt,name=resource_uid,json=resourceUid,proto3" json:"resource_uid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResourceUID) Descriptor 

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

func (*ResourceUID) GetResourceUid 

func (m *ResourceUID) GetResourceUid() string

func (*ResourceUID) ProtoMessage 

func (*ResourceUID) ProtoMessage()

func (*ResourceUID) Reset 

func (m *ResourceUID) Reset()

func (*ResourceUID) String 

func (m *ResourceUID) String() string

func (*ResourceUID) XXX_DiscardUnknown 

func (m *ResourceUID) XXX_DiscardUnknown()

func (*ResourceUID) XXX_Marshal 

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

func (*ResourceUID) XXX_Merge 

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

func (*ResourceUID) XXX_Size 

func (m *ResourceUID) XXX_Size() int

func (*ResourceUID) XXX_Unmarshal 

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

type ResourceVector 

type ResourceVector struct {
	// cpu_cores is the cpu millicores of node..
	CpuCores float32 `protobuf:"fixed32,1,opt,name=cpu_cores,json=cpuCores,proto3" json:"cpu_cores,omitempty"`
	RamBw    uint64  `protobuf:"varint,2,opt,name=ram_bw,json=ramBw,proto3" json:"ram_bw,omitempty"`
	// ram_cap is the memory capacity of node.
	RamCap uint64 `protobuf:"varint,3,opt,name=ram_cap,json=ramCap,proto3" json:"ram_cap,omitempty"`
	DiskBw uint64 `protobuf:"varint,4,opt,name=disk_bw,json=diskBw,proto3" json:"disk_bw,omitempty"`
	// disk_cap is the disk capacity of node.
	DiskCap uint64 `protobuf:"varint,5,opt,name=disk_cap,json=diskCap,proto3" json:"disk_cap,omitempty"`
	// net_tx_bw is transmit network packets in KB.
	NetTxBw uint64 `protobuf:"varint,6,opt,name=net_tx_bw,json=netTxBw,proto3" json:"net_tx_bw,omitempty"`
	// net_tx_bw is receive network packets in KB.
	NetRxBw uint64 `protobuf:"varint,7,opt,name=net_rx_bw,json=netRxBw,proto3" json:"net_rx_bw,omitempty"`
	// ephemeral storage
	EphemeralCap         uint64   `protobuf:"varint,8,opt,name=ephemeral_cap,json=ephemeralCap,proto3" json:"ephemeral_cap,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ResourceVector stores all the resources which will be take in account during scheduling.

func (*ResourceVector) Descriptor 

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

func (*ResourceVector) GetCpuCores 

func (m *ResourceVector) GetCpuCores() float32

func (*ResourceVector) GetDiskBw 

func (m *ResourceVector) GetDiskBw() uint64

func (*ResourceVector) GetDiskCap 

func (m *ResourceVector) GetDiskCap() uint64

func (*ResourceVector) GetEphemeralCap 

func (m *ResourceVector) GetEphemeralCap() uint64

func (*ResourceVector) GetNetRxBw 

func (m *ResourceVector) GetNetRxBw() uint64

func (*ResourceVector) GetNetTxBw 

func (m *ResourceVector) GetNetTxBw() uint64

func (*ResourceVector) GetRamBw 

func (m *ResourceVector) GetRamBw() uint64

func (*ResourceVector) GetRamCap 

func (m *ResourceVector) GetRamCap() uint64

func (*ResourceVector) ProtoMessage 

func (*ResourceVector) ProtoMessage()

func (*ResourceVector) Reset 

func (m *ResourceVector) Reset()

func (*ResourceVector) String 

func (m *ResourceVector) String() string

func (*ResourceVector) XXX_DiscardUnknown 

func (m *ResourceVector) XXX_DiscardUnknown()

func (*ResourceVector) XXX_Marshal 

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

func (*ResourceVector) XXX_Merge 

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

func (*ResourceVector) XXX_Size 

func (m *ResourceVector) XXX_Size() int

func (*ResourceVector) XXX_Unmarshal 

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

type ScheduleRequest 

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

func (*ScheduleRequest) Descriptor 

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

func (*ScheduleRequest) ProtoMessage 

func (*ScheduleRequest) ProtoMessage()

func (*ScheduleRequest) Reset 

func (m *ScheduleRequest) Reset()

func (*ScheduleRequest) String 

func (m *ScheduleRequest) String() string

func (*ScheduleRequest) XXX_DiscardUnknown 

func (m *ScheduleRequest) XXX_DiscardUnknown()

func (*ScheduleRequest) XXX_Marshal 

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

func (*ScheduleRequest) XXX_Merge 

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

func (*ScheduleRequest) XXX_Size 

func (m *ScheduleRequest) XXX_Size() int

func (*ScheduleRequest) XXX_Unmarshal 

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

type SchedulingDelta 

type SchedulingDelta struct {
	TaskId     uint64 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	ResourceId string `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// type is the scheduling decision type.
	Type                 SchedulingDelta_ChangeType `protobuf:"varint,3,opt,name=type,proto3,enum=firmament.SchedulingDelta_ChangeType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

SchedulingDelta is a scheduling decision from previous state.

func (*SchedulingDelta) Descriptor 

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

func (*SchedulingDelta) GetResourceId 

func (m *SchedulingDelta) GetResourceId() string

func (*SchedulingDelta) GetTaskId 

func (m *SchedulingDelta) GetTaskId() uint64

func (*SchedulingDelta) GetType 

func (m *SchedulingDelta) GetType() SchedulingDelta_ChangeType

func (*SchedulingDelta) ProtoMessage 

func (*SchedulingDelta) ProtoMessage()

func (*SchedulingDelta) Reset 

func (m *SchedulingDelta) Reset()

func (*SchedulingDelta) String 

func (m *SchedulingDelta) String() string

func (*SchedulingDelta) XXX_DiscardUnknown 

func (m *SchedulingDelta) XXX_DiscardUnknown()

func (*SchedulingDelta) XXX_Marshal 

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

func (*SchedulingDelta) XXX_Merge 

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

func (*SchedulingDelta) XXX_Size 

func (m *SchedulingDelta) XXX_Size() int

func (*SchedulingDelta) XXX_Unmarshal 

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

type SchedulingDelta_ChangeType 

type SchedulingDelta_ChangeType int32
const (
	// NOOP indicates does not change the previous scheduling state.
	SchedulingDelta_NOOP SchedulingDelta_ChangeType = 0
	// PLACE indicates schedule a task onto a node.
	SchedulingDelta_PLACE SchedulingDelta_ChangeType = 1
	// PREEMPT indicates a task preempt some tasks' resouces.
	SchedulingDelta_PREEMPT SchedulingDelta_ChangeType = 2
	// MIGRATE indicates migrate a task from one node the other node.
	SchedulingDelta_MIGRATE SchedulingDelta_ChangeType = 3
)

func (SchedulingDelta_ChangeType) EnumDescriptor 

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

func (SchedulingDelta_ChangeType) String 

func (x SchedulingDelta_ChangeType) String() string

type SchedulingDeltas 

type SchedulingDeltas struct {
	Deltas               []*SchedulingDelta `protobuf:"bytes,1,rep,name=deltas,proto3" json:"deltas,omitempty"`
	UnscheduledTasks     []uint64           `protobuf:"varint,2,rep,packed,name=unscheduled_tasks,json=unscheduledTasks,proto3" json:"unscheduled_tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func Schedule 

func Schedule(client FirmamentSchedulerClient) *SchedulingDeltas

Schedule sends a schedule request to firmament server.

func (*SchedulingDeltas) Descriptor 

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

func (*SchedulingDeltas) GetDeltas 

func (m *SchedulingDeltas) GetDeltas() []*SchedulingDelta

func (*SchedulingDeltas) GetUnscheduledTasks 

func (m *SchedulingDeltas) GetUnscheduledTasks() []uint64

func (*SchedulingDeltas) ProtoMessage 

func (*SchedulingDeltas) ProtoMessage()

func (*SchedulingDeltas) Reset 

func (m *SchedulingDeltas) Reset()

func (*SchedulingDeltas) String 

func (m *SchedulingDeltas) String() string

func (*SchedulingDeltas) XXX_DiscardUnknown 

func (m *SchedulingDeltas) XXX_DiscardUnknown()

func (*SchedulingDeltas) XXX_Marshal 

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

func (*SchedulingDeltas) XXX_Merge 

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

func (*SchedulingDeltas) XXX_Size 

func (m *SchedulingDeltas) XXX_Size() int

func (*SchedulingDeltas) XXX_Unmarshal 

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

type ServingStatus 

type ServingStatus int32
const (
	ServingStatus_UNKNOWN     ServingStatus = 0
	ServingStatus_SERVING     ServingStatus = 1
	ServingStatus_NOT_SERVING ServingStatus = 2
)

func (ServingStatus) EnumDescriptor 

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

func (ServingStatus) String 

func (x ServingStatus) String() string

type Taint 

type Taint struct {
	// Required. The taint key to be applied to a node.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Required. The taint value corresponding to the taint key.
	// +optional
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// Required. The effect of the taint on pods
	// that do not tolerate the taint.
	// Valid effects are NoSchedule, PreferNoSchedule and NoExecute.
	Effect               string   `protobuf:"bytes,3,opt,name=effect,proto3" json:"effect,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The node this Taint is attached to has the "effect" on any pod that does not tolerate the Taint.

func (*Taint) Descriptor 

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

func (*Taint) GetEffect 

func (m *Taint) GetEffect() string

func (*Taint) GetKey 

func (m *Taint) GetKey() string

func (*Taint) GetValue 

func (m *Taint) GetValue() string

func (*Taint) ProtoMessage 

func (*Taint) ProtoMessage()

func (*Taint) Reset 

func (m *Taint) Reset()

func (*Taint) String 

func (m *Taint) String() string

func (*Taint) XXX_DiscardUnknown 

func (m *Taint) XXX_DiscardUnknown()

func (*Taint) XXX_Marshal 

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

func (*Taint) XXX_Merge 

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

func (*Taint) XXX_Size 

func (m *Taint) XXX_Size() int

func (*Taint) XXX_Unmarshal 

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

type TaskCompletedResponse 

type TaskCompletedResponse struct {
	Type                 TaskReplyType `protobuf:"varint,1,opt,name=type,proto3,enum=firmament.TaskReplyType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*TaskCompletedResponse) Descriptor 

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

func (*TaskCompletedResponse) GetType 

func (m *TaskCompletedResponse) GetType() TaskReplyType

func (*TaskCompletedResponse) ProtoMessage 

func (*TaskCompletedResponse) ProtoMessage()

func (*TaskCompletedResponse) Reset 

func (m *TaskCompletedResponse) Reset()

func (*TaskCompletedResponse) String 

func (m *TaskCompletedResponse) String() string

func (*TaskCompletedResponse) XXX_DiscardUnknown 

func (m *TaskCompletedResponse) XXX_DiscardUnknown()

func (*TaskCompletedResponse) XXX_Marshal 

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

func (*TaskCompletedResponse) XXX_Merge 

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

func (*TaskCompletedResponse) XXX_Size 

func (m *TaskCompletedResponse) XXX_Size() int

func (*TaskCompletedResponse) XXX_Unmarshal 

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

type TaskDescription 

type TaskDescription struct {
	TaskDescriptor       *TaskDescriptor `protobuf:"bytes,1,opt,name=task_descriptor,json=taskDescriptor,proto3" json:"task_descriptor,omitempty"`
	JobDescriptor        *JobDescriptor  `protobuf:"bytes,2,opt,name=job_descriptor,json=jobDescriptor,proto3" json:"job_descriptor,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*TaskDescription) Descriptor 

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

func (*TaskDescription) GetJobDescriptor 

func (m *TaskDescription) GetJobDescriptor() *JobDescriptor

func (*TaskDescription) GetTaskDescriptor 

func (m *TaskDescription) GetTaskDescriptor() *TaskDescriptor

func (*TaskDescription) ProtoMessage 

func (*TaskDescription) ProtoMessage()

func (*TaskDescription) Reset 

func (m *TaskDescription) Reset()

func (*TaskDescription) String 

func (m *TaskDescription) String() string

func (*TaskDescription) XXX_DiscardUnknown 

func (m *TaskDescription) XXX_DiscardUnknown()

func (*TaskDescription) XXX_Marshal 

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

func (*TaskDescription) XXX_Merge 

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

func (*TaskDescription) XXX_Size 

func (m *TaskDescription) XXX_Size() int

func (*TaskDescription) XXX_Unmarshal 

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

type TaskDescriptor 

type TaskDescriptor struct {
	Uid   uint64                   `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Name  string                   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	State TaskDescriptor_TaskState `protobuf:"varint,3,opt,name=state,proto3,enum=firmament.TaskDescriptor_TaskState" json:"state,omitempty"`
	JobId string                   `protobuf:"bytes,4,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Index uint64                   `protobuf:"varint,5,opt,name=index,proto3" json:"index,omitempty"`
	// Inputs/outputs
	Dependencies []*ReferenceDescriptor `protobuf:"bytes,6,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	Outputs      []*ReferenceDescriptor `protobuf:"bytes,7,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// Command and arguments
	Binary string   `protobuf:"bytes,8,opt,name=binary,proto3" json:"binary,omitempty"`
	Args   []string `protobuf:"bytes,9,rep,name=args,proto3" json:"args,omitempty"`
	// spawned is the list of children tasks
	Spawned []*TaskDescriptor `protobuf:"bytes,10,rep,name=spawned,proto3" json:"spawned,omitempty"`
	// Runtime meta-data
	ScheduledToResource   string `protobuf:"bytes,11,opt,name=scheduled_to_resource,json=scheduledToResource,proto3" json:"scheduled_to_resource,omitempty"`
	LastHeartbeatLocation string `` /* 127-byte string literal not displayed */
	LastHeartbeatTime     uint64 `protobuf:"varint,13,opt,name=last_heartbeat_time,json=lastHeartbeatTime,proto3" json:"last_heartbeat_time,omitempty"`
	// Delegation info
	DelegatedTo   string `protobuf:"bytes,14,opt,name=delegated_to,json=delegatedTo,proto3" json:"delegated_to,omitempty"`
	DelegatedFrom string `protobuf:"bytes,15,opt,name=delegated_from,json=delegatedFrom,proto3" json:"delegated_from,omitempty"`
	// Timestamps
	SubmitTime uint64 `protobuf:"varint,16,opt,name=submit_time,json=submitTime,proto3" json:"submit_time,omitempty"`
	StartTime  uint64 `protobuf:"varint,17,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	FinishTime uint64 `protobuf:"varint,18,opt,name=finish_time,json=finishTime,proto3" json:"finish_time,omitempty"`
	// The total time spent unscheduled before previous runs.
	TotalUnscheduledTime uint64 `protobuf:"varint,19,opt,name=total_unscheduled_time,json=totalUnscheduledTime,proto3" json:"total_unscheduled_time,omitempty"`
	// The total time spent in previous runs. This field only gets updated when
	//   the task finishes running.
	TotalRunTime uint64 `protobuf:"varint,20,opt,name=total_run_time,json=totalRunTime,proto3" json:"total_run_time,omitempty"`
	// Deadlines
	RelativeDeadline uint64 `protobuf:"varint,21,opt,name=relative_deadline,json=relativeDeadline,proto3" json:"relative_deadline,omitempty"`
	AbsoluteDeadline uint64 `protobuf:"varint,22,opt,name=absolute_deadline,json=absoluteDeadline,proto3" json:"absolute_deadline,omitempty"`
	// Application-specific fields
	// TODO(malte): move these to sub-messages
	Port      uint64 `protobuf:"varint,23,opt,name=port,proto3" json:"port,omitempty"`
	InputSize uint64 `protobuf:"varint,24,opt,name=input_size,json=inputSize,proto3" json:"input_size,omitempty"`
	// TaskLib related stuff
	InjectTaskLib bool `protobuf:"varint,25,opt,name=inject_task_lib,json=injectTaskLib,proto3" json:"inject_task_lib,omitempty"`
	// Task resource request and priority
	ResourceRequest *ResourceVector `protobuf:"bytes,26,opt,name=resource_request,json=resourceRequest,proto3" json:"resource_request,omitempty"`
	Priority        uint32          `protobuf:"varint,27,opt,name=priority,proto3" json:"priority,omitempty"`
	// TODO(malte): move this to a policy-specific sub-message
	TaskType TaskDescriptor_TaskType `` /* 126-byte string literal not displayed */
	// Final report of a task after successful execution
	FinalReport *TaskFinalReport `protobuf:"bytes,29,opt,name=final_report,json=finalReport,proto3" json:"final_report,omitempty"`
	// Simulation related fields
	TraceJobId  uint64 `protobuf:"varint,30,opt,name=trace_job_id,json=traceJobId,proto3" json:"trace_job_id,omitempty"`
	TraceTaskId uint64 `protobuf:"varint,31,opt,name=trace_task_id,json=traceTaskId,proto3" json:"trace_task_id,omitempty"`
	// Task labels
	Labels []*Label `protobuf:"bytes,32,rep,name=labels,proto3" json:"labels,omitempty"`
	// Resource label selectors
	LabelSelectors []*LabelSelector `protobuf:"bytes,33,rep,name=label_selectors,json=labelSelectors,proto3" json:"label_selectors,omitempty"`
	// Affinity
	Affinity *Affinity `protobuf:"bytes,34,opt,name=affinity,proto3" json:"affinity,omitempty"`
	// NameSpace
	Namespace string `protobuf:"bytes,35,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Toleration
	Toleration []*Toleration `protobuf:"bytes,36,rep,name=toleration,proto3" json:"toleration,omitempty"`
	// Owner reference kind
	OwnerRefKind string `protobuf:"bytes,37,opt,name=owner_ref_kind,json=ownerRefKind,proto3" json:"owner_ref_kind,omitempty"`
	// Owner reference uid
	OwnerRefUid          string   `protobuf:"bytes,38,opt,name=owner_ref_uid,json=ownerRefUid,proto3" json:"owner_ref_uid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TaskDescriptor describes a task in firmament scheduler.

func (*TaskDescriptor) Descriptor 

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

func (*TaskDescriptor) GetAbsoluteDeadline 

func (m *TaskDescriptor) GetAbsoluteDeadline() uint64

func (*TaskDescriptor) GetAffinity 

func (m *TaskDescriptor) GetAffinity() *Affinity

func (*TaskDescriptor) GetArgs 

func (m *TaskDescriptor) GetArgs() []string

func (*TaskDescriptor) GetBinary 

func (m *TaskDescriptor) GetBinary() string

func (*TaskDescriptor) GetDelegatedFrom 

func (m *TaskDescriptor) GetDelegatedFrom() string

func (*TaskDescriptor) GetDelegatedTo 

func (m *TaskDescriptor) GetDelegatedTo() string

func (*TaskDescriptor) GetDependencies 

func (m *TaskDescriptor) GetDependencies() []*ReferenceDescriptor

func (*TaskDescriptor) GetFinalReport 

func (m *TaskDescriptor) GetFinalReport() *TaskFinalReport

func (*TaskDescriptor) GetFinishTime 

func (m *TaskDescriptor) GetFinishTime() uint64

func (*TaskDescriptor) GetIndex 

func (m *TaskDescriptor) GetIndex() uint64

func (*TaskDescriptor) GetInjectTaskLib 

func (m *TaskDescriptor) GetInjectTaskLib() bool

func (*TaskDescriptor) GetInputSize 

func (m *TaskDescriptor) GetInputSize() uint64

func (*TaskDescriptor) GetJobId 

func (m *TaskDescriptor) GetJobId() string

func (*TaskDescriptor) GetLabelSelectors 

func (m *TaskDescriptor) GetLabelSelectors() []*LabelSelector

func (*TaskDescriptor) GetLabels 

func (m *TaskDescriptor) GetLabels() []*Label

func (*TaskDescriptor) GetLastHeartbeatLocation 

func (m *TaskDescriptor) GetLastHeartbeatLocation() string

func (*TaskDescriptor) GetLastHeartbeatTime 

func (m *TaskDescriptor) GetLastHeartbeatTime() uint64

func (*TaskDescriptor) GetName 

func (m *TaskDescriptor) GetName() string

func (*TaskDescriptor) GetNamespace 

func (m *TaskDescriptor) GetNamespace() string

func (*TaskDescriptor) GetOutputs 

func (m *TaskDescriptor) GetOutputs() []*ReferenceDescriptor

func (*TaskDescriptor) GetOwnerRefKind 

func (m *TaskDescriptor) GetOwnerRefKind() string

func (*TaskDescriptor) GetOwnerRefUid 

func (m *TaskDescriptor) GetOwnerRefUid() string

func (*TaskDescriptor) GetPort 

func (m *TaskDescriptor) GetPort() uint64

func (*TaskDescriptor) GetPriority 

func (m *TaskDescriptor) GetPriority() uint32

func (*TaskDescriptor) GetRelativeDeadline 

func (m *TaskDescriptor) GetRelativeDeadline() uint64

func (*TaskDescriptor) GetResourceRequest 

func (m *TaskDescriptor) GetResourceRequest() *ResourceVector

func (*TaskDescriptor) GetScheduledToResource 

func (m *TaskDescriptor) GetScheduledToResource() string

func (*TaskDescriptor) GetSpawned 

func (m *TaskDescriptor) GetSpawned() []*TaskDescriptor

func (*TaskDescriptor) GetStartTime 

func (m *TaskDescriptor) GetStartTime() uint64

func (*TaskDescriptor) GetState 

func (m *TaskDescriptor) GetState() TaskDescriptor_TaskState

func (*TaskDescriptor) GetSubmitTime 

func (m *TaskDescriptor) GetSubmitTime() uint64

func (*TaskDescriptor) GetTaskType 

func (m *TaskDescriptor) GetTaskType() TaskDescriptor_TaskType

func (*TaskDescriptor) GetToleration 

func (m *TaskDescriptor) GetToleration() []*Toleration

func (*TaskDescriptor) GetTotalRunTime 

func (m *TaskDescriptor) GetTotalRunTime() uint64

func (*TaskDescriptor) GetTotalUnscheduledTime 

func (m *TaskDescriptor) GetTotalUnscheduledTime() uint64

func (*TaskDescriptor) GetTraceJobId 

func (m *TaskDescriptor) GetTraceJobId() uint64

func (*TaskDescriptor) GetTraceTaskId 

func (m *TaskDescriptor) GetTraceTaskId() uint64

func (*TaskDescriptor) GetUid 

func (m *TaskDescriptor) GetUid() uint64

func (*TaskDescriptor) ProtoMessage 

func (*TaskDescriptor) ProtoMessage()

func (*TaskDescriptor) Reset 

func (m *TaskDescriptor) Reset()

func (*TaskDescriptor) String 

func (m *TaskDescriptor) String() string

func (*TaskDescriptor) XXX_DiscardUnknown 

func (m *TaskDescriptor) XXX_DiscardUnknown()

func (*TaskDescriptor) XXX_Marshal 

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

func (*TaskDescriptor) XXX_Merge 

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

func (*TaskDescriptor) XXX_Size 

func (m *TaskDescriptor) XXX_Size() int

func (*TaskDescriptor) XXX_Unmarshal 

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

type TaskDescriptor_TaskState 

type TaskDescriptor_TaskState int32
const (
	TaskDescriptor_CREATED   TaskDescriptor_TaskState = 0
	TaskDescriptor_BLOCKING  TaskDescriptor_TaskState = 1
	TaskDescriptor_RUNNABLE  TaskDescriptor_TaskState = 2
	TaskDescriptor_ASSIGNED  TaskDescriptor_TaskState = 3
	TaskDescriptor_RUNNING   TaskDescriptor_TaskState = 4
	TaskDescriptor_COMPLETED TaskDescriptor_TaskState = 5
	TaskDescriptor_FAILED    TaskDescriptor_TaskState = 6
	TaskDescriptor_ABORTED   TaskDescriptor_TaskState = 7
	TaskDescriptor_DELEGATED TaskDescriptor_TaskState = 8
	TaskDescriptor_UNKNOWN   TaskDescriptor_TaskState = 9
)

func (TaskDescriptor_TaskState) EnumDescriptor 

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

func (TaskDescriptor_TaskState) String 

func (x TaskDescriptor_TaskState) String() string

type TaskDescriptor_TaskType 

type TaskDescriptor_TaskType int32
const (
	TaskDescriptor_SHEEP  TaskDescriptor_TaskType = 0
	TaskDescriptor_RABBIT TaskDescriptor_TaskType = 1
	TaskDescriptor_DEVIL  TaskDescriptor_TaskType = 2
	TaskDescriptor_TURTLE TaskDescriptor_TaskType = 3
)

func (TaskDescriptor_TaskType) EnumDescriptor 

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

func (TaskDescriptor_TaskType) String 

func (x TaskDescriptor_TaskType) String() string

type TaskFailedResponse 

type TaskFailedResponse struct {
	Type                 TaskReplyType `protobuf:"varint,1,opt,name=type,proto3,enum=firmament.TaskReplyType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*TaskFailedResponse) Descriptor 

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

func (*TaskFailedResponse) GetType 

func (m *TaskFailedResponse) GetType() TaskReplyType

func (*TaskFailedResponse) ProtoMessage 

func (*TaskFailedResponse) ProtoMessage()

func (*TaskFailedResponse) Reset 

func (m *TaskFailedResponse) Reset()

func (*TaskFailedResponse) String 

func (m *TaskFailedResponse) String() string

func (*TaskFailedResponse) XXX_DiscardUnknown 

func (m *TaskFailedResponse) XXX_DiscardUnknown()

func (*TaskFailedResponse) XXX_Marshal 

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

func (*TaskFailedResponse) XXX_Merge 

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

func (*TaskFailedResponse) XXX_Size 

func (m *TaskFailedResponse) XXX_Size() int

func (*TaskFailedResponse) XXX_Unmarshal 

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

type TaskFinalReport 

type TaskFinalReport struct {
	TaskId               uint64   `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	StartTime            uint64   `protobuf:"varint,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	FinishTime           uint64   `protobuf:"varint,3,opt,name=finish_time,json=finishTime,proto3" json:"finish_time,omitempty"`
	Instructions         uint64   `protobuf:"varint,4,opt,name=instructions,proto3" json:"instructions,omitempty"`
	Cycles               uint64   `protobuf:"varint,5,opt,name=cycles,proto3" json:"cycles,omitempty"`
	LlcRefs              uint64   `protobuf:"varint,6,opt,name=llc_refs,json=llcRefs,proto3" json:"llc_refs,omitempty"`
	LlcMisses            uint64   `protobuf:"varint,7,opt,name=llc_misses,json=llcMisses,proto3" json:"llc_misses,omitempty"`
	Runtime              float64  `protobuf:"fixed64,8,opt,name=runtime,proto3" json:"runtime,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TaskFinalReport describes the final state of a task in firmament scheduler.

func (*TaskFinalReport) Descriptor 

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

func (*TaskFinalReport) GetCycles 

func (m *TaskFinalReport) GetCycles() uint64

func (*TaskFinalReport) GetFinishTime 

func (m *TaskFinalReport) GetFinishTime() uint64

func (*TaskFinalReport) GetInstructions 

func (m *TaskFinalReport) GetInstructions() uint64

func (*TaskFinalReport) GetLlcMisses 

func (m *TaskFinalReport) GetLlcMisses() uint64

func (*TaskFinalReport) GetLlcRefs 

func (m *TaskFinalReport) GetLlcRefs() uint64

func (*TaskFinalReport) GetRuntime 

func (m *TaskFinalReport) GetRuntime() float64

func (*TaskFinalReport) GetStartTime 

func (m *TaskFinalReport) GetStartTime() uint64

func (*TaskFinalReport) GetTaskId 

func (m *TaskFinalReport) GetTaskId() uint64

func (*TaskFinalReport) ProtoMessage 

func (*TaskFinalReport) ProtoMessage()

func (*TaskFinalReport) Reset 

func (m *TaskFinalReport) Reset()

func (*TaskFinalReport) String 

func (m *TaskFinalReport) String() string

func (*TaskFinalReport) XXX_DiscardUnknown 

func (m *TaskFinalReport) XXX_DiscardUnknown()

func (*TaskFinalReport) XXX_Marshal 

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

func (*TaskFinalReport) XXX_Merge 

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

func (*TaskFinalReport) XXX_Size 

func (m *TaskFinalReport) XXX_Size() int

func (*TaskFinalReport) XXX_Unmarshal 

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

type TaskInfo 

type TaskInfo struct {
	TaskName                    string       `protobuf:"bytes,1,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	ResourceId                  string       `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	CpuUtilization              int64        `protobuf:"varint,3,opt,name=cpu_utilization,json=cpuUtilization,proto3" json:"cpu_utilization,omitempty"`
	MemUtilization              int64        `protobuf:"varint,4,opt,name=mem_utilization,json=memUtilization,proto3" json:"mem_utilization,omitempty"`
	EphemeralStorageUtilization int64        `` /* 145-byte string literal not displayed */
	Type                        TaskInfoType `protobuf:"varint,6,opt,name=type,proto3,enum=firmament.TaskInfoType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral        struct{}     `json:"-"`
	XXX_unrecognized            []byte       `json:"-"`
	XXX_sizecache               int32        `json:"-"`
}

TaskInfo is the stats(including CPU, Memory and ephemeral) of a task.

func (*TaskInfo) Descriptor 

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

func (*TaskInfo) GetCpuUtilization 

func (m *TaskInfo) GetCpuUtilization() int64

func (*TaskInfo) GetEphemeralStorageUtilization 

func (m *TaskInfo) GetEphemeralStorageUtilization() int64

func (*TaskInfo) GetMemUtilization 

func (m *TaskInfo) GetMemUtilization() int64

func (*TaskInfo) GetResourceId 

func (m *TaskInfo) GetResourceId() string

func (*TaskInfo) GetTaskName 

func (m *TaskInfo) GetTaskName() string

func (*TaskInfo) GetType 

func (m *TaskInfo) GetType() TaskInfoType

func (*TaskInfo) ProtoMessage 

func (*TaskInfo) ProtoMessage()

func (*TaskInfo) Reset 

func (m *TaskInfo) Reset()

func (*TaskInfo) String 

func (m *TaskInfo) String() string

func (*TaskInfo) XXX_DiscardUnknown 

func (m *TaskInfo) XXX_DiscardUnknown()

func (*TaskInfo) XXX_Marshal 

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

func (*TaskInfo) XXX_Merge 

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

func (*TaskInfo) XXX_Size 

func (m *TaskInfo) XXX_Size() int

func (*TaskInfo) XXX_Unmarshal 

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

type TaskInfoReplyType 

type TaskInfoReplyType int32
const (
	TaskInfoReplyType_TASKINFO_SUBMITTED_OK  TaskInfoReplyType = 0
	TaskInfoReplyType_TASKINFO_REMOVED_OK    TaskInfoReplyType = 2
	TaskInfoReplyType_TASKINFO_SUBMIT_FAILED TaskInfoReplyType = 3
	TaskInfoReplyType_TASKINFO_REMOVE_FAILED TaskInfoReplyType = 4
)

func (TaskInfoReplyType) EnumDescriptor 

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

func (TaskInfoReplyType) String 

func (x TaskInfoReplyType) String() string

type TaskInfoResponse 

type TaskInfoResponse struct {
	Type                 TaskInfoReplyType `protobuf:"varint,1,opt,name=type,proto3,enum=firmament.TaskInfoReplyType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*TaskInfoResponse) Descriptor 

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

func (*TaskInfoResponse) GetType 

func (m *TaskInfoResponse) GetType() TaskInfoReplyType

func (*TaskInfoResponse) ProtoMessage 

func (*TaskInfoResponse) ProtoMessage()

func (*TaskInfoResponse) Reset 

func (m *TaskInfoResponse) Reset()

func (*TaskInfoResponse) String 

func (m *TaskInfoResponse) String() string

func (*TaskInfoResponse) XXX_DiscardUnknown 

func (m *TaskInfoResponse) XXX_DiscardUnknown()

func (*TaskInfoResponse) XXX_Marshal 

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

func (*TaskInfoResponse) XXX_Merge 

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

func (*TaskInfoResponse) XXX_Size 

func (m *TaskInfoResponse) XXX_Size() int

func (*TaskInfoResponse) XXX_Unmarshal 

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

type TaskInfoType 

type TaskInfoType int32
const (
	TaskInfoType_TASKINFO_ADD    TaskInfoType = 0
	TaskInfoType_TASKINFO_REMOVE TaskInfoType = 1
)

func (TaskInfoType) EnumDescriptor 

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

func (TaskInfoType) String 

func (x TaskInfoType) String() string

type TaskRemovedResponse 

type TaskRemovedResponse struct {
	Type                 TaskReplyType `protobuf:"varint,1,opt,name=type,proto3,enum=firmament.TaskReplyType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*TaskRemovedResponse) Descriptor 

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

func (*TaskRemovedResponse) GetType 

func (m *TaskRemovedResponse) GetType() TaskReplyType

func (*TaskRemovedResponse) ProtoMessage 

func (*TaskRemovedResponse) ProtoMessage()

func (*TaskRemovedResponse) Reset 

func (m *TaskRemovedResponse) Reset()

func (*TaskRemovedResponse) String 

func (m *TaskRemovedResponse) String() string

func (*TaskRemovedResponse) XXX_DiscardUnknown 

func (m *TaskRemovedResponse) XXX_DiscardUnknown()

func (*TaskRemovedResponse) XXX_Marshal 

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

func (*TaskRemovedResponse) XXX_Merge 

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

func (*TaskRemovedResponse) XXX_Size 

func (m *TaskRemovedResponse) XXX_Size() int

func (*TaskRemovedResponse) XXX_Unmarshal 

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

type TaskReplyType 

type TaskReplyType int32
const (
	TaskReplyType_TASK_COMPLETED_OK      TaskReplyType = 0
	TaskReplyType_TASK_SUBMITTED_OK      TaskReplyType = 1
	TaskReplyType_TASK_REMOVED_OK        TaskReplyType = 2
	TaskReplyType_TASK_FAILED_OK         TaskReplyType = 3
	TaskReplyType_TASK_UPDATED_OK        TaskReplyType = 4
	TaskReplyType_TASK_NOT_FOUND         TaskReplyType = 5
	TaskReplyType_TASK_JOB_NOT_FOUND     TaskReplyType = 6
	TaskReplyType_TASK_ALREADY_SUBMITTED TaskReplyType = 7
	TaskReplyType_TASK_STATE_NOT_CREATED TaskReplyType = 8
)

func (TaskReplyType) EnumDescriptor 

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

func (TaskReplyType) String 

func (x TaskReplyType) String() string

type TaskStats 

type TaskStats struct {
	TaskId    uint64 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Hostname  string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Timestamp uint64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// CPU stats in millicores.
	CpuLimit   int64 `protobuf:"varint,4,opt,name=cpu_limit,json=cpuLimit,proto3" json:"cpu_limit,omitempty"`
	CpuRequest int64 `protobuf:"varint,5,opt,name=cpu_request,json=cpuRequest,proto3" json:"cpu_request,omitempty"`
	CpuUsage   int64 `protobuf:"varint,6,opt,name=cpu_usage,json=cpuUsage,proto3" json:"cpu_usage,omitempty"`
	// Memory stats in Kb.
	MemLimit            int64   `protobuf:"varint,7,opt,name=mem_limit,json=memLimit,proto3" json:"mem_limit,omitempty"`
	MemRequest          int64   `protobuf:"varint,8,opt,name=mem_request,json=memRequest,proto3" json:"mem_request,omitempty"`
	MemUsage            int64   `protobuf:"varint,9,opt,name=mem_usage,json=memUsage,proto3" json:"mem_usage,omitempty"`
	MemRss              int64   `protobuf:"varint,10,opt,name=mem_rss,json=memRss,proto3" json:"mem_rss,omitempty"`
	MemCache            int64   `protobuf:"varint,11,opt,name=mem_cache,json=memCache,proto3" json:"mem_cache,omitempty"`
	MemWorkingSet       int64   `protobuf:"varint,12,opt,name=mem_working_set,json=memWorkingSet,proto3" json:"mem_working_set,omitempty"`
	MemPageFaults       int64   `protobuf:"varint,13,opt,name=mem_page_faults,json=memPageFaults,proto3" json:"mem_page_faults,omitempty"`
	MemPageFaultsRate   float64 `protobuf:"fixed64,14,opt,name=mem_page_faults_rate,json=memPageFaultsRate,proto3" json:"mem_page_faults_rate,omitempty"`
	MajorPageFaults     int64   `protobuf:"varint,15,opt,name=major_page_faults,json=majorPageFaults,proto3" json:"major_page_faults,omitempty"`
	MajorPageFaultsRate float64 `protobuf:"fixed64,16,opt,name=major_page_faults_rate,json=majorPageFaultsRate,proto3" json:"major_page_faults_rate,omitempty"`
	// Network stats in Kb.
	NetRx                int64    `protobuf:"varint,17,opt,name=net_rx,json=netRx,proto3" json:"net_rx,omitempty"`
	NetRxErrors          int64    `protobuf:"varint,18,opt,name=net_rx_errors,json=netRxErrors,proto3" json:"net_rx_errors,omitempty"`
	NetRxErrorsRate      float64  `protobuf:"fixed64,19,opt,name=net_rx_errors_rate,json=netRxErrorsRate,proto3" json:"net_rx_errors_rate,omitempty"`
	NetRxRate            float64  `protobuf:"fixed64,20,opt,name=net_rx_rate,json=netRxRate,proto3" json:"net_rx_rate,omitempty"`
	NetTx                int64    `protobuf:"varint,21,opt,name=net_tx,json=netTx,proto3" json:"net_tx,omitempty"`
	NetTxErrors          int64    `protobuf:"varint,22,opt,name=net_tx_errors,json=netTxErrors,proto3" json:"net_tx_errors,omitempty"`
	NetTxErrorsRate      float64  `protobuf:"fixed64,23,opt,name=net_tx_errors_rate,json=netTxErrorsRate,proto3" json:"net_tx_errors_rate,omitempty"`
	NetTxRate            float64  `protobuf:"fixed64,24,opt,name=net_tx_rate,json=netTxRate,proto3" json:"net_tx_rate,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TaskStats is the stats(including CPU, Memory and Network) of a task.

func (*TaskStats) Descriptor 

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

func (*TaskStats) GetCpuLimit 

func (m *TaskStats) GetCpuLimit() int64

func (*TaskStats) GetCpuRequest 

func (m *TaskStats) GetCpuRequest() int64

func (*TaskStats) GetCpuUsage 

func (m *TaskStats) GetCpuUsage() int64

func (*TaskStats) GetHostname 

func (m *TaskStats) GetHostname() string

func (*TaskStats) GetMajorPageFaults 

func (m *TaskStats) GetMajorPageFaults() int64

func (*TaskStats) GetMajorPageFaultsRate 

func (m *TaskStats) GetMajorPageFaultsRate() float64

func (*TaskStats) GetMemCache 

func (m *TaskStats) GetMemCache() int64

func (*TaskStats) GetMemLimit 

func (m *TaskStats) GetMemLimit() int64

func (*TaskStats) GetMemPageFaults 

func (m *TaskStats) GetMemPageFaults() int64

func (*TaskStats) GetMemPageFaultsRate 

func (m *TaskStats) GetMemPageFaultsRate() float64

func (*TaskStats) GetMemRequest 

func (m *TaskStats) GetMemRequest() int64

func (*TaskStats) GetMemRss 

func (m *TaskStats) GetMemRss() int64

func (*TaskStats) GetMemUsage 

func (m *TaskStats) GetMemUsage() int64

func (*TaskStats) GetMemWorkingSet 

func (m *TaskStats) GetMemWorkingSet() int64

func (*TaskStats) GetNetRx 

func (m *TaskStats) GetNetRx() int64

func (*TaskStats) GetNetRxErrors 

func (m *TaskStats) GetNetRxErrors() int64

func (*TaskStats) GetNetRxErrorsRate 

func (m *TaskStats) GetNetRxErrorsRate() float64

func (*TaskStats) GetNetRxRate 

func (m *TaskStats) GetNetRxRate() float64

func (*TaskStats) GetNetTx 

func (m *TaskStats) GetNetTx() int64

func (*TaskStats) GetNetTxErrors 

func (m *TaskStats) GetNetTxErrors() int64

func (*TaskStats) GetNetTxErrorsRate 

func (m *TaskStats) GetNetTxErrorsRate() float64

func (*TaskStats) GetNetTxRate 

func (m *TaskStats) GetNetTxRate() float64

func (*TaskStats) GetTaskId 

func (m *TaskStats) GetTaskId() uint64

func (*TaskStats) GetTimestamp 

func (m *TaskStats) GetTimestamp() uint64

func (*TaskStats) ProtoMessage 

func (*TaskStats) ProtoMessage()

func (*TaskStats) Reset 

func (m *TaskStats) Reset()

func (*TaskStats) String 

func (m *TaskStats) String() string

func (*TaskStats) XXX_DiscardUnknown 

func (m *TaskStats) XXX_DiscardUnknown()

func (*TaskStats) XXX_Marshal 

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

func (*TaskStats) XXX_Merge 

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

func (*TaskStats) XXX_Size 

func (m *TaskStats) XXX_Size() int

func (*TaskStats) XXX_Unmarshal 

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

type TaskStatsResponse 

type TaskStatsResponse struct {
	Type                 TaskReplyType `protobuf:"varint,1,opt,name=type,proto3,enum=firmament.TaskReplyType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*TaskStatsResponse) Descriptor 

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

func (*TaskStatsResponse) GetType 

func (m *TaskStatsResponse) GetType() TaskReplyType

func (*TaskStatsResponse) ProtoMessage 

func (*TaskStatsResponse) ProtoMessage()

func (*TaskStatsResponse) Reset 

func (m *TaskStatsResponse) Reset()

func (*TaskStatsResponse) String 

func (m *TaskStatsResponse) String() string

func (*TaskStatsResponse) XXX_DiscardUnknown 

func (m *TaskStatsResponse) XXX_DiscardUnknown()

func (*TaskStatsResponse) XXX_Marshal 

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

func (*TaskStatsResponse) XXX_Merge 

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

func (*TaskStatsResponse) XXX_Size 

func (m *TaskStatsResponse) XXX_Size() int

func (*TaskStatsResponse) XXX_Unmarshal 

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

type TaskSubmittedResponse 

type TaskSubmittedResponse struct {
	Type                 TaskReplyType `protobuf:"varint,1,opt,name=type,proto3,enum=firmament.TaskReplyType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*TaskSubmittedResponse) Descriptor 

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

func (*TaskSubmittedResponse) GetType 

func (m *TaskSubmittedResponse) GetType() TaskReplyType

func (*TaskSubmittedResponse) ProtoMessage 

func (*TaskSubmittedResponse) ProtoMessage()

func (*TaskSubmittedResponse) Reset 

func (m *TaskSubmittedResponse) Reset()

func (*TaskSubmittedResponse) String 

func (m *TaskSubmittedResponse) String() string

func (*TaskSubmittedResponse) XXX_DiscardUnknown 

func (m *TaskSubmittedResponse) XXX_DiscardUnknown()

func (*TaskSubmittedResponse) XXX_Marshal 

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

func (*TaskSubmittedResponse) XXX_Merge 

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

func (*TaskSubmittedResponse) XXX_Size 

func (m *TaskSubmittedResponse) XXX_Size() int

func (*TaskSubmittedResponse) XXX_Unmarshal 

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

type TaskUID 

type TaskUID struct {
	TaskUid              uint64   `protobuf:"varint,1,opt,name=task_uid,json=taskUid,proto3" json:"task_uid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskUID) Descriptor 

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

func (*TaskUID) GetTaskUid 

func (m *TaskUID) GetTaskUid() uint64

func (*TaskUID) ProtoMessage 

func (*TaskUID) ProtoMessage()

func (*TaskUID) Reset 

func (m *TaskUID) Reset()

func (*TaskUID) String 

func (m *TaskUID) String() string

func (*TaskUID) XXX_DiscardUnknown 

func (m *TaskUID) XXX_DiscardUnknown()

func (*TaskUID) XXX_Marshal 

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

func (*TaskUID) XXX_Merge 

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

func (*TaskUID) XXX_Size 

func (m *TaskUID) XXX_Size() int

func (*TaskUID) XXX_Unmarshal 

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

type TaskUpdatedResponse 

type TaskUpdatedResponse struct {
	Type                 TaskReplyType `protobuf:"varint,1,opt,name=type,proto3,enum=firmament.TaskReplyType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*TaskUpdatedResponse) Descriptor 

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

func (*TaskUpdatedResponse) GetType 

func (m *TaskUpdatedResponse) GetType() TaskReplyType

func (*TaskUpdatedResponse) ProtoMessage 

func (*TaskUpdatedResponse) ProtoMessage()

func (*TaskUpdatedResponse) Reset 

func (m *TaskUpdatedResponse) Reset()

func (*TaskUpdatedResponse) String 

func (m *TaskUpdatedResponse) String() string

func (*TaskUpdatedResponse) XXX_DiscardUnknown 

func (m *TaskUpdatedResponse) XXX_DiscardUnknown()

func (*TaskUpdatedResponse) XXX_Marshal 

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

func (*TaskUpdatedResponse) XXX_Merge 

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

func (*TaskUpdatedResponse) XXX_Size 

func (m *TaskUpdatedResponse) XXX_Size() int

func (*TaskUpdatedResponse) XXX_Unmarshal 

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

type Toleration 

type Toleration struct {
	// Key is the taint key that the toleration applies to. Empty means match all taint keys.
	// If the key is empty, operator must be Exists; this combination means to match all values and all keys.
	// +optional
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Operator represents a key's relationship to the value.
	// Valid operators are Exists and Equal. Defaults to Equal.
	// Exists is equivalent to wildcard for value, so that a pod can
	// tolerate all taints of a particular category.
	// +optional
	Operator string `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"`
	// Value is the taint value the toleration matches to.
	// If the operator is Exists, the value should be empty, otherwise just a regular string.
	// +optional
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// Effect indicates the taint effect to match. Empty means match all taint effects.
	// When specified, allowed values are NoSchedule, PreferNoSchedule and NoExecute.
	// +optional
	Effect string `protobuf:"bytes,4,opt,name=effect,proto3" json:"effect,omitempty"`
	// TolerationSeconds represents the period of time the toleration (which must be
	// of effect NoExecute, otherwise this field is ignored) tolerates the taint. By default,
	// it is not set, which means tolerate the taint forever (do not evict). Zero and
	// negative values will be treated as 0 (evict immediately) by the system.
	// +optional
	TolerationSeconds    int64    `protobuf:"varint,5,opt,name=tolerationSeconds,proto3" json:"tolerationSeconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The pod this Toleration is attached to tolerates any taint that matches the triple <key,value,effect> using the matching operator <operator>.

func (*Toleration) Descriptor 

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

func (*Toleration) GetEffect 

func (m *Toleration) GetEffect() string

func (*Toleration) GetKey 

func (m *Toleration) GetKey() string

func (*Toleration) GetOperator 

func (m *Toleration) GetOperator() string

func (*Toleration) GetTolerationSeconds 

func (m *Toleration) GetTolerationSeconds() int64

func (*Toleration) GetValue 

func (m *Toleration) GetValue() string

func (*Toleration) ProtoMessage 

func (*Toleration) ProtoMessage()

func (*Toleration) Reset 

func (m *Toleration) Reset()

func (*Toleration) String 

func (m *Toleration) String() string

func (*Toleration) XXX_DiscardUnknown 

func (m *Toleration) XXX_DiscardUnknown()

func (*Toleration) XXX_Marshal 

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

func (*Toleration) XXX_Merge 

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

func (*Toleration) XXX_Size 

func (m *Toleration) XXX_Size() int

func (*Toleration) XXX_Unmarshal 

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

type WeightedPodAffinityTerm 

type WeightedPodAffinityTerm struct {
	// weight associated with matching the corresponding podAffinityTerm,
	// in the range 1-100.
	Weight int32 `protobuf:"varint,1,opt,name=weight,proto3" json:"weight,omitempty"`
	// A pod affinity term, associated with the corresponding weight.
	PodAffinityTerm      *PodAffinityTerm `protobuf:"bytes,2,opt,name=podAffinityTerm,proto3" json:"podAffinityTerm,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*WeightedPodAffinityTerm) Descriptor 

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

func (*WeightedPodAffinityTerm) GetPodAffinityTerm 

func (m *WeightedPodAffinityTerm) GetPodAffinityTerm() *PodAffinityTerm

func (*WeightedPodAffinityTerm) GetWeight 

func (m *WeightedPodAffinityTerm) GetWeight() int32

func (*WeightedPodAffinityTerm) ProtoMessage 

func (*WeightedPodAffinityTerm) ProtoMessage()

func (*WeightedPodAffinityTerm) Reset 

func (m *WeightedPodAffinityTerm) Reset()

func (*WeightedPodAffinityTerm) String 

func (m *WeightedPodAffinityTerm) String() string

func (*WeightedPodAffinityTerm) XXX_DiscardUnknown 

func (m *WeightedPodAffinityTerm) XXX_DiscardUnknown()

func (*WeightedPodAffinityTerm) XXX_Marshal 

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

func (*WeightedPodAffinityTerm) XXX_Merge 

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

func (*WeightedPodAffinityTerm) XXX_Size 

func (m *WeightedPodAffinityTerm) XXX_Size() int

func (*WeightedPodAffinityTerm) XXX_Unmarshal 

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

type WeightedPodAffinityTermAntiAff 

type WeightedPodAffinityTermAntiAff struct {
	// weight associated with matching the corresponding podAffinityTerm,
	// in the range 1-100.
	Weight int32 `protobuf:"varint,1,opt,name=weight,proto3" json:"weight,omitempty"`
	// A pod affinity term, associated with the corresponding weight.
	PodAffinityTerm      *PodAffinityTermAntiAff `protobuf:"bytes,2,opt,name=podAffinityTerm,proto3" json:"podAffinityTerm,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*WeightedPodAffinityTermAntiAff) Descriptor 

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

func (*WeightedPodAffinityTermAntiAff) GetPodAffinityTerm 

func (m *WeightedPodAffinityTermAntiAff) GetPodAffinityTerm() *PodAffinityTermAntiAff

func (*WeightedPodAffinityTermAntiAff) GetWeight 

func (m *WeightedPodAffinityTermAntiAff) GetWeight() int32

func (*WeightedPodAffinityTermAntiAff) ProtoMessage 

func (*WeightedPodAffinityTermAntiAff) ProtoMessage()

func (*WeightedPodAffinityTermAntiAff) Reset 

func (m *WeightedPodAffinityTermAntiAff) Reset()

func (*WeightedPodAffinityTermAntiAff) String 

func (m *WeightedPodAffinityTermAntiAff) String() string

func (*WeightedPodAffinityTermAntiAff) XXX_DiscardUnknown 

func (m *WeightedPodAffinityTermAntiAff) XXX_DiscardUnknown()

func (*WeightedPodAffinityTermAntiAff) XXX_Marshal 

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

func (*WeightedPodAffinityTermAntiAff) XXX_Merge 

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

func (*WeightedPodAffinityTermAntiAff) XXX_Size 

func (m *WeightedPodAffinityTermAntiAff) XXX_Size() int

func (*WeightedPodAffinityTermAntiAff) XXX_Unmarshal 

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

type WhareMapStats 

type WhareMapStats struct {
	NumIdle              uint64   `protobuf:"varint,1,opt,name=num_idle,json=numIdle,proto3" json:"num_idle,omitempty"`
	NumDevils            uint64   `protobuf:"varint,2,opt,name=num_devils,json=numDevils,proto3" json:"num_devils,omitempty"`
	NumRabbits           uint64   `protobuf:"varint,3,opt,name=num_rabbits,json=numRabbits,proto3" json:"num_rabbits,omitempty"`
	NumSheep             uint64   `protobuf:"varint,4,opt,name=num_sheep,json=numSheep,proto3" json:"num_sheep,omitempty"`
	NumTurtles           uint64   `protobuf:"varint,5,opt,name=num_turtles,json=numTurtles,proto3" json:"num_turtles,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

WhareMapStats is the stats of WhareMap scheduling cost model, as described in the ISCA 2013 paper.

func (*WhareMapStats) Descriptor 

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

func (*WhareMapStats) GetNumDevils 

func (m *WhareMapStats) GetNumDevils() uint64

func (*WhareMapStats) GetNumIdle 

func (m *WhareMapStats) GetNumIdle() uint64

func (*WhareMapStats) GetNumRabbits 

func (m *WhareMapStats) GetNumRabbits() uint64

func (*WhareMapStats) GetNumSheep 

func (m *WhareMapStats) GetNumSheep() uint64

func (*WhareMapStats) GetNumTurtles 

func (m *WhareMapStats) GetNumTurtles() uint64

func (*WhareMapStats) ProtoMessage 

func (*WhareMapStats) ProtoMessage()

func (*WhareMapStats) Reset 

func (m *WhareMapStats) Reset()

func (*WhareMapStats) String 

func (m *WhareMapStats) String() string

func (*WhareMapStats) XXX_DiscardUnknown 

func (m *WhareMapStats) XXX_DiscardUnknown()

func (*WhareMapStats) XXX_Marshal 

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

func (*WhareMapStats) XXX_Merge 

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

func (*WhareMapStats) XXX_Size 

func (m *WhareMapStats) XXX_Size() int

func (*WhareMapStats) XXX_Unmarshal 

func (m *WhareMapStats) 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.