Documentation ¶
Overview ¶
Package proto is a generated protocol buffer package.
It is generated from these files:
coco_interference_scores.proto job_desc.proto reference_desc.proto resource_desc.proto resource_topology_node_desc.proto resource_vector.proto scheduling_delta.proto task_desc.proto task_final_report.proto whare_map_stats.proto
It has these top-level messages:
CoCoInterferenceScores JobDescriptor ReferenceDescriptor ResourceDescriptor ResourceTopologyNodeDescriptor ResourceVector SchedulingDelta TaskDescriptor TaskFinalReport WhareMapStats
Index ¶
- Variables
- type CoCoInterferenceScores
- func (*CoCoInterferenceScores) Descriptor() ([]byte, []int)
- func (m *CoCoInterferenceScores) Marshal() (data []byte, err error)
- func (m *CoCoInterferenceScores) MarshalTo(data []byte) (int, error)
- func (*CoCoInterferenceScores) ProtoMessage()
- func (m *CoCoInterferenceScores) Reset()
- func (m *CoCoInterferenceScores) Size() (n int)
- func (m *CoCoInterferenceScores) String() string
- func (m *CoCoInterferenceScores) Unmarshal(data []byte) error
- type JobDescriptor
- func (*JobDescriptor) Descriptor() ([]byte, []int)
- func (m *JobDescriptor) GetRootTask() *TaskDescriptor
- func (m *JobDescriptor) Marshal() (data []byte, err error)
- func (m *JobDescriptor) MarshalTo(data []byte) (int, error)
- func (*JobDescriptor) ProtoMessage()
- func (m *JobDescriptor) Reset()
- func (m *JobDescriptor) Size() (n int)
- func (m *JobDescriptor) String() string
- func (m *JobDescriptor) Unmarshal(data []byte) error
- type JobDescriptor_JobState
- type ReferenceDescriptor
- func (*ReferenceDescriptor) Descriptor() ([]byte, []int)
- func (m *ReferenceDescriptor) Marshal() (data []byte, err error)
- func (m *ReferenceDescriptor) MarshalTo(data []byte) (int, error)
- func (*ReferenceDescriptor) ProtoMessage()
- func (m *ReferenceDescriptor) Reset()
- func (m *ReferenceDescriptor) Size() (n int)
- func (m *ReferenceDescriptor) String() string
- func (m *ReferenceDescriptor) Unmarshal(data []byte) error
- type ReferenceDescriptor_ReferenceScope
- type ReferenceDescriptor_ReferenceType
- type ResourceDescriptor
- func (*ResourceDescriptor) Descriptor() ([]byte, []int)
- func (m *ResourceDescriptor) GetAvailableResources() *ResourceVector
- func (m *ResourceDescriptor) GetCocoInterferenceScores() *CoCoInterferenceScores
- func (m *ResourceDescriptor) GetMaxAvailableResourcesBelow() *ResourceVector
- func (m *ResourceDescriptor) GetMaxUnreservedResourcesBelow() *ResourceVector
- func (m *ResourceDescriptor) GetMinAvailableResourcesBelow() *ResourceVector
- func (m *ResourceDescriptor) GetMinUnreservedResourcesBelow() *ResourceVector
- func (m *ResourceDescriptor) GetReservedResources() *ResourceVector
- func (m *ResourceDescriptor) GetResourceCapacity() *ResourceVector
- func (m *ResourceDescriptor) GetWhareMapStats() *WhareMapStats
- func (m *ResourceDescriptor) Marshal() (data []byte, err error)
- func (m *ResourceDescriptor) MarshalTo(data []byte) (int, error)
- func (*ResourceDescriptor) ProtoMessage()
- func (m *ResourceDescriptor) Reset()
- func (m *ResourceDescriptor) Size() (n int)
- func (m *ResourceDescriptor) String() string
- func (m *ResourceDescriptor) Unmarshal(data []byte) error
- type ResourceDescriptor_ResourceState
- type ResourceDescriptor_ResourceType
- type ResourceTopologyNodeDescriptor
- func (*ResourceTopologyNodeDescriptor) Descriptor() ([]byte, []int)
- func (m *ResourceTopologyNodeDescriptor) GetChildren() []*ResourceTopologyNodeDescriptor
- func (m *ResourceTopologyNodeDescriptor) GetResourceDesc() *ResourceDescriptor
- func (m *ResourceTopologyNodeDescriptor) Marshal() (data []byte, err error)
- func (m *ResourceTopologyNodeDescriptor) MarshalTo(data []byte) (int, error)
- func (*ResourceTopologyNodeDescriptor) ProtoMessage()
- func (m *ResourceTopologyNodeDescriptor) Reset()
- func (m *ResourceTopologyNodeDescriptor) Size() (n int)
- func (m *ResourceTopologyNodeDescriptor) String() string
- func (m *ResourceTopologyNodeDescriptor) Unmarshal(data []byte) error
- type ResourceVector
- func (*ResourceVector) Descriptor() ([]byte, []int)
- func (m *ResourceVector) Marshal() (data []byte, err error)
- func (m *ResourceVector) MarshalTo(data []byte) (int, error)
- func (*ResourceVector) ProtoMessage()
- func (m *ResourceVector) Reset()
- func (m *ResourceVector) Size() (n int)
- func (m *ResourceVector) String() string
- func (m *ResourceVector) Unmarshal(data []byte) error
- type SchedulingDelta
- func (*SchedulingDelta) Descriptor() ([]byte, []int)
- func (m *SchedulingDelta) Marshal() (data []byte, err error)
- func (m *SchedulingDelta) MarshalTo(data []byte) (int, error)
- func (*SchedulingDelta) ProtoMessage()
- func (m *SchedulingDelta) Reset()
- func (m *SchedulingDelta) Size() (n int)
- func (m *SchedulingDelta) String() string
- func (m *SchedulingDelta) Unmarshal(data []byte) error
- type SchedulingDelta_ChangeType
- type TaskDescriptor
- func (*TaskDescriptor) Descriptor() ([]byte, []int)
- func (m *TaskDescriptor) GetDependencies() []*ReferenceDescriptor
- func (m *TaskDescriptor) GetFinalReport() *TaskFinalReport
- func (m *TaskDescriptor) GetOutputs() []*ReferenceDescriptor
- func (m *TaskDescriptor) GetResourceRequest() *ResourceVector
- func (m *TaskDescriptor) GetSpawned() []*TaskDescriptor
- func (m *TaskDescriptor) Marshal() (data []byte, err error)
- func (m *TaskDescriptor) MarshalTo(data []byte) (int, error)
- func (*TaskDescriptor) ProtoMessage()
- func (m *TaskDescriptor) Reset()
- func (m *TaskDescriptor) Size() (n int)
- func (m *TaskDescriptor) String() string
- func (m *TaskDescriptor) Unmarshal(data []byte) error
- type TaskDescriptor_TaskState
- type TaskDescriptor_TaskType
- type TaskFinalReport
- func (*TaskFinalReport) Descriptor() ([]byte, []int)
- func (m *TaskFinalReport) Marshal() (data []byte, err error)
- func (m *TaskFinalReport) MarshalTo(data []byte) (int, error)
- func (*TaskFinalReport) ProtoMessage()
- func (m *TaskFinalReport) Reset()
- func (m *TaskFinalReport) Size() (n int)
- func (m *TaskFinalReport) String() string
- func (m *TaskFinalReport) Unmarshal(data []byte) error
- type WhareMapStats
- func (*WhareMapStats) Descriptor() ([]byte, []int)
- func (m *WhareMapStats) Marshal() (data []byte, err error)
- func (m *WhareMapStats) MarshalTo(data []byte) (int, error)
- func (*WhareMapStats) ProtoMessage()
- func (m *WhareMapStats) Reset()
- func (m *WhareMapStats) Size() (n int)
- func (m *WhareMapStats) String() string
- func (m *WhareMapStats) Unmarshal(data []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthCocoInterferenceScores = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowCocoInterferenceScores = fmt.Errorf("proto: integer overflow") )
View Source
var ( ErrInvalidLengthJobDesc = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowJobDesc = fmt.Errorf("proto: integer overflow") )
View Source
var ( ErrInvalidLengthReferenceDesc = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowReferenceDesc = fmt.Errorf("proto: integer overflow") )
View Source
var ( ErrInvalidLengthResourceDesc = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowResourceDesc = fmt.Errorf("proto: integer overflow") )
View Source
var ( ErrInvalidLengthResourceTopologyNodeDesc = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowResourceTopologyNodeDesc = fmt.Errorf("proto: integer overflow") )
View Source
var ( ErrInvalidLengthResourceVector = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowResourceVector = fmt.Errorf("proto: integer overflow") )
View Source
var ( ErrInvalidLengthSchedulingDelta = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowSchedulingDelta = fmt.Errorf("proto: integer overflow") )
View Source
var ( ErrInvalidLengthTaskDesc = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTaskDesc = fmt.Errorf("proto: integer overflow") )
View Source
var ( ErrInvalidLengthTaskFinalReport = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTaskFinalReport = fmt.Errorf("proto: integer overflow") )
View Source
var ( ErrInvalidLengthWhareMapStats = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowWhareMapStats = fmt.Errorf("proto: integer overflow") )
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 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: "ResourceUnknown",
1: "ResourceIdle",
2: "ResourceBusy",
3: "ResourceLost",
}
View Source
var ResourceDescriptor_ResourceState_value = map[string]int32{
"ResourceUnknown": 0,
"ResourceIdle": 1,
"ResourceBusy": 2,
"ResourceLost": 3,
}
View Source
var ResourceDescriptor_ResourceType_name = map[int32]string{
0: "ResourcePu",
1: "ResourceCore",
2: "ResourceCache",
3: "ResourceNic",
4: "ResourceDisk",
5: "ResourceSsd",
6: "ResourceMachine",
7: "ResourceLogical",
8: "ResourceNumaNode",
9: "ResourceSocket",
10: "ResourceCoordinator",
}
View Source
var ResourceDescriptor_ResourceType_value = map[string]int32{
"ResourcePu": 0,
"ResourceCore": 1,
"ResourceCache": 2,
"ResourceNic": 3,
"ResourceDisk": 4,
"ResourceSsd": 5,
"ResourceMachine": 6,
"ResourceLogical": 7,
"ResourceNumaNode": 8,
"ResourceSocket": 9,
"ResourceCoordinator": 10,
}
View Source
var SchedulingDelta_ChangeType_name = map[int32]string{
0: "PLACE",
1: "PREEMPT",
2: "MIGRATE",
3: "NOOP",
}
View Source
var SchedulingDelta_ChangeType_value = map[string]int32{
"PLACE": 0,
"PREEMPT": 1,
"MIGRATE": 2,
"NOOP": 3,
}
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,
}
Functions ¶
This section is empty.
Types ¶
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"` }
func (*CoCoInterferenceScores) Descriptor ¶
func (*CoCoInterferenceScores) Descriptor() ([]byte, []int)
func (*CoCoInterferenceScores) Marshal ¶
func (m *CoCoInterferenceScores) Marshal() (data []byte, err error)
func (*CoCoInterferenceScores) MarshalTo ¶
func (m *CoCoInterferenceScores) MarshalTo(data []byte) (int, error)
func (*CoCoInterferenceScores) ProtoMessage ¶
func (*CoCoInterferenceScores) ProtoMessage()
func (*CoCoInterferenceScores) Reset ¶
func (m *CoCoInterferenceScores) Reset()
func (*CoCoInterferenceScores) Size ¶
func (m *CoCoInterferenceScores) Size() (n int)
func (*CoCoInterferenceScores) String ¶
func (m *CoCoInterferenceScores) String() string
func (*CoCoInterferenceScores) Unmarshal ¶
func (m *CoCoInterferenceScores) Unmarshal(data []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=proto.JobDescriptor_JobState" json:"state,omitempty"` RootTask *TaskDescriptor `protobuf:"bytes,4,opt,name=root_task,json=rootTask" json:"root_task,omitempty"` OutputIds [][]byte `protobuf:"bytes,5,rep,name=output_ids,json=outputIds" json:"output_ids,omitempty"` }
func (*JobDescriptor) Descriptor ¶
func (*JobDescriptor) Descriptor() ([]byte, []int)
func (*JobDescriptor) GetRootTask ¶
func (m *JobDescriptor) GetRootTask() *TaskDescriptor
func (*JobDescriptor) Marshal ¶
func (m *JobDescriptor) Marshal() (data []byte, err error)
func (*JobDescriptor) ProtoMessage ¶
func (*JobDescriptor) ProtoMessage()
func (*JobDescriptor) Reset ¶
func (m *JobDescriptor) Reset()
func (*JobDescriptor) Size ¶
func (m *JobDescriptor) Size() (n int)
func (*JobDescriptor) String ¶
func (m *JobDescriptor) String() string
func (*JobDescriptor) Unmarshal ¶
func (m *JobDescriptor) Unmarshal(data []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 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=proto.ReferenceDescriptor_ReferenceType" json:"type,omitempty"` Scope ReferenceDescriptor_ReferenceScope `protobuf:"varint,3,opt,name=scope,proto3,enum=proto.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"` // Modifications for storage engine IsModified bool `protobuf:"varint,11,opt,name=is_modified,json=isModified,proto3" json:"is_modified,omitempty"` }
func (*ReferenceDescriptor) Descriptor ¶
func (*ReferenceDescriptor) Descriptor() ([]byte, []int)
func (*ReferenceDescriptor) Marshal ¶
func (m *ReferenceDescriptor) Marshal() (data []byte, err error)
func (*ReferenceDescriptor) MarshalTo ¶
func (m *ReferenceDescriptor) MarshalTo(data []byte) (int, error)
func (*ReferenceDescriptor) ProtoMessage ¶
func (*ReferenceDescriptor) ProtoMessage()
func (*ReferenceDescriptor) Reset ¶
func (m *ReferenceDescriptor) Reset()
func (*ReferenceDescriptor) Size ¶
func (m *ReferenceDescriptor) Size() (n int)
func (*ReferenceDescriptor) String ¶
func (m *ReferenceDescriptor) String() string
func (*ReferenceDescriptor) Unmarshal ¶
func (m *ReferenceDescriptor) Unmarshal(data []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 ResourceDescriptor_ResourceState `protobuf:"varint,4,opt,name=state,proto3,enum=proto.ResourceDescriptor_ResourceState" json:"state,omitempty"` TaskCapacity uint64 `protobuf:"varint,5,opt,name=task_capacity,json=taskCapacity,proto3" json:"task_capacity,omitempty"` LastHeartbeat uint64 `protobuf:"varint,6,opt,name=last_heartbeat,json=lastHeartbeat,proto3" json:"last_heartbeat,omitempty"` Type ResourceDescriptor_ResourceType `protobuf:"varint,7,opt,name=type,proto3,enum=proto.ResourceDescriptor_ResourceType" json:"type,omitempty"` Schedulable bool `protobuf:"varint,8,opt,name=schedulable,proto3" json:"schedulable,omitempty"` CurrentRunningTasks []uint64 `protobuf:"varint,9,rep,name=current_running_tasks,json=currentRunningTasks" json:"current_running_tasks,omitempty"` // 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" json:"available_resources,omitempty"` ReservedResources *ResourceVector `protobuf:"bytes,13,opt,name=reserved_resources,json=reservedResources" json:"reserved_resources,omitempty"` MinAvailableResourcesBelow *ResourceVector `` /* 137-byte string literal not displayed */ MaxAvailableResourcesBelow *ResourceVector `` /* 137-byte string literal not displayed */ MinUnreservedResourcesBelow *ResourceVector `` /* 140-byte string literal not displayed */ MaxUnreservedResourcesBelow *ResourceVector `` /* 140-byte string literal not displayed */ ResourceCapacity *ResourceVector `protobuf:"bytes,18,opt,name=resource_capacity,json=resourceCapacity" json:"resource_capacity,omitempty"` // Cost-model-specific statistics WhareMapStats *WhareMapStats `protobuf:"bytes,19,opt,name=whare_map_stats,json=whareMapStats" json:"whare_map_stats,omitempty"` CocoInterferenceScores *CoCoInterferenceScores `protobuf:"bytes,20,opt,name=coco_interference_scores,json=cocoInterferenceScores" json:"coco_interference_scores,omitempty"` // Simulation related fields TraceMachineId uint64 `protobuf:"varint,21,opt,name=trace_machine_id,json=traceMachineId,proto3" json:"trace_machine_id,omitempty"` }
func (*ResourceDescriptor) Descriptor ¶
func (*ResourceDescriptor) Descriptor() ([]byte, []int)
func (*ResourceDescriptor) GetAvailableResources ¶
func (m *ResourceDescriptor) GetAvailableResources() *ResourceVector
func (*ResourceDescriptor) GetCocoInterferenceScores ¶
func (m *ResourceDescriptor) GetCocoInterferenceScores() *CoCoInterferenceScores
func (*ResourceDescriptor) GetMaxAvailableResourcesBelow ¶
func (m *ResourceDescriptor) GetMaxAvailableResourcesBelow() *ResourceVector
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) GetReservedResources ¶
func (m *ResourceDescriptor) GetReservedResources() *ResourceVector
func (*ResourceDescriptor) GetResourceCapacity ¶
func (m *ResourceDescriptor) GetResourceCapacity() *ResourceVector
func (*ResourceDescriptor) GetWhareMapStats ¶
func (m *ResourceDescriptor) GetWhareMapStats() *WhareMapStats
func (*ResourceDescriptor) Marshal ¶
func (m *ResourceDescriptor) Marshal() (data []byte, err error)
func (*ResourceDescriptor) MarshalTo ¶
func (m *ResourceDescriptor) MarshalTo(data []byte) (int, error)
func (*ResourceDescriptor) ProtoMessage ¶
func (*ResourceDescriptor) ProtoMessage()
func (*ResourceDescriptor) Reset ¶
func (m *ResourceDescriptor) Reset()
func (*ResourceDescriptor) Size ¶
func (m *ResourceDescriptor) Size() (n int)
func (*ResourceDescriptor) String ¶
func (m *ResourceDescriptor) String() string
func (*ResourceDescriptor) Unmarshal ¶
func (m *ResourceDescriptor) Unmarshal(data []byte) error
type ResourceDescriptor_ResourceState ¶
type ResourceDescriptor_ResourceState int32
const ( ResourceDescriptor_ResourceUnknown ResourceDescriptor_ResourceState = 0 ResourceDescriptor_ResourceIdle ResourceDescriptor_ResourceState = 1 ResourceDescriptor_ResourceBusy ResourceDescriptor_ResourceState = 2 ResourceDescriptor_ResourceLost 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_ResourcePu ResourceDescriptor_ResourceType = 0 ResourceDescriptor_ResourceCore ResourceDescriptor_ResourceType = 1 ResourceDescriptor_ResourceCache ResourceDescriptor_ResourceType = 2 ResourceDescriptor_ResourceNic ResourceDescriptor_ResourceType = 3 ResourceDescriptor_ResourceDisk ResourceDescriptor_ResourceType = 4 ResourceDescriptor_ResourceSsd ResourceDescriptor_ResourceType = 5 ResourceDescriptor_ResourceMachine ResourceDescriptor_ResourceType = 6 ResourceDescriptor_ResourceLogical ResourceDescriptor_ResourceType = 7 ResourceDescriptor_ResourceNumaNode ResourceDescriptor_ResourceType = 8 ResourceDescriptor_ResourceSocket ResourceDescriptor_ResourceType = 9 ResourceDescriptor_ResourceCoordinator ResourceDescriptor_ResourceType = 10 )
func (ResourceDescriptor_ResourceType) EnumDescriptor ¶
func (ResourceDescriptor_ResourceType) EnumDescriptor() ([]byte, []int)
func (ResourceDescriptor_ResourceType) String ¶
func (x ResourceDescriptor_ResourceType) String() string
type ResourceTopologyNodeDescriptor ¶
type ResourceTopologyNodeDescriptor struct { ResourceDesc *ResourceDescriptor `protobuf:"bytes,1,opt,name=resource_desc,json=resourceDesc" json:"resource_desc,omitempty"` Children []*ResourceTopologyNodeDescriptor `protobuf:"bytes,2,rep,name=children" json:"children,omitempty"` ParentId string `protobuf:"bytes,3,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"` }
func (*ResourceTopologyNodeDescriptor) Descriptor ¶
func (*ResourceTopologyNodeDescriptor) Descriptor() ([]byte, []int)
func (*ResourceTopologyNodeDescriptor) GetChildren ¶
func (m *ResourceTopologyNodeDescriptor) GetChildren() []*ResourceTopologyNodeDescriptor
func (*ResourceTopologyNodeDescriptor) GetResourceDesc ¶
func (m *ResourceTopologyNodeDescriptor) GetResourceDesc() *ResourceDescriptor
func (*ResourceTopologyNodeDescriptor) Marshal ¶
func (m *ResourceTopologyNodeDescriptor) Marshal() (data []byte, err error)
func (*ResourceTopologyNodeDescriptor) MarshalTo ¶
func (m *ResourceTopologyNodeDescriptor) MarshalTo(data []byte) (int, error)
func (*ResourceTopologyNodeDescriptor) ProtoMessage ¶
func (*ResourceTopologyNodeDescriptor) ProtoMessage()
func (*ResourceTopologyNodeDescriptor) Reset ¶
func (m *ResourceTopologyNodeDescriptor) Reset()
func (*ResourceTopologyNodeDescriptor) Size ¶
func (m *ResourceTopologyNodeDescriptor) Size() (n int)
func (*ResourceTopologyNodeDescriptor) String ¶
func (m *ResourceTopologyNodeDescriptor) String() string
func (*ResourceTopologyNodeDescriptor) Unmarshal ¶
func (m *ResourceTopologyNodeDescriptor) Unmarshal(data []byte) error
type ResourceVector ¶
type ResourceVector struct { 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"` 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"` DiskCap uint64 `protobuf:"varint,5,opt,name=disk_cap,json=diskCap,proto3" json:"disk_cap,omitempty"` NetBw uint64 `protobuf:"varint,6,opt,name=net_bw,json=netBw,proto3" json:"net_bw,omitempty"` }
func (*ResourceVector) Descriptor ¶
func (*ResourceVector) Descriptor() ([]byte, []int)
func (*ResourceVector) Marshal ¶
func (m *ResourceVector) Marshal() (data []byte, err error)
func (*ResourceVector) ProtoMessage ¶
func (*ResourceVector) ProtoMessage()
func (*ResourceVector) Reset ¶
func (m *ResourceVector) Reset()
func (*ResourceVector) Size ¶
func (m *ResourceVector) Size() (n int)
func (*ResourceVector) String ¶
func (m *ResourceVector) String() string
func (*ResourceVector) Unmarshal ¶
func (m *ResourceVector) Unmarshal(data []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 SchedulingDelta_ChangeType `protobuf:"varint,3,opt,name=type,proto3,enum=proto.SchedulingDelta_ChangeType" json:"type,omitempty"` }
func (*SchedulingDelta) Descriptor ¶
func (*SchedulingDelta) Descriptor() ([]byte, []int)
func (*SchedulingDelta) Marshal ¶
func (m *SchedulingDelta) Marshal() (data []byte, err error)
func (*SchedulingDelta) ProtoMessage ¶
func (*SchedulingDelta) ProtoMessage()
func (*SchedulingDelta) Reset ¶
func (m *SchedulingDelta) Reset()
func (*SchedulingDelta) Size ¶
func (m *SchedulingDelta) Size() (n int)
func (*SchedulingDelta) String ¶
func (m *SchedulingDelta) String() string
func (*SchedulingDelta) Unmarshal ¶
func (m *SchedulingDelta) Unmarshal(data []byte) error
type SchedulingDelta_ChangeType ¶
type SchedulingDelta_ChangeType int32
const ( SchedulingDelta_PLACE SchedulingDelta_ChangeType = 0 SchedulingDelta_PREEMPT SchedulingDelta_ChangeType = 1 SchedulingDelta_MIGRATE SchedulingDelta_ChangeType = 2 SchedulingDelta_NOOP SchedulingDelta_ChangeType = 3 )
func (SchedulingDelta_ChangeType) EnumDescriptor ¶
func (SchedulingDelta_ChangeType) EnumDescriptor() ([]byte, []int)
func (SchedulingDelta_ChangeType) String ¶
func (x SchedulingDelta_ChangeType) String() string
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=proto.TaskDescriptor_TaskState" json:"state,omitempty"` JobID string `protobuf:"bytes,4,opt,name=jobID,proto3" json:"jobID,omitempty"` Index uint64 `protobuf:"varint,5,opt,name=index,proto3" json:"index,omitempty"` // Inputs/outputs Dependencies []*ReferenceDescriptor `protobuf:"bytes,6,rep,name=dependencies" json:"dependencies,omitempty"` Outputs []*ReferenceDescriptor `protobuf:"bytes,7,rep,name=outputs" json:"outputs,omitempty"` // Command and arguments Binary []byte `protobuf:"bytes,8,opt,name=binary,proto3" json:"binary,omitempty"` Args []string `protobuf:"bytes,9,rep,name=args" json:"args,omitempty"` // Children Spawned []*TaskDescriptor `protobuf:"bytes,10,rep,name=spawned" 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" json:"resource_request,omitempty"` Priority uint32 `protobuf:"varint,27,opt,name=priority,proto3" json:"priority,omitempty"` TaskType TaskDescriptor_TaskType `protobuf:"varint,28,opt,name=task_type,json=taskType,proto3,enum=proto.TaskDescriptor_TaskType" json:"task_type,omitempty"` // Final report after successful execution FinalReport *TaskFinalReport `protobuf:"bytes,29,opt,name=final_report,json=finalReport" 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"` }
func (*TaskDescriptor) Descriptor ¶
func (*TaskDescriptor) Descriptor() ([]byte, []int)
func (*TaskDescriptor) GetDependencies ¶
func (m *TaskDescriptor) GetDependencies() []*ReferenceDescriptor
func (*TaskDescriptor) GetFinalReport ¶
func (m *TaskDescriptor) GetFinalReport() *TaskFinalReport
func (*TaskDescriptor) GetOutputs ¶
func (m *TaskDescriptor) GetOutputs() []*ReferenceDescriptor
func (*TaskDescriptor) GetResourceRequest ¶
func (m *TaskDescriptor) GetResourceRequest() *ResourceVector
func (*TaskDescriptor) GetSpawned ¶
func (m *TaskDescriptor) GetSpawned() []*TaskDescriptor
func (*TaskDescriptor) Marshal ¶
func (m *TaskDescriptor) Marshal() (data []byte, err error)
func (*TaskDescriptor) ProtoMessage ¶
func (*TaskDescriptor) ProtoMessage()
func (*TaskDescriptor) Reset ¶
func (m *TaskDescriptor) Reset()
func (*TaskDescriptor) Size ¶
func (m *TaskDescriptor) Size() (n int)
func (*TaskDescriptor) String ¶
func (m *TaskDescriptor) String() string
func (*TaskDescriptor) Unmarshal ¶
func (m *TaskDescriptor) Unmarshal(data []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 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"` }
func (*TaskFinalReport) Descriptor ¶
func (*TaskFinalReport) Descriptor() ([]byte, []int)
func (*TaskFinalReport) Marshal ¶
func (m *TaskFinalReport) Marshal() (data []byte, err error)
func (*TaskFinalReport) ProtoMessage ¶
func (*TaskFinalReport) ProtoMessage()
func (*TaskFinalReport) Reset ¶
func (m *TaskFinalReport) Reset()
func (*TaskFinalReport) Size ¶
func (m *TaskFinalReport) Size() (n int)
func (*TaskFinalReport) String ¶
func (m *TaskFinalReport) String() string
func (*TaskFinalReport) Unmarshal ¶
func (m *TaskFinalReport) Unmarshal(data []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"` }
func (*WhareMapStats) Descriptor ¶
func (*WhareMapStats) Descriptor() ([]byte, []int)
func (*WhareMapStats) Marshal ¶
func (m *WhareMapStats) Marshal() (data []byte, err error)
func (*WhareMapStats) ProtoMessage ¶
func (*WhareMapStats) ProtoMessage()
func (*WhareMapStats) Reset ¶
func (m *WhareMapStats) Reset()
func (*WhareMapStats) Size ¶
func (m *WhareMapStats) Size() (n int)
func (*WhareMapStats) String ¶
func (m *WhareMapStats) String() string
func (*WhareMapStats) Unmarshal ¶
func (m *WhareMapStats) Unmarshal(data []byte) error
Click to show internal directories.
Click to hide internal directories.