transferservicev1beta1

package
v1.36.11-2024092708402... Latest Latest
Warning

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

 Go to latest Published: unknown License: AGPL-3.0 Imports: 5 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	PackageStatus_name = map[int32]string{
		0: "PACKAGE_STATUS_UNSPECIFIED",
		1: "PACKAGE_STATUS_FAILED",
		2: "PACKAGE_STATUS_REJECTED",
		3: "PACKAGE_STATUS_COMPLETE",
		4: "PACKAGE_STATUS_PROCESSING",
	}
	PackageStatus_value = map[string]int32{
		"PACKAGE_STATUS_UNSPECIFIED": 0,
		"PACKAGE_STATUS_FAILED":      1,
		"PACKAGE_STATUS_REJECTED":    2,
		"PACKAGE_STATUS_COMPLETE":    3,
		"PACKAGE_STATUS_PROCESSING":  4,
	}
)

Enum value maps for PackageStatus.

View Source 
var (
	Job_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "STATUS_COMPLETE",
		2: "STATUS_PROCESSING",
		3: "STATUS_FAILED",
	}
	Job_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"STATUS_COMPLETE":    1,
		"STATUS_PROCESSING":  2,
		"STATUS_FAILED":      3,
	}
)

Enum value maps for Job_Status.

View Source 
var (
	ProcessingConfig_AIPCompressionAlgorithm_name = map[int32]string{
		0: "AIP_COMPRESSION_ALGORITHM_UNSPECIFIED",
		1: "AIP_COMPRESSION_ALGORITHM_UNCOMPRESSED",
		2: "AIP_COMPRESSION_ALGORITHM_TAR",
		3: "AIP_COMPRESSION_ALGORITHM_TAR_BZIP2",
		4: "AIP_COMPRESSION_ALGORITHM_TAR_GZIP",
		5: "AIP_COMPRESSION_ALGORITHM_S7_COPY",
		6: "AIP_COMPRESSION_ALGORITHM_S7_BZIP2",
		7: "AIP_COMPRESSION_ALGORITHM_S7_LZMA",
	}
	ProcessingConfig_AIPCompressionAlgorithm_value = map[string]int32{
		"AIP_COMPRESSION_ALGORITHM_UNSPECIFIED":  0,
		"AIP_COMPRESSION_ALGORITHM_UNCOMPRESSED": 1,
		"AIP_COMPRESSION_ALGORITHM_TAR":          2,
		"AIP_COMPRESSION_ALGORITHM_TAR_BZIP2":    3,
		"AIP_COMPRESSION_ALGORITHM_TAR_GZIP":     4,
		"AIP_COMPRESSION_ALGORITHM_S7_COPY":      5,
		"AIP_COMPRESSION_ALGORITHM_S7_BZIP2":     6,
		"AIP_COMPRESSION_ALGORITHM_S7_LZMA":      7,
	}
)

Enum value maps for ProcessingConfig_AIPCompressionAlgorithm.

View Source 
var File_a3m_api_transferservice_v1beta1_request_response_proto protoreflect.FileDescriptor
View Source 
var File_a3m_api_transferservice_v1beta1_service_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type EmptyRequest 

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

func (*EmptyRequest) ProtoMessage 

func (*EmptyRequest) ProtoMessage()

func (*EmptyRequest) ProtoReflect 

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

func (*EmptyRequest) Reset 

func (x *EmptyRequest) Reset()

func (*EmptyRequest) String 

func (x *EmptyRequest) String() string

type EmptyRequest_builder 

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

func (EmptyRequest_builder) Build 

func (b0 EmptyRequest_builder) Build() *EmptyRequest

type EmptyResponse 

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

func (*EmptyResponse) ProtoMessage 

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) ProtoReflect 

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

func (*EmptyResponse) Reset 

func (x *EmptyResponse) Reset()

func (*EmptyResponse) String 

func (x *EmptyResponse) String() string

type EmptyResponse_builder 

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

func (EmptyResponse_builder) Build 

func (b0 EmptyResponse_builder) Build() *EmptyResponse

type Job 

type Job 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"`
	Group     string                 `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	LinkId    string                 `protobuf:"bytes,4,opt,name=link_id,json=linkId,proto3" json:"link_id,omitempty"`
	Status    Job_Status             `protobuf:"varint,5,opt,name=status,proto3,enum=a3m.api.transferservice.v1beta1.Job_Status" json:"status,omitempty"`
	StartTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// contains filtered or unexported fields
}

func (*Job) ClearStartTime 

func (x *Job) ClearStartTime()

func (*Job) GetGroup 

func (x *Job) GetGroup() string

func (*Job) GetId 

func (x *Job) GetId() string

func (*Job) GetLinkId 

func (x *Job) GetLinkId() string

func (*Job) GetName 

func (x *Job) GetName() string

func (*Job) GetStartTime 

func (x *Job) GetStartTime() *timestamppb.Timestamp

func (*Job) GetStatus 

func (x *Job) GetStatus() Job_Status

func (*Job) HasStartTime 

func (x *Job) HasStartTime() bool

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

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

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) SetGroup 

func (x *Job) SetGroup(v string)

func (*Job) SetId 

func (x *Job) SetId(v string)

func (*Job) SetLinkId 

func (x *Job) SetLinkId(v string)

func (*Job) SetName 

func (x *Job) SetName(v string)

func (*Job) SetStartTime 

func (x *Job) SetStartTime(v *timestamppb.Timestamp)

func (*Job) SetStatus 

func (x *Job) SetStatus(v Job_Status)

func (*Job) String 

func (x *Job) String() string

type Job_Status 

type Job_Status int32
const (
	Job_STATUS_UNSPECIFIED Job_Status = 0
	Job_STATUS_COMPLETE    Job_Status = 1
	Job_STATUS_PROCESSING  Job_Status = 2
	Job_STATUS_FAILED      Job_Status = 3
)

func (Job_Status) Descriptor 

func (Job_Status) Descriptor() protoreflect.EnumDescriptor

func (Job_Status) Enum 

func (x Job_Status) Enum() *Job_Status

func (Job_Status) Number 

func (x Job_Status) Number() protoreflect.EnumNumber

func (Job_Status) String 

func (x Job_Status) String() string

func (Job_Status) Type 

func (Job_Status) Type() protoreflect.EnumType

type Job_builder 

type Job_builder struct {
	Id        string
	Name      string
	Group     string
	LinkId    string
	Status    Job_Status
	StartTime *timestamppb.Timestamp
	// contains filtered or unexported fields
}

func (Job_builder) Build 

func (b0 Job_builder) Build() *Job

type ListTasksRequest 

type ListTasksRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksRequest) GetJobId 

func (x *ListTasksRequest) GetJobId() 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) SetJobId 

func (x *ListTasksRequest) SetJobId(v string)

func (*ListTasksRequest) String 

func (x *ListTasksRequest) String() string

type ListTasksRequest_builder 

type ListTasksRequest_builder struct {
	JobId string
	// contains filtered or unexported fields
}

func (ListTasksRequest_builder) Build 

func (b0 ListTasksRequest_builder) Build() *ListTasksRequest

type ListTasksResponse 

type ListTasksResponse struct {
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksResponse) GetTasks 

func (x *ListTasksResponse) GetTasks() []*Task

func (*ListTasksResponse) ProtoMessage 

func (*ListTasksResponse) ProtoMessage()

func (*ListTasksResponse) ProtoReflect 

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

func (*ListTasksResponse) Reset 

func (x *ListTasksResponse) Reset()

func (*ListTasksResponse) SetTasks 

func (x *ListTasksResponse) SetTasks(v []*Task)

func (*ListTasksResponse) String 

func (x *ListTasksResponse) String() string

type ListTasksResponse_builder 

type ListTasksResponse_builder struct {
	Tasks []*Task
	// contains filtered or unexported fields
}

func (ListTasksResponse_builder) Build 

func (b0 ListTasksResponse_builder) Build() *ListTasksResponse

type PackageStatus 

type PackageStatus int32
const (
	PackageStatus_PACKAGE_STATUS_UNSPECIFIED PackageStatus = 0
	PackageStatus_PACKAGE_STATUS_FAILED      PackageStatus = 1
	PackageStatus_PACKAGE_STATUS_REJECTED    PackageStatus = 2
	PackageStatus_PACKAGE_STATUS_COMPLETE    PackageStatus = 3
	PackageStatus_PACKAGE_STATUS_PROCESSING  PackageStatus = 4
)

func (PackageStatus) Descriptor 

func (PackageStatus) Descriptor() protoreflect.EnumDescriptor

func (PackageStatus) Enum 

func (x PackageStatus) Enum() *PackageStatus

func (PackageStatus) Number 

func (x PackageStatus) Number() protoreflect.EnumNumber

func (PackageStatus) String 

func (x PackageStatus) String() string

func (PackageStatus) Type 

func (PackageStatus) Type() protoreflect.EnumType

type ProcessingConfig 

type ProcessingConfig struct {
	AssignUuidsToDirectories        bool `` /* 138-byte string literal not displayed */
	ExamineContents                 bool `protobuf:"varint,2,opt,name=examine_contents,json=examineContents,proto3" json:"examine_contents,omitempty"`
	GenerateTransferStructureReport bool `` /* 159-byte string literal not displayed */
	DocumentEmptyDirectories        bool `` /* 136-byte string literal not displayed */
	ExtractPackages                 bool `protobuf:"varint,5,opt,name=extract_packages,json=extractPackages,proto3" json:"extract_packages,omitempty"`
	DeletePackagesAfterExtraction   bool `` /* 153-byte string literal not displayed */
	IdentifyTransfer                bool `protobuf:"varint,7,opt,name=identify_transfer,json=identifyTransfer,proto3" json:"identify_transfer,omitempty"`
	// identify_submission_and_metadata represents a single configuration
	// attribute that controls two separate file format identification jobs
	// in the workflow: one for objects/submissionDocumentation and one
	// for objects/metadata
	IdentifySubmissionAndMetadata                bool `` /* 153-byte string literal not displayed */
	IdentifyBeforeNormalization                  bool `` /* 145-byte string literal not displayed */
	Normalize                                    bool `protobuf:"varint,10,opt,name=normalize,proto3" json:"normalize,omitempty"`
	TranscribeFiles                              bool `protobuf:"varint,11,opt,name=transcribe_files,json=transcribeFiles,proto3" json:"transcribe_files,omitempty"`
	PerformPolicyChecksOnOriginals               bool `` /* 159-byte string literal not displayed */
	PerformPolicyChecksOnPreservationDerivatives bool `` /* 203-byte string literal not displayed */
	// AIP compression level (1 is the fastest, 9 is the smallest).
	AipCompressionLevel int32 `protobuf:"varint,14,opt,name=aip_compression_level,json=aipCompressionLevel,proto3" json:"aip_compression_level,omitempty"`
	// AIP compression algorithm
	AipCompressionAlgorithm ProcessingConfig_AIPCompressionAlgorithm `` /* 212-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ProcessingConfig) GetAipCompressionAlgorithm 

func (x *ProcessingConfig) GetAipCompressionAlgorithm() ProcessingConfig_AIPCompressionAlgorithm

func (*ProcessingConfig) GetAipCompressionLevel 

func (x *ProcessingConfig) GetAipCompressionLevel() int32

func (*ProcessingConfig) GetAssignUuidsToDirectories 

func (x *ProcessingConfig) GetAssignUuidsToDirectories() bool

func (*ProcessingConfig) GetDeletePackagesAfterExtraction 

func (x *ProcessingConfig) GetDeletePackagesAfterExtraction() bool

func (*ProcessingConfig) GetDocumentEmptyDirectories 

func (x *ProcessingConfig) GetDocumentEmptyDirectories() bool

func (*ProcessingConfig) GetExamineContents 

func (x *ProcessingConfig) GetExamineContents() bool

func (*ProcessingConfig) GetExtractPackages 

func (x *ProcessingConfig) GetExtractPackages() bool

func (*ProcessingConfig) GetGenerateTransferStructureReport 

func (x *ProcessingConfig) GetGenerateTransferStructureReport() bool

func (*ProcessingConfig) GetIdentifyBeforeNormalization 

func (x *ProcessingConfig) GetIdentifyBeforeNormalization() bool

func (*ProcessingConfig) GetIdentifySubmissionAndMetadata 

func (x *ProcessingConfig) GetIdentifySubmissionAndMetadata() bool

func (*ProcessingConfig) GetIdentifyTransfer 

func (x *ProcessingConfig) GetIdentifyTransfer() bool

func (*ProcessingConfig) GetNormalize 

func (x *ProcessingConfig) GetNormalize() bool

func (*ProcessingConfig) GetPerformPolicyChecksOnOriginals 

func (x *ProcessingConfig) GetPerformPolicyChecksOnOriginals() bool

func (*ProcessingConfig) GetPerformPolicyChecksOnPreservationDerivatives 

func (x *ProcessingConfig) GetPerformPolicyChecksOnPreservationDerivatives() bool

func (*ProcessingConfig) GetTranscribeFiles 

func (x *ProcessingConfig) GetTranscribeFiles() bool

func (*ProcessingConfig) ProtoMessage 

func (*ProcessingConfig) ProtoMessage()

func (*ProcessingConfig) ProtoReflect 

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

func (*ProcessingConfig) Reset 

func (x *ProcessingConfig) Reset()

func (*ProcessingConfig) SetAipCompressionAlgorithm 

func (x *ProcessingConfig) SetAipCompressionAlgorithm(v ProcessingConfig_AIPCompressionAlgorithm)

func (*ProcessingConfig) SetAipCompressionLevel 

func (x *ProcessingConfig) SetAipCompressionLevel(v int32)

func (*ProcessingConfig) SetAssignUuidsToDirectories 

func (x *ProcessingConfig) SetAssignUuidsToDirectories(v bool)

func (*ProcessingConfig) SetDeletePackagesAfterExtraction 

func (x *ProcessingConfig) SetDeletePackagesAfterExtraction(v bool)

func (*ProcessingConfig) SetDocumentEmptyDirectories 

func (x *ProcessingConfig) SetDocumentEmptyDirectories(v bool)

func (*ProcessingConfig) SetExamineContents 

func (x *ProcessingConfig) SetExamineContents(v bool)

func (*ProcessingConfig) SetExtractPackages 

func (x *ProcessingConfig) SetExtractPackages(v bool)

func (*ProcessingConfig) SetGenerateTransferStructureReport 

func (x *ProcessingConfig) SetGenerateTransferStructureReport(v bool)

func (*ProcessingConfig) SetIdentifyBeforeNormalization 

func (x *ProcessingConfig) SetIdentifyBeforeNormalization(v bool)

func (*ProcessingConfig) SetIdentifySubmissionAndMetadata 

func (x *ProcessingConfig) SetIdentifySubmissionAndMetadata(v bool)

func (*ProcessingConfig) SetIdentifyTransfer 

func (x *ProcessingConfig) SetIdentifyTransfer(v bool)

func (*ProcessingConfig) SetNormalize 

func (x *ProcessingConfig) SetNormalize(v bool)

func (*ProcessingConfig) SetPerformPolicyChecksOnOriginals 

func (x *ProcessingConfig) SetPerformPolicyChecksOnOriginals(v bool)

func (*ProcessingConfig) SetPerformPolicyChecksOnPreservationDerivatives 

func (x *ProcessingConfig) SetPerformPolicyChecksOnPreservationDerivatives(v bool)

func (*ProcessingConfig) SetTranscribeFiles 

func (x *ProcessingConfig) SetTranscribeFiles(v bool)

func (*ProcessingConfig) String 

func (x *ProcessingConfig) String() string

type ProcessingConfig_AIPCompressionAlgorithm 

type ProcessingConfig_AIPCompressionAlgorithm int32
const (
	ProcessingConfig_AIP_COMPRESSION_ALGORITHM_UNSPECIFIED  ProcessingConfig_AIPCompressionAlgorithm = 0
	ProcessingConfig_AIP_COMPRESSION_ALGORITHM_UNCOMPRESSED ProcessingConfig_AIPCompressionAlgorithm = 1 // It breaks in verify_aip.
	ProcessingConfig_AIP_COMPRESSION_ALGORITHM_TAR          ProcessingConfig_AIPCompressionAlgorithm = 2 // Not supported yet!
	ProcessingConfig_AIP_COMPRESSION_ALGORITHM_TAR_BZIP2    ProcessingConfig_AIPCompressionAlgorithm = 3
	ProcessingConfig_AIP_COMPRESSION_ALGORITHM_TAR_GZIP     ProcessingConfig_AIPCompressionAlgorithm = 4
	ProcessingConfig_AIP_COMPRESSION_ALGORITHM_S7_COPY      ProcessingConfig_AIPCompressionAlgorithm = 5
	ProcessingConfig_AIP_COMPRESSION_ALGORITHM_S7_BZIP2     ProcessingConfig_AIPCompressionAlgorithm = 6
	ProcessingConfig_AIP_COMPRESSION_ALGORITHM_S7_LZMA      ProcessingConfig_AIPCompressionAlgorithm = 7
)

func (ProcessingConfig_AIPCompressionAlgorithm) Descriptor 

func (ProcessingConfig_AIPCompressionAlgorithm) Descriptor() protoreflect.EnumDescriptor

func (ProcessingConfig_AIPCompressionAlgorithm) Enum 

func (x ProcessingConfig_AIPCompressionAlgorithm) Enum() *ProcessingConfig_AIPCompressionAlgorithm

func (ProcessingConfig_AIPCompressionAlgorithm) Number 

func (x ProcessingConfig_AIPCompressionAlgorithm) Number() protoreflect.EnumNumber

func (ProcessingConfig_AIPCompressionAlgorithm) String 

func (x ProcessingConfig_AIPCompressionAlgorithm) String() string

func (ProcessingConfig_AIPCompressionAlgorithm) Type 

func (ProcessingConfig_AIPCompressionAlgorithm) Type() protoreflect.EnumType

type ProcessingConfig_builder 

type ProcessingConfig_builder struct {
	AssignUuidsToDirectories        bool
	ExamineContents                 bool
	GenerateTransferStructureReport bool
	DocumentEmptyDirectories        bool
	ExtractPackages                 bool
	DeletePackagesAfterExtraction   bool
	IdentifyTransfer                bool
	// identify_submission_and_metadata represents a single configuration
	// attribute that controls two separate file format identification jobs
	// in the workflow: one for objects/submissionDocumentation and one
	// for objects/metadata
	IdentifySubmissionAndMetadata                bool
	IdentifyBeforeNormalization                  bool
	Normalize                                    bool
	TranscribeFiles                              bool
	PerformPolicyChecksOnOriginals               bool
	PerformPolicyChecksOnPreservationDerivatives bool
	// AIP compression level (1 is the fastest, 9 is the smallest).
	AipCompressionLevel int32
	// AIP compression algorithm
	AipCompressionAlgorithm ProcessingConfig_AIPCompressionAlgorithm
	// contains filtered or unexported fields
}

func (ProcessingConfig_builder) Build 

func (b0 ProcessingConfig_builder) Build() *ProcessingConfig

type ReadRequest 

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

func (*ReadRequest) GetId 

func (x *ReadRequest) GetId() string

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) ProtoReflect 

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

func (*ReadRequest) Reset 

func (x *ReadRequest) Reset()

func (*ReadRequest) SetId 

func (x *ReadRequest) SetId(v string)

func (*ReadRequest) String 

func (x *ReadRequest) String() string

type ReadRequest_builder 

type ReadRequest_builder struct {
	Id string
	// contains filtered or unexported fields
}

func (ReadRequest_builder) Build 

func (b0 ReadRequest_builder) Build() *ReadRequest

type ReadResponse 

type ReadResponse struct {
	Status PackageStatus `protobuf:"varint,1,opt,name=status,proto3,enum=a3m.api.transferservice.v1beta1.PackageStatus" json:"status,omitempty"`
	Job    string        `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	Jobs   []*Job        `protobuf:"bytes,3,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse) GetJob 

func (x *ReadResponse) GetJob() string

func (*ReadResponse) GetJobs 

func (x *ReadResponse) GetJobs() []*Job

func (*ReadResponse) GetStatus 

func (x *ReadResponse) GetStatus() PackageStatus

func (*ReadResponse) ProtoMessage 

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) ProtoReflect 

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

func (*ReadResponse) Reset 

func (x *ReadResponse) Reset()

func (*ReadResponse) SetJob 

func (x *ReadResponse) SetJob(v string)

func (*ReadResponse) SetJobs 

func (x *ReadResponse) SetJobs(v []*Job)

func (*ReadResponse) SetStatus 

func (x *ReadResponse) SetStatus(v PackageStatus)

func (*ReadResponse) String 

func (x *ReadResponse) String() string

type ReadResponse_builder 

type ReadResponse_builder struct {
	Status PackageStatus
	Job    string
	Jobs   []*Job
	// contains filtered or unexported fields
}

func (ReadResponse_builder) Build 

func (b0 ReadResponse_builder) Build() *ReadResponse

type SubmitRequest 

type SubmitRequest struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Url    string            `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Config *ProcessingConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitRequest) ClearConfig 

func (x *SubmitRequest) ClearConfig()

func (*SubmitRequest) GetConfig 

func (x *SubmitRequest) GetConfig() *ProcessingConfig

func (*SubmitRequest) GetName 

func (x *SubmitRequest) GetName() string

func (*SubmitRequest) GetUrl 

func (x *SubmitRequest) GetUrl() string

func (*SubmitRequest) HasConfig 

func (x *SubmitRequest) HasConfig() bool

func (*SubmitRequest) ProtoMessage 

func (*SubmitRequest) ProtoMessage()

func (*SubmitRequest) ProtoReflect 

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

func (*SubmitRequest) Reset 

func (x *SubmitRequest) Reset()

func (*SubmitRequest) SetConfig 

func (x *SubmitRequest) SetConfig(v *ProcessingConfig)

func (*SubmitRequest) SetName 

func (x *SubmitRequest) SetName(v string)

func (*SubmitRequest) SetUrl 

func (x *SubmitRequest) SetUrl(v string)

func (*SubmitRequest) String 

func (x *SubmitRequest) String() string

type SubmitRequest_builder 

type SubmitRequest_builder struct {
	Name   string
	Url    string
	Config *ProcessingConfig
	// contains filtered or unexported fields
}

func (SubmitRequest_builder) Build 

func (b0 SubmitRequest_builder) Build() *SubmitRequest

type SubmitResponse 

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

func (*SubmitResponse) GetId 

func (x *SubmitResponse) GetId() string

func (*SubmitResponse) ProtoMessage 

func (*SubmitResponse) ProtoMessage()

func (*SubmitResponse) ProtoReflect 

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

func (*SubmitResponse) Reset 

func (x *SubmitResponse) Reset()

func (*SubmitResponse) SetId 

func (x *SubmitResponse) SetId(v string)

func (*SubmitResponse) String 

func (x *SubmitResponse) String() string

type SubmitResponse_builder 

type SubmitResponse_builder struct {
	Id string
	// contains filtered or unexported fields
}

func (SubmitResponse_builder) Build 

func (b0 SubmitResponse_builder) Build() *SubmitResponse

type Task 

type Task struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	FileId    string                 `protobuf:"bytes,2,opt,name=file_id,json=fileId,proto3" json:"file_id,omitempty"`
	ExitCode  int32                  `protobuf:"varint,3,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	Filename  string                 `protobuf:"bytes,4,opt,name=filename,proto3" json:"filename,omitempty"`
	Execution string                 `protobuf:"bytes,5,opt,name=execution,proto3" json:"execution,omitempty"`
	Arguments string                 `protobuf:"bytes,6,opt,name=arguments,proto3" json:"arguments,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"`
	StartTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) ClearEndTime 

func (x *Task) ClearEndTime()

func (*Task) ClearStartTime 

func (x *Task) ClearStartTime()

func (*Task) GetArguments 

func (x *Task) GetArguments() string

func (*Task) GetEndTime 

func (x *Task) GetEndTime() *timestamppb.Timestamp

func (*Task) GetExecution 

func (x *Task) GetExecution() string

func (*Task) GetExitCode 

func (x *Task) GetExitCode() int32

func (*Task) GetFileId 

func (x *Task) GetFileId() string

func (*Task) GetFilename 

func (x *Task) GetFilename() string

func (*Task) GetId 

func (x *Task) GetId() string

func (*Task) GetStartTime 

func (x *Task) GetStartTime() *timestamppb.Timestamp

func (*Task) GetStderr 

func (x *Task) GetStderr() string

func (*Task) GetStdout 

func (x *Task) GetStdout() string

func (*Task) HasEndTime 

func (x *Task) HasEndTime() bool

func (*Task) HasStartTime 

func (x *Task) HasStartTime() bool

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) SetArguments 

func (x *Task) SetArguments(v string)

func (*Task) SetEndTime 

func (x *Task) SetEndTime(v *timestamppb.Timestamp)

func (*Task) SetExecution 

func (x *Task) SetExecution(v string)

func (*Task) SetExitCode 

func (x *Task) SetExitCode(v int32)

func (*Task) SetFileId 

func (x *Task) SetFileId(v string)

func (*Task) SetFilename 

func (x *Task) SetFilename(v string)

func (*Task) SetId 

func (x *Task) SetId(v string)

func (*Task) SetStartTime 

func (x *Task) SetStartTime(v *timestamppb.Timestamp)

func (*Task) SetStderr 

func (x *Task) SetStderr(v string)

func (*Task) SetStdout 

func (x *Task) SetStdout(v string)

func (*Task) String 

func (x *Task) String() string

type Task_builder 

type Task_builder struct {
	Id        string
	FileId    string
	ExitCode  int32
	Filename  string
	Execution string
	Arguments string
	Stdout    string
	Stderr    string
	StartTime *timestamppb.Timestamp
	EndTime   *timestamppb.Timestamp
	// contains filtered or unexported fields
}

func (Task_builder) Build 

func (b0 Task_builder) Build() *Task

Source Files

  • request_response.pb.go
  • service.pb.go

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.