proto

package
v0.0.0-...-5d2b7a7 Latest Latest
Warning

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

 Go to latest Published: Jan 4, 2018 License: Apache-2.0 Imports: 5 Imported by: 0

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

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

func (m *JobDescriptor) MarshalTo(data []byte) (int, 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) MarshalTo 

func (m *ResourceVector) MarshalTo(data []byte) (int, 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) MarshalTo 

func (m *SchedulingDelta) MarshalTo(data []byte) (int, 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) MarshalTo 

func (m *TaskDescriptor) MarshalTo(data []byte) (int, 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) MarshalTo 

func (m *TaskFinalReport) MarshalTo(data []byte) (int, 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) MarshalTo 

func (m *WhareMapStats) MarshalTo(data []byte) (int, 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

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.