libc_to_manage_container

type AddShareDataFrameRequest struct {
	BaseDataId string `protobuf:"bytes,1,opt,name=base_data_id,json=baseDataId,proto3" json:"base_data_id,omitempty"`
	AddDataId  string `protobuf:"bytes,2,opt,name=add_data_id,json=addDataId,proto3" json:"add_data_id,omitempty"`
	Token      string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

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

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
}

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
}

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

type GetComputationRequest 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
}

type GetComputationResultResponse struct {
	Result       []string `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"`
	ColumnNumber int32    `protobuf:"varint,2,opt,name=column_number,json=columnNumber,proto3" json:"column_number,omitempty"`
	PieceId      int32    `protobuf:"varint,3,opt,name=piece_id,json=pieceId,proto3" json:"piece_id,omitempty"`
	// Types that are assignable to ResultType:
	//	*GetComputationResultResponse_IsDim1
	//	*GetComputationResultResponse_IsDim2
	//	*GetComputationResultResponse_IsSchema
	ResultType isGetComputationResultResponse_ResultType `protobuf_oneof:"result_type"`
	// contains filtered or unexported fields
}

type GetComputationResultResponse_IsDim1 struct {
	IsDim1 bool `protobuf:"varint,4,opt,name=is_dim1,json=isDim1,proto3,oneof"`
}

type GetComputationResultResponse_IsDim2 struct {
	IsDim2 bool `protobuf:"varint,5,opt,name=is_dim2,json=isDim2,proto3,oneof"`
}

type GetComputationResultResponse_IsSchema struct {
	IsSchema bool `protobuf:"varint,6,opt,name=is_schema,json=isSchema,proto3,oneof"`
}

type GetComputationStatusResponse struct {
	Status   common_types.JobStatus    `protobuf:"varint,1,opt,name=status,proto3,enum=pb_common_types.JobStatus" json:"status,omitempty"`
	Progress *common_types.JobProgress `protobuf:"bytes,2,opt,name=progress,proto3,oneof" json:"progress,omitempty"`
	// contains filtered or unexported fields
}

type GetElapsedTimeRequest 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
}

type GetElapsedTimeResponse struct {
	ElapsedTime float64 `protobuf:"fixed64,1,opt,name=elapsed_time,json=elapsedTime,proto3" json:"elapsed_time,omitempty"`
	// contains filtered or unexported fields
}

type GetJobErrorInfoResponse struct {
	JobErrorInfo *common_types.JobErrorInfo `protobuf:"bytes,1,opt,name=job_error_info,json=jobErrorInfo,proto3,oneof" json:"job_error_info,omitempty"`
	// contains filtered or unexported fields
}

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
}

type GetSchemaResponse struct {
	Schema []*common_types.Schema `protobuf:"bytes,1,rep,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

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
}

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
}

type LibcToManageClient interface {
	SendShares(ctx context.Context, in *SendSharesRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteShares(ctx context.Context, in *DeleteSharesRequest, opts ...grpc.CallOption) (*emptypb.Empty, 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 *GetComputationRequest, opts ...grpc.CallOption) (LibcToManage_GetComputationResultClient, error)
	GetComputationStatus(ctx context.Context, in *GetComputationRequest, opts ...grpc.CallOption) (*GetComputationStatusResponse, error)
	GetJobErrorInfo(ctx context.Context, in *GetComputationRequest, opts ...grpc.CallOption) (*GetJobErrorInfoResponse, error)
	GetElapsedTime(ctx context.Context, in *GetElapsedTimeRequest, opts ...grpc.CallOption) (*GetElapsedTimeResponse, error)
	AddShareDataFrame(ctx context.Context, in *AddShareDataFrameRequest, opts ...grpc.CallOption) (*AddShareDataFrameResponse, error)
}

type LibcToManageServer interface {
	SendShares(context.Context, *SendSharesRequest) (*emptypb.Empty, error)
	DeleteShares(context.Context, *DeleteSharesRequest) (*emptypb.Empty, error)
	GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)
	ExecuteComputation(context.Context, *ExecuteComputationRequest) (*ExecuteComputationResponse, error)
	GetComputationResult(*GetComputationRequest, LibcToManage_GetComputationResultServer) error
	GetComputationStatus(context.Context, *GetComputationRequest) (*GetComputationStatusResponse, error)
	GetJobErrorInfo(context.Context, *GetComputationRequest) (*GetJobErrorInfoResponse, error)
	GetElapsedTime(context.Context, *GetElapsedTimeRequest) (*GetElapsedTimeResponse, error)
	AddShareDataFrame(context.Context, *AddShareDataFrameRequest) (*AddShareDataFrameResponse, error)
	// contains filtered or unexported methods
}

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

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

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         []*common_types.Schema `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"`
	MatchingColumn int32                  `protobuf:"varint,6,opt,name=matching_column,json=matchingColumn,proto3" json:"matching_column,omitempty"`
	Token          string                 `protobuf:"bytes,7,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedLibcToManageServer struct {
}

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