Versions in this module Expand all Collapse all v1 v1.0.0 May 31, 2023 Changes in this version + const SubmissionService_CancelRun_FullMethodName + const SubmissionService_CancelSubmission_FullMethodName + const SubmissionService_CheckSubmission_FullMethodName + const SubmissionService_CreateSubmission_FullMethodName + const SubmissionService_DeleteSubmission_FullMethodName + const SubmissionService_ListRuns_FullMethodName + const SubmissionService_ListSubmissions_FullMethodName + const SubmissionService_ListTasks_FullMethodName + var File_internal_context_submission_interface_grpc_proto_submission_proto protoreflect.FileDescriptor + var SubmissionErrorReason_name = map[int32]string + var SubmissionErrorReason_value = map[string]int32 + var SubmissionService_ServiceDesc = grpc.ServiceDesc + func ErrorSubmissionNotFound(format string, args ...interface{}) *errors.Error + func ErrorSubmissionValidateError(format string, args ...interface{}) *errors.Error + func IsSubmissionNotFound(err error) bool + func IsSubmissionValidateError(err error) bool + func RegisterSubmissionServiceServer(s grpc.ServiceRegistrar, srv SubmissionServiceServer) + type CancelRunRequest struct + Id string + SubmissionID string + WorkspaceID string + func (*CancelRunRequest) Descriptor() ([]byte, []int) + func (*CancelRunRequest) ProtoMessage() + func (x *CancelRunRequest) GetId() string + func (x *CancelRunRequest) GetSubmissionID() string + func (x *CancelRunRequest) GetWorkspaceID() string + func (x *CancelRunRequest) ProtoReflect() protoreflect.Message + func (x *CancelRunRequest) Reset() + func (x *CancelRunRequest) String() string + type CancelRunResponse struct + func (*CancelRunResponse) Descriptor() ([]byte, []int) + func (*CancelRunResponse) ProtoMessage() + func (x *CancelRunResponse) ProtoReflect() protoreflect.Message + func (x *CancelRunResponse) Reset() + func (x *CancelRunResponse) String() string + type CancelSubmissionRequest struct + Id string + WorkspaceID string + func (*CancelSubmissionRequest) Descriptor() ([]byte, []int) + func (*CancelSubmissionRequest) ProtoMessage() + func (x *CancelSubmissionRequest) GetId() string + func (x *CancelSubmissionRequest) GetWorkspaceID() string + func (x *CancelSubmissionRequest) ProtoReflect() protoreflect.Message + func (x *CancelSubmissionRequest) Reset() + func (x *CancelSubmissionRequest) String() string + type CancelSubmissionResponse struct + func (*CancelSubmissionResponse) Descriptor() ([]byte, []int) + func (*CancelSubmissionResponse) ProtoMessage() + func (x *CancelSubmissionResponse) ProtoReflect() protoreflect.Message + func (x *CancelSubmissionResponse) Reset() + func (x *CancelSubmissionResponse) String() string + type CheckSubmissionRequest struct + Name string + WorkspaceID string + func (*CheckSubmissionRequest) Descriptor() ([]byte, []int) + func (*CheckSubmissionRequest) ProtoMessage() + func (x *CheckSubmissionRequest) GetName() string + func (x *CheckSubmissionRequest) GetWorkspaceID() string + func (x *CheckSubmissionRequest) ProtoReflect() protoreflect.Message + func (x *CheckSubmissionRequest) Reset() + func (x *CheckSubmissionRequest) String() string + type CheckSubmissionResponse struct + IsNameExist bool + func (*CheckSubmissionResponse) Descriptor() ([]byte, []int) + func (*CheckSubmissionResponse) ProtoMessage() + func (x *CheckSubmissionResponse) GetIsNameExist() bool + func (x *CheckSubmissionResponse) ProtoReflect() protoreflect.Message + func (x *CheckSubmissionResponse) Reset() + func (x *CheckSubmissionResponse) String() string + type CreateSubmissionRequest struct + Description string + Entity *Entity + ExposedOptions *ExposedOptions + InOutMaterial *InOutMaterial + Name string + Type string + WorkflowID string + WorkspaceID string + func (*CreateSubmissionRequest) Descriptor() ([]byte, []int) + func (*CreateSubmissionRequest) ProtoMessage() + func (x *CreateSubmissionRequest) GetDescription() string + func (x *CreateSubmissionRequest) GetEntity() *Entity + func (x *CreateSubmissionRequest) GetExposedOptions() *ExposedOptions + func (x *CreateSubmissionRequest) GetInOutMaterial() *InOutMaterial + func (x *CreateSubmissionRequest) GetName() string + func (x *CreateSubmissionRequest) GetType() string + func (x *CreateSubmissionRequest) GetWorkflowID() string + func (x *CreateSubmissionRequest) GetWorkspaceID() string + func (x *CreateSubmissionRequest) ProtoReflect() protoreflect.Message + func (x *CreateSubmissionRequest) Reset() + func (x *CreateSubmissionRequest) String() string + type CreateSubmissionResponse struct + Id string + func (*CreateSubmissionResponse) Descriptor() ([]byte, []int) + func (*CreateSubmissionResponse) ProtoMessage() + func (x *CreateSubmissionResponse) GetId() string + func (x *CreateSubmissionResponse) ProtoReflect() protoreflect.Message + func (x *CreateSubmissionResponse) Reset() + func (x *CreateSubmissionResponse) String() string + type DeleteSubmissionRequest struct + Id string + WorkspaceID string + func (*DeleteSubmissionRequest) Descriptor() ([]byte, []int) + func (*DeleteSubmissionRequest) ProtoMessage() + func (x *DeleteSubmissionRequest) GetId() string + func (x *DeleteSubmissionRequest) GetWorkspaceID() string + func (x *DeleteSubmissionRequest) ProtoReflect() protoreflect.Message + func (x *DeleteSubmissionRequest) Reset() + func (x *DeleteSubmissionRequest) String() string + type DeleteSubmissionResponse struct + func (*DeleteSubmissionResponse) Descriptor() ([]byte, []int) + func (*DeleteSubmissionResponse) ProtoMessage() + func (x *DeleteSubmissionResponse) ProtoReflect() protoreflect.Message + func (x *DeleteSubmissionResponse) Reset() + func (x *DeleteSubmissionResponse) String() string + type Entity struct + DataModelID string + DataModelRowIDs []string + InputsTemplate string + OutputsTemplate string + func (*Entity) Descriptor() ([]byte, []int) + func (*Entity) ProtoMessage() + func (x *Entity) GetDataModelID() string + func (x *Entity) GetDataModelRowIDs() []string + func (x *Entity) GetInputsTemplate() string + func (x *Entity) GetOutputsTemplate() string + func (x *Entity) ProtoReflect() protoreflect.Message + func (x *Entity) Reset() + func (x *Entity) String() string + type ExposedOptions struct + ReadFromCache bool + func (*ExposedOptions) Descriptor() ([]byte, []int) + func (*ExposedOptions) ProtoMessage() + func (x *ExposedOptions) GetReadFromCache() bool + func (x *ExposedOptions) ProtoReflect() protoreflect.Message + func (x *ExposedOptions) Reset() + func (x *ExposedOptions) String() string + type InOutMaterial struct + InputsMaterial string + OutputsMaterial string + func (*InOutMaterial) Descriptor() ([]byte, []int) + func (*InOutMaterial) ProtoMessage() + func (x *InOutMaterial) GetInputsMaterial() string + func (x *InOutMaterial) GetOutputsMaterial() string + func (x *InOutMaterial) ProtoReflect() protoreflect.Message + func (x *InOutMaterial) Reset() + func (x *InOutMaterial) String() string + type ListRunsRequest struct + Ids []string + OrderBy string + Page int32 + SearchWord string + Size int32 + Status []string + SubmissionID string + WorkspaceID string + func (*ListRunsRequest) Descriptor() ([]byte, []int) + func (*ListRunsRequest) ProtoMessage() + func (x *ListRunsRequest) GetIds() []string + func (x *ListRunsRequest) GetOrderBy() string + func (x *ListRunsRequest) GetPage() int32 + func (x *ListRunsRequest) GetSearchWord() string + func (x *ListRunsRequest) GetSize() int32 + func (x *ListRunsRequest) GetStatus() []string + func (x *ListRunsRequest) GetSubmissionID() string + func (x *ListRunsRequest) GetWorkspaceID() string + func (x *ListRunsRequest) ProtoReflect() protoreflect.Message + func (x *ListRunsRequest) Reset() + func (x *ListRunsRequest) String() string + type ListRunsResponse struct + Items []*RunItem + Page int32 + Size int32 + Total int32 + func (*ListRunsResponse) Descriptor() ([]byte, []int) + func (*ListRunsResponse) ProtoMessage() + func (x *ListRunsResponse) GetItems() []*RunItem + func (x *ListRunsResponse) GetPage() int32 + func (x *ListRunsResponse) GetSize() int32 + func (x *ListRunsResponse) GetTotal() int32 + func (x *ListRunsResponse) ProtoReflect() protoreflect.Message + func (x *ListRunsResponse) Reset() + func (x *ListRunsResponse) String() string + type ListSubmissionsRequest struct + Exact bool + Ids []string + OrderBy string + Page int32 + SearchWord string + Size int32 + Status []string + WorkflowID string + WorkspaceID string + func (*ListSubmissionsRequest) Descriptor() ([]byte, []int) + func (*ListSubmissionsRequest) ProtoMessage() + func (x *ListSubmissionsRequest) GetExact() bool + func (x *ListSubmissionsRequest) GetIds() []string + func (x *ListSubmissionsRequest) GetOrderBy() string + func (x *ListSubmissionsRequest) GetPage() int32 + func (x *ListSubmissionsRequest) GetSearchWord() string + func (x *ListSubmissionsRequest) GetSize() int32 + func (x *ListSubmissionsRequest) GetStatus() []string + func (x *ListSubmissionsRequest) GetWorkflowID() string + func (x *ListSubmissionsRequest) GetWorkspaceID() string + func (x *ListSubmissionsRequest) ProtoReflect() protoreflect.Message + func (x *ListSubmissionsRequest) Reset() + func (x *ListSubmissionsRequest) String() string + type ListSubmissionsResponse struct + Items []*SubmissionItem + Page int32 + Size int32 + Total int32 + func (*ListSubmissionsResponse) Descriptor() ([]byte, []int) + func (*ListSubmissionsResponse) ProtoMessage() + func (x *ListSubmissionsResponse) GetItems() []*SubmissionItem + func (x *ListSubmissionsResponse) GetPage() int32 + func (x *ListSubmissionsResponse) GetSize() int32 + func (x *ListSubmissionsResponse) GetTotal() int32 + func (x *ListSubmissionsResponse) ProtoReflect() protoreflect.Message + func (x *ListSubmissionsResponse) Reset() + func (x *ListSubmissionsResponse) String() string + type ListTasksRequest struct + OrderBy string + Page int32 + RunID string + Size int32 + SubmissionID string + WorkspaceID string + func (*ListTasksRequest) Descriptor() ([]byte, []int) + func (*ListTasksRequest) ProtoMessage() + func (x *ListTasksRequest) GetOrderBy() string + func (x *ListTasksRequest) GetPage() int32 + func (x *ListTasksRequest) GetRunID() string + func (x *ListTasksRequest) GetSize() int32 + func (x *ListTasksRequest) GetSubmissionID() string + func (x *ListTasksRequest) GetWorkspaceID() string + func (x *ListTasksRequest) ProtoReflect() protoreflect.Message + func (x *ListTasksRequest) Reset() + func (x *ListTasksRequest) String() string + type ListTasksResponse struct + Items []*TaskItem + Page int32 + Size int32 + Total int32 + func (*ListTasksResponse) Descriptor() ([]byte, []int) + func (*ListTasksResponse) ProtoMessage() + func (x *ListTasksResponse) GetItems() []*TaskItem + func (x *ListTasksResponse) GetPage() int32 + func (x *ListTasksResponse) GetSize() int32 + func (x *ListTasksResponse) GetTotal() int32 + func (x *ListTasksResponse) ProtoReflect() protoreflect.Message + func (x *ListTasksResponse) Reset() + func (x *ListTasksResponse) String() string + type RunItem struct + Duration int64 + EngineRunID string + FinishTime int64 + Id string + Inputs string + Log string + Message string + Name string + Outputs string + StartTime int64 + Status string + TaskStatus *Status + func (*RunItem) Descriptor() ([]byte, []int) + func (*RunItem) ProtoMessage() + func (x *RunItem) GetDuration() int64 + func (x *RunItem) GetEngineRunID() string + func (x *RunItem) GetFinishTime() int64 + func (x *RunItem) GetId() string + func (x *RunItem) GetInputs() string + func (x *RunItem) GetLog() string + func (x *RunItem) GetMessage() string + func (x *RunItem) GetName() string + func (x *RunItem) GetOutputs() string + func (x *RunItem) GetStartTime() int64 + func (x *RunItem) GetStatus() string + func (x *RunItem) GetTaskStatus() *Status + func (x *RunItem) ProtoReflect() protoreflect.Message + func (x *RunItem) Reset() + func (x *RunItem) String() string + type Status struct + Cancelled int64 + Cancelling int64 + Count int64 + Failed int64 + Initializing int64 + Pending int64 + Queued int64 + Running int64 + Succeeded int64 + func (*Status) Descriptor() ([]byte, []int) + func (*Status) ProtoMessage() + func (x *Status) GetCancelled() int64 + func (x *Status) GetCancelling() int64 + func (x *Status) GetCount() int64 + func (x *Status) GetFailed() int64 + func (x *Status) GetInitializing() int64 + func (x *Status) GetPending() int64 + func (x *Status) GetQueued() int64 + func (x *Status) GetRunning() int64 + func (x *Status) GetSucceeded() int64 + func (x *Status) ProtoReflect() protoreflect.Message + func (x *Status) Reset() + func (x *Status) String() string + type SubmissionErrorReason int32 + const SubmissionErrorReason_SUBMISSION_NOT_FOUND + const SubmissionErrorReason_SUBMISSION_VALIDATE_ERROR + func (SubmissionErrorReason) Descriptor() protoreflect.EnumDescriptor + func (SubmissionErrorReason) EnumDescriptor() ([]byte, []int) + func (SubmissionErrorReason) Type() protoreflect.EnumType + func (x SubmissionErrorReason) Enum() *SubmissionErrorReason + func (x SubmissionErrorReason) Number() protoreflect.EnumNumber + func (x SubmissionErrorReason) String() string + type SubmissionItem struct + Description string + Duration int64 + Entity *Entity + ExposedOptions *ExposedOptions + FinishTime int64 + Id string + InOutMaterial *InOutMaterial + Name string + RunStatus *Status + StartTime int64 + Status string + Type string + WorkflowVersion *WorkflowVersionInfo + func (*SubmissionItem) Descriptor() ([]byte, []int) + func (*SubmissionItem) ProtoMessage() + func (x *SubmissionItem) GetDescription() string + func (x *SubmissionItem) GetDuration() int64 + func (x *SubmissionItem) GetEntity() *Entity + func (x *SubmissionItem) GetExposedOptions() *ExposedOptions + func (x *SubmissionItem) GetFinishTime() int64 + func (x *SubmissionItem) GetId() string + func (x *SubmissionItem) GetInOutMaterial() *InOutMaterial + func (x *SubmissionItem) GetName() string + func (x *SubmissionItem) GetRunStatus() *Status + func (x *SubmissionItem) GetStartTime() int64 + func (x *SubmissionItem) GetStatus() string + func (x *SubmissionItem) GetType() string + func (x *SubmissionItem) GetWorkflowVersion() *WorkflowVersionInfo + func (x *SubmissionItem) ProtoReflect() protoreflect.Message + func (x *SubmissionItem) Reset() + func (x *SubmissionItem) String() string + type SubmissionServiceClient interface + CancelRun func(ctx context.Context, in *CancelRunRequest, opts ...grpc.CallOption) (*CancelRunResponse, error) + CancelSubmission func(ctx context.Context, in *CancelSubmissionRequest, opts ...grpc.CallOption) (*CancelSubmissionResponse, error) + CheckSubmission func(ctx context.Context, in *CheckSubmissionRequest, opts ...grpc.CallOption) (*CheckSubmissionResponse, error) + CreateSubmission func(ctx context.Context, in *CreateSubmissionRequest, opts ...grpc.CallOption) (*CreateSubmissionResponse, error) + DeleteSubmission func(ctx context.Context, in *DeleteSubmissionRequest, opts ...grpc.CallOption) (*DeleteSubmissionResponse, error) + ListRuns func(ctx context.Context, in *ListRunsRequest, opts ...grpc.CallOption) (*ListRunsResponse, error) + ListSubmissions func(ctx context.Context, in *ListSubmissionsRequest, opts ...grpc.CallOption) (*ListSubmissionsResponse, error) + ListTasks func(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error) + func NewSubmissionServiceClient(cc grpc.ClientConnInterface) SubmissionServiceClient + type SubmissionServiceServer interface + CancelRun func(context.Context, *CancelRunRequest) (*CancelRunResponse, error) + CancelSubmission func(context.Context, *CancelSubmissionRequest) (*CancelSubmissionResponse, error) + CheckSubmission func(context.Context, *CheckSubmissionRequest) (*CheckSubmissionResponse, error) + CreateSubmission func(context.Context, *CreateSubmissionRequest) (*CreateSubmissionResponse, error) + DeleteSubmission func(context.Context, *DeleteSubmissionRequest) (*DeleteSubmissionResponse, error) + ListRuns func(context.Context, *ListRunsRequest) (*ListRunsResponse, error) + ListSubmissions func(context.Context, *ListSubmissionsRequest) (*ListSubmissionsResponse, error) + ListTasks func(context.Context, *ListTasksRequest) (*ListTasksResponse, error) + type TaskItem struct + Duration int64 + FinishTime int64 + Name string + RunID string + StartTime int64 + Status string + Stderr string + Stdout string + func (*TaskItem) Descriptor() ([]byte, []int) + func (*TaskItem) ProtoMessage() + func (x *TaskItem) GetDuration() int64 + func (x *TaskItem) GetFinishTime() int64 + func (x *TaskItem) GetName() string + func (x *TaskItem) GetRunID() string + func (x *TaskItem) GetStartTime() int64 + func (x *TaskItem) GetStatus() string + func (x *TaskItem) GetStderr() string + func (x *TaskItem) GetStdout() string + func (x *TaskItem) ProtoReflect() protoreflect.Message + func (x *TaskItem) Reset() + func (x *TaskItem) String() string + type UnimplementedSubmissionServiceServer struct + func (UnimplementedSubmissionServiceServer) CancelRun(context.Context, *CancelRunRequest) (*CancelRunResponse, error) + func (UnimplementedSubmissionServiceServer) CancelSubmission(context.Context, *CancelSubmissionRequest) (*CancelSubmissionResponse, error) + func (UnimplementedSubmissionServiceServer) CheckSubmission(context.Context, *CheckSubmissionRequest) (*CheckSubmissionResponse, error) + func (UnimplementedSubmissionServiceServer) CreateSubmission(context.Context, *CreateSubmissionRequest) (*CreateSubmissionResponse, error) + func (UnimplementedSubmissionServiceServer) DeleteSubmission(context.Context, *DeleteSubmissionRequest) (*DeleteSubmissionResponse, error) + func (UnimplementedSubmissionServiceServer) ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error) + func (UnimplementedSubmissionServiceServer) ListSubmissions(context.Context, *ListSubmissionsRequest) (*ListSubmissionsResponse, error) + func (UnimplementedSubmissionServiceServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error) + type UnsafeSubmissionServiceServer interface + type WorkflowVersionInfo struct + Id string + VersionID string + func (*WorkflowVersionInfo) Descriptor() ([]byte, []int) + func (*WorkflowVersionInfo) ProtoMessage() + func (x *WorkflowVersionInfo) GetId() string + func (x *WorkflowVersionInfo) GetVersionID() string + func (x *WorkflowVersionInfo) ProtoReflect() protoreflect.Message + func (x *WorkflowVersionInfo) Reset() + func (x *WorkflowVersionInfo) String() string
Go to main page