proto

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: May 31, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SubmissionService_CheckSubmission_FullMethodName  = "/proto.SubmissionService/CheckSubmission"
	SubmissionService_ListSubmissions_FullMethodName  = "/proto.SubmissionService/ListSubmissions"
	SubmissionService_CreateSubmission_FullMethodName = "/proto.SubmissionService/CreateSubmission"
	SubmissionService_DeleteSubmission_FullMethodName = "/proto.SubmissionService/DeleteSubmission"
	SubmissionService_CancelSubmission_FullMethodName = "/proto.SubmissionService/CancelSubmission"
	SubmissionService_ListRuns_FullMethodName         = "/proto.SubmissionService/ListRuns"
	SubmissionService_CancelRun_FullMethodName        = "/proto.SubmissionService/CancelRun"
	SubmissionService_ListTasks_FullMethodName        = "/proto.SubmissionService/ListTasks"
)

Variables

View Source 
var (
	SubmissionErrorReason_name = map[int32]string{
		0: "SUBMISSION_NOT_FOUND",
		1: "SUBMISSION_VALIDATE_ERROR",
	}
	SubmissionErrorReason_value = map[string]int32{
		"SUBMISSION_NOT_FOUND":      0,
		"SUBMISSION_VALIDATE_ERROR": 1,
	}
)

Enum value maps for SubmissionErrorReason.

View Source 
var File_internal_context_submission_interface_grpc_proto_submission_proto protoreflect.FileDescriptor
View Source 
var SubmissionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.SubmissionService",
	HandlerType: (*SubmissionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CheckSubmission",
			Handler:    _SubmissionService_CheckSubmission_Handler,
		},
		{
			MethodName: "ListSubmissions",
			Handler:    _SubmissionService_ListSubmissions_Handler,
		},
		{
			MethodName: "CreateSubmission",
			Handler:    _SubmissionService_CreateSubmission_Handler,
		},
		{
			MethodName: "DeleteSubmission",
			Handler:    _SubmissionService_DeleteSubmission_Handler,
		},
		{
			MethodName: "CancelSubmission",
			Handler:    _SubmissionService_CancelSubmission_Handler,
		},
		{
			MethodName: "ListRuns",
			Handler:    _SubmissionService_ListRuns_Handler,
		},
		{
			MethodName: "CancelRun",
			Handler:    _SubmissionService_CancelRun_Handler,
		},
		{
			MethodName: "ListTasks",
			Handler:    _SubmissionService_ListTasks_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/context/submission/interface/grpc/proto/submission.proto",
}

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

Functions

func ErrorSubmissionNotFound 

func ErrorSubmissionNotFound(format string, args ...interface{}) *errors.Error

func ErrorSubmissionValidateError 

func ErrorSubmissionValidateError(format string, args ...interface{}) *errors.Error

func IsSubmissionNotFound 

func IsSubmissionNotFound(err error) bool

func IsSubmissionValidateError 

func IsSubmissionValidateError(err error) bool

func RegisterSubmissionServiceServer 

func RegisterSubmissionServiceServer(s grpc.ServiceRegistrar, srv SubmissionServiceServer)

Types

type CancelRunRequest 

type CancelRunRequest struct {
	WorkspaceID  string `protobuf:"bytes,1,opt,name=workspaceID,proto3" json:"workspaceID,omitempty"`
	SubmissionID string `protobuf:"bytes,2,opt,name=submissionID,proto3" json:"submissionID,omitempty"`
	Id           string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelRunRequest) Descriptor deprecated 

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

Deprecated: Use CancelRunRequest.ProtoReflect.Descriptor instead.

func (*CancelRunRequest) GetId 

func (x *CancelRunRequest) GetId() string

func (*CancelRunRequest) GetSubmissionID 

func (x *CancelRunRequest) GetSubmissionID() string

func (*CancelRunRequest) GetWorkspaceID 

func (x *CancelRunRequest) GetWorkspaceID() string

func (*CancelRunRequest) ProtoMessage 

func (*CancelRunRequest) ProtoMessage()

func (*CancelRunRequest) ProtoReflect 

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

func (*CancelRunRequest) Reset 

func (x *CancelRunRequest) Reset()

func (*CancelRunRequest) String 

func (x *CancelRunRequest) String() string

type CancelRunResponse 

type CancelRunResponse struct {
	// contains filtered or unexported fields
}

func (*CancelRunResponse) Descriptor deprecated 

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

Deprecated: Use CancelRunResponse.ProtoReflect.Descriptor instead.

func (*CancelRunResponse) ProtoMessage 

func (*CancelRunResponse) ProtoMessage()

func (*CancelRunResponse) ProtoReflect 

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

func (*CancelRunResponse) Reset 

func (x *CancelRunResponse) Reset()

func (*CancelRunResponse) String 

func (x *CancelRunResponse) String() string

type CancelSubmissionRequest 

type CancelSubmissionRequest struct {
	WorkspaceID string `protobuf:"bytes,1,opt,name=workspaceID,proto3" json:"workspaceID,omitempty"`
	Id          string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelSubmissionRequest) Descriptor deprecated 

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

Deprecated: Use CancelSubmissionRequest.ProtoReflect.Descriptor instead.

func (*CancelSubmissionRequest) GetId 

func (x *CancelSubmissionRequest) GetId() string

func (*CancelSubmissionRequest) GetWorkspaceID 

func (x *CancelSubmissionRequest) GetWorkspaceID() string

func (*CancelSubmissionRequest) ProtoMessage 

func (*CancelSubmissionRequest) ProtoMessage()

func (*CancelSubmissionRequest) ProtoReflect 

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

func (*CancelSubmissionRequest) Reset 

func (x *CancelSubmissionRequest) Reset()

func (*CancelSubmissionRequest) String 

func (x *CancelSubmissionRequest) String() string

type CancelSubmissionResponse 

type CancelSubmissionResponse struct {
	// contains filtered or unexported fields
}

func (*CancelSubmissionResponse) Descriptor deprecated 

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

Deprecated: Use CancelSubmissionResponse.ProtoReflect.Descriptor instead.

func (*CancelSubmissionResponse) ProtoMessage 

func (*CancelSubmissionResponse) ProtoMessage()

func (*CancelSubmissionResponse) ProtoReflect 

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

func (*CancelSubmissionResponse) Reset 

func (x *CancelSubmissionResponse) Reset()

func (*CancelSubmissionResponse) String 

func (x *CancelSubmissionResponse) String() string

type CheckSubmissionRequest 

type CheckSubmissionRequest struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	WorkspaceID string `protobuf:"bytes,2,opt,name=workspaceID,proto3" json:"workspaceID,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckSubmissionRequest) Descriptor deprecated 

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

Deprecated: Use CheckSubmissionRequest.ProtoReflect.Descriptor instead.

func (*CheckSubmissionRequest) GetName 

func (x *CheckSubmissionRequest) GetName() string

func (*CheckSubmissionRequest) GetWorkspaceID 

func (x *CheckSubmissionRequest) GetWorkspaceID() string

func (*CheckSubmissionRequest) ProtoMessage 

func (*CheckSubmissionRequest) ProtoMessage()

func (*CheckSubmissionRequest) ProtoReflect 

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

func (*CheckSubmissionRequest) Reset 

func (x *CheckSubmissionRequest) Reset()

func (*CheckSubmissionRequest) String 

func (x *CheckSubmissionRequest) String() string

type CheckSubmissionResponse 

type CheckSubmissionResponse struct {
	IsNameExist bool `protobuf:"varint,1,opt,name=isNameExist,proto3" json:"isNameExist,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckSubmissionResponse) Descriptor deprecated 

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

Deprecated: Use CheckSubmissionResponse.ProtoReflect.Descriptor instead.

func (*CheckSubmissionResponse) GetIsNameExist 

func (x *CheckSubmissionResponse) GetIsNameExist() bool

func (*CheckSubmissionResponse) ProtoMessage 

func (*CheckSubmissionResponse) ProtoMessage()

func (*CheckSubmissionResponse) ProtoReflect 

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

func (*CheckSubmissionResponse) Reset 

func (x *CheckSubmissionResponse) Reset()

func (*CheckSubmissionResponse) String 

func (x *CheckSubmissionResponse) String() string

type CreateSubmissionRequest 

type CreateSubmissionRequest struct {
	WorkspaceID    string          `protobuf:"bytes,1,opt,name=workspaceID,proto3" json:"workspaceID,omitempty"`
	Name           string          `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	WorkflowID     string          `protobuf:"bytes,3,opt,name=workflowID,proto3" json:"workflowID,omitempty"`
	Description    string          `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Type           string          `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
	Entity         *Entity         `protobuf:"bytes,6,opt,name=entity,proto3" json:"entity,omitempty"`
	ExposedOptions *ExposedOptions `protobuf:"bytes,7,opt,name=exposedOptions,proto3" json:"exposedOptions,omitempty"`
	InOutMaterial  *InOutMaterial  `protobuf:"bytes,8,opt,name=inOutMaterial,proto3" json:"inOutMaterial,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSubmissionRequest) Descriptor deprecated 

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

Deprecated: Use CreateSubmissionRequest.ProtoReflect.Descriptor instead.

func (*CreateSubmissionRequest) GetDescription 

func (x *CreateSubmissionRequest) GetDescription() string

func (*CreateSubmissionRequest) GetEntity 

func (x *CreateSubmissionRequest) GetEntity() *Entity

func (*CreateSubmissionRequest) GetExposedOptions 

func (x *CreateSubmissionRequest) GetExposedOptions() *ExposedOptions

func (*CreateSubmissionRequest) GetInOutMaterial 

func (x *CreateSubmissionRequest) GetInOutMaterial() *InOutMaterial

func (*CreateSubmissionRequest) GetName 

func (x *CreateSubmissionRequest) GetName() string

func (*CreateSubmissionRequest) GetType 

func (x *CreateSubmissionRequest) GetType() string

func (*CreateSubmissionRequest) GetWorkflowID 

func (x *CreateSubmissionRequest) GetWorkflowID() string

func (*CreateSubmissionRequest) GetWorkspaceID 

func (x *CreateSubmissionRequest) GetWorkspaceID() string

func (*CreateSubmissionRequest) ProtoMessage 

func (*CreateSubmissionRequest) ProtoMessage()

func (*CreateSubmissionRequest) ProtoReflect 

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

func (*CreateSubmissionRequest) Reset 

func (x *CreateSubmissionRequest) Reset()

func (*CreateSubmissionRequest) String 

func (x *CreateSubmissionRequest) String() string

type CreateSubmissionResponse 

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

func (*CreateSubmissionResponse) Descriptor deprecated 

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

Deprecated: Use CreateSubmissionResponse.ProtoReflect.Descriptor instead.

func (*CreateSubmissionResponse) GetId 

func (x *CreateSubmissionResponse) GetId() string

func (*CreateSubmissionResponse) ProtoMessage 

func (*CreateSubmissionResponse) ProtoMessage()

func (*CreateSubmissionResponse) ProtoReflect 

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

func (*CreateSubmissionResponse) Reset 

func (x *CreateSubmissionResponse) Reset()

func (*CreateSubmissionResponse) String 

func (x *CreateSubmissionResponse) String() string

type DeleteSubmissionRequest 

type DeleteSubmissionRequest struct {
	WorkspaceID string `protobuf:"bytes,1,opt,name=workspaceID,proto3" json:"workspaceID,omitempty"`
	Id          string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSubmissionRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSubmissionRequest.ProtoReflect.Descriptor instead.

func (*DeleteSubmissionRequest) GetId 

func (x *DeleteSubmissionRequest) GetId() string

func (*DeleteSubmissionRequest) GetWorkspaceID 

func (x *DeleteSubmissionRequest) GetWorkspaceID() string

func (*DeleteSubmissionRequest) ProtoMessage 

func (*DeleteSubmissionRequest) ProtoMessage()

func (*DeleteSubmissionRequest) ProtoReflect 

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

func (*DeleteSubmissionRequest) Reset 

func (x *DeleteSubmissionRequest) Reset()

func (*DeleteSubmissionRequest) String 

func (x *DeleteSubmissionRequest) String() string

type DeleteSubmissionResponse 

type DeleteSubmissionResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteSubmissionResponse) Descriptor deprecated 

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

Deprecated: Use DeleteSubmissionResponse.ProtoReflect.Descriptor instead.

func (*DeleteSubmissionResponse) ProtoMessage 

func (*DeleteSubmissionResponse) ProtoMessage()

func (*DeleteSubmissionResponse) ProtoReflect 

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

func (*DeleteSubmissionResponse) Reset 

func (x *DeleteSubmissionResponse) Reset()

func (*DeleteSubmissionResponse) String 

func (x *DeleteSubmissionResponse) String() string

type Entity 

type Entity struct {
	DataModelID     string   `protobuf:"bytes,1,opt,name=dataModelID,proto3" json:"dataModelID,omitempty"`
	DataModelRowIDs []string `protobuf:"bytes,2,rep,name=dataModelRowIDs,proto3" json:"dataModelRowIDs,omitempty"`
	InputsTemplate  string   `protobuf:"bytes,3,opt,name=inputsTemplate,proto3" json:"inputsTemplate,omitempty"`
	OutputsTemplate string   `protobuf:"bytes,4,opt,name=outputsTemplate,proto3" json:"outputsTemplate,omitempty"`
	// contains filtered or unexported fields
}

func (*Entity) Descriptor deprecated 

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

Deprecated: Use Entity.ProtoReflect.Descriptor instead.

func (*Entity) GetDataModelID 

func (x *Entity) GetDataModelID() string

func (*Entity) GetDataModelRowIDs 

func (x *Entity) GetDataModelRowIDs() []string

func (*Entity) GetInputsTemplate 

func (x *Entity) GetInputsTemplate() string

func (*Entity) GetOutputsTemplate 

func (x *Entity) GetOutputsTemplate() string

func (*Entity) ProtoMessage 

func (*Entity) ProtoMessage()

func (*Entity) ProtoReflect 

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

func (*Entity) Reset 

func (x *Entity) Reset()

func (*Entity) String 

func (x *Entity) String() string

type ExposedOptions 

type ExposedOptions struct {
	ReadFromCache bool `protobuf:"varint,1,opt,name=readFromCache,proto3" json:"readFromCache,omitempty"`
	// contains filtered or unexported fields
}

func (*ExposedOptions) Descriptor deprecated 

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

Deprecated: Use ExposedOptions.ProtoReflect.Descriptor instead.

func (*ExposedOptions) GetReadFromCache 

func (x *ExposedOptions) GetReadFromCache() bool

func (*ExposedOptions) ProtoMessage 

func (*ExposedOptions) ProtoMessage()

func (*ExposedOptions) ProtoReflect 

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

func (*ExposedOptions) Reset 

func (x *ExposedOptions) Reset()

func (*ExposedOptions) String 

func (x *ExposedOptions) String() string

type InOutMaterial 

type InOutMaterial struct {
	InputsMaterial  string `protobuf:"bytes,1,opt,name=inputsMaterial,proto3" json:"inputsMaterial,omitempty"`
	OutputsMaterial string `protobuf:"bytes,2,opt,name=outputsMaterial,proto3" json:"outputsMaterial,omitempty"`
	// contains filtered or unexported fields
}

func (*InOutMaterial) Descriptor deprecated 

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

Deprecated: Use InOutMaterial.ProtoReflect.Descriptor instead.

func (*InOutMaterial) GetInputsMaterial 

func (x *InOutMaterial) GetInputsMaterial() string

func (*InOutMaterial) GetOutputsMaterial 

func (x *InOutMaterial) GetOutputsMaterial() string

func (*InOutMaterial) ProtoMessage 

func (*InOutMaterial) ProtoMessage()

func (*InOutMaterial) ProtoReflect 

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

func (*InOutMaterial) Reset 

func (x *InOutMaterial) Reset()

func (*InOutMaterial) String 

func (x *InOutMaterial) String() string

type ListRunsRequest 

type ListRunsRequest struct {
	WorkspaceID  string   `protobuf:"bytes,1,opt,name=workspaceID,proto3" json:"workspaceID,omitempty"`
	SubmissionID string   `protobuf:"bytes,2,opt,name=submissionID,proto3" json:"submissionID,omitempty"`
	Page         int32    `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"`
	Size         int32    `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	OrderBy      string   `protobuf:"bytes,5,opt,name=orderBy,proto3" json:"orderBy,omitempty"`
	SearchWord   string   `protobuf:"bytes,6,opt,name=searchWord,proto3" json:"searchWord,omitempty"`
	Status       []string `protobuf:"bytes,7,rep,name=status,proto3" json:"status,omitempty"`
	Ids          []string `protobuf:"bytes,8,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRunsRequest) Descriptor deprecated 

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

Deprecated: Use ListRunsRequest.ProtoReflect.Descriptor instead.

func (*ListRunsRequest) GetIds 

func (x *ListRunsRequest) GetIds() []string

func (*ListRunsRequest) GetOrderBy 

func (x *ListRunsRequest) GetOrderBy() string

func (*ListRunsRequest) GetPage 

func (x *ListRunsRequest) GetPage() int32

func (*ListRunsRequest) GetSearchWord 

func (x *ListRunsRequest) GetSearchWord() string

func (*ListRunsRequest) GetSize 

func (x *ListRunsRequest) GetSize() int32

func (*ListRunsRequest) GetStatus 

func (x *ListRunsRequest) GetStatus() []string

func (*ListRunsRequest) GetSubmissionID 

func (x *ListRunsRequest) GetSubmissionID() string

func (*ListRunsRequest) GetWorkspaceID 

func (x *ListRunsRequest) GetWorkspaceID() string

func (*ListRunsRequest) ProtoMessage 

func (*ListRunsRequest) ProtoMessage()

func (*ListRunsRequest) ProtoReflect 

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

func (*ListRunsRequest) Reset 

func (x *ListRunsRequest) Reset()

func (*ListRunsRequest) String 

func (x *ListRunsRequest) String() string

type ListRunsResponse 

type ListRunsResponse struct {
	Page  int32      `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`
	Size  int32      `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Total int32      `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"`
	Items []*RunItem `protobuf:"bytes,4,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRunsResponse) Descriptor deprecated 

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

Deprecated: Use ListRunsResponse.ProtoReflect.Descriptor instead.

func (*ListRunsResponse) GetItems 

func (x *ListRunsResponse) GetItems() []*RunItem

func (*ListRunsResponse) GetPage 

func (x *ListRunsResponse) GetPage() int32

func (*ListRunsResponse) GetSize 

func (x *ListRunsResponse) GetSize() int32

func (*ListRunsResponse) GetTotal 

func (x *ListRunsResponse) GetTotal() int32

func (*ListRunsResponse) ProtoMessage 

func (*ListRunsResponse) ProtoMessage()

func (*ListRunsResponse) ProtoReflect 

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

func (*ListRunsResponse) Reset 

func (x *ListRunsResponse) Reset()

func (*ListRunsResponse) String 

func (x *ListRunsResponse) String() string

type ListSubmissionsRequest 

type ListSubmissionsRequest struct {
	WorkspaceID string   `protobuf:"bytes,1,opt,name=workspaceID,proto3" json:"workspaceID,omitempty"`
	Page        int32    `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	Size        int32    `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	OrderBy     string   `protobuf:"bytes,4,opt,name=orderBy,proto3" json:"orderBy,omitempty"`
	SearchWord  string   `protobuf:"bytes,5,opt,name=searchWord,proto3" json:"searchWord,omitempty"`
	WorkflowID  string   `protobuf:"bytes,6,opt,name=workflowID,proto3" json:"workflowID,omitempty"`
	Status      []string `protobuf:"bytes,7,rep,name=status,proto3" json:"status,omitempty"`
	Ids         []string `protobuf:"bytes,8,rep,name=ids,proto3" json:"ids,omitempty"`
	Exact       bool     `protobuf:"varint,9,opt,name=exact,proto3" json:"exact,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSubmissionsRequest) Descriptor deprecated 

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

Deprecated: Use ListSubmissionsRequest.ProtoReflect.Descriptor instead.

func (*ListSubmissionsRequest) GetExact 

func (x *ListSubmissionsRequest) GetExact() bool

func (*ListSubmissionsRequest) GetIds 

func (x *ListSubmissionsRequest) GetIds() []string

func (*ListSubmissionsRequest) GetOrderBy 

func (x *ListSubmissionsRequest) GetOrderBy() string

func (*ListSubmissionsRequest) GetPage 

func (x *ListSubmissionsRequest) GetPage() int32

func (*ListSubmissionsRequest) GetSearchWord 

func (x *ListSubmissionsRequest) GetSearchWord() string

func (*ListSubmissionsRequest) GetSize 

func (x *ListSubmissionsRequest) GetSize() int32

func (*ListSubmissionsRequest) GetStatus 

func (x *ListSubmissionsRequest) GetStatus() []string

func (*ListSubmissionsRequest) GetWorkflowID 

func (x *ListSubmissionsRequest) GetWorkflowID() string

func (*ListSubmissionsRequest) GetWorkspaceID 

func (x *ListSubmissionsRequest) GetWorkspaceID() string

func (*ListSubmissionsRequest) ProtoMessage 

func (*ListSubmissionsRequest) ProtoMessage()

func (*ListSubmissionsRequest) ProtoReflect 

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

func (*ListSubmissionsRequest) Reset 

func (x *ListSubmissionsRequest) Reset()

func (*ListSubmissionsRequest) String 

func (x *ListSubmissionsRequest) String() string

type ListSubmissionsResponse 

type ListSubmissionsResponse struct {
	Page  int32             `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`
	Size  int32             `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Total int32             `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"`
	Items []*SubmissionItem `protobuf:"bytes,4,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSubmissionsResponse) Descriptor deprecated 

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

Deprecated: Use ListSubmissionsResponse.ProtoReflect.Descriptor instead.

func (*ListSubmissionsResponse) GetItems 

func (x *ListSubmissionsResponse) GetItems() []*SubmissionItem

func (*ListSubmissionsResponse) GetPage 

func (x *ListSubmissionsResponse) GetPage() int32

func (*ListSubmissionsResponse) GetSize 

func (x *ListSubmissionsResponse) GetSize() int32

func (*ListSubmissionsResponse) GetTotal 

func (x *ListSubmissionsResponse) GetTotal() int32

func (*ListSubmissionsResponse) ProtoMessage 

func (*ListSubmissionsResponse) ProtoMessage()

func (*ListSubmissionsResponse) ProtoReflect 

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

func (*ListSubmissionsResponse) Reset 

func (x *ListSubmissionsResponse) Reset()

func (*ListSubmissionsResponse) String 

func (x *ListSubmissionsResponse) String() string

type ListTasksRequest 

type ListTasksRequest struct {
	WorkspaceID  string `protobuf:"bytes,1,opt,name=workspaceID,proto3" json:"workspaceID,omitempty"`
	SubmissionID string `protobuf:"bytes,2,opt,name=submissionID,proto3" json:"submissionID,omitempty"`
	RunID        string `protobuf:"bytes,3,opt,name=runID,proto3" json:"runID,omitempty"`
	Page         int32  `protobuf:"varint,4,opt,name=page,proto3" json:"page,omitempty"`
	Size         int32  `protobuf:"varint,5,opt,name=size,proto3" json:"size,omitempty"`
	OrderBy      string `protobuf:"bytes,6,opt,name=orderBy,proto3" json:"orderBy,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksRequest) Descriptor deprecated 

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

Deprecated: Use ListTasksRequest.ProtoReflect.Descriptor instead.

func (*ListTasksRequest) GetOrderBy 

func (x *ListTasksRequest) GetOrderBy() string

func (*ListTasksRequest) GetPage 

func (x *ListTasksRequest) GetPage() int32

func (*ListTasksRequest) GetRunID 

func (x *ListTasksRequest) GetRunID() string

func (*ListTasksRequest) GetSize 

func (x *ListTasksRequest) GetSize() int32

func (*ListTasksRequest) GetSubmissionID 

func (x *ListTasksRequest) GetSubmissionID() string

func (*ListTasksRequest) GetWorkspaceID 

func (x *ListTasksRequest) GetWorkspaceID() string

func (*ListTasksRequest) ProtoMessage 

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) ProtoReflect 

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

func (*ListTasksRequest) Reset 

func (x *ListTasksRequest) Reset()

func (*ListTasksRequest) String 

func (x *ListTasksRequest) String() string

type ListTasksResponse 

type ListTasksResponse struct {
	Page  int32       `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`
	Size  int32       `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Total int32       `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"`
	Items []*TaskItem `protobuf:"bytes,4,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksResponse) Descriptor deprecated 

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

Deprecated: Use ListTasksResponse.ProtoReflect.Descriptor instead.

func (*ListTasksResponse) GetItems 

func (x *ListTasksResponse) GetItems() []*TaskItem

func (*ListTasksResponse) GetPage 

func (x *ListTasksResponse) GetPage() int32

func (*ListTasksResponse) GetSize 

func (x *ListTasksResponse) GetSize() int32

func (*ListTasksResponse) GetTotal 

func (x *ListTasksResponse) GetTotal() int32

func (*ListTasksResponse) ProtoMessage 

func (*ListTasksResponse) ProtoMessage()

func (*ListTasksResponse) ProtoReflect 

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

func (*ListTasksResponse) Reset 

func (x *ListTasksResponse) Reset()

func (*ListTasksResponse) String 

func (x *ListTasksResponse) String() string

type RunItem 

type RunItem struct {
	Id          string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Status      string  `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	StartTime   int64   `protobuf:"varint,4,opt,name=startTime,proto3" json:"startTime,omitempty"`
	FinishTime  int64   `protobuf:"varint,5,opt,name=finishTime,proto3" json:"finishTime,omitempty"`
	Duration    int64   `protobuf:"varint,6,opt,name=duration,proto3" json:"duration,omitempty"`
	EngineRunID string  `protobuf:"bytes,7,opt,name=engineRunID,proto3" json:"engineRunID,omitempty"`
	Inputs      string  `protobuf:"bytes,8,opt,name=inputs,proto3" json:"inputs,omitempty"`
	Outputs     string  `protobuf:"bytes,9,opt,name=outputs,proto3" json:"outputs,omitempty"`
	TaskStatus  *Status `protobuf:"bytes,10,opt,name=taskStatus,proto3" json:"taskStatus,omitempty"`
	Log         string  `protobuf:"bytes,11,opt,name=log,proto3" json:"log,omitempty"`
	Message     string  `protobuf:"bytes,12,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*RunItem) Descriptor deprecated 

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

Deprecated: Use RunItem.ProtoReflect.Descriptor instead.

func (*RunItem) GetDuration 

func (x *RunItem) GetDuration() int64

func (*RunItem) GetEngineRunID 

func (x *RunItem) GetEngineRunID() string

func (*RunItem) GetFinishTime 

func (x *RunItem) GetFinishTime() int64

func (*RunItem) GetId 

func (x *RunItem) GetId() string

func (*RunItem) GetInputs 

func (x *RunItem) GetInputs() string

func (*RunItem) GetLog 

func (x *RunItem) GetLog() string

func (*RunItem) GetMessage 

func (x *RunItem) GetMessage() string

func (*RunItem) GetName 

func (x *RunItem) GetName() string

func (*RunItem) GetOutputs 

func (x *RunItem) GetOutputs() string

func (*RunItem) GetStartTime 

func (x *RunItem) GetStartTime() int64

func (*RunItem) GetStatus 

func (x *RunItem) GetStatus() string

func (*RunItem) GetTaskStatus 

func (x *RunItem) GetTaskStatus() *Status

func (*RunItem) ProtoMessage 

func (*RunItem) ProtoMessage()

func (*RunItem) ProtoReflect 

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

func (*RunItem) Reset 

func (x *RunItem) Reset()

func (*RunItem) String 

func (x *RunItem) String() string

type Status 

type Status struct {
	Count        int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Pending      int64 `protobuf:"varint,2,opt,name=pending,proto3" json:"pending,omitempty"`
	Succeeded    int64 `protobuf:"varint,3,opt,name=succeeded,proto3" json:"succeeded,omitempty"`
	Failed       int64 `protobuf:"varint,4,opt,name=failed,proto3" json:"failed,omitempty"`
	Running      int64 `protobuf:"varint,5,opt,name=running,proto3" json:"running,omitempty"`
	Cancelling   int64 `protobuf:"varint,6,opt,name=cancelling,proto3" json:"cancelling,omitempty"`
	Cancelled    int64 `protobuf:"varint,7,opt,name=cancelled,proto3" json:"cancelled,omitempty"`
	Queued       int64 `protobuf:"varint,8,opt,name=queued,proto3" json:"queued,omitempty"`
	Initializing int64 `protobuf:"varint,9,opt,name=initializing,proto3" json:"initializing,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCancelled 

func (x *Status) GetCancelled() int64

func (*Status) GetCancelling 

func (x *Status) GetCancelling() int64

func (*Status) GetCount 

func (x *Status) GetCount() int64

func (*Status) GetFailed 

func (x *Status) GetFailed() int64

func (*Status) GetInitializing 

func (x *Status) GetInitializing() int64

func (*Status) GetPending 

func (x *Status) GetPending() int64

func (*Status) GetQueued 

func (x *Status) GetQueued() int64

func (*Status) GetRunning 

func (x *Status) GetRunning() int64

func (*Status) GetSucceeded 

func (x *Status) GetSucceeded() int64

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type SubmissionErrorReason 

type SubmissionErrorReason int32
const (
	SubmissionErrorReason_SUBMISSION_NOT_FOUND      SubmissionErrorReason = 0
	SubmissionErrorReason_SUBMISSION_VALIDATE_ERROR SubmissionErrorReason = 1
)

func (SubmissionErrorReason) Descriptor 

func (SubmissionErrorReason) Descriptor() protoreflect.EnumDescriptor

func (SubmissionErrorReason) Enum 

func (x SubmissionErrorReason) Enum() *SubmissionErrorReason

func (SubmissionErrorReason) EnumDescriptor deprecated 

func (SubmissionErrorReason) EnumDescriptor() ([]byte, []int)

Deprecated: Use SubmissionErrorReason.Descriptor instead.

func (SubmissionErrorReason) Number 

func (x SubmissionErrorReason) Number() protoreflect.EnumNumber

func (SubmissionErrorReason) String 

func (x SubmissionErrorReason) String() string

func (SubmissionErrorReason) Type 

func (SubmissionErrorReason) Type() protoreflect.EnumType

type SubmissionItem 

type SubmissionItem struct {
	Id              string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name            string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description     string               `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Type            string               `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Status          string               `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	StartTime       int64                `protobuf:"varint,6,opt,name=startTime,proto3" json:"startTime,omitempty"`
	FinishTime      int64                `protobuf:"varint,7,opt,name=finishTime,proto3" json:"finishTime,omitempty"`
	Duration        int64                `protobuf:"varint,8,opt,name=duration,proto3" json:"duration,omitempty"`
	WorkflowVersion *WorkflowVersionInfo `protobuf:"bytes,9,opt,name=workflowVersion,proto3" json:"workflowVersion,omitempty"`
	RunStatus       *Status              `protobuf:"bytes,10,opt,name=runStatus,proto3" json:"runStatus,omitempty"`
	Entity          *Entity              `protobuf:"bytes,11,opt,name=entity,proto3" json:"entity,omitempty"`
	ExposedOptions  *ExposedOptions      `protobuf:"bytes,12,opt,name=exposedOptions,proto3" json:"exposedOptions,omitempty"`
	InOutMaterial   *InOutMaterial       `protobuf:"bytes,13,opt,name=inOutMaterial,proto3" json:"inOutMaterial,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmissionItem) Descriptor deprecated 

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

Deprecated: Use SubmissionItem.ProtoReflect.Descriptor instead.

func (*SubmissionItem) GetDescription 

func (x *SubmissionItem) GetDescription() string

func (*SubmissionItem) GetDuration 

func (x *SubmissionItem) GetDuration() int64

func (*SubmissionItem) GetEntity 

func (x *SubmissionItem) GetEntity() *Entity

func (*SubmissionItem) GetExposedOptions 

func (x *SubmissionItem) GetExposedOptions() *ExposedOptions

func (*SubmissionItem) GetFinishTime 

func (x *SubmissionItem) GetFinishTime() int64

func (*SubmissionItem) GetId 

func (x *SubmissionItem) GetId() string

func (*SubmissionItem) GetInOutMaterial 

func (x *SubmissionItem) GetInOutMaterial() *InOutMaterial

func (*SubmissionItem) GetName 

func (x *SubmissionItem) GetName() string

func (*SubmissionItem) GetRunStatus 

func (x *SubmissionItem) GetRunStatus() *Status

func (*SubmissionItem) GetStartTime 

func (x *SubmissionItem) GetStartTime() int64

func (*SubmissionItem) GetStatus 

func (x *SubmissionItem) GetStatus() string

func (*SubmissionItem) GetType 

func (x *SubmissionItem) GetType() string

func (*SubmissionItem) GetWorkflowVersion 

func (x *SubmissionItem) GetWorkflowVersion() *WorkflowVersionInfo

func (*SubmissionItem) ProtoMessage 

func (*SubmissionItem) ProtoMessage()

func (*SubmissionItem) ProtoReflect 

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

func (*SubmissionItem) Reset 

func (x *SubmissionItem) Reset()

func (*SubmissionItem) String 

func (x *SubmissionItem) String() string

type SubmissionServiceClient 

type SubmissionServiceClient interface {
	CheckSubmission(ctx context.Context, in *CheckSubmissionRequest, opts ...grpc.CallOption) (*CheckSubmissionResponse, error)
	ListSubmissions(ctx context.Context, in *ListSubmissionsRequest, opts ...grpc.CallOption) (*ListSubmissionsResponse, error)
	CreateSubmission(ctx context.Context, in *CreateSubmissionRequest, opts ...grpc.CallOption) (*CreateSubmissionResponse, error)
	DeleteSubmission(ctx context.Context, in *DeleteSubmissionRequest, opts ...grpc.CallOption) (*DeleteSubmissionResponse, error)
	CancelSubmission(ctx context.Context, in *CancelSubmissionRequest, opts ...grpc.CallOption) (*CancelSubmissionResponse, error)
	ListRuns(ctx context.Context, in *ListRunsRequest, opts ...grpc.CallOption) (*ListRunsResponse, error)
	CancelRun(ctx context.Context, in *CancelRunRequest, opts ...grpc.CallOption) (*CancelRunResponse, error)
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
}

SubmissionServiceClient is the client API for SubmissionService 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 NewSubmissionServiceClient 

func NewSubmissionServiceClient(cc grpc.ClientConnInterface) SubmissionServiceClient

type SubmissionServiceServer 

type SubmissionServiceServer interface {
	CheckSubmission(context.Context, *CheckSubmissionRequest) (*CheckSubmissionResponse, error)
	ListSubmissions(context.Context, *ListSubmissionsRequest) (*ListSubmissionsResponse, error)
	CreateSubmission(context.Context, *CreateSubmissionRequest) (*CreateSubmissionResponse, error)
	DeleteSubmission(context.Context, *DeleteSubmissionRequest) (*DeleteSubmissionResponse, error)
	CancelSubmission(context.Context, *CancelSubmissionRequest) (*CancelSubmissionResponse, error)
	ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error)
	CancelRun(context.Context, *CancelRunRequest) (*CancelRunResponse, error)
	ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
	// contains filtered or unexported methods
}

SubmissionServiceServer is the server API for SubmissionService service. All implementations must embed UnimplementedSubmissionServiceServer for forward compatibility

type TaskItem 

type TaskItem struct {
	Name       string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	RunID      string `protobuf:"bytes,2,opt,name=runID,proto3" json:"runID,omitempty"`
	Status     string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	StartTime  int64  `protobuf:"varint,4,opt,name=startTime,proto3" json:"startTime,omitempty"`
	FinishTime int64  `protobuf:"varint,5,opt,name=finishTime,proto3" json:"finishTime,omitempty"`
	Duration   int64  `protobuf:"varint,6,opt,name=duration,proto3" json:"duration,omitempty"`
	Stdout     string `protobuf:"bytes,7,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr     string `protobuf:"bytes,8,opt,name=stderr,proto3" json:"stderr,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskItem) Descriptor deprecated 

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

Deprecated: Use TaskItem.ProtoReflect.Descriptor instead.

func (*TaskItem) GetDuration 

func (x *TaskItem) GetDuration() int64

func (*TaskItem) GetFinishTime 

func (x *TaskItem) GetFinishTime() int64

func (*TaskItem) GetName 

func (x *TaskItem) GetName() string

func (*TaskItem) GetRunID 

func (x *TaskItem) GetRunID() string

func (*TaskItem) GetStartTime 

func (x *TaskItem) GetStartTime() int64

func (*TaskItem) GetStatus 

func (x *TaskItem) GetStatus() string

func (*TaskItem) GetStderr 

func (x *TaskItem) GetStderr() string

func (*TaskItem) GetStdout 

func (x *TaskItem) GetStdout() string

func (*TaskItem) ProtoMessage 

func (*TaskItem) ProtoMessage()

func (*TaskItem) ProtoReflect 

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

func (*TaskItem) Reset 

func (x *TaskItem) Reset()

func (*TaskItem) String 

func (x *TaskItem) String() string

type UnimplementedSubmissionServiceServer 

type UnimplementedSubmissionServiceServer struct {
}

UnimplementedSubmissionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSubmissionServiceServer) CancelRun 

func (UnimplementedSubmissionServiceServer) CancelRun(context.Context, *CancelRunRequest) (*CancelRunResponse, error)

func (UnimplementedSubmissionServiceServer) CancelSubmission 

func (UnimplementedSubmissionServiceServer) CancelSubmission(context.Context, *CancelSubmissionRequest) (*CancelSubmissionResponse, error)

func (UnimplementedSubmissionServiceServer) CheckSubmission 

func (UnimplementedSubmissionServiceServer) CheckSubmission(context.Context, *CheckSubmissionRequest) (*CheckSubmissionResponse, error)

func (UnimplementedSubmissionServiceServer) CreateSubmission 

func (UnimplementedSubmissionServiceServer) CreateSubmission(context.Context, *CreateSubmissionRequest) (*CreateSubmissionResponse, error)

func (UnimplementedSubmissionServiceServer) DeleteSubmission 

func (UnimplementedSubmissionServiceServer) DeleteSubmission(context.Context, *DeleteSubmissionRequest) (*DeleteSubmissionResponse, error)

func (UnimplementedSubmissionServiceServer) ListRuns 

func (UnimplementedSubmissionServiceServer) ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error)

func (UnimplementedSubmissionServiceServer) ListSubmissions 

func (UnimplementedSubmissionServiceServer) ListSubmissions(context.Context, *ListSubmissionsRequest) (*ListSubmissionsResponse, error)

func (UnimplementedSubmissionServiceServer) ListTasks 

func (UnimplementedSubmissionServiceServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)

type UnsafeSubmissionServiceServer 

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

UnsafeSubmissionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SubmissionServiceServer will result in compilation errors.

type WorkflowVersionInfo 

type WorkflowVersionInfo struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	VersionID string `protobuf:"bytes,2,opt,name=versionID,proto3" json:"versionID,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowVersionInfo) Descriptor deprecated 

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

Deprecated: Use WorkflowVersionInfo.ProtoReflect.Descriptor instead.

func (*WorkflowVersionInfo) GetId 

func (x *WorkflowVersionInfo) GetId() string

func (*WorkflowVersionInfo) GetVersionID 

func (x *WorkflowVersionInfo) GetVersionID() string

func (*WorkflowVersionInfo) ProtoMessage 

func (*WorkflowVersionInfo) ProtoMessage()

func (*WorkflowVersionInfo) ProtoReflect 

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

func (*WorkflowVersionInfo) Reset 

func (x *WorkflowVersionInfo) Reset()

func (*WorkflowVersionInfo) String 

func (x *WorkflowVersionInfo) String() string

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.