manage_to_computation_container

package module
v0.0.0-...-a47a548 Latest Latest
Warning

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

 Go to latest Published: Oct 12, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_manage_to_computation_proto protoreflect.FileDescriptor
View Source 
var ManageToComputation_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "managetocomputation.ManageToComputation",
	HandlerType: (*ManageToComputationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ExecuteComputation",
			Handler:    _ManageToComputation_ExecuteComputation_Handler,
		},
		{
			MethodName: "CheckProgress",
			Handler:    _ManageToComputation_CheckProgress_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "manage_to_computation.proto",
}

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

Functions

func RegisterManageToComputationServer 

func RegisterManageToComputationServer(s grpc.ServiceRegistrar, srv ManageToComputationServer)

Types

type CheckProgressRequest 

type CheckProgressRequest struct {
	JobUuid string `protobuf:"bytes,1,opt,name=job_uuid,json=jobUuid,proto3" json:"job_uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckProgressRequest) Descriptor deprecated 

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

Deprecated: Use CheckProgressRequest.ProtoReflect.Descriptor instead.

func (*CheckProgressRequest) GetJobUuid 

func (x *CheckProgressRequest) GetJobUuid() string

func (*CheckProgressRequest) ProtoMessage 

func (*CheckProgressRequest) ProtoMessage()

func (*CheckProgressRequest) ProtoReflect 

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

func (*CheckProgressRequest) Reset 

func (x *CheckProgressRequest) Reset()

func (*CheckProgressRequest) String 

func (x *CheckProgressRequest) String() string

type CheckStateResponse 

type CheckStateResponse struct {
	State int32 `protobuf:"varint,1,opt,name=state,proto3" json:"state,omitempty"` // the state of computation container(1:working)
	// contains filtered or unexported fields
}

* the message of CheckStateResponse

func (*CheckStateResponse) Descriptor deprecated 

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

Deprecated: Use CheckStateResponse.ProtoReflect.Descriptor instead.

func (*CheckStateResponse) GetState 

func (x *CheckStateResponse) GetState() int32

func (*CheckStateResponse) ProtoMessage 

func (*CheckStateResponse) ProtoMessage()

func (*CheckStateResponse) ProtoReflect 

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

func (*CheckStateResponse) Reset 

func (x *CheckStateResponse) Reset()

func (*CheckStateResponse) String 

func (x *CheckStateResponse) String() string

type ExecuteComputationRequest 

type ExecuteComputationRequest struct {
	MethodId common_types.ComputationMethod `protobuf:"varint,1,opt,name=method_id,json=methodId,proto3,enum=pb_common_types.ComputationMethod" json:"method_id,omitempty"` // the methodID of this request
	JobUuid  string                         `protobuf:"bytes,2,opt,name=job_uuid,json=jobUuid,proto3" json:"job_uuid,omitempty"`                                            // the jobUUID of this request
	Table    *JoinOrder                     `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	Arg      *Input                         `protobuf:"bytes,4,opt,name=arg,proto3" json:"arg,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteComputationRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteComputationRequest.ProtoReflect.Descriptor instead.

func (*ExecuteComputationRequest) GetArg 

func (x *ExecuteComputationRequest) GetArg() *Input

func (*ExecuteComputationRequest) GetJobUuid 

func (x *ExecuteComputationRequest) GetJobUuid() string

func (*ExecuteComputationRequest) GetMethodId 

func (x *ExecuteComputationRequest) GetMethodId() common_types.ComputationMethod

func (*ExecuteComputationRequest) GetTable 

func (x *ExecuteComputationRequest) GetTable() *JoinOrder

func (*ExecuteComputationRequest) ProtoMessage 

func (*ExecuteComputationRequest) ProtoMessage()

func (*ExecuteComputationRequest) ProtoReflect 

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

func (*ExecuteComputationRequest) Reset 

func (x *ExecuteComputationRequest) Reset()

func (*ExecuteComputationRequest) String 

func (x *ExecuteComputationRequest) String() string

type Input 

type Input struct {
	Src    []int32 `protobuf:"varint,1,rep,packed,name=src,proto3" json:"src,omitempty"`
	Target []int32 `protobuf:"varint,2,rep,packed,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

func (*Input) Descriptor deprecated 

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

Deprecated: Use Input.ProtoReflect.Descriptor instead.

func (*Input) GetSrc 

func (x *Input) GetSrc() []int32

func (*Input) GetTarget 

func (x *Input) GetTarget() []int32

func (*Input) ProtoMessage 

func (*Input) ProtoMessage()

func (*Input) ProtoReflect 

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

func (*Input) Reset 

func (x *Input) Reset()

func (*Input) String 

func (x *Input) String() string

type JoinOrder 

type JoinOrder struct {
	DataIds   []string `protobuf:"bytes,1,rep,name=data_ids,json=dataIds,proto3" json:"data_ids,omitempty"`
	DebugMode bool     `protobuf:"varint,2,opt,name=debug_mode,json=debugMode,proto3" json:"debug_mode,omitempty"`
	// contains filtered or unexported fields
}

* the message of ExecuteComputationRequest

func (*JoinOrder) Descriptor deprecated 

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

Deprecated: Use JoinOrder.ProtoReflect.Descriptor instead.

func (*JoinOrder) GetDataIds 

func (x *JoinOrder) GetDataIds() []string

func (*JoinOrder) GetDebugMode 

func (x *JoinOrder) GetDebugMode() bool

func (*JoinOrder) ProtoMessage 

func (*JoinOrder) ProtoMessage()

func (*JoinOrder) ProtoReflect 

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

func (*JoinOrder) Reset 

func (x *JoinOrder) Reset()

func (*JoinOrder) String 

func (x *JoinOrder) String() string

type ManageToComputationClient 

type ManageToComputationClient interface {
	// receive executing computation request from manage container
	ExecuteComputation(ctx context.Context, in *ExecuteComputationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// receive progress check request from manage container
	CheckProgress(ctx context.Context, in *CheckProgressRequest, opts ...grpc.CallOption) (*common_types.JobProgress, error)
}

ManageToComputationClient is the client API for ManageToComputation 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 NewManageToComputationClient 

func NewManageToComputationClient(cc grpc.ClientConnInterface) ManageToComputationClient

type ManageToComputationServer 

type ManageToComputationServer interface {
	// receive executing computation request from manage container
	ExecuteComputation(context.Context, *ExecuteComputationRequest) (*emptypb.Empty, error)
	// receive progress check request from manage container
	CheckProgress(context.Context, *CheckProgressRequest) (*common_types.JobProgress, error)
	// contains filtered or unexported methods
}

ManageToComputationServer is the server API for ManageToComputation service. All implementations must embed UnimplementedManageToComputationServer for forward compatibility

type UnimplementedManageToComputationServer 

type UnimplementedManageToComputationServer struct {
}

UnimplementedManageToComputationServer must be embedded to have forward compatible implementations.

func (UnimplementedManageToComputationServer) CheckProgress 

func (UnimplementedManageToComputationServer) CheckProgress(context.Context, *CheckProgressRequest) (*common_types.JobProgress, error)

func (UnimplementedManageToComputationServer) ExecuteComputation 

func (UnimplementedManageToComputationServer) ExecuteComputation(context.Context, *ExecuteComputationRequest) (*emptypb.Empty, error)

type UnsafeManageToComputationServer 

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

UnsafeManageToComputationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ManageToComputationServer 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.