rpc

package
v0.0.0-...-79c606f Latest Latest
Warning

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

 Go to latest Published: Jun 11, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ClusterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpc.ClusterService",
	HandlerType: (*ClusterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterWorker",
			Handler:    _ClusterService_RegisterWorker_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "s_cluster.proto",
}

ClusterService_ServiceDesc is the grpc.ServiceDesc for ClusterService 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 ExecutionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpc.ExecutionService",
	HandlerType: (*ExecutionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RunStage",
			Handler:    _ExecutionService_RunStage_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "s_execution.proto",
}

ExecutionService_ServiceDesc is the grpc.ServiceDesc for ExecutionService 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_s_cluster_proto protoreflect.FileDescriptor
View Source 
var File_s_execution_proto protoreflect.FileDescriptor
View Source 
var File_s_lifecycle_proto protoreflect.FileDescriptor
View Source 
var File_s_log_proto protoreflect.FileDescriptor
View Source 
var File_s_partition_proto protoreflect.FileDescriptor
View Source 
var LifecycleService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpc.LifecycleService",
	HandlerType: (*LifecycleServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GracefulStop",
			Handler:    _LifecycleService_GracefulStop_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _LifecycleService_Stop_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "s_lifecycle.proto",
}

LifecycleService_ServiceDesc is the grpc.ServiceDesc for LifecycleService 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 LogService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpc.LogService",
	HandlerType: (*LogServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Log",
			Handler:       _LogService_Log_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "s_log.proto",
}

LogService_ServiceDesc is the grpc.ServiceDesc for LogService 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 PartitionsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpc.PartitionsService",
	HandlerType: (*PartitionsServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AssignPartition",
			Handler:    _PartitionsService_AssignPartition_Handler,
		},
		{
			MethodName: "ShufflePartition",
			Handler:    _PartitionsService_ShufflePartition_Handler,
		},
		{
			MethodName: "ShuffleAccumulator",
			Handler:    _PartitionsService_ShuffleAccumulator_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "TransferPartitionData",
			Handler:       _PartitionsService_TransferPartitionData_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "TransferAccumulatorData",
			Handler:       _PartitionsService_TransferAccumulatorData_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "s_partition.proto",
}

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

Functions

func RegisterClusterServiceServer 

func RegisterClusterServiceServer(s grpc.ServiceRegistrar, srv ClusterServiceServer)

func RegisterExecutionServiceServer 

func RegisterExecutionServiceServer(s grpc.ServiceRegistrar, srv ExecutionServiceServer)

func RegisterLifecycleServiceServer 

func RegisterLifecycleServiceServer(s grpc.ServiceRegistrar, srv LifecycleServiceServer)

func RegisterLogServiceServer 

func RegisterLogServiceServer(s grpc.ServiceRegistrar, srv LogServiceServer)

func RegisterPartitionsServiceServer 

func RegisterPartitionsServiceServer(s grpc.ServiceRegistrar, srv PartitionsServiceServer)

Types

type ClusterServiceClient 

type ClusterServiceClient interface {
	RegisterWorker(ctx context.Context, in *MRegisterRequest, opts ...grpc.CallOption) (*MRegisterResponse, error)
}

ClusterServiceClient is the client API for ClusterService 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 NewClusterServiceClient 

func NewClusterServiceClient(cc grpc.ClientConnInterface) ClusterServiceClient

type ClusterServiceServer 

type ClusterServiceServer interface {
	RegisterWorker(context.Context, *MRegisterRequest) (*MRegisterResponse, error)
	// contains filtered or unexported methods
}

ClusterServiceServer is the server API for ClusterService service. All implementations must embed UnimplementedClusterServiceServer for forward compatibility

type ExecutionServiceClient 

type ExecutionServiceClient interface {
	RunStage(ctx context.Context, in *MRunStageRequest, opts ...grpc.CallOption) (*MRunStageResponse, error)
}

ExecutionServiceClient is the client API for ExecutionService 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 NewExecutionServiceClient 

func NewExecutionServiceClient(cc grpc.ClientConnInterface) ExecutionServiceClient

type ExecutionServiceServer 

type ExecutionServiceServer interface {
	RunStage(context.Context, *MRunStageRequest) (*MRunStageResponse, error)
	// contains filtered or unexported methods
}

ExecutionServiceServer is the server API for ExecutionService service. All implementations must embed UnimplementedExecutionServiceServer for forward compatibility

type LifecycleServiceClient 

type LifecycleServiceClient interface {
	GracefulStop(ctx context.Context, in *MWorkerDescriptor, opts ...grpc.CallOption) (*MStopResponse, error)
	Stop(ctx context.Context, in *MWorkerDescriptor, opts ...grpc.CallOption) (*MStopResponse, error)
}

LifecycleServiceClient is the client API for LifecycleService 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 NewLifecycleServiceClient 

func NewLifecycleServiceClient(cc grpc.ClientConnInterface) LifecycleServiceClient

type LifecycleServiceServer 

type LifecycleServiceServer interface {
	GracefulStop(context.Context, *MWorkerDescriptor) (*MStopResponse, error)
	Stop(context.Context, *MWorkerDescriptor) (*MStopResponse, error)
	// contains filtered or unexported methods
}

LifecycleServiceServer is the server API for LifecycleService service. All implementations must embed UnimplementedLifecycleServiceServer for forward compatibility

type LogServiceClient 

type LogServiceClient interface {
	Log(ctx context.Context, opts ...grpc.CallOption) (LogService_LogClient, error)
}

LogServiceClient is the client API for LogService 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 NewLogServiceClient 

func NewLogServiceClient(cc grpc.ClientConnInterface) LogServiceClient

type LogServiceServer 

type LogServiceServer interface {
	Log(LogService_LogServer) error
	// contains filtered or unexported methods
}

LogServiceServer is the server API for LogService service. All implementations must embed UnimplementedLogServiceServer for forward compatibility

type LogService_LogClient 

type LogService_LogClient interface {
	Send(*MLogMsg) error
	CloseAndRecv() (*MLogMsgAck, error)
	grpc.ClientStream
}

type LogService_LogServer 

type LogService_LogServer interface {
	SendAndClose(*MLogMsgAck) error
	Recv() (*MLogMsg, error)
	grpc.ServerStream
}

type MAccumulatorChunk 

type MAccumulatorChunk struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*MAccumulatorChunk) Descriptor deprecated 

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

Deprecated: Use MAccumulatorChunk.ProtoReflect.Descriptor instead.

func (*MAccumulatorChunk) GetData 

func (x *MAccumulatorChunk) GetData() []byte

func (*MAccumulatorChunk) ProtoMessage 

func (*MAccumulatorChunk) ProtoMessage()

func (*MAccumulatorChunk) ProtoReflect 

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

func (*MAccumulatorChunk) Reset 

func (x *MAccumulatorChunk) Reset()

func (*MAccumulatorChunk) String 

func (x *MAccumulatorChunk) String() string

type MAssignPartitionRequest 

type MAssignPartitionRequest struct {
	Loader []byte `protobuf:"bytes,1,opt,name=loader,proto3" json:"loader,omitempty"`
	// contains filtered or unexported fields
}

func (*MAssignPartitionRequest) Descriptor deprecated 

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

Deprecated: Use MAssignPartitionRequest.ProtoReflect.Descriptor instead.

func (*MAssignPartitionRequest) GetLoader 

func (x *MAssignPartitionRequest) GetLoader() []byte

func (*MAssignPartitionRequest) ProtoMessage 

func (*MAssignPartitionRequest) ProtoMessage()

func (*MAssignPartitionRequest) ProtoReflect 

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

func (*MAssignPartitionRequest) Reset 

func (x *MAssignPartitionRequest) Reset()

func (*MAssignPartitionRequest) String 

func (x *MAssignPartitionRequest) String() string

type MAssignPartitionResponse 

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

func (*MAssignPartitionResponse) Descriptor deprecated 

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

Deprecated: Use MAssignPartitionResponse.ProtoReflect.Descriptor instead.

func (*MAssignPartitionResponse) ProtoMessage 

func (*MAssignPartitionResponse) ProtoMessage()

func (*MAssignPartitionResponse) ProtoReflect 

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

func (*MAssignPartitionResponse) Reset 

func (x *MAssignPartitionResponse) Reset()

func (*MAssignPartitionResponse) String 

func (x *MAssignPartitionResponse) String() string

type MLogMsg 

type MLogMsg struct {
	Level   int32  `protobuf:"varint,1,opt,name=level,proto3" json:"level,omitempty"`
	Source  string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*MLogMsg) Descriptor deprecated 

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

Deprecated: Use MLogMsg.ProtoReflect.Descriptor instead.

func (*MLogMsg) GetLevel 

func (x *MLogMsg) GetLevel() int32

func (*MLogMsg) GetMessage 

func (x *MLogMsg) GetMessage() string

func (*MLogMsg) GetSource 

func (x *MLogMsg) GetSource() string

func (*MLogMsg) ProtoMessage 

func (*MLogMsg) ProtoMessage()

func (*MLogMsg) ProtoReflect 

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

func (*MLogMsg) Reset 

func (x *MLogMsg) Reset()

func (*MLogMsg) String 

func (x *MLogMsg) String() string

type MLogMsgAck 

type MLogMsgAck struct {
	Time  int64 `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	Count int32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*MLogMsgAck) Descriptor deprecated 

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

Deprecated: Use MLogMsgAck.ProtoReflect.Descriptor instead.

func (*MLogMsgAck) GetCount 

func (x *MLogMsgAck) GetCount() int32

func (*MLogMsgAck) GetTime 

func (x *MLogMsgAck) GetTime() int64

func (*MLogMsgAck) ProtoMessage 

func (*MLogMsgAck) ProtoMessage()

func (*MLogMsgAck) ProtoReflect 

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

func (*MLogMsgAck) Reset 

func (x *MLogMsgAck) Reset()

func (*MLogMsgAck) String 

func (x *MLogMsgAck) String() string

type MPartitionChunk 

type MPartitionChunk struct {
	Data     []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	DataType int32  `protobuf:"varint,2,opt,name=dataType,proto3" json:"dataType,omitempty"`
	// contains filtered or unexported fields
}

func (*MPartitionChunk) Descriptor deprecated 

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

Deprecated: Use MPartitionChunk.ProtoReflect.Descriptor instead.

func (*MPartitionChunk) GetData 

func (x *MPartitionChunk) GetData() []byte

func (*MPartitionChunk) GetDataType 

func (x *MPartitionChunk) GetDataType() int32

func (*MPartitionChunk) ProtoMessage 

func (*MPartitionChunk) ProtoMessage()

func (*MPartitionChunk) ProtoReflect 

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

func (*MPartitionChunk) Reset 

func (x *MPartitionChunk) Reset()

func (*MPartitionChunk) String 

func (x *MPartitionChunk) String() string

type MPartitionMeta 

type MPartitionMeta struct {
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Bytes uint32 `protobuf:"varint,2,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*MPartitionMeta) Descriptor deprecated 

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

Deprecated: Use MPartitionMeta.ProtoReflect.Descriptor instead.

func (*MPartitionMeta) GetBytes 

func (x *MPartitionMeta) GetBytes() uint32

func (*MPartitionMeta) GetId 

func (x *MPartitionMeta) GetId() string

func (*MPartitionMeta) ProtoMessage 

func (*MPartitionMeta) ProtoMessage()

func (*MPartitionMeta) ProtoReflect 

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

func (*MPartitionMeta) Reset 

func (x *MPartitionMeta) Reset()

func (*MPartitionMeta) String 

func (x *MPartitionMeta) String() string

type MRegisterRequest 

type MRegisterRequest struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Port int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*MRegisterRequest) Descriptor deprecated 

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

Deprecated: Use MRegisterRequest.ProtoReflect.Descriptor instead.

func (*MRegisterRequest) GetId 

func (x *MRegisterRequest) GetId() string

func (*MRegisterRequest) GetPort 

func (x *MRegisterRequest) GetPort() int32

func (*MRegisterRequest) ProtoMessage 

func (*MRegisterRequest) ProtoMessage()

func (*MRegisterRequest) ProtoReflect 

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

func (*MRegisterRequest) Reset 

func (x *MRegisterRequest) Reset()

func (*MRegisterRequest) String 

func (x *MRegisterRequest) String() string

type MRegisterResponse 

type MRegisterResponse struct {
	Time int64 `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*MRegisterResponse) Descriptor deprecated 

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

Deprecated: Use MRegisterResponse.ProtoReflect.Descriptor instead.

func (*MRegisterResponse) GetTime 

func (x *MRegisterResponse) GetTime() int64

func (*MRegisterResponse) ProtoMessage 

func (*MRegisterResponse) ProtoMessage()

func (*MRegisterResponse) ProtoReflect 

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

func (*MRegisterResponse) Reset 

func (x *MRegisterResponse) Reset()

func (*MRegisterResponse) String 

func (x *MRegisterResponse) String() string

type MRunStageRequest 

type MRunStageRequest struct {
	StageId        int32                `protobuf:"varint,1,opt,name=stageId,proto3" json:"stageId,omitempty"`
	RunShuffle     bool                 `protobuf:"varint,2,opt,name=runShuffle,proto3" json:"runShuffle,omitempty"`
	PrepCollect    int32                `protobuf:"varint,3,opt,name=prepCollect,proto3" json:"prepCollect,omitempty"`
	PrepAccumulate bool                 `protobuf:"varint,4,opt,name=prepAccumulate,proto3" json:"prepAccumulate,omitempty"`
	AssignedBucket uint64               `protobuf:"varint,5,opt,name=assignedBucket,proto3" json:"assignedBucket,omitempty"`
	Buckets        []uint64             `protobuf:"varint,6,rep,packed,name=buckets,proto3" json:"buckets,omitempty"`
	Workers        []*MWorkerDescriptor `protobuf:"bytes,7,rep,name=workers,proto3" json:"workers,omitempty"`
	// contains filtered or unexported fields
}

func (*MRunStageRequest) Descriptor deprecated 

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

Deprecated: Use MRunStageRequest.ProtoReflect.Descriptor instead.

func (*MRunStageRequest) GetAssignedBucket 

func (x *MRunStageRequest) GetAssignedBucket() uint64

func (*MRunStageRequest) GetBuckets 

func (x *MRunStageRequest) GetBuckets() []uint64

func (*MRunStageRequest) GetPrepAccumulate 

func (x *MRunStageRequest) GetPrepAccumulate() bool

func (*MRunStageRequest) GetPrepCollect 

func (x *MRunStageRequest) GetPrepCollect() int32

func (*MRunStageRequest) GetRunShuffle 

func (x *MRunStageRequest) GetRunShuffle() bool

func (*MRunStageRequest) GetStageId 

func (x *MRunStageRequest) GetStageId() int32

func (*MRunStageRequest) GetWorkers 

func (x *MRunStageRequest) GetWorkers() []*MWorkerDescriptor

func (*MRunStageRequest) ProtoMessage 

func (*MRunStageRequest) ProtoMessage()

func (*MRunStageRequest) ProtoReflect 

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

func (*MRunStageRequest) Reset 

func (x *MRunStageRequest) Reset()

func (*MRunStageRequest) String 

func (x *MRunStageRequest) String() string

type MRunStageResponse 

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

func (*MRunStageResponse) Descriptor deprecated 

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

Deprecated: Use MRunStageResponse.ProtoReflect.Descriptor instead.

func (*MRunStageResponse) ProtoMessage 

func (*MRunStageResponse) ProtoMessage()

func (*MRunStageResponse) ProtoReflect 

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

func (*MRunStageResponse) Reset 

func (x *MRunStageResponse) Reset()

func (*MRunStageResponse) String 

func (x *MRunStageResponse) String() string

type MShuffleAccumulatorRequest 

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

func (*MShuffleAccumulatorRequest) Descriptor deprecated 

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

Deprecated: Use MShuffleAccumulatorRequest.ProtoReflect.Descriptor instead.

func (*MShuffleAccumulatorRequest) ProtoMessage 

func (*MShuffleAccumulatorRequest) ProtoMessage()

func (*MShuffleAccumulatorRequest) ProtoReflect 

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

func (*MShuffleAccumulatorRequest) Reset 

func (x *MShuffleAccumulatorRequest) Reset()

func (*MShuffleAccumulatorRequest) String 

func (x *MShuffleAccumulatorRequest) String() string

type MShuffleAccumulatorResponse 

type MShuffleAccumulatorResponse struct {
	Ready          bool  `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	TotalSizeBytes int32 `protobuf:"varint,2,opt,name=totalSizeBytes,proto3" json:"totalSizeBytes,omitempty"`
	// contains filtered or unexported fields
}

func (*MShuffleAccumulatorResponse) Descriptor deprecated 

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

Deprecated: Use MShuffleAccumulatorResponse.ProtoReflect.Descriptor instead.

func (*MShuffleAccumulatorResponse) GetReady 

func (x *MShuffleAccumulatorResponse) GetReady() bool

func (*MShuffleAccumulatorResponse) GetTotalSizeBytes 

func (x *MShuffleAccumulatorResponse) GetTotalSizeBytes() int32

func (*MShuffleAccumulatorResponse) ProtoMessage 

func (*MShuffleAccumulatorResponse) ProtoMessage()

func (*MShuffleAccumulatorResponse) ProtoReflect 

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

func (*MShuffleAccumulatorResponse) Reset 

func (x *MShuffleAccumulatorResponse) Reset()

func (*MShuffleAccumulatorResponse) String 

func (x *MShuffleAccumulatorResponse) String() string

type MShufflePartitionRequest 

type MShufflePartitionRequest struct {
	Bucket uint64 `protobuf:"varint,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// contains filtered or unexported fields
}

func (*MShufflePartitionRequest) Descriptor deprecated 

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

Deprecated: Use MShufflePartitionRequest.ProtoReflect.Descriptor instead.

func (*MShufflePartitionRequest) GetBucket 

func (x *MShufflePartitionRequest) GetBucket() uint64

func (*MShufflePartitionRequest) ProtoMessage 

func (*MShufflePartitionRequest) ProtoMessage()

func (*MShufflePartitionRequest) ProtoReflect 

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

func (*MShufflePartitionRequest) Reset 

func (x *MShufflePartitionRequest) Reset()

func (*MShufflePartitionRequest) String 

func (x *MShufflePartitionRequest) String() string

type MShufflePartitionResponse 

type MShufflePartitionResponse struct {
	Ready   bool            `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	HasNext bool            `protobuf:"varint,2,opt,name=hasNext,proto3" json:"hasNext,omitempty"`
	Part    *MPartitionMeta `protobuf:"bytes,3,opt,name=part,proto3" json:"part,omitempty"`
	// contains filtered or unexported fields
}

func (*MShufflePartitionResponse) Descriptor deprecated 

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

Deprecated: Use MShufflePartitionResponse.ProtoReflect.Descriptor instead.

func (*MShufflePartitionResponse) GetHasNext 

func (x *MShufflePartitionResponse) GetHasNext() bool

func (*MShufflePartitionResponse) GetPart 

func (x *MShufflePartitionResponse) GetPart() *MPartitionMeta

func (*MShufflePartitionResponse) GetReady 

func (x *MShufflePartitionResponse) GetReady() bool

func (*MShufflePartitionResponse) ProtoMessage 

func (*MShufflePartitionResponse) ProtoMessage()

func (*MShufflePartitionResponse) ProtoReflect 

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

func (*MShufflePartitionResponse) Reset 

func (x *MShufflePartitionResponse) Reset()

func (*MShufflePartitionResponse) String 

func (x *MShufflePartitionResponse) String() string

type MStopResponse 

type MStopResponse struct {
	Time int64 `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*MStopResponse) Descriptor deprecated 

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

Deprecated: Use MStopResponse.ProtoReflect.Descriptor instead.

func (*MStopResponse) GetTime 

func (x *MStopResponse) GetTime() int64

func (*MStopResponse) ProtoMessage 

func (*MStopResponse) ProtoMessage()

func (*MStopResponse) ProtoReflect 

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

func (*MStopResponse) Reset 

func (x *MStopResponse) Reset()

func (*MStopResponse) String 

func (x *MStopResponse) String() string

type MTransferAccumulatorDataRequest 

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

func (*MTransferAccumulatorDataRequest) Descriptor deprecated 

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

Deprecated: Use MTransferAccumulatorDataRequest.ProtoReflect.Descriptor instead.

func (*MTransferAccumulatorDataRequest) ProtoMessage 

func (*MTransferAccumulatorDataRequest) ProtoMessage()

func (*MTransferAccumulatorDataRequest) ProtoReflect 

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

func (*MTransferAccumulatorDataRequest) Reset 

func (x *MTransferAccumulatorDataRequest) Reset()

func (*MTransferAccumulatorDataRequest) String 

func (x *MTransferAccumulatorDataRequest) String() string

type MTransferPartitionDataRequest 

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

func (*MTransferPartitionDataRequest) Descriptor deprecated 

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

Deprecated: Use MTransferPartitionDataRequest.ProtoReflect.Descriptor instead.

func (*MTransferPartitionDataRequest) GetId 

func (x *MTransferPartitionDataRequest) GetId() string

func (*MTransferPartitionDataRequest) ProtoMessage 

func (*MTransferPartitionDataRequest) ProtoMessage()

func (*MTransferPartitionDataRequest) ProtoReflect 

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

func (*MTransferPartitionDataRequest) Reset 

func (x *MTransferPartitionDataRequest) Reset()

func (*MTransferPartitionDataRequest) String 

func (x *MTransferPartitionDataRequest) String() string

type MWorkerDescriptor 

type MWorkerDescriptor struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Port int32  `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

For the moment, this is identical to MRegisterRequest, but may diverge in the future.

func (*MWorkerDescriptor) Descriptor deprecated 

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

Deprecated: Use MWorkerDescriptor.ProtoReflect.Descriptor instead.

func (*MWorkerDescriptor) GetHost 

func (x *MWorkerDescriptor) GetHost() string

func (*MWorkerDescriptor) GetId 

func (x *MWorkerDescriptor) GetId() string

func (*MWorkerDescriptor) GetPort 

func (x *MWorkerDescriptor) GetPort() int32

func (*MWorkerDescriptor) ProtoMessage 

func (*MWorkerDescriptor) ProtoMessage()

func (*MWorkerDescriptor) ProtoReflect 

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

func (*MWorkerDescriptor) Reset 

func (x *MWorkerDescriptor) Reset()

func (*MWorkerDescriptor) String 

func (x *MWorkerDescriptor) String() string

type PartitionsServiceClient 

type PartitionsServiceClient interface {
	AssignPartition(ctx context.Context, in *MAssignPartitionRequest, opts ...grpc.CallOption) (*MAssignPartitionResponse, error)
	ShufflePartition(ctx context.Context, in *MShufflePartitionRequest, opts ...grpc.CallOption) (*MShufflePartitionResponse, error)
	ShuffleAccumulator(ctx context.Context, in *MShuffleAccumulatorRequest, opts ...grpc.CallOption) (*MShuffleAccumulatorResponse, error)
	TransferPartitionData(ctx context.Context, in *MTransferPartitionDataRequest, opts ...grpc.CallOption) (PartitionsService_TransferPartitionDataClient, error)
	TransferAccumulatorData(ctx context.Context, in *MTransferAccumulatorDataRequest, opts ...grpc.CallOption) (PartitionsService_TransferAccumulatorDataClient, error)
}

PartitionsServiceClient is the client API for PartitionsService 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 NewPartitionsServiceClient 

func NewPartitionsServiceClient(cc grpc.ClientConnInterface) PartitionsServiceClient

type PartitionsServiceServer 

type PartitionsServiceServer interface {
	AssignPartition(context.Context, *MAssignPartitionRequest) (*MAssignPartitionResponse, error)
	ShufflePartition(context.Context, *MShufflePartitionRequest) (*MShufflePartitionResponse, error)
	ShuffleAccumulator(context.Context, *MShuffleAccumulatorRequest) (*MShuffleAccumulatorResponse, error)
	TransferPartitionData(*MTransferPartitionDataRequest, PartitionsService_TransferPartitionDataServer) error
	TransferAccumulatorData(*MTransferAccumulatorDataRequest, PartitionsService_TransferAccumulatorDataServer) error
	// contains filtered or unexported methods
}

PartitionsServiceServer is the server API for PartitionsService service. All implementations must embed UnimplementedPartitionsServiceServer for forward compatibility

type PartitionsService_TransferAccumulatorDataClient 

type PartitionsService_TransferAccumulatorDataClient interface {
	Recv() (*MAccumulatorChunk, error)
	grpc.ClientStream
}

type PartitionsService_TransferAccumulatorDataServer 

type PartitionsService_TransferAccumulatorDataServer interface {
	Send(*MAccumulatorChunk) error
	grpc.ServerStream
}

type PartitionsService_TransferPartitionDataClient 

type PartitionsService_TransferPartitionDataClient interface {
	Recv() (*MPartitionChunk, error)
	grpc.ClientStream
}

type PartitionsService_TransferPartitionDataServer 

type PartitionsService_TransferPartitionDataServer interface {
	Send(*MPartitionChunk) error
	grpc.ServerStream
}

type UnimplementedClusterServiceServer 

type UnimplementedClusterServiceServer struct {
}

UnimplementedClusterServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedClusterServiceServer) RegisterWorker 

func (UnimplementedClusterServiceServer) RegisterWorker(context.Context, *MRegisterRequest) (*MRegisterResponse, error)

type UnimplementedExecutionServiceServer 

type UnimplementedExecutionServiceServer struct {
}

UnimplementedExecutionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedExecutionServiceServer) RunStage 

func (UnimplementedExecutionServiceServer) RunStage(context.Context, *MRunStageRequest) (*MRunStageResponse, error)

type UnimplementedLifecycleServiceServer 

type UnimplementedLifecycleServiceServer struct {
}

UnimplementedLifecycleServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedLifecycleServiceServer) GracefulStop 

func (UnimplementedLifecycleServiceServer) GracefulStop(context.Context, *MWorkerDescriptor) (*MStopResponse, error)

func (UnimplementedLifecycleServiceServer) Stop 

func (UnimplementedLifecycleServiceServer) Stop(context.Context, *MWorkerDescriptor) (*MStopResponse, error)

type UnimplementedLogServiceServer 

type UnimplementedLogServiceServer struct {
}

UnimplementedLogServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedLogServiceServer) Log 

func (UnimplementedLogServiceServer) Log(LogService_LogServer) error

type UnimplementedPartitionsServiceServer 

type UnimplementedPartitionsServiceServer struct {
}

UnimplementedPartitionsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPartitionsServiceServer) AssignPartition 

func (UnimplementedPartitionsServiceServer) AssignPartition(context.Context, *MAssignPartitionRequest) (*MAssignPartitionResponse, error)

func (UnimplementedPartitionsServiceServer) ShuffleAccumulator 

func (UnimplementedPartitionsServiceServer) ShuffleAccumulator(context.Context, *MShuffleAccumulatorRequest) (*MShuffleAccumulatorResponse, error)

func (UnimplementedPartitionsServiceServer) ShufflePartition 

func (UnimplementedPartitionsServiceServer) ShufflePartition(context.Context, *MShufflePartitionRequest) (*MShufflePartitionResponse, error)

func (UnimplementedPartitionsServiceServer) TransferAccumulatorData 

func (UnimplementedPartitionsServiceServer) TransferAccumulatorData(*MTransferAccumulatorDataRequest, PartitionsService_TransferAccumulatorDataServer) error

func (UnimplementedPartitionsServiceServer) TransferPartitionData 

func (UnimplementedPartitionsServiceServer) TransferPartitionData(*MTransferPartitionDataRequest, PartitionsService_TransferPartitionDataServer) error

type UnsafeClusterServiceServer 

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

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

type UnsafeExecutionServiceServer 

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

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

type UnsafeLifecycleServiceServer 

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

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

type UnsafeLogServiceServer 

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

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

type UnsafePartitionsServiceServer 

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

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

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.