pvn_wrapper

package
v0.3.42 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2024 License: MIT Imports: 20 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	JobManager_ReportJobResult_FullMethodName = "/prodvana.pvn_wrapper.JobManager/ReportJobResult"
)

Variables

View Source 
var File_prodvana_pvn_wrapper_job_manager_proto protoreflect.FileDescriptor
View Source 
var File_prodvana_pvn_wrapper_output_proto protoreflect.FileDescriptor
View Source 
var JobManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "prodvana.pvn_wrapper.JobManager",
	HandlerType: (*JobManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ReportJobResult",
			Handler:    _JobManager_ReportJobResult_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "prodvana/pvn_wrapper/job_manager.proto",
}

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

Functions

func RegisterJobManagerServer added in v0.3.32 

func RegisterJobManagerServer(s grpc.ServiceRegistrar, srv JobManagerServer)

Types

type JobManagerClient added in v0.3.32 

type JobManagerClient interface {
	ReportJobResult(ctx context.Context, in *ReportJobResultReq, opts ...grpc.CallOption) (*ReportJobResultResp, error)
}

JobManagerClient is the client API for JobManager 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 NewJobManagerClient added in v0.3.32 

func NewJobManagerClient(cc grpc.ClientConnInterface) JobManagerClient

type JobManagerServer added in v0.3.32 

type JobManagerServer interface {
	ReportJobResult(context.Context, *ReportJobResultReq) (*ReportJobResultResp, error)
	// contains filtered or unexported methods
}

JobManagerServer is the server API for JobManager service. All implementations must embed UnimplementedJobManagerServer for forward compatibility

type Output 

type Output struct {
	ExitCode         int32         `protobuf:"varint,1,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`   // Exit code of wrapped process. -1 if process failed to execute.
	ExecError        string        `protobuf:"bytes,2,opt,name=exec_error,json=execError,proto3" json:"exec_error,omitempty"` // Internal error when trying to execute wrapped process.
	StdoutBlobId     string        `protobuf:"bytes,3,opt,name=stdout_blob_id,json=stdoutBlobId,proto3" json:"stdout_blob_id,omitempty"`
	StderrBlobId     string        `protobuf:"bytes,4,opt,name=stderr_blob_id,json=stderrBlobId,proto3" json:"stderr_blob_id,omitempty"`
	Version          string        `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`                                              // Wrapper version.
	StartTimestampNs int64         `protobuf:"varint,6,opt,name=start_timestamp_ns,json=startTimestampNs,proto3" json:"start_timestamp_ns,omitempty"` // Timestamp when the process began executing, in ns.
	DurationNs       int64         `protobuf:"varint,7,opt,name=duration_ns,json=durationNs,proto3" json:"duration_ns,omitempty"`                     // Total execution duration of the process, in ns.
	Files            []*OutputFile `protobuf:"bytes,8,rep,name=files,proto3" json:"files,omitempty"`
	Hostname         string        `protobuf:"bytes,9,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

func (*Output) Descriptor deprecated 

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

Deprecated: Use Output.ProtoReflect.Descriptor instead.

func (*Output) GetDurationNs 

func (x *Output) GetDurationNs() int64

func (*Output) GetExecError 

func (x *Output) GetExecError() string

func (*Output) GetExitCode 

func (x *Output) GetExitCode() int32

func (*Output) GetFiles 

func (x *Output) GetFiles() []*OutputFile

func (*Output) GetHostname added in v0.3.33 

func (x *Output) GetHostname() string

func (*Output) GetStartTimestampNs 

func (x *Output) GetStartTimestampNs() int64

func (*Output) GetStderrBlobId added in v0.2.7 

func (x *Output) GetStderrBlobId() string

func (*Output) GetStdoutBlobId added in v0.2.7 

func (x *Output) GetStdoutBlobId() string

func (*Output) GetVersion 

func (x *Output) GetVersion() string

func (*Output) ProtoMessage 

func (*Output) ProtoMessage()

func (*Output) ProtoReflect 

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

func (*Output) Reset 

func (x *Output) Reset()

func (*Output) String 

func (x *Output) String() string

func (*Output) Validate 

func (m *Output) Validate() error

Validate checks the field values on Output with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Output) ValidateAll 

func (m *Output) ValidateAll() error

ValidateAll checks the field values on Output with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in OutputMultiError, or nil if none found.

type OutputFile 

type OutputFile struct {
	Name          string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ContentBlobId string `protobuf:"bytes,2,opt,name=content_blob_id,json=contentBlobId,proto3" json:"content_blob_id,omitempty"`
	// contains filtered or unexported fields
}

func (*OutputFile) Descriptor deprecated 

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

Deprecated: Use OutputFile.ProtoReflect.Descriptor instead.

func (*OutputFile) GetContentBlobId 

func (x *OutputFile) GetContentBlobId() string

func (*OutputFile) GetName 

func (x *OutputFile) GetName() string

func (*OutputFile) ProtoMessage 

func (*OutputFile) ProtoMessage()

func (*OutputFile) ProtoReflect 

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

func (*OutputFile) Reset 

func (x *OutputFile) Reset()

func (*OutputFile) String 

func (x *OutputFile) String() string

func (*OutputFile) Validate 

func (m *OutputFile) Validate() error

Validate checks the field values on OutputFile with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*OutputFile) ValidateAll 

func (m *OutputFile) ValidateAll() error

ValidateAll checks the field values on OutputFile with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in OutputFileMultiError, or nil if none found.

type OutputFileMultiError 

type OutputFileMultiError []error

OutputFileMultiError is an error wrapping multiple validation errors returned by OutputFile.ValidateAll() if the designated constraints aren't met.

func (OutputFileMultiError) AllErrors 

func (m OutputFileMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (OutputFileMultiError) Error 

func (m OutputFileMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type OutputFileValidationError 

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

OutputFileValidationError is the validation error returned by OutputFile.Validate if the designated constraints aren't met.

func (OutputFileValidationError) Cause 

func (e OutputFileValidationError) Cause() error

Cause function returns cause value.

func (OutputFileValidationError) Error 

func (e OutputFileValidationError) Error() string

Error satisfies the builtin error interface

func (OutputFileValidationError) ErrorName 

func (e OutputFileValidationError) ErrorName() string

ErrorName returns error name.

func (OutputFileValidationError) Field 

func (e OutputFileValidationError) Field() string

Field function returns field value.

func (OutputFileValidationError) Key 

func (e OutputFileValidationError) Key() bool

Key function returns key value.

func (OutputFileValidationError) Reason 

func (e OutputFileValidationError) Reason() string

Reason function returns reason value.

type OutputMultiError 

type OutputMultiError []error

OutputMultiError is an error wrapping multiple validation errors returned by Output.ValidateAll() if the designated constraints aren't met.

func (OutputMultiError) AllErrors 

func (m OutputMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (OutputMultiError) Error 

func (m OutputMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type OutputValidationError 

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

OutputValidationError is the validation error returned by Output.Validate if the designated constraints aren't met.

func (OutputValidationError) Cause 

func (e OutputValidationError) Cause() error

Cause function returns cause value.

func (OutputValidationError) Error 

func (e OutputValidationError) Error() string

Error satisfies the builtin error interface

func (OutputValidationError) ErrorName 

func (e OutputValidationError) ErrorName() string

ErrorName returns error name.

func (OutputValidationError) Field 

func (e OutputValidationError) Field() string

Field function returns field value.

func (OutputValidationError) Key 

func (e OutputValidationError) Key() bool

Key function returns key value.

func (OutputValidationError) Reason 

func (e OutputValidationError) Reason() string

Reason function returns reason value.

type ReportJobResultReq added in v0.3.32 

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

func (*ReportJobResultReq) Descriptor deprecated added in v0.3.32 

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

Deprecated: Use ReportJobResultReq.ProtoReflect.Descriptor instead.

func (*ReportJobResultReq) GetJobId added in v0.3.32 

func (x *ReportJobResultReq) GetJobId() string

func (*ReportJobResultReq) GetOutput added in v0.3.32 

func (x *ReportJobResultReq) GetOutput() *Output

func (*ReportJobResultReq) ProtoMessage added in v0.3.32 

func (*ReportJobResultReq) ProtoMessage()

func (*ReportJobResultReq) ProtoReflect added in v0.3.32 

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

func (*ReportJobResultReq) Reset added in v0.3.32 

func (x *ReportJobResultReq) Reset()

func (*ReportJobResultReq) String added in v0.3.32 

func (x *ReportJobResultReq) String() string

func (*ReportJobResultReq) Validate added in v0.3.32 

func (m *ReportJobResultReq) Validate() error

Validate checks the field values on ReportJobResultReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ReportJobResultReq) ValidateAll added in v0.3.32 

func (m *ReportJobResultReq) ValidateAll() error

ValidateAll checks the field values on ReportJobResultReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ReportJobResultReqMultiError, or nil if none found.

type ReportJobResultReqMultiError added in v0.3.32 

type ReportJobResultReqMultiError []error

ReportJobResultReqMultiError is an error wrapping multiple validation errors returned by ReportJobResultReq.ValidateAll() if the designated constraints aren't met.

func (ReportJobResultReqMultiError) AllErrors added in v0.3.32 

func (m ReportJobResultReqMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ReportJobResultReqMultiError) Error added in v0.3.32 

func (m ReportJobResultReqMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ReportJobResultReqValidationError added in v0.3.32 

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

ReportJobResultReqValidationError is the validation error returned by ReportJobResultReq.Validate if the designated constraints aren't met.

func (ReportJobResultReqValidationError) Cause added in v0.3.32 

func (e ReportJobResultReqValidationError) Cause() error

Cause function returns cause value.

func (ReportJobResultReqValidationError) Error added in v0.3.32 

func (e ReportJobResultReqValidationError) Error() string

Error satisfies the builtin error interface

func (ReportJobResultReqValidationError) ErrorName added in v0.3.32 

func (e ReportJobResultReqValidationError) ErrorName() string

ErrorName returns error name.

func (ReportJobResultReqValidationError) Field added in v0.3.32 

func (e ReportJobResultReqValidationError) Field() string

Field function returns field value.

func (ReportJobResultReqValidationError) Key added in v0.3.32 

func (e ReportJobResultReqValidationError) Key() bool

Key function returns key value.

func (ReportJobResultReqValidationError) Reason added in v0.3.32 

func (e ReportJobResultReqValidationError) Reason() string

Reason function returns reason value.

type ReportJobResultResp added in v0.3.32 

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

func (*ReportJobResultResp) Descriptor deprecated added in v0.3.32 

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

Deprecated: Use ReportJobResultResp.ProtoReflect.Descriptor instead.

func (*ReportJobResultResp) ProtoMessage added in v0.3.32 

func (*ReportJobResultResp) ProtoMessage()

func (*ReportJobResultResp) ProtoReflect added in v0.3.32 

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

func (*ReportJobResultResp) Reset added in v0.3.32 

func (x *ReportJobResultResp) Reset()

func (*ReportJobResultResp) String added in v0.3.32 

func (x *ReportJobResultResp) String() string

func (*ReportJobResultResp) Validate added in v0.3.32 

func (m *ReportJobResultResp) Validate() error

Validate checks the field values on ReportJobResultResp with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ReportJobResultResp) ValidateAll added in v0.3.32 

func (m *ReportJobResultResp) ValidateAll() error

ValidateAll checks the field values on ReportJobResultResp with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ReportJobResultRespMultiError, or nil if none found.

type ReportJobResultRespMultiError added in v0.3.32 

type ReportJobResultRespMultiError []error

ReportJobResultRespMultiError is an error wrapping multiple validation errors returned by ReportJobResultResp.ValidateAll() if the designated constraints aren't met.

func (ReportJobResultRespMultiError) AllErrors added in v0.3.32 

func (m ReportJobResultRespMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ReportJobResultRespMultiError) Error added in v0.3.32 

func (m ReportJobResultRespMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ReportJobResultRespValidationError added in v0.3.32 

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

ReportJobResultRespValidationError is the validation error returned by ReportJobResultResp.Validate if the designated constraints aren't met.

func (ReportJobResultRespValidationError) Cause added in v0.3.32 

func (e ReportJobResultRespValidationError) Cause() error

Cause function returns cause value.

func (ReportJobResultRespValidationError) Error added in v0.3.32 

func (e ReportJobResultRespValidationError) Error() string

Error satisfies the builtin error interface

func (ReportJobResultRespValidationError) ErrorName added in v0.3.32 

func (e ReportJobResultRespValidationError) ErrorName() string

ErrorName returns error name.

func (ReportJobResultRespValidationError) Field added in v0.3.32 

func (e ReportJobResultRespValidationError) Field() string

Field function returns field value.

func (ReportJobResultRespValidationError) Key added in v0.3.32 

func (e ReportJobResultRespValidationError) Key() bool

Key function returns key value.

func (ReportJobResultRespValidationError) Reason added in v0.3.32 

func (e ReportJobResultRespValidationError) Reason() string

Reason function returns reason value.

type UnimplementedJobManagerServer added in v0.3.32 

type UnimplementedJobManagerServer struct {
}

UnimplementedJobManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedJobManagerServer) ReportJobResult added in v0.3.32 

func (UnimplementedJobManagerServer) ReportJobResult(context.Context, *ReportJobResultReq) (*ReportJobResultResp, error)

type UnsafeJobManagerServer added in v0.3.32 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.