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 (*ExecuteComputationRequest) GetTable

func (x *ExecuteComputationRequest) GetTable() *JoinOrder

func (*ExecuteComputationRequest) ProtoMessage

func (*ExecuteComputationRequest) ProtoMessage()

func (*ExecuteComputationRequest) ProtoReflect

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.

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) Predict

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL