LibcToManageContainer

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: 9 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_libc_to_manage_proto protoreflect.FileDescriptor
View Source 
var LibcToManage_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "libctomanage.LibcToManage",
	HandlerType: (*LibcToManageServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SendShares",
			Handler:    _LibcToManage_SendShares_Handler,
		},
		{
			MethodName: "DeleteShares",
			Handler:    _LibcToManage_DeleteShares_Handler,
		},
		{
			MethodName: "GetSchema",
			Handler:    _LibcToManage_GetSchema_Handler,
		},
		{
			MethodName: "ExecuteComputation",
			Handler:    _LibcToManage_ExecuteComputation_Handler,
		},
		{
			MethodName: "SendModelParam",
			Handler:    _LibcToManage_SendModelParam_Handler,
		},
		{
			MethodName: "Predict",
			Handler:    _LibcToManage_Predict_Handler,
		},
		{
			MethodName: "GetDataList",
			Handler:    _LibcToManage_GetDataList_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetComputationResult",
			Handler:       _LibcToManage_GetComputationResult_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "libc_to_manage.proto",
}

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

Functions

func RegisterLibcToManageServer 

func RegisterLibcToManageServer(s grpc.ServiceRegistrar, srv LibcToManageServer)

Types

type DeleteSharesRequest 

type DeleteSharesRequest struct {
	DataIds []string `protobuf:"bytes,1,rep,name=dataIds,proto3" json:"dataIds,omitempty"`
	Token   string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

* the message of DeleteSharesRequest

func (*DeleteSharesRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSharesRequest.ProtoReflect.Descriptor instead.

func (*DeleteSharesRequest) GetDataIds 

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

func (*DeleteSharesRequest) GetToken 

func (x *DeleteSharesRequest) GetToken() string

func (*DeleteSharesRequest) ProtoMessage 

func (*DeleteSharesRequest) ProtoMessage()

func (*DeleteSharesRequest) ProtoReflect 

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

func (*DeleteSharesRequest) Reset 

func (x *DeleteSharesRequest) Reset()

func (*DeleteSharesRequest) String 

func (x *DeleteSharesRequest) String() string

type DeleteSharesResponse 

type DeleteSharesResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	IsOk    bool   `protobuf:"varint,2,opt,name=is_ok,json=isOk,proto3" json:"is_ok,omitempty"`
	// contains filtered or unexported fields
}

* the message of DeleteSharesResponse

func (*DeleteSharesResponse) Descriptor deprecated 

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

Deprecated: Use DeleteSharesResponse.ProtoReflect.Descriptor instead.

func (*DeleteSharesResponse) GetIsOk 

func (x *DeleteSharesResponse) GetIsOk() bool

func (*DeleteSharesResponse) GetMessage 

func (x *DeleteSharesResponse) GetMessage() string

func (*DeleteSharesResponse) ProtoMessage 

func (*DeleteSharesResponse) ProtoMessage()

func (*DeleteSharesResponse) ProtoReflect 

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

func (*DeleteSharesResponse) Reset 

func (x *DeleteSharesResponse) Reset()

func (*DeleteSharesResponse) String 

func (x *DeleteSharesResponse) 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"`
	Token    string                         `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	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) GetMethodId 

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

func (*ExecuteComputationRequest) GetTable 

func (x *ExecuteComputationRequest) GetTable() *JoinOrder

func (*ExecuteComputationRequest) GetToken 

func (x *ExecuteComputationRequest) GetToken() string

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 ExecuteComputationResponse 

type ExecuteComputationResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	IsOk    bool   `protobuf:"varint,2,opt,name=is_ok,json=isOk,proto3" json:"is_ok,omitempty"`
	JobUuid string `protobuf:"bytes,3,opt,name=job_uuid,json=jobUuid,proto3" json:"job_uuid,omitempty"`
	// contains filtered or unexported fields
}

* the message of ExecuteComputationResponse

func (*ExecuteComputationResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteComputationResponse.ProtoReflect.Descriptor instead.

func (*ExecuteComputationResponse) GetIsOk 

func (x *ExecuteComputationResponse) GetIsOk() bool

func (*ExecuteComputationResponse) GetJobUuid 

func (x *ExecuteComputationResponse) GetJobUuid() string

func (*ExecuteComputationResponse) GetMessage 

func (x *ExecuteComputationResponse) GetMessage() string

func (*ExecuteComputationResponse) ProtoMessage 

func (*ExecuteComputationResponse) ProtoMessage()

func (*ExecuteComputationResponse) ProtoReflect 

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

func (*ExecuteComputationResponse) Reset 

func (x *ExecuteComputationResponse) Reset()

func (*ExecuteComputationResponse) String 

func (x *ExecuteComputationResponse) String() string

type GetComputationResultRequest 

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

* the message of GetComputationResultRequest

func (*GetComputationResultRequest) Descriptor deprecated 

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

Deprecated: Use GetComputationResultRequest.ProtoReflect.Descriptor instead.

func (*GetComputationResultRequest) GetJobUuid 

func (x *GetComputationResultRequest) GetJobUuid() string

func (*GetComputationResultRequest) GetToken 

func (x *GetComputationResultRequest) GetToken() string

func (*GetComputationResultRequest) ProtoMessage 

func (*GetComputationResultRequest) ProtoMessage()

func (*GetComputationResultRequest) ProtoReflect 

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

func (*GetComputationResultRequest) Reset 

func (x *GetComputationResultRequest) Reset()

func (*GetComputationResultRequest) String 

func (x *GetComputationResultRequest) String() string

type GetComputationResultResponse 

type GetComputationResultResponse struct {
	Message string                 `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	IsOk    bool                   `protobuf:"varint,2,opt,name=is_ok,json=isOk,proto3" json:"is_ok,omitempty"`
	Result  string                 `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	Status  common_types.JobStatus `protobuf:"varint,4,opt,name=status,proto3,enum=pb_common_types.JobStatus" json:"status,omitempty"`
	PieceId int32                  `protobuf:"varint,5,opt,name=piece_id,json=pieceId,proto3" json:"piece_id,omitempty"`
	// contains filtered or unexported fields
}

* the message of GetComputationResultResponse

func (*GetComputationResultResponse) Descriptor deprecated 

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

Deprecated: Use GetComputationResultResponse.ProtoReflect.Descriptor instead.

func (*GetComputationResultResponse) GetIsOk 

func (x *GetComputationResultResponse) GetIsOk() bool

func (*GetComputationResultResponse) GetMessage 

func (x *GetComputationResultResponse) GetMessage() string

func (*GetComputationResultResponse) GetPieceId 

func (x *GetComputationResultResponse) GetPieceId() int32

func (*GetComputationResultResponse) GetResult 

func (x *GetComputationResultResponse) GetResult() string

func (*GetComputationResultResponse) GetStatus 

func (x *GetComputationResultResponse) GetStatus() common_types.JobStatus

func (*GetComputationResultResponse) ProtoMessage 

func (*GetComputationResultResponse) ProtoMessage()

func (*GetComputationResultResponse) ProtoReflect 

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

func (*GetComputationResultResponse) Reset 

func (x *GetComputationResultResponse) Reset()

func (*GetComputationResultResponse) String 

func (x *GetComputationResultResponse) String() string

type GetDataListRequest 

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

func (*GetDataListRequest) Descriptor deprecated 

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

Deprecated: Use GetDataListRequest.ProtoReflect.Descriptor instead.

func (*GetDataListRequest) GetToken 

func (x *GetDataListRequest) GetToken() string

func (*GetDataListRequest) ProtoMessage 

func (*GetDataListRequest) ProtoMessage()

func (*GetDataListRequest) ProtoReflect 

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

func (*GetDataListRequest) Reset 

func (x *GetDataListRequest) Reset()

func (*GetDataListRequest) String 

func (x *GetDataListRequest) String() string

type GetDataListResponse 

type GetDataListResponse struct {
	Result string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	IsOk   bool   `protobuf:"varint,2,opt,name=is_ok,json=isOk,proto3" json:"is_ok,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDataListResponse) Descriptor deprecated 

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

Deprecated: Use GetDataListResponse.ProtoReflect.Descriptor instead.

func (*GetDataListResponse) GetIsOk 

func (x *GetDataListResponse) GetIsOk() bool

func (*GetDataListResponse) GetResult 

func (x *GetDataListResponse) GetResult() string

func (*GetDataListResponse) ProtoMessage 

func (*GetDataListResponse) ProtoMessage()

func (*GetDataListResponse) ProtoReflect 

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

func (*GetDataListResponse) Reset 

func (x *GetDataListResponse) Reset()

func (*GetDataListResponse) String 

func (x *GetDataListResponse) String() string

type GetSchemaRequest 

type GetSchemaRequest struct {
	DataId string `protobuf:"bytes,1,opt,name=data_id,json=dataId,proto3" json:"data_id,omitempty"`
	Token  string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

* the message of GetSchemaRequest

func (*GetSchemaRequest) Descriptor deprecated 

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

Deprecated: Use GetSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaRequest) GetDataId 

func (x *GetSchemaRequest) GetDataId() string

func (*GetSchemaRequest) GetToken 

func (x *GetSchemaRequest) GetToken() string

func (*GetSchemaRequest) ProtoMessage 

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) ProtoReflect 

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

func (*GetSchemaRequest) Reset 

func (x *GetSchemaRequest) Reset()

func (*GetSchemaRequest) String 

func (x *GetSchemaRequest) String() string

type GetSchemaResponse 

type GetSchemaResponse struct {
	Message string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	IsOk    bool     `protobuf:"varint,2,opt,name=is_ok,json=isOk,proto3" json:"is_ok,omitempty"`
	Schema  []string `protobuf:"bytes,3,rep,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

* the message of GetSchemaResponse

func (*GetSchemaResponse) Descriptor deprecated 

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

Deprecated: Use GetSchemaResponse.ProtoReflect.Descriptor instead.

func (*GetSchemaResponse) GetIsOk 

func (x *GetSchemaResponse) GetIsOk() bool

func (*GetSchemaResponse) GetMessage 

func (x *GetSchemaResponse) GetMessage() string

func (*GetSchemaResponse) GetSchema 

func (x *GetSchemaResponse) GetSchema() []string

func (*GetSchemaResponse) ProtoMessage 

func (*GetSchemaResponse) ProtoMessage()

func (*GetSchemaResponse) ProtoReflect 

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

func (*GetSchemaResponse) Reset 

func (x *GetSchemaResponse) Reset()

func (*GetSchemaResponse) String 

func (x *GetSchemaResponse) 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 LibcToManageClient 

type LibcToManageClient interface {
	SendShares(ctx context.Context, in *SendSharesRequest, opts ...grpc.CallOption) (*SendSharesResponse, error)
	DeleteShares(ctx context.Context, in *DeleteSharesRequest, opts ...grpc.CallOption) (*DeleteSharesResponse, error)
	GetSchema(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*GetSchemaResponse, error)
	ExecuteComputation(ctx context.Context, in *ExecuteComputationRequest, opts ...grpc.CallOption) (*ExecuteComputationResponse, error)
	GetComputationResult(ctx context.Context, in *GetComputationResultRequest, opts ...grpc.CallOption) (LibcToManage_GetComputationResultClient, error)
	SendModelParam(ctx context.Context, in *SendModelParamRequest, opts ...grpc.CallOption) (*SendModelParamResponse, error)
	Predict(ctx context.Context, in *PredictRequest, opts ...grpc.CallOption) (*PredictResponse, error)
	GetDataList(ctx context.Context, in *GetDataListRequest, opts ...grpc.CallOption) (*GetDataListResponse, error)
}

LibcToManageClient is the client API for LibcToManage 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 NewLibcToManageClient 

func NewLibcToManageClient(cc grpc.ClientConnInterface) LibcToManageClient

type LibcToManageServer 

type LibcToManageServer interface {
	SendShares(context.Context, *SendSharesRequest) (*SendSharesResponse, error)
	DeleteShares(context.Context, *DeleteSharesRequest) (*DeleteSharesResponse, error)
	GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)
	ExecuteComputation(context.Context, *ExecuteComputationRequest) (*ExecuteComputationResponse, error)
	GetComputationResult(*GetComputationResultRequest, LibcToManage_GetComputationResultServer) error
	SendModelParam(context.Context, *SendModelParamRequest) (*SendModelParamResponse, error)
	Predict(context.Context, *PredictRequest) (*PredictResponse, error)
	GetDataList(context.Context, *GetDataListRequest) (*GetDataListResponse, error)
	// contains filtered or unexported methods
}

LibcToManageServer is the server API for LibcToManage service. All implementations must embed UnimplementedLibcToManageServer for forward compatibility

type LibcToManage_GetComputationResultClient 

type LibcToManage_GetComputationResultClient interface {
	Recv() (*GetComputationResultResponse, error)
	grpc.ClientStream
}

type LibcToManage_GetComputationResultServer 

type LibcToManage_GetComputationResultServer interface {
	Send(*GetComputationResultResponse) error
	grpc.ServerStream
}

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"`
	Token             string                     `protobuf:"bytes,6,opt,name=token,proto3" json:"token,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) GetToken 

func (x *PredictRequest) GetToken() string

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 PredictResponse 

type PredictResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	IsOk    bool   `protobuf:"varint,2,opt,name=is_ok,json=isOk,proto3" json:"is_ok,omitempty"`
	// contains filtered or unexported fields
}

* the message of PredictResponse

func (*PredictResponse) Descriptor deprecated 

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

Deprecated: Use PredictResponse.ProtoReflect.Descriptor instead.

func (*PredictResponse) GetIsOk 

func (x *PredictResponse) GetIsOk() bool

func (*PredictResponse) GetMessage 

func (x *PredictResponse) GetMessage() string

func (*PredictResponse) ProtoMessage 

func (*PredictResponse) ProtoMessage()

func (*PredictResponse) ProtoReflect 

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

func (*PredictResponse) Reset 

func (x *PredictResponse) Reset()

func (*PredictResponse) String 

func (x *PredictResponse) String() string

type SendModelParamRequest 

type SendModelParamRequest struct {
	JobUuid string `protobuf:"bytes,1,opt,name=job_uuid,json=jobUuid,proto3" json:"job_uuid,omitempty"`
	Params  string `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"`
	PieceId int32  `protobuf:"varint,3,opt,name=piece_id,json=pieceId,proto3" json:"piece_id,omitempty"`
	Token   string `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

* the message of SendModelParamRequest

func (*SendModelParamRequest) Descriptor deprecated 

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

Deprecated: Use SendModelParamRequest.ProtoReflect.Descriptor instead.

func (*SendModelParamRequest) GetJobUuid 

func (x *SendModelParamRequest) GetJobUuid() string

func (*SendModelParamRequest) GetParams 

func (x *SendModelParamRequest) GetParams() string

func (*SendModelParamRequest) GetPieceId 

func (x *SendModelParamRequest) GetPieceId() int32

func (*SendModelParamRequest) GetToken 

func (x *SendModelParamRequest) GetToken() string

func (*SendModelParamRequest) ProtoMessage 

func (*SendModelParamRequest) ProtoMessage()

func (*SendModelParamRequest) ProtoReflect 

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

func (*SendModelParamRequest) Reset 

func (x *SendModelParamRequest) Reset()

func (*SendModelParamRequest) String 

func (x *SendModelParamRequest) String() string

type SendModelParamResponse 

type SendModelParamResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	IsOk    bool   `protobuf:"varint,2,opt,name=is_ok,json=isOk,proto3" json:"is_ok,omitempty"`
	// contains filtered or unexported fields
}

* the message of SendModelParamResponse

func (*SendModelParamResponse) Descriptor deprecated 

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

Deprecated: Use SendModelParamResponse.ProtoReflect.Descriptor instead.

func (*SendModelParamResponse) GetIsOk 

func (x *SendModelParamResponse) GetIsOk() bool

func (*SendModelParamResponse) GetMessage 

func (x *SendModelParamResponse) GetMessage() string

func (*SendModelParamResponse) ProtoMessage 

func (*SendModelParamResponse) ProtoMessage()

func (*SendModelParamResponse) ProtoReflect 

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

func (*SendModelParamResponse) Reset 

func (x *SendModelParamResponse) Reset()

func (*SendModelParamResponse) String 

func (x *SendModelParamResponse) String() string

type SendSharesRequest 

type SendSharesRequest struct {
	DataId  string   `protobuf:"bytes,1,opt,name=data_id,json=dataId,proto3" json:"data_id,omitempty"`
	Shares  string   `protobuf:"bytes,2,opt,name=shares,proto3" json:"shares,omitempty"`
	Schema  []string `protobuf:"bytes,3,rep,name=schema,proto3" json:"schema,omitempty"`
	PieceId int32    `protobuf:"varint,4,opt,name=piece_id,json=pieceId,proto3" json:"piece_id,omitempty"`
	SentAt  string   `protobuf:"bytes,5,opt,name=sent_at,json=sentAt,proto3" json:"sent_at,omitempty"`
	Token   string   `protobuf:"bytes,6,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

* the message of SendSharesRequest

func (*SendSharesRequest) Descriptor deprecated 

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

Deprecated: Use SendSharesRequest.ProtoReflect.Descriptor instead.

func (*SendSharesRequest) GetDataId 

func (x *SendSharesRequest) GetDataId() string

func (*SendSharesRequest) GetPieceId 

func (x *SendSharesRequest) GetPieceId() int32

func (*SendSharesRequest) GetSchema 

func (x *SendSharesRequest) GetSchema() []string

func (*SendSharesRequest) GetSentAt 

func (x *SendSharesRequest) GetSentAt() string

func (*SendSharesRequest) GetShares 

func (x *SendSharesRequest) GetShares() string

func (*SendSharesRequest) GetToken 

func (x *SendSharesRequest) GetToken() string

func (*SendSharesRequest) ProtoMessage 

func (*SendSharesRequest) ProtoMessage()

func (*SendSharesRequest) ProtoReflect 

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

func (*SendSharesRequest) Reset 

func (x *SendSharesRequest) Reset()

func (*SendSharesRequest) String 

func (x *SendSharesRequest) String() string

type SendSharesResponse 

type SendSharesResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	IsOk    bool   `protobuf:"varint,2,opt,name=is_ok,json=isOk,proto3" json:"is_ok,omitempty"`
	// contains filtered or unexported fields
}

* the message of SendSharesResponse

func (*SendSharesResponse) Descriptor deprecated 

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

Deprecated: Use SendSharesResponse.ProtoReflect.Descriptor instead.

func (*SendSharesResponse) GetIsOk 

func (x *SendSharesResponse) GetIsOk() bool

func (*SendSharesResponse) GetMessage 

func (x *SendSharesResponse) GetMessage() string

func (*SendSharesResponse) ProtoMessage 

func (*SendSharesResponse) ProtoMessage()

func (*SendSharesResponse) ProtoReflect 

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

func (*SendSharesResponse) Reset 

func (x *SendSharesResponse) Reset()

func (*SendSharesResponse) String 

func (x *SendSharesResponse) String() string

type UnimplementedLibcToManageServer 

type UnimplementedLibcToManageServer struct {
}

UnimplementedLibcToManageServer must be embedded to have forward compatible implementations.

func (UnimplementedLibcToManageServer) DeleteShares 

func (UnimplementedLibcToManageServer) DeleteShares(context.Context, *DeleteSharesRequest) (*DeleteSharesResponse, error)

func (UnimplementedLibcToManageServer) ExecuteComputation 

func (UnimplementedLibcToManageServer) ExecuteComputation(context.Context, *ExecuteComputationRequest) (*ExecuteComputationResponse, error)

func (UnimplementedLibcToManageServer) GetComputationResult 

func (UnimplementedLibcToManageServer) GetComputationResult(*GetComputationResultRequest, LibcToManage_GetComputationResultServer) error

func (UnimplementedLibcToManageServer) GetDataList 

func (UnimplementedLibcToManageServer) GetDataList(context.Context, *GetDataListRequest) (*GetDataListResponse, error)

func (UnimplementedLibcToManageServer) GetSchema 

func (UnimplementedLibcToManageServer) GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)

func (UnimplementedLibcToManageServer) Predict 

func (UnimplementedLibcToManageServer) Predict(context.Context, *PredictRequest) (*PredictResponse, error)

func (UnimplementedLibcToManageServer) SendModelParam 

func (UnimplementedLibcToManageServer) SendModelParam(context.Context, *SendModelParamRequest) (*SendModelParamResponse, error)

func (UnimplementedLibcToManageServer) SendShares 

func (UnimplementedLibcToManageServer) SendShares(context.Context, *SendSharesRequest) (*SendSharesResponse, error)

type UnsafeLibcToManageServer 

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

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