ManageToComputationContainer

package module
v0.0.0-...-763d59e Latest Latest
Warning

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

 Go to latest Published: Sep 20, 2022 License: Apache-2.0 Imports: 10 Imported by: 2

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: "Predict",
			Handler:    _ManageToComputation_Predict_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 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=dataIds,proto3" json:"dataIds,omitempty"`
	Join    []int32  `protobuf:"varint,2,rep,packed,name=join,proto3" json:"join,omitempty"`
	Index   []int32  `protobuf:"varint,3,rep,packed,name=index,proto3" json:"index,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) GetIndex 

func (x *JoinOrder) GetIndex() []int32

func (*JoinOrder) GetJoin 

func (x *JoinOrder) GetJoin() []int32

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 predict request from manage container
	Predict(ctx context.Context, in *PredictRequest, opts ...grpc.CallOption) (*emptypb.Empty, 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 predict request from manage container
	Predict(context.Context, *PredictRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

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

type PredictRequest 

type PredictRequest struct {
	JobUuid           string                     `protobuf:"bytes,1,opt,name=job_uuid,json=jobUuid,proto3" json:"job_uuid,omitempty"`
	ModelParamJobUuid string                     `protobuf:"bytes,2,opt,name=model_param_job_uuid,json=modelParamJobUuid,proto3" json:"model_param_job_uuid,omitempty"`
	ModelId           common_types.PredictMethod `protobuf:"varint,3,opt,name=model_id,json=modelId,proto3,enum=pb_common_types.PredictMethod" json:"model_id,omitempty"`
	Table             *JoinOrder                 `protobuf:"bytes,4,opt,name=table,proto3" json:"table,omitempty"`
	Src               []int32                    `protobuf:"varint,5,rep,packed,name=src,proto3" json:"src,omitempty"`
	// contains filtered or unexported fields
}

* the message of PredictRequest

func (*PredictRequest) Descriptor deprecated 

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

Deprecated: Use PredictRequest.ProtoReflect.Descriptor instead.

func (*PredictRequest) GetJobUuid 

func (x *PredictRequest) GetJobUuid() string

func (*PredictRequest) GetModelId 

func (x *PredictRequest) GetModelId() common_types.PredictMethod

func (*PredictRequest) GetModelParamJobUuid 

func (x *PredictRequest) GetModelParamJobUuid() string

func (*PredictRequest) GetSrc 

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

func (*PredictRequest) GetTable 

func (x *PredictRequest) GetTable() *JoinOrder

func (*PredictRequest) ProtoMessage 

func (*PredictRequest) ProtoMessage()

func (*PredictRequest) ProtoReflect 

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

func (*PredictRequest) Reset 

func (x *PredictRequest) Reset()

func (*PredictRequest) String 

func (x *PredictRequest) String() string

type UnimplementedManageToComputationServer 

type UnimplementedManageToComputationServer struct {
}

UnimplementedManageToComputationServer must be embedded to have forward compatible implementations.

func (UnimplementedManageToComputationServer) ExecuteComputation 

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

func (UnimplementedManageToComputationServer) Predict 

func (UnimplementedManageToComputationServer) Predict(context.Context, *PredictRequest) (*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.