pb

package
v0.0.0-...-f305919 Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TaskType_name = map[int32]string{
		0: "SORT",
		1: "SAMPLE",
		2: "SHUFFLE_SEND",
		3: "SHUFFLE_RECV",
		4: "FLUSH",
		5: "UPLOAD",
		6: "ABORT",
	}
	TaskType_value = map[string]int32{
		"SORT":         0,
		"SAMPLE":       1,
		"SHUFFLE_SEND": 2,
		"SHUFFLE_RECV": 3,
		"FLUSH":        4,
		"UPLOAD":       5,
		"ABORT":        6,
	}
)

Enum value maps for TaskType.

View Source 
var (
	TaskState_name = map[int32]string{
		0: "UNKNOWN",
		1: "ACCEPTED",
		2: "IN_PROGRESS",
		3: "FAILED",
		4: "DONE",
	}
	TaskState_value = map[string]int32{
		"UNKNOWN":     0,
		"ACCEPTED":    1,
		"IN_PROGRESS": 2,
		"FAILED":      3,
		"DONE":        4,
	}
)

Enum value maps for TaskState.

View Source 
var Control_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cloudsort.v1.Control",
	HandlerType: (*ControlServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Heartbeat",
			Handler:    _Control_Heartbeat_Handler,
		},
		{
			MethodName: "PullTask",
			Handler:    _Control_PullTask_Handler,
		},
		{
			MethodName: "ReportTask",
			Handler:    _Control_ReportTask_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubmitJob",
			Handler:       _Control_SubmitJob_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "service.proto",
}

Control_ServiceDesc is the grpc.ServiceDesc for Control service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_data_proto protoreflect.FileDescriptor
View Source 
var File_service_proto protoreflect.FileDescriptor

Functions

func RegisterControlServer 

func RegisterControlServer(s grpc.ServiceRegistrar, srv ControlServer)

Types

type ControlClient 

type ControlClient interface {
	// Client-facing API
	SubmitJob(ctx context.Context, in *SubmitJobRequest, opts ...grpc.CallOption) (Control_SubmitJobClient, error)
	// Worker-facing API
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
	PullTask(ctx context.Context, in *PullTaskRequest, opts ...grpc.CallOption) (*PullTaskResponse, error)
	ReportTask(ctx context.Context, in *ReportTaskRequest, opts ...grpc.CallOption) (*ReportTaskResponse, error)
}

ControlClient is the client API for Control service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewControlClient 

func NewControlClient(cc grpc.ClientConnInterface) ControlClient

type ControlServer 

type ControlServer interface {
	// Client-facing API
	SubmitJob(*SubmitJobRequest, Control_SubmitJobServer) error
	// Worker-facing API
	Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
	PullTask(context.Context, *PullTaskRequest) (*PullTaskResponse, error)
	ReportTask(context.Context, *ReportTaskRequest) (*ReportTaskResponse, error)
	// contains filtered or unexported methods
}

ControlServer is the server API for Control service. All implementations must embed UnimplementedControlServer for forward compatibility

type Control_SubmitJobClient 

type Control_SubmitJobClient interface {
	Recv() (*SubmitJobResponse, error)
	grpc.ClientStream
}

type Control_SubmitJobServer 

type Control_SubmitJobServer interface {
	Send(*SubmitJobResponse) error
	grpc.ServerStream
}

type Event 

type Event struct {
	Message   string               `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Progress  float32              `protobuf:"fixed32,2,opt,name=progress,proto3" json:"progress,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetMessage 

func (x *Event) GetMessage() string

func (*Event) GetProgress 

func (x *Event) GetProgress() float32

func (*Event) GetTimestamp 

func (x *Event) GetTimestamp() *timestamp.Timestamp

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type HeartbeatRequest 

type HeartbeatRequest struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatRequest) Descriptor deprecated 

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

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetAddress 

func (x *HeartbeatRequest) GetAddress() string

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoReflect 

func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message

func (*HeartbeatRequest) Reset 

func (x *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (x *HeartbeatRequest) String() string

type HeartbeatResponse 

type HeartbeatResponse struct {
	TaskAvailable bool `protobuf:"varint,1,opt,name=task_available,json=taskAvailable,proto3" json:"task_available,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) GetTaskAvailable 

func (x *HeartbeatResponse) GetTaskAvailable() bool

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) ProtoReflect 

func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message

func (*HeartbeatResponse) Reset 

func (x *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String 

func (x *HeartbeatResponse) String() string

type Peer 

type Peer struct {
	Address       string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	KeyRangeStart []byte `protobuf:"bytes,2,opt,name=keyRangeStart,proto3" json:"keyRangeStart,omitempty"`
	KeyRangeEnd   []byte `protobuf:"bytes,3,opt,name=keyRangeEnd,proto3" json:"keyRangeEnd,omitempty"`
	// contains filtered or unexported fields
}

func (*Peer) Descriptor deprecated 

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

Deprecated: Use Peer.ProtoReflect.Descriptor instead.

func (*Peer) GetAddress 

func (x *Peer) GetAddress() string

func (*Peer) GetKeyRangeEnd 

func (x *Peer) GetKeyRangeEnd() []byte

func (*Peer) GetKeyRangeStart 

func (x *Peer) GetKeyRangeStart() []byte

func (*Peer) ProtoMessage 

func (*Peer) ProtoMessage()

func (*Peer) ProtoReflect 

func (x *Peer) ProtoReflect() protoreflect.Message

func (*Peer) Reset 

func (x *Peer) Reset()

func (*Peer) String 

func (x *Peer) String() string

type PullTaskRequest 

type PullTaskRequest struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*PullTaskRequest) Descriptor deprecated 

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

Deprecated: Use PullTaskRequest.ProtoReflect.Descriptor instead.

func (*PullTaskRequest) GetAddress 

func (x *PullTaskRequest) GetAddress() string

func (*PullTaskRequest) ProtoMessage 

func (*PullTaskRequest) ProtoMessage()

func (*PullTaskRequest) ProtoReflect 

func (x *PullTaskRequest) ProtoReflect() protoreflect.Message

func (*PullTaskRequest) Reset 

func (x *PullTaskRequest) Reset()

func (*PullTaskRequest) String 

func (x *PullTaskRequest) String() string

type PullTaskResponse 

type PullTaskResponse struct {
	Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*PullTaskResponse) Descriptor deprecated 

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

Deprecated: Use PullTaskResponse.ProtoReflect.Descriptor instead.

func (*PullTaskResponse) GetTask 

func (x *PullTaskResponse) GetTask() *Task

func (*PullTaskResponse) ProtoMessage 

func (*PullTaskResponse) ProtoMessage()

func (*PullTaskResponse) ProtoReflect 

func (x *PullTaskResponse) ProtoReflect() protoreflect.Message

func (*PullTaskResponse) Reset 

func (x *PullTaskResponse) Reset()

func (*PullTaskResponse) String 

func (x *PullTaskResponse) String() string

type ReportTaskRequest 

type ReportTaskRequest struct {
	Name  string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	State TaskState `protobuf:"varint,2,opt,name=state,proto3,enum=cloudsort.v1.TaskState" json:"state,omitempty"`
	Data  *TaskData `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportTaskRequest) Descriptor deprecated 

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

Deprecated: Use ReportTaskRequest.ProtoReflect.Descriptor instead.

func (*ReportTaskRequest) GetData 

func (x *ReportTaskRequest) GetData() *TaskData

func (*ReportTaskRequest) GetName 

func (x *ReportTaskRequest) GetName() string

func (*ReportTaskRequest) GetState 

func (x *ReportTaskRequest) GetState() TaskState

func (*ReportTaskRequest) ProtoMessage 

func (*ReportTaskRequest) ProtoMessage()

func (*ReportTaskRequest) ProtoReflect 

func (x *ReportTaskRequest) ProtoReflect() protoreflect.Message

func (*ReportTaskRequest) Reset 

func (x *ReportTaskRequest) Reset()

func (*ReportTaskRequest) String 

func (x *ReportTaskRequest) String() string

type ReportTaskResponse 

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

func (*ReportTaskResponse) Descriptor deprecated 

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

Deprecated: Use ReportTaskResponse.ProtoReflect.Descriptor instead.

func (*ReportTaskResponse) ProtoMessage 

func (*ReportTaskResponse) ProtoMessage()

func (*ReportTaskResponse) ProtoReflect 

func (x *ReportTaskResponse) ProtoReflect() protoreflect.Message

func (*ReportTaskResponse) Reset 

func (x *ReportTaskResponse) Reset()

func (*ReportTaskResponse) String 

func (x *ReportTaskResponse) String() string

type S3Credentials 

type S3Credentials struct {
	Endpoints       []string `protobuf:"bytes,1,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	Region          string   `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	AccessKeyId     string   `protobuf:"bytes,3,opt,name=access_key_id,json=accessKeyId,proto3" json:"access_key_id,omitempty"`
	SecretAccessKey string   `protobuf:"bytes,4,opt,name=secret_access_key,json=secretAccessKey,proto3" json:"secret_access_key,omitempty"`
	BucketId        string   `protobuf:"bytes,5,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	ObjectKey       string   `protobuf:"bytes,6,opt,name=object_key,json=objectKey,proto3" json:"object_key,omitempty"`
	DisableSsl      bool     `protobuf:"varint,7,opt,name=disable_ssl,json=disableSsl,proto3" json:"disable_ssl,omitempty"`
	// contains filtered or unexported fields
}

func (*S3Credentials) Descriptor deprecated 

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

Deprecated: Use S3Credentials.ProtoReflect.Descriptor instead.

func (*S3Credentials) GetAccessKeyId 

func (x *S3Credentials) GetAccessKeyId() string

func (*S3Credentials) GetBucketId 

func (x *S3Credentials) GetBucketId() string

func (*S3Credentials) GetDisableSsl 

func (x *S3Credentials) GetDisableSsl() bool

func (*S3Credentials) GetEndpoints 

func (x *S3Credentials) GetEndpoints() []string

func (*S3Credentials) GetObjectKey 

func (x *S3Credentials) GetObjectKey() string

func (*S3Credentials) GetRegion 

func (x *S3Credentials) GetRegion() string

func (*S3Credentials) GetSecretAccessKey 

func (x *S3Credentials) GetSecretAccessKey() string

func (*S3Credentials) ProtoMessage 

func (*S3Credentials) ProtoMessage()

func (*S3Credentials) ProtoReflect 

func (x *S3Credentials) ProtoReflect() protoreflect.Message

func (*S3Credentials) Reset 

func (x *S3Credentials) Reset()

func (*S3Credentials) String 

func (x *S3Credentials) String() string

type SampleTask 

type SampleTask struct {
	NumberOfPeers int64 `protobuf:"varint,1,opt,name=number_of_peers,json=numberOfPeers,proto3" json:"number_of_peers,omitempty"`
	// contains filtered or unexported fields
}

func (*SampleTask) Descriptor deprecated 

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

Deprecated: Use SampleTask.ProtoReflect.Descriptor instead.

func (*SampleTask) GetNumberOfPeers 

func (x *SampleTask) GetNumberOfPeers() int64

func (*SampleTask) ProtoMessage 

func (*SampleTask) ProtoMessage()

func (*SampleTask) ProtoReflect 

func (x *SampleTask) ProtoReflect() protoreflect.Message

func (*SampleTask) Reset 

func (x *SampleTask) Reset()

func (*SampleTask) String 

func (x *SampleTask) String() string

type ShuffleRecvTask 

type ShuffleRecvTask struct {
	NumberOfPeers int64 `protobuf:"varint,1,opt,name=number_of_peers,json=numberOfPeers,proto3" json:"number_of_peers,omitempty"`
	// contains filtered or unexported fields
}

func (*ShuffleRecvTask) Descriptor deprecated 

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

Deprecated: Use ShuffleRecvTask.ProtoReflect.Descriptor instead.

func (*ShuffleRecvTask) GetNumberOfPeers 

func (x *ShuffleRecvTask) GetNumberOfPeers() int64

func (*ShuffleRecvTask) ProtoMessage 

func (*ShuffleRecvTask) ProtoMessage()

func (*ShuffleRecvTask) ProtoReflect 

func (x *ShuffleRecvTask) ProtoReflect() protoreflect.Message

func (*ShuffleRecvTask) Reset 

func (x *ShuffleRecvTask) Reset()

func (*ShuffleRecvTask) String 

func (x *ShuffleRecvTask) String() string

type ShuffleSendTask 

type ShuffleSendTask struct {
	Peers []*Peer `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"`
	// contains filtered or unexported fields
}

func (*ShuffleSendTask) Descriptor deprecated 

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

Deprecated: Use ShuffleSendTask.ProtoReflect.Descriptor instead.

func (*ShuffleSendTask) GetPeers 

func (x *ShuffleSendTask) GetPeers() []*Peer

func (*ShuffleSendTask) ProtoMessage 

func (*ShuffleSendTask) ProtoMessage()

func (*ShuffleSendTask) ProtoReflect 

func (x *ShuffleSendTask) ProtoReflect() protoreflect.Message

func (*ShuffleSendTask) Reset 

func (x *ShuffleSendTask) Reset()

func (*ShuffleSendTask) String 

func (x *ShuffleSendTask) String() string

type SortTask 

type SortTask struct {
	Credentials *S3Credentials `protobuf:"bytes,1,opt,name=credentials,proto3" json:"credentials,omitempty"`
	RangeStart  int64          `protobuf:"varint,2,opt,name=range_start,json=rangeStart,proto3" json:"range_start,omitempty"`
	RangeEnd    int64          `protobuf:"varint,3,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"`
	// contains filtered or unexported fields
}

func (*SortTask) Descriptor deprecated 

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

Deprecated: Use SortTask.ProtoReflect.Descriptor instead.

func (*SortTask) GetCredentials 

func (x *SortTask) GetCredentials() *S3Credentials

func (*SortTask) GetRangeEnd 

func (x *SortTask) GetRangeEnd() int64

func (*SortTask) GetRangeStart 

func (x *SortTask) GetRangeStart() int64

func (*SortTask) ProtoMessage 

func (*SortTask) ProtoMessage()

func (*SortTask) ProtoReflect 

func (x *SortTask) ProtoReflect() protoreflect.Message

func (*SortTask) Reset 

func (x *SortTask) Reset()

func (*SortTask) String 

func (x *SortTask) String() string

type SubmitJobRequest 

type SubmitJobRequest struct {
	Name  string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Creds *S3Credentials `protobuf:"bytes,2,opt,name=creds,proto3" json:"creds,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitJobRequest) Descriptor deprecated 

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

Deprecated: Use SubmitJobRequest.ProtoReflect.Descriptor instead.

func (*SubmitJobRequest) GetCreds 

func (x *SubmitJobRequest) GetCreds() *S3Credentials

func (*SubmitJobRequest) GetName 

func (x *SubmitJobRequest) GetName() string

func (*SubmitJobRequest) ProtoMessage 

func (*SubmitJobRequest) ProtoMessage()

func (*SubmitJobRequest) ProtoReflect 

func (x *SubmitJobRequest) ProtoReflect() protoreflect.Message

func (*SubmitJobRequest) Reset 

func (x *SubmitJobRequest) Reset()

func (*SubmitJobRequest) String 

func (x *SubmitJobRequest) String() string

type SubmitJobResponse 

type SubmitJobResponse struct {
	Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitJobResponse) Descriptor deprecated 

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

Deprecated: Use SubmitJobResponse.ProtoReflect.Descriptor instead.

func (*SubmitJobResponse) GetEvent 

func (x *SubmitJobResponse) GetEvent() *Event

func (*SubmitJobResponse) ProtoMessage 

func (*SubmitJobResponse) ProtoMessage()

func (*SubmitJobResponse) ProtoReflect 

func (x *SubmitJobResponse) ProtoReflect() protoreflect.Message

func (*SubmitJobResponse) Reset 

func (x *SubmitJobResponse) Reset()

func (*SubmitJobResponse) String 

func (x *SubmitJobResponse) String() string

type Task 

type Task struct {
	Name string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Job  string   `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	Type TaskType `protobuf:"varint,3,opt,name=type,proto3,enum=cloudsort.v1.TaskType" json:"type,omitempty"`
	// Types that are assignable to Details:
	//	*Task_Sort
	//	*Task_Sample
	//	*Task_ShuffleSend
	//	*Task_ShuffleRecv
	//	*Task_Upload
	Details isTask_Details `protobuf_oneof:"details"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetDetails 

func (m *Task) GetDetails() isTask_Details

func (*Task) GetJob 

func (x *Task) GetJob() string

func (*Task) GetName 

func (x *Task) GetName() string

func (*Task) GetSample 

func (x *Task) GetSample() *SampleTask

func (*Task) GetShuffleRecv 

func (x *Task) GetShuffleRecv() *ShuffleRecvTask

func (*Task) GetShuffleSend 

func (x *Task) GetShuffleSend() *ShuffleSendTask

func (*Task) GetSort 

func (x *Task) GetSort() *SortTask

func (*Task) GetType 

func (x *Task) GetType() TaskType

func (*Task) GetUpload 

func (x *Task) GetUpload() *UploadTask

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

func (x *Task) ProtoReflect() protoreflect.Message

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskData 

type TaskData struct {

	// Types that are assignable to Properties:
	//	*TaskData_ShuffleRecvAddr
	Properties isTaskData_Properties `protobuf_oneof:"properties"`
	// contains filtered or unexported fields
}

func (*TaskData) Descriptor deprecated 

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

Deprecated: Use TaskData.ProtoReflect.Descriptor instead.

func (*TaskData) GetProperties 

func (m *TaskData) GetProperties() isTaskData_Properties

func (*TaskData) GetShuffleRecvAddr 

func (x *TaskData) GetShuffleRecvAddr() string

func (*TaskData) ProtoMessage 

func (*TaskData) ProtoMessage()

func (*TaskData) ProtoReflect 

func (x *TaskData) ProtoReflect() protoreflect.Message

func (*TaskData) Reset 

func (x *TaskData) Reset()

func (*TaskData) String 

func (x *TaskData) String() string

type TaskData_ShuffleRecvAddr 

type TaskData_ShuffleRecvAddr struct {
	ShuffleRecvAddr string `protobuf:"bytes,3,opt,name=shuffleRecvAddr,proto3,oneof"`
}

type TaskState 

type TaskState int32
const (
	TaskState_UNKNOWN     TaskState = 0
	TaskState_ACCEPTED    TaskState = 1
	TaskState_IN_PROGRESS TaskState = 2
	TaskState_FAILED      TaskState = 3
	TaskState_DONE        TaskState = 4
)

func (TaskState) Descriptor 

func (TaskState) Descriptor() protoreflect.EnumDescriptor

func (TaskState) Enum 

func (x TaskState) Enum() *TaskState

func (TaskState) EnumDescriptor deprecated 

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

Deprecated: Use TaskState.Descriptor instead.

func (TaskState) Number 

func (x TaskState) Number() protoreflect.EnumNumber

func (TaskState) String 

func (x TaskState) String() string

func (TaskState) Type 

func (TaskState) Type() protoreflect.EnumType

type TaskType 

type TaskType int32
const (
	// SORT is the first stage in a job. During sort,
	// the worker fetch data from S3 and sort it.
	TaskType_SORT TaskType = 0
	// SAMPLE is the second stage. Each worker computes a local histogram
	// using sampled data from its minibatch.
	TaskType_SAMPLE TaskType = 1
	// SHUFFLE_SEND is the third stage in a job. Each worker sends a part of its sorted data
	// to the respective peers.
	TaskType_SHUFFLE_SEND TaskType = 2
	// SHUFFLE_RECV is the fourth stage in a job. Each worker receives sorted data from its peers and
	// combines them into a single file.
	TaskType_SHUFFLE_RECV TaskType = 3
	// FLUSH is the fifth stage and marks the end of the combined SHUFFLE/MERGE stage.
	TaskType_FLUSH TaskType = 4
	// UPLOAD is the final stage. During upload, the merge result is pushed to S3.
	// After UPLOAD, all resources attached to this job are freed.
	TaskType_UPLOAD TaskType = 5
	// ABORT signals abortion of the current job. After ABORT, all resources attached to this job are freed.
	TaskType_ABORT TaskType = 6
)

func (TaskType) Descriptor 

func (TaskType) Descriptor() protoreflect.EnumDescriptor

func (TaskType) Enum 

func (x TaskType) Enum() *TaskType

func (TaskType) EnumDescriptor deprecated 

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

Deprecated: Use TaskType.Descriptor instead.

func (TaskType) Number 

func (x TaskType) Number() protoreflect.EnumNumber

func (TaskType) String 

func (x TaskType) String() string

func (TaskType) Type 

func (TaskType) Type() protoreflect.EnumType

type Task_Sample 

type Task_Sample struct {
	Sample *SampleTask `protobuf:"bytes,5,opt,name=sample,proto3,oneof"`
}

type Task_ShuffleRecv 

type Task_ShuffleRecv struct {
	ShuffleRecv *ShuffleRecvTask `protobuf:"bytes,7,opt,name=shuffle_recv,json=shuffleRecv,proto3,oneof"`
}

type Task_ShuffleSend 

type Task_ShuffleSend struct {
	ShuffleSend *ShuffleSendTask `protobuf:"bytes,6,opt,name=shuffle_send,json=shuffleSend,proto3,oneof"`
}

type Task_Sort 

type Task_Sort struct {
	Sort *SortTask `protobuf:"bytes,4,opt,name=sort,proto3,oneof"`
}

type Task_Upload 

type Task_Upload struct {
	Upload *UploadTask `protobuf:"bytes,8,opt,name=upload,proto3,oneof"`
}

type UnimplementedControlServer 

type UnimplementedControlServer struct {
}

UnimplementedControlServer must be embedded to have forward compatible implementations.

func (UnimplementedControlServer) Heartbeat 

func (UnimplementedControlServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)

func (UnimplementedControlServer) PullTask 

func (UnimplementedControlServer) PullTask(context.Context, *PullTaskRequest) (*PullTaskResponse, error)

func (UnimplementedControlServer) ReportTask 

func (UnimplementedControlServer) ReportTask(context.Context, *ReportTaskRequest) (*ReportTaskResponse, error)

func (UnimplementedControlServer) SubmitJob 

func (UnimplementedControlServer) SubmitJob(*SubmitJobRequest, Control_SubmitJobServer) error

type UnsafeControlServer 

type UnsafeControlServer interface {
	// contains filtered or unexported methods
}

UnsafeControlServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControlServer will result in compilation errors.

type UploadTask 

type UploadTask struct {
	Credentials *S3Credentials `protobuf:"bytes,1,opt,name=credentials,proto3" json:"credentials,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadTask) Descriptor deprecated 

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

Deprecated: Use UploadTask.ProtoReflect.Descriptor instead.

func (*UploadTask) GetCredentials 

func (x *UploadTask) GetCredentials() *S3Credentials

func (*UploadTask) ProtoMessage 

func (*UploadTask) ProtoMessage()

func (*UploadTask) ProtoReflect 

func (x *UploadTask) ProtoReflect() protoreflect.Message

func (*UploadTask) Reset 

func (x *UploadTask) Reset()

func (*UploadTask) String 

func (x *UploadTask) 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.