pb

package
v0.0.0-...-404dc1e Latest Latest
Warning

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

 Go to latest Published: Aug 10, 2017 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package pb is a generated protocol buffer package.

It is generated from these files: 

master_agent.proto

It has these top-level messages: 

ComputeRequest
ComputeResource
DataResource
Location
Allocation
AllocationResult
Heartbeat
Empty
DataLocation
FlowExecutionStatus
FileResourceRequest
FileResourceResponse
ExecutionRequest
ExecutionResponse
ExecutionStat
InstructionStat
ControlMessage
DeleteDatasetShardRequest
DeleteDatasetShardResponse
WriteRequest
ReadRequest
InstructionSet
Instruction
OrderBy
DatasetShard
DatasetShardLocation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterGleamoldAgentServer 

func RegisterGleamoldAgentServer(s *grpc.Server, srv GleamoldAgentServer)

func RegisterGleamoldMasterServer 

func RegisterGleamoldMasterServer(s *grpc.Server, srv GleamoldMasterServer)

Types

type Allocation 

type Allocation struct {
	Location  *Location        `protobuf:"bytes,1,opt,name=location" json:"location,omitempty"`
	Allocated *ComputeResource `protobuf:"bytes,2,opt,name=allocated" json:"allocated,omitempty"`
}

func (*Allocation) Descriptor 

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

func (*Allocation) GetAllocated 

func (m *Allocation) GetAllocated() *ComputeResource

func (*Allocation) GetLocation 

func (m *Allocation) GetLocation() *Location

func (*Allocation) ProtoMessage 

func (*Allocation) ProtoMessage()

func (*Allocation) Reset 

func (m *Allocation) Reset()

func (*Allocation) String 

func (m *Allocation) String() string

type AllocationResult 

type AllocationResult struct {
	Allocations []*Allocation `protobuf:"bytes,1,rep,name=allocations" json:"allocations,omitempty"`
}

func (*AllocationResult) Descriptor 

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

func (*AllocationResult) GetAllocations 

func (m *AllocationResult) GetAllocations() []*Allocation

func (*AllocationResult) ProtoMessage 

func (*AllocationResult) ProtoMessage()

func (*AllocationResult) Reset 

func (m *AllocationResult) Reset()

func (*AllocationResult) String 

func (m *AllocationResult) String() string

type ComputeRequest 

type ComputeRequest struct {
	DataCenter       string             `protobuf:"bytes,1,opt,name=data_center,json=dataCenter" json:"data_center,omitempty"`
	ComputeResources []*ComputeResource `protobuf:"bytes,2,rep,name=compute_resources,json=computeResources" json:"compute_resources,omitempty"`
	Username         string             `protobuf:"bytes,3,opt,name=username" json:"username,omitempty"`
	Hostname         string             `protobuf:"bytes,4,opt,name=hostname" json:"hostname,omitempty"`
	FlowHashCode     uint32             `protobuf:"varint,5,opt,name=flowHashCode" json:"flowHashCode,omitempty"`
}

////////////////////////////////////////////////

func (*ComputeRequest) Descriptor 

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

func (*ComputeRequest) GetComputeResources 

func (m *ComputeRequest) GetComputeResources() []*ComputeResource

func (*ComputeRequest) GetDataCenter 

func (m *ComputeRequest) GetDataCenter() string

func (*ComputeRequest) GetFlowHashCode 

func (m *ComputeRequest) GetFlowHashCode() uint32

func (*ComputeRequest) GetHostname 

func (m *ComputeRequest) GetHostname() string

func (*ComputeRequest) GetUsername 

func (m *ComputeRequest) GetUsername() string

func (*ComputeRequest) ProtoMessage 

func (*ComputeRequest) ProtoMessage()

func (*ComputeRequest) Reset 

func (m *ComputeRequest) Reset()

func (*ComputeRequest) String 

func (m *ComputeRequest) String() string

type ComputeResource 

type ComputeResource struct {
	CpuCount int32 `protobuf:"varint,1,opt,name=cpu_count,json=cpuCount" json:"cpu_count,omitempty"`
	CpuLevel int32 `protobuf:"varint,2,opt,name=cpu_level,json=cpuLevel" json:"cpu_level,omitempty"`
	GpuCount int32 `protobuf:"varint,3,opt,name=gpu_count,json=gpuCount" json:"gpu_count,omitempty"`
	GpuLevel int32 `protobuf:"varint,4,opt,name=gpu_level,json=gpuLevel" json:"gpu_level,omitempty"`
	MemoryMb int64 `protobuf:"varint,5,opt,name=memory_mb,json=memoryMb" json:"memory_mb,omitempty"`
	DiskMb   int64 `protobuf:"varint,6,opt,name=disk_mb,json=diskMb" json:"disk_mb,omitempty"`
}

func (ComputeResource) Covers 

func (a ComputeResource) Covers(b ComputeResource) bool

func (*ComputeResource) Descriptor 

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

func (*ComputeResource) GetCpuCount 

func (m *ComputeResource) GetCpuCount() int32

func (*ComputeResource) GetCpuLevel 

func (m *ComputeResource) GetCpuLevel() int32

func (*ComputeResource) GetDiskMb 

func (m *ComputeResource) GetDiskMb() int64

func (*ComputeResource) GetGpuCount 

func (m *ComputeResource) GetGpuCount() int32

func (*ComputeResource) GetGpuLevel 

func (m *ComputeResource) GetGpuLevel() int32

func (*ComputeResource) GetMemoryMb 

func (m *ComputeResource) GetMemoryMb() int64

func (ComputeResource) GreaterThanZero 

func (a ComputeResource) GreaterThanZero() bool

func (ComputeResource) IsZero 

func (a ComputeResource) IsZero() bool

func (ComputeResource) Minus 

func (a ComputeResource) Minus(b ComputeResource) ComputeResource

func (ComputeResource) Plus 

func (a ComputeResource) Plus(b ComputeResource) ComputeResource

func (*ComputeResource) ProtoMessage 

func (*ComputeResource) ProtoMessage()

func (*ComputeResource) Reset 

func (m *ComputeResource) Reset()

func (*ComputeResource) String 

func (m *ComputeResource) String() string

type ControlMessage 

type ControlMessage struct {
	IsOnDiskIO   bool          `protobuf:"varint,1,opt,name=isOnDiskIO" json:"isOnDiskIO,omitempty"`
	ReadRequest  *ReadRequest  `protobuf:"bytes,2,opt,name=readRequest" json:"readRequest,omitempty"`
	WriteRequest *WriteRequest `protobuf:"bytes,3,opt,name=writeRequest" json:"writeRequest,omitempty"`
}

func (*ControlMessage) Descriptor 

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

func (*ControlMessage) GetIsOnDiskIO 

func (m *ControlMessage) GetIsOnDiskIO() bool

func (*ControlMessage) GetReadRequest 

func (m *ControlMessage) GetReadRequest() *ReadRequest

func (*ControlMessage) GetWriteRequest 

func (m *ControlMessage) GetWriteRequest() *WriteRequest

func (*ControlMessage) ProtoMessage 

func (*ControlMessage) ProtoMessage()

func (*ControlMessage) Reset 

func (m *ControlMessage) Reset()

func (*ControlMessage) String 

func (m *ControlMessage) String() string

type DataLocation 

type DataLocation struct {
	Name     string    `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Location *Location `protobuf:"bytes,2,opt,name=location" json:"location,omitempty"`
	OnDisk   bool      `protobuf:"varint,3,opt,name=onDisk" json:"onDisk,omitempty"`
}

////////////////////////////////////////////////

func (*DataLocation) Descriptor 

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

func (*DataLocation) GetLocation 

func (m *DataLocation) GetLocation() *Location

func (*DataLocation) GetName 

func (m *DataLocation) GetName() string

func (*DataLocation) GetOnDisk 

func (m *DataLocation) GetOnDisk() bool

func (*DataLocation) ProtoMessage 

func (*DataLocation) ProtoMessage()

func (*DataLocation) Reset 

func (m *DataLocation) Reset()

func (*DataLocation) String 

func (m *DataLocation) String() string

type DataResource 

type DataResource struct {
	Location *Location `protobuf:"bytes,1,opt,name=location" json:"location,omitempty"`
	Size     int64     `protobuf:"varint,2,opt,name=size" json:"size,omitempty"`
}

func (*DataResource) Descriptor 

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

func (*DataResource) GetLocation 

func (m *DataResource) GetLocation() *Location

func (*DataResource) GetSize 

func (m *DataResource) GetSize() int64

func (*DataResource) ProtoMessage 

func (*DataResource) ProtoMessage()

func (*DataResource) Reset 

func (m *DataResource) Reset()

func (*DataResource) String 

func (m *DataResource) String() string

type DatasetShard 

type DatasetShard struct {
	FlowName       string `protobuf:"bytes,1,opt,name=FlowName,json=flowName" json:"FlowName,omitempty"`
	DatasetId      int32  `protobuf:"varint,2,opt,name=DatasetId,json=datasetId" json:"DatasetId,omitempty"`
	DatasetShardId int32  `protobuf:"varint,3,opt,name=DatasetShardId,json=datasetShardId" json:"DatasetShardId,omitempty"`
	FlowHashCode   uint32 `protobuf:"varint,4,opt,name=FlowHashCode,json=flowHashCode" json:"FlowHashCode,omitempty"`
}

func (*DatasetShard) Descriptor 

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

func (*DatasetShard) GetDatasetId 

func (m *DatasetShard) GetDatasetId() int32

func (*DatasetShard) GetDatasetShardId 

func (m *DatasetShard) GetDatasetShardId() int32

func (*DatasetShard) GetFlowHashCode 

func (m *DatasetShard) GetFlowHashCode() uint32

func (*DatasetShard) GetFlowName 

func (m *DatasetShard) GetFlowName() string

func (*DatasetShard) Name 

func (m *DatasetShard) Name() string

func (*DatasetShard) ProtoMessage 

func (*DatasetShard) ProtoMessage()

func (*DatasetShard) Reset 

func (m *DatasetShard) Reset()

func (*DatasetShard) String 

func (m *DatasetShard) String() string

type DatasetShardLocation 

type DatasetShardLocation struct {
	Name   string `protobuf:"bytes,1,opt,name=Name,json=name" json:"Name,omitempty"`
	Host   string `protobuf:"bytes,2,opt,name=Host,json=host" json:"Host,omitempty"`
	Port   int32  `protobuf:"varint,3,opt,name=Port,json=port" json:"Port,omitempty"`
	OnDisk bool   `protobuf:"varint,4,opt,name=onDisk" json:"onDisk,omitempty"`
}

func (*DatasetShardLocation) Address 

func (m *DatasetShardLocation) Address() string

func (*DatasetShardLocation) Descriptor 

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

func (*DatasetShardLocation) GetHost 

func (m *DatasetShardLocation) GetHost() string

func (*DatasetShardLocation) GetName 

func (m *DatasetShardLocation) GetName() string

func (*DatasetShardLocation) GetOnDisk 

func (m *DatasetShardLocation) GetOnDisk() bool

func (*DatasetShardLocation) GetPort 

func (m *DatasetShardLocation) GetPort() int32

func (*DatasetShardLocation) ProtoMessage 

func (*DatasetShardLocation) ProtoMessage()

func (*DatasetShardLocation) Reset 

func (m *DatasetShardLocation) Reset()

func (*DatasetShardLocation) String 

func (m *DatasetShardLocation) String() string

type DeleteDatasetShardRequest 

type DeleteDatasetShardRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

func (*DeleteDatasetShardRequest) Descriptor 

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

func (*DeleteDatasetShardRequest) GetName 

func (m *DeleteDatasetShardRequest) GetName() string

func (*DeleteDatasetShardRequest) ProtoMessage 

func (*DeleteDatasetShardRequest) ProtoMessage()

func (*DeleteDatasetShardRequest) Reset 

func (m *DeleteDatasetShardRequest) Reset()

func (*DeleteDatasetShardRequest) String 

func (m *DeleteDatasetShardRequest) String() string

type DeleteDatasetShardResponse 

type DeleteDatasetShardResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*DeleteDatasetShardResponse) Descriptor 

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

func (*DeleteDatasetShardResponse) GetError 

func (m *DeleteDatasetShardResponse) GetError() string

func (*DeleteDatasetShardResponse) ProtoMessage 

func (*DeleteDatasetShardResponse) ProtoMessage()

func (*DeleteDatasetShardResponse) Reset 

func (m *DeleteDatasetShardResponse) Reset()

func (*DeleteDatasetShardResponse) String 

func (m *DeleteDatasetShardResponse) String() string

type Empty 

type Empty struct {
}

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

type ExecutionRequest 

type ExecutionRequest struct {
	InstructionSet *InstructionSet  `protobuf:"bytes,1,opt,name=instructionSet" json:"instructionSet,omitempty"`
	Dir            string           `protobuf:"bytes,2,opt,name=dir" json:"dir,omitempty"`
	Resource       *ComputeResource `protobuf:"bytes,3,opt,name=resource" json:"resource,omitempty"`
}

func (*ExecutionRequest) Descriptor 

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

func (*ExecutionRequest) GetDir 

func (m *ExecutionRequest) GetDir() string

func (*ExecutionRequest) GetInstructionSet 

func (m *ExecutionRequest) GetInstructionSet() *InstructionSet

func (*ExecutionRequest) GetResource 

func (m *ExecutionRequest) GetResource() *ComputeResource

func (*ExecutionRequest) ProtoMessage 

func (*ExecutionRequest) ProtoMessage()

func (*ExecutionRequest) Reset 

func (m *ExecutionRequest) Reset()

func (*ExecutionRequest) String 

func (m *ExecutionRequest) String() string

type ExecutionResponse 

type ExecutionResponse struct {
	Output        []byte         `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	Error         []byte         `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	SystemTime    float64        `protobuf:"fixed64,3,opt,name=systemTime" json:"systemTime,omitempty"`
	UserTime      float64        `protobuf:"fixed64,4,opt,name=userTime" json:"userTime,omitempty"`
	ExecutionStat *ExecutionStat `protobuf:"bytes,5,opt,name=executionStat" json:"executionStat,omitempty"`
}

func (*ExecutionResponse) Descriptor 

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

func (*ExecutionResponse) GetError 

func (m *ExecutionResponse) GetError() []byte

func (*ExecutionResponse) GetExecutionStat 

func (m *ExecutionResponse) GetExecutionStat() *ExecutionStat

func (*ExecutionResponse) GetOutput 

func (m *ExecutionResponse) GetOutput() []byte

func (*ExecutionResponse) GetSystemTime 

func (m *ExecutionResponse) GetSystemTime() float64

func (*ExecutionResponse) GetUserTime 

func (m *ExecutionResponse) GetUserTime() float64

func (*ExecutionResponse) ProtoMessage 

func (*ExecutionResponse) ProtoMessage()

func (*ExecutionResponse) Reset 

func (m *ExecutionResponse) Reset()

func (*ExecutionResponse) String 

func (m *ExecutionResponse) String() string

type ExecutionStat 

type ExecutionStat struct {
	FlowHashCode uint32             `protobuf:"varint,1,opt,name=flowHashCode" json:"flowHashCode,omitempty"`
	Name         string             `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	Stats        []*InstructionStat `protobuf:"bytes,3,rep,name=stats" json:"stats,omitempty"`
}

func (*ExecutionStat) Descriptor 

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

func (*ExecutionStat) GetFlowHashCode 

func (m *ExecutionStat) GetFlowHashCode() uint32

func (*ExecutionStat) GetName 

func (m *ExecutionStat) GetName() string

func (*ExecutionStat) GetStats 

func (m *ExecutionStat) GetStats() []*InstructionStat

func (*ExecutionStat) ProtoMessage 

func (*ExecutionStat) ProtoMessage()

func (*ExecutionStat) Reset 

func (m *ExecutionStat) Reset()

func (*ExecutionStat) String 

func (m *ExecutionStat) String() string

type FileResourceRequest 

type FileResourceRequest struct {
	Name         string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Dir          string `protobuf:"bytes,2,opt,name=dir" json:"dir,omitempty"`
	Hash         uint32 `protobuf:"varint,3,opt,name=hash" json:"hash,omitempty"`
	FlowHashCode uint32 `protobuf:"varint,4,opt,name=flowHashCode" json:"flowHashCode,omitempty"`
	Content      []byte `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"`
}

func (*FileResourceRequest) Descriptor 

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

func (*FileResourceRequest) GetContent 

func (m *FileResourceRequest) GetContent() []byte

func (*FileResourceRequest) GetDir 

func (m *FileResourceRequest) GetDir() string

func (*FileResourceRequest) GetFlowHashCode 

func (m *FileResourceRequest) GetFlowHashCode() uint32

func (*FileResourceRequest) GetHash 

func (m *FileResourceRequest) GetHash() uint32

func (*FileResourceRequest) GetName 

func (m *FileResourceRequest) GetName() string

func (*FileResourceRequest) ProtoMessage 

func (*FileResourceRequest) ProtoMessage()

func (*FileResourceRequest) Reset 

func (m *FileResourceRequest) Reset()

func (*FileResourceRequest) String 

func (m *FileResourceRequest) String() string

type FileResourceResponse 

type FileResourceResponse struct {
	AlreadyExists bool `protobuf:"varint,1,opt,name=alreadyExists" json:"alreadyExists,omitempty"`
	Ok            bool `protobuf:"varint,2,opt,name=ok" json:"ok,omitempty"`
}

func (*FileResourceResponse) Descriptor 

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

func (*FileResourceResponse) GetAlreadyExists 

func (m *FileResourceResponse) GetAlreadyExists() bool

func (*FileResourceResponse) GetOk 

func (m *FileResourceResponse) GetOk() bool

func (*FileResourceResponse) ProtoMessage 

func (*FileResourceResponse) ProtoMessage()

func (*FileResourceResponse) Reset 

func (m *FileResourceResponse) Reset()

func (*FileResourceResponse) String 

func (m *FileResourceResponse) String() string

type FlowExecutionStatus 

type FlowExecutionStatus struct {
	StepGroups    []*FlowExecutionStatus_StepGroup    `protobuf:"bytes,1,rep,name=stepGroups" json:"stepGroups,omitempty"`
	TaskGroups    []*FlowExecutionStatus_TaskGroup    `protobuf:"bytes,2,rep,name=taskGroups" json:"taskGroups,omitempty"`
	Datasets      []*FlowExecutionStatus_Dataset      `protobuf:"bytes,3,rep,name=datasets" json:"datasets,omitempty"`
	DatasetShards []*FlowExecutionStatus_DatasetShard `protobuf:"bytes,4,rep,name=datasetShards" json:"datasetShards,omitempty"`
	Tasks         []*FlowExecutionStatus_Task         `protobuf:"bytes,5,rep,name=tasks" json:"tasks,omitempty"`
	Steps         []*FlowExecutionStatus_Step         `protobuf:"bytes,6,rep,name=steps" json:"steps,omitempty"`
	Id            uint32                              `protobuf:"varint,7,opt,name=id" json:"id,omitempty"`
	Driver        *FlowExecutionStatus_DriverInfo     `protobuf:"bytes,8,opt,name=driver" json:"driver,omitempty"`
}

////////////////////////////////////////////////

func (*FlowExecutionStatus) Descriptor 

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

func (*FlowExecutionStatus) GetDataset 

func (m *FlowExecutionStatus) GetDataset(datasetId int32) *FlowExecutionStatus_Dataset

func (*FlowExecutionStatus) GetDatasetShard 

func (m *FlowExecutionStatus) GetDatasetShard(datasetId, datasetShardId int32) *FlowExecutionStatus_DatasetShard

func (*FlowExecutionStatus) GetDatasetShards 

func (m *FlowExecutionStatus) GetDatasetShards() []*FlowExecutionStatus_DatasetShard

func (*FlowExecutionStatus) GetDatasets 

func (m *FlowExecutionStatus) GetDatasets() []*FlowExecutionStatus_Dataset

func (*FlowExecutionStatus) GetDriver 

func (m *FlowExecutionStatus) GetDriver() *FlowExecutionStatus_DriverInfo

func (*FlowExecutionStatus) GetId 

func (m *FlowExecutionStatus) GetId() uint32

func (*FlowExecutionStatus) GetStep 

func (m *FlowExecutionStatus) GetStep(stepId int32) *FlowExecutionStatus_Step

func (*FlowExecutionStatus) GetStepGroups 

func (m *FlowExecutionStatus) GetStepGroups() []*FlowExecutionStatus_StepGroup

func (*FlowExecutionStatus) GetSteps 

func (m *FlowExecutionStatus) GetSteps() []*FlowExecutionStatus_Step

func (*FlowExecutionStatus) GetTask 

func (m *FlowExecutionStatus) GetTask(stepId, taskId int32) *FlowExecutionStatus_Task

func (*FlowExecutionStatus) GetTaskGroups 

func (m *FlowExecutionStatus) GetTaskGroups() []*FlowExecutionStatus_TaskGroup

func (*FlowExecutionStatus) GetTasks 

func (m *FlowExecutionStatus) GetTasks() []*FlowExecutionStatus_Task

func (*FlowExecutionStatus) ProtoMessage 

func (*FlowExecutionStatus) ProtoMessage()

func (*FlowExecutionStatus) Reset 

func (m *FlowExecutionStatus) Reset()

func (*FlowExecutionStatus) String 

func (m *FlowExecutionStatus) String() string

type FlowExecutionStatus_Dataset 

type FlowExecutionStatus_Dataset struct {
	Id             int32   `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	StepId         int32   `protobuf:"varint,2,opt,name=stepId" json:"stepId,omitempty"`
	ReadingStepIds []int32 `protobuf:"varint,3,rep,packed,name=readingStepIds" json:"readingStepIds,omitempty"`
}

func (*FlowExecutionStatus_Dataset) Descriptor 

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

func (*FlowExecutionStatus_Dataset) GetId 

func (m *FlowExecutionStatus_Dataset) GetId() int32

func (*FlowExecutionStatus_Dataset) GetReadingStepIds 

func (m *FlowExecutionStatus_Dataset) GetReadingStepIds() []int32

func (*FlowExecutionStatus_Dataset) GetStepId 

func (m *FlowExecutionStatus_Dataset) GetStepId() int32

func (*FlowExecutionStatus_Dataset) ProtoMessage 

func (*FlowExecutionStatus_Dataset) ProtoMessage()

func (*FlowExecutionStatus_Dataset) Reset 

func (m *FlowExecutionStatus_Dataset) Reset()

func (*FlowExecutionStatus_Dataset) String 

func (m *FlowExecutionStatus_Dataset) String() string

type FlowExecutionStatus_DatasetShard 

type FlowExecutionStatus_DatasetShard struct {
	DatasetId int32 `protobuf:"varint,1,opt,name=datasetId" json:"datasetId,omitempty"`
	Id        int32 `protobuf:"varint,2,opt,name=id" json:"id,omitempty"`
}

func (*FlowExecutionStatus_DatasetShard) Descriptor 

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

func (*FlowExecutionStatus_DatasetShard) GetDatasetId 

func (m *FlowExecutionStatus_DatasetShard) GetDatasetId() int32

func (*FlowExecutionStatus_DatasetShard) GetId 

func (m *FlowExecutionStatus_DatasetShard) GetId() int32

func (*FlowExecutionStatus_DatasetShard) ProtoMessage 

func (*FlowExecutionStatus_DatasetShard) ProtoMessage()

func (*FlowExecutionStatus_DatasetShard) Reset 

func (m *FlowExecutionStatus_DatasetShard) Reset()

func (*FlowExecutionStatus_DatasetShard) String 

func (m *FlowExecutionStatus_DatasetShard) String() string

type FlowExecutionStatus_DriverInfo 

type FlowExecutionStatus_DriverInfo struct {
	Username       string `protobuf:"bytes,1,opt,name=username" json:"username,omitempty"`
	Hostname       string `protobuf:"bytes,2,opt,name=hostname" json:"hostname,omitempty"`
	Executable     string `protobuf:"bytes,3,opt,name=executable" json:"executable,omitempty"`
	ExecutableHash string `protobuf:"bytes,4,opt,name=executable_hash,json=executableHash" json:"executable_hash,omitempty"`
	StartTime      int64  `protobuf:"varint,5,opt,name=start_time,json=startTime" json:"start_time,omitempty"`
	StopTime       int64  `protobuf:"varint,6,opt,name=stop_time,json=stopTime" json:"stop_time,omitempty"`
}

func (*FlowExecutionStatus_DriverInfo) Descriptor 

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

func (*FlowExecutionStatus_DriverInfo) GetExecutable 

func (m *FlowExecutionStatus_DriverInfo) GetExecutable() string

func (*FlowExecutionStatus_DriverInfo) GetExecutableHash 

func (m *FlowExecutionStatus_DriverInfo) GetExecutableHash() string

func (*FlowExecutionStatus_DriverInfo) GetHostname 

func (m *FlowExecutionStatus_DriverInfo) GetHostname() string

func (*FlowExecutionStatus_DriverInfo) GetStartTime 

func (m *FlowExecutionStatus_DriverInfo) GetStartTime() int64

func (*FlowExecutionStatus_DriverInfo) GetStopTime 

func (m *FlowExecutionStatus_DriverInfo) GetStopTime() int64

func (*FlowExecutionStatus_DriverInfo) GetUsername 

func (m *FlowExecutionStatus_DriverInfo) GetUsername() string

func (*FlowExecutionStatus_DriverInfo) ProtoMessage 

func (*FlowExecutionStatus_DriverInfo) ProtoMessage()

func (*FlowExecutionStatus_DriverInfo) Reset 

func (m *FlowExecutionStatus_DriverInfo) Reset()

func (*FlowExecutionStatus_DriverInfo) String 

func (m *FlowExecutionStatus_DriverInfo) String() string

type FlowExecutionStatus_Step 

type FlowExecutionStatus_Step struct {
	Id              int32   `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Name            string  `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	ParentIds       []int32 `protobuf:"varint,3,rep,packed,name=parentIds" json:"parentIds,omitempty"`
	TaskIds         []int32 `protobuf:"varint,4,rep,packed,name=taskIds" json:"taskIds,omitempty"`
	InputDatasetId  []int32 `protobuf:"varint,5,rep,packed,name=inputDatasetId" json:"inputDatasetId,omitempty"`
	OutputDatasetId int32   `protobuf:"varint,6,opt,name=outputDatasetId" json:"outputDatasetId,omitempty"`
}

func (*FlowExecutionStatus_Step) Descriptor 

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

func (*FlowExecutionStatus_Step) GetId 

func (m *FlowExecutionStatus_Step) GetId() int32

func (*FlowExecutionStatus_Step) GetInputDatasetId 

func (m *FlowExecutionStatus_Step) GetInputDatasetId() []int32

func (*FlowExecutionStatus_Step) GetName 

func (m *FlowExecutionStatus_Step) GetName() string

func (*FlowExecutionStatus_Step) GetOutputDatasetId 

func (m *FlowExecutionStatus_Step) GetOutputDatasetId() int32

func (*FlowExecutionStatus_Step) GetParentIds 

func (m *FlowExecutionStatus_Step) GetParentIds() []int32

func (*FlowExecutionStatus_Step) GetTaskIds 

func (m *FlowExecutionStatus_Step) GetTaskIds() []int32

func (*FlowExecutionStatus_Step) ProtoMessage 

func (*FlowExecutionStatus_Step) ProtoMessage()

func (*FlowExecutionStatus_Step) Reset 

func (m *FlowExecutionStatus_Step) Reset()

func (*FlowExecutionStatus_Step) String 

func (m *FlowExecutionStatus_Step) String() string

type FlowExecutionStatus_StepGroup 

type FlowExecutionStatus_StepGroup struct {
	StepIds   []int32 `protobuf:"varint,1,rep,packed,name=stepIds" json:"stepIds,omitempty"`
	ParentIds []int32 `protobuf:"varint,2,rep,packed,name=parentIds" json:"parentIds,omitempty"`
}

func (*FlowExecutionStatus_StepGroup) Descriptor 

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

func (*FlowExecutionStatus_StepGroup) GetParentIds 

func (m *FlowExecutionStatus_StepGroup) GetParentIds() []int32

func (*FlowExecutionStatus_StepGroup) GetStepIds 

func (m *FlowExecutionStatus_StepGroup) GetStepIds() []int32

func (*FlowExecutionStatus_StepGroup) ProtoMessage 

func (*FlowExecutionStatus_StepGroup) ProtoMessage()

func (*FlowExecutionStatus_StepGroup) Reset 

func (m *FlowExecutionStatus_StepGroup) Reset()

func (*FlowExecutionStatus_StepGroup) String 

func (m *FlowExecutionStatus_StepGroup) String() string

type FlowExecutionStatus_Task 

type FlowExecutionStatus_Task struct {
	StepId int32 `protobuf:"varint,1,opt,name=stepId" json:"stepId,omitempty"`
	Id     int32 `protobuf:"varint,2,opt,name=id" json:"id,omitempty"`
}

func (*FlowExecutionStatus_Task) Descriptor 

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

func (*FlowExecutionStatus_Task) GetId 

func (m *FlowExecutionStatus_Task) GetId() int32

func (*FlowExecutionStatus_Task) GetStepId 

func (m *FlowExecutionStatus_Task) GetStepId() int32

func (*FlowExecutionStatus_Task) ProtoMessage 

func (*FlowExecutionStatus_Task) ProtoMessage()

func (*FlowExecutionStatus_Task) Reset 

func (m *FlowExecutionStatus_Task) Reset()

func (*FlowExecutionStatus_Task) String 

func (m *FlowExecutionStatus_Task) String() string

type FlowExecutionStatus_TaskGroup 

type FlowExecutionStatus_TaskGroup struct {
	StepIds    []int32                                    `protobuf:"varint,1,rep,packed,name=stepIds" json:"stepIds,omitempty"`
	TaskIds    []int32                                    `protobuf:"varint,2,rep,packed,name=taskIds" json:"taskIds,omitempty"`
	Request    *ExecutionRequest                          `protobuf:"bytes,3,opt,name=request" json:"request,omitempty"`
	Allocation *Allocation                                `protobuf:"bytes,4,opt,name=allocation" json:"allocation,omitempty"`
	Executions []*FlowExecutionStatus_TaskGroup_Execution `protobuf:"bytes,5,rep,name=executions" json:"executions,omitempty"`
}

func (*FlowExecutionStatus_TaskGroup) Descriptor 

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

func (*FlowExecutionStatus_TaskGroup) GetAllocation 

func (m *FlowExecutionStatus_TaskGroup) GetAllocation() *Allocation

func (*FlowExecutionStatus_TaskGroup) GetExecutions 

func (m *FlowExecutionStatus_TaskGroup) GetExecutions() []*FlowExecutionStatus_TaskGroup_Execution

func (*FlowExecutionStatus_TaskGroup) GetRequest 

func (m *FlowExecutionStatus_TaskGroup) GetRequest() *ExecutionRequest

func (*FlowExecutionStatus_TaskGroup) GetStepIds 

func (m *FlowExecutionStatus_TaskGroup) GetStepIds() []int32

func (*FlowExecutionStatus_TaskGroup) GetTaskIds 

func (m *FlowExecutionStatus_TaskGroup) GetTaskIds() []int32

func (*FlowExecutionStatus_TaskGroup) ProtoMessage 

func (*FlowExecutionStatus_TaskGroup) ProtoMessage()

func (*FlowExecutionStatus_TaskGroup) Reset 

func (m *FlowExecutionStatus_TaskGroup) Reset()

func (*FlowExecutionStatus_TaskGroup) String 

func (m *FlowExecutionStatus_TaskGroup) String() string

func (*FlowExecutionStatus_TaskGroup) Track 

func (taskGroupStatus *FlowExecutionStatus_TaskGroup) Track(
	execute func(*FlowExecutionStatus_TaskGroup_Execution) error) error

type FlowExecutionStatus_TaskGroup_Execution 

type FlowExecutionStatus_TaskGroup_Execution struct {
	StartTime     int64          `protobuf:"varint,1,opt,name=start_time,json=startTime" json:"start_time,omitempty"`
	StopTime      int64          `protobuf:"varint,2,opt,name=stop_time,json=stopTime" json:"stop_time,omitempty"`
	SystemTime    float64        `protobuf:"fixed64,3,opt,name=system_time,json=systemTime" json:"system_time,omitempty"`
	UserTime      float64        `protobuf:"fixed64,4,opt,name=user_time,json=userTime" json:"user_time,omitempty"`
	Error         []byte         `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	OutputHash    []byte         `protobuf:"bytes,6,opt,name=output_hash,json=outputHash,proto3" json:"output_hash,omitempty"`
	ExecutionStat *ExecutionStat `protobuf:"bytes,7,opt,name=executionStat" json:"executionStat,omitempty"`
}

func (*FlowExecutionStatus_TaskGroup_Execution) Descriptor 

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

func (*FlowExecutionStatus_TaskGroup_Execution) GetError 

func (m *FlowExecutionStatus_TaskGroup_Execution) GetError() []byte

func (*FlowExecutionStatus_TaskGroup_Execution) GetExecutionStat 

func (m *FlowExecutionStatus_TaskGroup_Execution) GetExecutionStat() *ExecutionStat

func (*FlowExecutionStatus_TaskGroup_Execution) GetOutputHash 

func (m *FlowExecutionStatus_TaskGroup_Execution) GetOutputHash() []byte

func (*FlowExecutionStatus_TaskGroup_Execution) GetStartTime 

func (m *FlowExecutionStatus_TaskGroup_Execution) GetStartTime() int64

func (*FlowExecutionStatus_TaskGroup_Execution) GetStopTime 

func (m *FlowExecutionStatus_TaskGroup_Execution) GetStopTime() int64

func (*FlowExecutionStatus_TaskGroup_Execution) GetSystemTime 

func (m *FlowExecutionStatus_TaskGroup_Execution) GetSystemTime() float64

func (*FlowExecutionStatus_TaskGroup_Execution) GetUserTime 

func (m *FlowExecutionStatus_TaskGroup_Execution) GetUserTime() float64

func (*FlowExecutionStatus_TaskGroup_Execution) ProtoMessage 

func (*FlowExecutionStatus_TaskGroup_Execution) ProtoMessage()

func (*FlowExecutionStatus_TaskGroup_Execution) Reset 

func (m *FlowExecutionStatus_TaskGroup_Execution) Reset()

func (*FlowExecutionStatus_TaskGroup_Execution) String 

func (m *FlowExecutionStatus_TaskGroup_Execution) String() string

type GleamoldAgentClient 

type GleamoldAgentClient interface {
	SendFileResource(ctx context.Context, opts ...grpc.CallOption) (GleamoldAgent_SendFileResourceClient, error)
	Execute(ctx context.Context, in *ExecutionRequest, opts ...grpc.CallOption) (GleamoldAgent_ExecuteClient, error)
	// collect execution stats from "gleamold execute" processes
	CollectExecutionStatistics(ctx context.Context, opts ...grpc.CallOption) (GleamoldAgent_CollectExecutionStatisticsClient, error)
	Delete(ctx context.Context, in *DeleteDatasetShardRequest, opts ...grpc.CallOption) (*DeleteDatasetShardResponse, error)
}

func NewGleamoldAgentClient 

func NewGleamoldAgentClient(cc *grpc.ClientConn) GleamoldAgentClient

type GleamoldAgentServer 

type GleamoldAgentServer interface {
	SendFileResource(GleamoldAgent_SendFileResourceServer) error
	Execute(*ExecutionRequest, GleamoldAgent_ExecuteServer) error
	// collect execution stats from "gleamold execute" processes
	CollectExecutionStatistics(GleamoldAgent_CollectExecutionStatisticsServer) error
	Delete(context.Context, *DeleteDatasetShardRequest) (*DeleteDatasetShardResponse, error)
}

type GleamoldAgent_CollectExecutionStatisticsClient 

type GleamoldAgent_CollectExecutionStatisticsClient interface {
	Send(*ExecutionStat) error
	CloseAndRecv() (*Empty, error)
	grpc.ClientStream
}

type GleamoldAgent_CollectExecutionStatisticsServer 

type GleamoldAgent_CollectExecutionStatisticsServer interface {
	SendAndClose(*Empty) error
	Recv() (*ExecutionStat, error)
	grpc.ServerStream
}

type GleamoldAgent_ExecuteClient 

type GleamoldAgent_ExecuteClient interface {
	Recv() (*ExecutionResponse, error)
	grpc.ClientStream
}

type GleamoldAgent_ExecuteServer 

type GleamoldAgent_ExecuteServer interface {
	Send(*ExecutionResponse) error
	grpc.ServerStream
}

type GleamoldAgent_SendFileResourceClient 

type GleamoldAgent_SendFileResourceClient interface {
	Send(*FileResourceRequest) error
	Recv() (*FileResourceResponse, error)
	grpc.ClientStream
}

type GleamoldAgent_SendFileResourceServer 

type GleamoldAgent_SendFileResourceServer interface {
	Send(*FileResourceResponse) error
	Recv() (*FileResourceRequest, error)
	grpc.ServerStream
}

type GleamoldMasterClient 

type GleamoldMasterClient interface {
	GetResources(ctx context.Context, in *ComputeRequest, opts ...grpc.CallOption) (*AllocationResult, error)
	SendHeartbeat(ctx context.Context, opts ...grpc.CallOption) (GleamoldMaster_SendHeartbeatClient, error)
	SendFlowExecutionStatus(ctx context.Context, opts ...grpc.CallOption) (GleamoldMaster_SendFlowExecutionStatusClient, error)
}

func NewGleamoldMasterClient 

func NewGleamoldMasterClient(cc *grpc.ClientConn) GleamoldMasterClient

type GleamoldMasterServer 

type GleamoldMasterServer interface {
	GetResources(context.Context, *ComputeRequest) (*AllocationResult, error)
	SendHeartbeat(GleamoldMaster_SendHeartbeatServer) error
	SendFlowExecutionStatus(GleamoldMaster_SendFlowExecutionStatusServer) error
}

type GleamoldMaster_SendFlowExecutionStatusClient 

type GleamoldMaster_SendFlowExecutionStatusClient interface {
	Send(*FlowExecutionStatus) error
	CloseAndRecv() (*Empty, error)
	grpc.ClientStream
}

type GleamoldMaster_SendFlowExecutionStatusServer 

type GleamoldMaster_SendFlowExecutionStatusServer interface {
	SendAndClose(*Empty) error
	Recv() (*FlowExecutionStatus, error)
	grpc.ServerStream
}

type GleamoldMaster_SendHeartbeatClient 

type GleamoldMaster_SendHeartbeatClient interface {
	Send(*Heartbeat) error
	CloseAndRecv() (*Empty, error)
	grpc.ClientStream
}

type GleamoldMaster_SendHeartbeatServer 

type GleamoldMaster_SendHeartbeatServer interface {
	SendAndClose(*Empty) error
	Recv() (*Heartbeat, error)
	grpc.ServerStream
}

type Heartbeat 

type Heartbeat struct {
	Location  *Location        `protobuf:"bytes,1,opt,name=location" json:"location,omitempty"`
	Resource  *ComputeResource `protobuf:"bytes,2,opt,name=resource" json:"resource,omitempty"`
	Allocated *ComputeResource `protobuf:"bytes,3,opt,name=allocated" json:"allocated,omitempty"`
}

////////////////////////////////////////////////

func (*Heartbeat) Descriptor 

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

func (*Heartbeat) GetAllocated 

func (m *Heartbeat) GetAllocated() *ComputeResource

func (*Heartbeat) GetLocation 

func (m *Heartbeat) GetLocation() *Location

func (*Heartbeat) GetResource 

func (m *Heartbeat) GetResource() *ComputeResource

func (*Heartbeat) ProtoMessage 

func (*Heartbeat) ProtoMessage()

func (*Heartbeat) Reset 

func (m *Heartbeat) Reset()

func (*Heartbeat) String 

func (m *Heartbeat) String() string

type Instruction 

type Instruction struct {
	StepId                   int32                                 `protobuf:"varint,1,opt,name=stepId" json:"stepId,omitempty"`
	TaskId                   int32                                 `protobuf:"varint,2,opt,name=taskId" json:"taskId,omitempty"`
	MemoryInMB               int32                                 `protobuf:"varint,3,opt,name=memoryInMB" json:"memoryInMB,omitempty"`
	Name                     string                                `protobuf:"bytes,4,opt,name=name" json:"name,omitempty"`
	InputShardLocations      []*DatasetShardLocation               `protobuf:"bytes,5,rep,name=inputShardLocations" json:"inputShardLocations,omitempty"`
	OutputShardLocations     []*DatasetShardLocation               `protobuf:"bytes,6,rep,name=OutputShardLocations,json=outputShardLocations" json:"OutputShardLocations,omitempty"`
	JoinPartitionedSorted    *Instruction_JoinPartitionedSorted    `protobuf:"bytes,7,opt,name=joinPartitionedSorted" json:"joinPartitionedSorted,omitempty"`
	CoGroupPartitionedSorted *Instruction_CoGroupPartitionedSorted `protobuf:"bytes,8,opt,name=coGroupPartitionedSorted" json:"coGroupPartitionedSorted,omitempty"`
	PipeAsArgs               *Instruction_PipeAsArgs               `protobuf:"bytes,9,opt,name=pipeAsArgs" json:"pipeAsArgs,omitempty"`
	ScatterPartitions        *Instruction_ScatterPartitions        `protobuf:"bytes,10,opt,name=scatterPartitions" json:"scatterPartitions,omitempty"`
	CollectPartitions        *Instruction_CollectPartitions        `protobuf:"bytes,11,opt,name=collectPartitions" json:"collectPartitions,omitempty"`
	InputSplitReader         *Instruction_InputSplitReader         `protobuf:"bytes,12,opt,name=inputSplitReader" json:"inputSplitReader,omitempty"`
	RoundRobin               *Instruction_RoundRobin               `protobuf:"bytes,13,opt,name=roundRobin" json:"roundRobin,omitempty"`
	LocalTop                 *Instruction_LocalTop                 `protobuf:"bytes,14,opt,name=localTop" json:"localTop,omitempty"`
	Broadcast                *Instruction_Broadcast                `protobuf:"bytes,15,opt,name=broadcast" json:"broadcast,omitempty"`
	LocalHashAndJoinWith     *Instruction_LocalHashAndJoinWith     `protobuf:"bytes,16,opt,name=localHashAndJoinWith" json:"localHashAndJoinWith,omitempty"`
	Script                   *Instruction_Script                   `protobuf:"bytes,17,opt,name=script" json:"script,omitempty"`
	LocalSort                *Instruction_LocalSort                `protobuf:"bytes,18,opt,name=localSort" json:"localSort,omitempty"`
	MergeSortedTo            *Instruction_MergeSortedTo            `protobuf:"bytes,19,opt,name=mergeSortedTo" json:"mergeSortedTo,omitempty"`
	MergeTo                  *Instruction_MergeTo                  `protobuf:"bytes,22,opt,name=mergeTo" json:"mergeTo,omitempty"`
	LocalDistinct            *Instruction_LocalDistinct            `protobuf:"bytes,21,opt,name=localDistinct" json:"localDistinct,omitempty"`
}

func (*Instruction) Descriptor 

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

func (*Instruction) GetBroadcast 

func (m *Instruction) GetBroadcast() *Instruction_Broadcast

func (*Instruction) GetCoGroupPartitionedSorted 

func (m *Instruction) GetCoGroupPartitionedSorted() *Instruction_CoGroupPartitionedSorted

func (*Instruction) GetCollectPartitions 

func (m *Instruction) GetCollectPartitions() *Instruction_CollectPartitions

func (*Instruction) GetInputShardLocations 

func (m *Instruction) GetInputShardLocations() []*DatasetShardLocation

func (*Instruction) GetInputSplitReader 

func (m *Instruction) GetInputSplitReader() *Instruction_InputSplitReader

func (*Instruction) GetJoinPartitionedSorted 

func (m *Instruction) GetJoinPartitionedSorted() *Instruction_JoinPartitionedSorted

func (*Instruction) GetLocalDistinct 

func (m *Instruction) GetLocalDistinct() *Instruction_LocalDistinct

func (*Instruction) GetLocalHashAndJoinWith 

func (m *Instruction) GetLocalHashAndJoinWith() *Instruction_LocalHashAndJoinWith

func (*Instruction) GetLocalSort 

func (m *Instruction) GetLocalSort() *Instruction_LocalSort

func (*Instruction) GetLocalTop 

func (m *Instruction) GetLocalTop() *Instruction_LocalTop

func (*Instruction) GetMemoryInMB 

func (m *Instruction) GetMemoryInMB() int32

func (*Instruction) GetMergeSortedTo 

func (m *Instruction) GetMergeSortedTo() *Instruction_MergeSortedTo

func (*Instruction) GetMergeTo 

func (m *Instruction) GetMergeTo() *Instruction_MergeTo

func (*Instruction) GetName 

func (m *Instruction) GetName() string

func (*Instruction) GetOutputShardLocations 

func (m *Instruction) GetOutputShardLocations() []*DatasetShardLocation

func (*Instruction) GetPipeAsArgs 

func (m *Instruction) GetPipeAsArgs() *Instruction_PipeAsArgs

func (*Instruction) GetRoundRobin 

func (m *Instruction) GetRoundRobin() *Instruction_RoundRobin

func (*Instruction) GetScatterPartitions 

func (m *Instruction) GetScatterPartitions() *Instruction_ScatterPartitions

func (*Instruction) GetScript 

func (m *Instruction) GetScript() *Instruction_Script

func (*Instruction) GetStepId 

func (m *Instruction) GetStepId() int32

func (*Instruction) GetTaskId 

func (m *Instruction) GetTaskId() int32

func (*Instruction) ProtoMessage 

func (*Instruction) ProtoMessage()

func (*Instruction) Reset 

func (m *Instruction) Reset()

func (*Instruction) SetInputLocations 

func (i *Instruction) SetInputLocations(locations []DataLocation)

func (*Instruction) SetOutputLocations 

func (i *Instruction) SetOutputLocations(locations []DataLocation)

func (*Instruction) String 

func (m *Instruction) String() string

type InstructionSet 

type InstructionSet struct {
	Instructions []*Instruction `protobuf:"bytes,1,rep,name=instructions" json:"instructions,omitempty"`
	ReaderCount  int32          `protobuf:"varint,2,opt,name=readerCount" json:"readerCount,omitempty"`
	FlowHashCode uint32         `protobuf:"varint,3,opt,name=flowHashCode" json:"flowHashCode,omitempty"`
	IsProfiling  bool           `protobuf:"varint,4,opt,name=isProfiling" json:"isProfiling,omitempty"`
	AgentAddress string         `protobuf:"bytes,5,opt,name=agentAddress" json:"agentAddress,omitempty"`
	Name         string         `protobuf:"bytes,6,opt,name=name" json:"name,omitempty"`
}

func (*InstructionSet) Descriptor 

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

func (*InstructionSet) GetAgentAddress 

func (m *InstructionSet) GetAgentAddress() string

func (*InstructionSet) GetFlowHashCode 

func (m *InstructionSet) GetFlowHashCode() uint32

func (*InstructionSet) GetInstructions 

func (m *InstructionSet) GetInstructions() []*Instruction

func (*InstructionSet) GetIsProfiling 

func (m *InstructionSet) GetIsProfiling() bool

func (*InstructionSet) GetName 

func (m *InstructionSet) GetName() string

func (*InstructionSet) GetReaderCount 

func (m *InstructionSet) GetReaderCount() int32

func (*InstructionSet) InstructionNames 

func (m *InstructionSet) InstructionNames() (stepNames []string)

func (*InstructionSet) ProtoMessage 

func (*InstructionSet) ProtoMessage()

func (*InstructionSet) Reset 

func (m *InstructionSet) Reset()

func (*InstructionSet) String 

func (m *InstructionSet) String() string

type InstructionStat 

type InstructionStat struct {
	StepId        int32 `protobuf:"varint,1,opt,name=stepId" json:"stepId,omitempty"`
	TaskId        int32 `protobuf:"varint,2,opt,name=taskId" json:"taskId,omitempty"`
	InputCounter  int64 `protobuf:"varint,3,opt,name=inputCounter" json:"inputCounter,omitempty"`
	OutputCounter int64 `protobuf:"varint,4,opt,name=outputCounter" json:"outputCounter,omitempty"`
}

func (*InstructionStat) Descriptor 

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

func (*InstructionStat) GetInputCounter 

func (m *InstructionStat) GetInputCounter() int64

func (*InstructionStat) GetOutputCounter 

func (m *InstructionStat) GetOutputCounter() int64

func (*InstructionStat) GetStepId 

func (m *InstructionStat) GetStepId() int32

func (*InstructionStat) GetTaskId 

func (m *InstructionStat) GetTaskId() int32

func (*InstructionStat) ProtoMessage 

func (*InstructionStat) ProtoMessage()

func (*InstructionStat) Reset 

func (m *InstructionStat) Reset()

func (*InstructionStat) String 

func (m *InstructionStat) String() string

type Instruction_Broadcast 

type Instruction_Broadcast struct {
}

func (*Instruction_Broadcast) Descriptor 

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

func (*Instruction_Broadcast) ProtoMessage 

func (*Instruction_Broadcast) ProtoMessage()

func (*Instruction_Broadcast) Reset 

func (m *Instruction_Broadcast) Reset()

func (*Instruction_Broadcast) String 

func (m *Instruction_Broadcast) String() string

type Instruction_CoGroupPartitionedSorted 

type Instruction_CoGroupPartitionedSorted struct {
	Indexes []int32 `protobuf:"varint,1,rep,packed,name=indexes" json:"indexes,omitempty"`
}

func (*Instruction_CoGroupPartitionedSorted) Descriptor 

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

func (*Instruction_CoGroupPartitionedSorted) GetIndexes 

func (m *Instruction_CoGroupPartitionedSorted) GetIndexes() []int32

func (*Instruction_CoGroupPartitionedSorted) ProtoMessage 

func (*Instruction_CoGroupPartitionedSorted) ProtoMessage()

func (*Instruction_CoGroupPartitionedSorted) Reset 

func (m *Instruction_CoGroupPartitionedSorted) Reset()

func (*Instruction_CoGroupPartitionedSorted) String 

func (m *Instruction_CoGroupPartitionedSorted) String() string

type Instruction_CollectPartitions 

type Instruction_CollectPartitions struct {
}

func (*Instruction_CollectPartitions) Descriptor 

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

func (*Instruction_CollectPartitions) ProtoMessage 

func (*Instruction_CollectPartitions) ProtoMessage()

func (*Instruction_CollectPartitions) Reset 

func (m *Instruction_CollectPartitions) Reset()

func (*Instruction_CollectPartitions) String 

func (m *Instruction_CollectPartitions) String() string

type Instruction_InputSplitReader 

type Instruction_InputSplitReader struct {
	InputType string `protobuf:"bytes,1,opt,name=inputType" json:"inputType,omitempty"`
}

func (*Instruction_InputSplitReader) Descriptor 

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

func (*Instruction_InputSplitReader) GetInputType 

func (m *Instruction_InputSplitReader) GetInputType() string

func (*Instruction_InputSplitReader) ProtoMessage 

func (*Instruction_InputSplitReader) ProtoMessage()

func (*Instruction_InputSplitReader) Reset 

func (m *Instruction_InputSplitReader) Reset()

func (*Instruction_InputSplitReader) String 

func (m *Instruction_InputSplitReader) String() string

type Instruction_JoinPartitionedSorted 

type Instruction_JoinPartitionedSorted struct {
	Indexes          []int32 `protobuf:"varint,1,rep,packed,name=indexes" json:"indexes,omitempty"`
	IsLeftOuterJoin  bool    `protobuf:"varint,2,opt,name=isLeftOuterJoin" json:"isLeftOuterJoin,omitempty"`
	IsRightOuterJoin bool    `protobuf:"varint,3,opt,name=isRightOuterJoin" json:"isRightOuterJoin,omitempty"`
}

func (*Instruction_JoinPartitionedSorted) Descriptor 

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

func (*Instruction_JoinPartitionedSorted) GetIndexes 

func (m *Instruction_JoinPartitionedSorted) GetIndexes() []int32

func (*Instruction_JoinPartitionedSorted) GetIsLeftOuterJoin 

func (m *Instruction_JoinPartitionedSorted) GetIsLeftOuterJoin() bool

func (*Instruction_JoinPartitionedSorted) GetIsRightOuterJoin 

func (m *Instruction_JoinPartitionedSorted) GetIsRightOuterJoin() bool

func (*Instruction_JoinPartitionedSorted) ProtoMessage 

func (*Instruction_JoinPartitionedSorted) ProtoMessage()

func (*Instruction_JoinPartitionedSorted) Reset 

func (m *Instruction_JoinPartitionedSorted) Reset()

func (*Instruction_JoinPartitionedSorted) String 

func (m *Instruction_JoinPartitionedSorted) String() string

type Instruction_LocalDistinct 

type Instruction_LocalDistinct struct {
	OrderBys []*OrderBy `protobuf:"bytes,1,rep,name=orderBys" json:"orderBys,omitempty"`
}

func (*Instruction_LocalDistinct) Descriptor 

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

func (*Instruction_LocalDistinct) GetOrderBys 

func (m *Instruction_LocalDistinct) GetOrderBys() []*OrderBy

func (*Instruction_LocalDistinct) ProtoMessage 

func (*Instruction_LocalDistinct) ProtoMessage()

func (*Instruction_LocalDistinct) Reset 

func (m *Instruction_LocalDistinct) Reset()

func (*Instruction_LocalDistinct) String 

func (m *Instruction_LocalDistinct) String() string

type Instruction_LocalHashAndJoinWith 

type Instruction_LocalHashAndJoinWith struct {
	Indexes []int32 `protobuf:"varint,1,rep,packed,name=indexes" json:"indexes,omitempty"`
}

func (*Instruction_LocalHashAndJoinWith) Descriptor 

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

func (*Instruction_LocalHashAndJoinWith) GetIndexes 

func (m *Instruction_LocalHashAndJoinWith) GetIndexes() []int32

func (*Instruction_LocalHashAndJoinWith) ProtoMessage 

func (*Instruction_LocalHashAndJoinWith) ProtoMessage()

func (*Instruction_LocalHashAndJoinWith) Reset 

func (m *Instruction_LocalHashAndJoinWith) Reset()

func (*Instruction_LocalHashAndJoinWith) String 

func (m *Instruction_LocalHashAndJoinWith) String() string

type Instruction_LocalSort 

type Instruction_LocalSort struct {
	OrderBys []*OrderBy `protobuf:"bytes,1,rep,name=orderBys" json:"orderBys,omitempty"`
}

func (*Instruction_LocalSort) Descriptor 

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

func (*Instruction_LocalSort) GetOrderBys 

func (m *Instruction_LocalSort) GetOrderBys() []*OrderBy

func (*Instruction_LocalSort) ProtoMessage 

func (*Instruction_LocalSort) ProtoMessage()

func (*Instruction_LocalSort) Reset 

func (m *Instruction_LocalSort) Reset()

func (*Instruction_LocalSort) String 

func (m *Instruction_LocalSort) String() string

type Instruction_LocalTop 

type Instruction_LocalTop struct {
	N        int32      `protobuf:"varint,1,opt,name=n" json:"n,omitempty"`
	OrderBys []*OrderBy `protobuf:"bytes,2,rep,name=orderBys" json:"orderBys,omitempty"`
}

func (*Instruction_LocalTop) Descriptor 

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

func (*Instruction_LocalTop) GetN 

func (m *Instruction_LocalTop) GetN() int32

func (*Instruction_LocalTop) GetOrderBys 

func (m *Instruction_LocalTop) GetOrderBys() []*OrderBy

func (*Instruction_LocalTop) ProtoMessage 

func (*Instruction_LocalTop) ProtoMessage()

func (*Instruction_LocalTop) Reset 

func (m *Instruction_LocalTop) Reset()

func (*Instruction_LocalTop) String 

func (m *Instruction_LocalTop) String() string

type Instruction_MergeSortedTo 

type Instruction_MergeSortedTo struct {
	OrderBys []*OrderBy `protobuf:"bytes,1,rep,name=orderBys" json:"orderBys,omitempty"`
}

func (*Instruction_MergeSortedTo) Descriptor 

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

func (*Instruction_MergeSortedTo) GetOrderBys 

func (m *Instruction_MergeSortedTo) GetOrderBys() []*OrderBy

func (*Instruction_MergeSortedTo) ProtoMessage 

func (*Instruction_MergeSortedTo) ProtoMessage()

func (*Instruction_MergeSortedTo) Reset 

func (m *Instruction_MergeSortedTo) Reset()

func (*Instruction_MergeSortedTo) String 

func (m *Instruction_MergeSortedTo) String() string

type Instruction_MergeTo 

type Instruction_MergeTo struct {
}

func (*Instruction_MergeTo) Descriptor 

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

func (*Instruction_MergeTo) ProtoMessage 

func (*Instruction_MergeTo) ProtoMessage()

func (*Instruction_MergeTo) Reset 

func (m *Instruction_MergeTo) Reset()

func (*Instruction_MergeTo) String 

func (m *Instruction_MergeTo) String() string

type Instruction_PipeAsArgs 

type Instruction_PipeAsArgs struct {
	Code string `protobuf:"bytes,1,opt,name=code" json:"code,omitempty"`
}

func (*Instruction_PipeAsArgs) Descriptor 

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

func (*Instruction_PipeAsArgs) GetCode 

func (m *Instruction_PipeAsArgs) GetCode() string

func (*Instruction_PipeAsArgs) ProtoMessage 

func (*Instruction_PipeAsArgs) ProtoMessage()

func (*Instruction_PipeAsArgs) Reset 

func (m *Instruction_PipeAsArgs) Reset()

func (*Instruction_PipeAsArgs) String 

func (m *Instruction_PipeAsArgs) String() string

type Instruction_RoundRobin 

type Instruction_RoundRobin struct {
}

func (*Instruction_RoundRobin) Descriptor 

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

func (*Instruction_RoundRobin) ProtoMessage 

func (*Instruction_RoundRobin) ProtoMessage()

func (*Instruction_RoundRobin) Reset 

func (m *Instruction_RoundRobin) Reset()

func (*Instruction_RoundRobin) String 

func (m *Instruction_RoundRobin) String() string

type Instruction_ScatterPartitions 

type Instruction_ScatterPartitions struct {
	Indexes []int32 `protobuf:"varint,1,rep,packed,name=indexes" json:"indexes,omitempty"`
}

func (*Instruction_ScatterPartitions) Descriptor 

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

func (*Instruction_ScatterPartitions) GetIndexes 

func (m *Instruction_ScatterPartitions) GetIndexes() []int32

func (*Instruction_ScatterPartitions) ProtoMessage 

func (*Instruction_ScatterPartitions) ProtoMessage()

func (*Instruction_ScatterPartitions) Reset 

func (m *Instruction_ScatterPartitions) Reset()

func (*Instruction_ScatterPartitions) String 

func (m *Instruction_ScatterPartitions) String() string

type Instruction_Script 

type Instruction_Script struct {
	IsPipe bool     `protobuf:"varint,1,opt,name=isPipe" json:"isPipe,omitempty"`
	Path   string   `protobuf:"bytes,2,opt,name=path" json:"path,omitempty"`
	Args   []string `protobuf:"bytes,3,rep,name=args" json:"args,omitempty"`
	Env    []string `protobuf:"bytes,4,rep,name=env" json:"env,omitempty"`
}

func (*Instruction_Script) Descriptor 

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

func (*Instruction_Script) GetArgs 

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

func (*Instruction_Script) GetEnv 

func (m *Instruction_Script) GetEnv() []string

func (*Instruction_Script) GetIsPipe 

func (m *Instruction_Script) GetIsPipe() bool

func (*Instruction_Script) GetPath 

func (m *Instruction_Script) GetPath() string

func (*Instruction_Script) ProtoMessage 

func (*Instruction_Script) ProtoMessage()

func (*Instruction_Script) Reset 

func (m *Instruction_Script) Reset()

func (*Instruction_Script) String 

func (m *Instruction_Script) String() string

type Location 

type Location struct {
	DataCenter string `protobuf:"bytes,1,opt,name=data_center,json=dataCenter" json:"data_center,omitempty"`
	Rack       string `protobuf:"bytes,2,opt,name=rack" json:"rack,omitempty"`
	Server     string `protobuf:"bytes,3,opt,name=server" json:"server,omitempty"`
	Port       int32  `protobuf:"varint,4,opt,name=port" json:"port,omitempty"`
}

func (*Location) Descriptor 

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

func (*Location) Distance 

func (a *Location) Distance(b *Location) float64

the distance is a relative value, similar to network lantency

func (*Location) GetDataCenter 

func (m *Location) GetDataCenter() string

func (*Location) GetPort 

func (m *Location) GetPort() int32

func (*Location) GetRack 

func (m *Location) GetRack() string

func (*Location) GetServer 

func (m *Location) GetServer() string

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) Reset 

func (m *Location) Reset()

func (*Location) String 

func (m *Location) String() string

func (*Location) URL 

func (l *Location) URL() string

type OrderBy 

type OrderBy struct {
	Index int32 `protobuf:"varint,1,opt,name=index" json:"index,omitempty"`
	Order int32 `protobuf:"varint,2,opt,name=order" json:"order,omitempty"`
}

func (*OrderBy) Descriptor 

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

func (*OrderBy) GetIndex 

func (m *OrderBy) GetIndex() int32

func (*OrderBy) GetOrder 

func (m *OrderBy) GetOrder() int32

func (*OrderBy) ProtoMessage 

func (*OrderBy) ProtoMessage()

func (*OrderBy) Reset 

func (m *OrderBy) Reset()

func (*OrderBy) String 

func (m *OrderBy) String() string

type ReadRequest 

type ReadRequest struct {
	ChannelName string `protobuf:"bytes,1,opt,name=channelName" json:"channelName,omitempty"`
	ReaderName  string `protobuf:"bytes,2,opt,name=readerName" json:"readerName,omitempty"`
}

func (*ReadRequest) Descriptor 

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

func (*ReadRequest) GetChannelName 

func (m *ReadRequest) GetChannelName() string

func (*ReadRequest) GetReaderName 

func (m *ReadRequest) GetReaderName() string

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset 

func (m *ReadRequest) Reset()

func (*ReadRequest) String 

func (m *ReadRequest) String() string

type WriteRequest 

type WriteRequest struct {
	ChannelName string `protobuf:"bytes,1,opt,name=channelName" json:"channelName,omitempty"`
	WriterName  string `protobuf:"bytes,2,opt,name=writerName" json:"writerName,omitempty"`
	ReaderCount int32  `protobuf:"varint,3,opt,name=readerCount" json:"readerCount,omitempty"`
}

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) GetChannelName 

func (m *WriteRequest) GetChannelName() string

func (*WriteRequest) GetReaderCount 

func (m *WriteRequest) GetReaderCount() int32

func (*WriteRequest) GetWriterName 

func (m *WriteRequest) GetWriterName() string

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) String 

func (m *WriteRequest) String() string

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.