server

package
v2.9.4 Latest Latest
Warning

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

 Go to latest Published: Apr 8, 2024 License: Apache-2.0 Imports: 94 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	StorageTaskNamespace = "storage"
)
View Source 
const (
	URLTaskNamespace = "url"
)

Variables

View Source 
var File_server_pfs_server_pfsserver_proto protoreflect.FileDescriptor

Functions

func IsPermissionError 

func IsPermissionError(err error) bool

IsPermissionError returns true if a given error is a permission error.

func NewAPIServer 

func NewAPIServer(env Env) (pfsserver.APIServer, error)

NewAPIServer creates an APIServer.

func TopologicalSort 

func TopologicalSort(cis []*pfs.CommitInfo) []*pfs.CommitInfo

TopologicalSort sorts a slice of commit infos topologically based on their provenance

func ValidateFilename 

func ValidateFilename(p string) error

Types

type APIServer added in v2.8.0 

type APIServer = *validatedAPIServer

type CommitEvent 

type CommitEvent struct {
	Err   error
	Value *pfs.CommitInfo
}

CommitEvent is an event that contains a CommitInfo or an error

type CommitStream 

type CommitStream interface {
	Stream() <-chan CommitEvent
	Close()
}

CommitStream is a stream of CommitInfos

type CompactTask 

type CompactTask struct {
	Inputs    []string   `protobuf:"bytes,1,rep,name=inputs,proto3" json:"inputs,omitempty"`
	PathRange *PathRange `protobuf:"bytes,2,opt,name=path_range,json=pathRange,proto3" json:"path_range,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactTask) Descriptor deprecated 

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

Deprecated: Use CompactTask.ProtoReflect.Descriptor instead.

func (*CompactTask) GetInputs 

func (x *CompactTask) GetInputs() []string

func (*CompactTask) GetPathRange 

func (x *CompactTask) GetPathRange() *PathRange

func (*CompactTask) MarshalLogObject 

func (x *CompactTask) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CompactTask) ProtoMessage 

func (*CompactTask) ProtoMessage()

func (*CompactTask) ProtoReflect added in v2.7.0 

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

func (*CompactTask) Reset 

func (x *CompactTask) Reset()

func (*CompactTask) String 

func (x *CompactTask) String() string

func (*CompactTask) Validate added in v2.8.0 

func (m *CompactTask) Validate() error

Validate checks the field values on CompactTask 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 (*CompactTask) ValidateAll added in v2.8.0 

func (m *CompactTask) ValidateAll() error

ValidateAll checks the field values on CompactTask 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 CompactTaskMultiError, or nil if none found.

type CompactTaskMultiError added in v2.8.0 

type CompactTaskMultiError []error

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

func (CompactTaskMultiError) AllErrors added in v2.8.0 

func (m CompactTaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CompactTaskMultiError) Error added in v2.8.0 

func (m CompactTaskMultiError) Error() string

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

type CompactTaskResult 

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

func (*CompactTaskResult) Descriptor deprecated 

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

Deprecated: Use CompactTaskResult.ProtoReflect.Descriptor instead.

func (*CompactTaskResult) GetId 

func (x *CompactTaskResult) GetId() string

func (*CompactTaskResult) MarshalLogObject 

func (x *CompactTaskResult) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CompactTaskResult) ProtoMessage 

func (*CompactTaskResult) ProtoMessage()

func (*CompactTaskResult) ProtoReflect added in v2.7.0 

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

func (*CompactTaskResult) Reset 

func (x *CompactTaskResult) Reset()

func (*CompactTaskResult) String 

func (x *CompactTaskResult) String() string

func (*CompactTaskResult) Validate added in v2.8.0 

func (m *CompactTaskResult) Validate() error

Validate checks the field values on CompactTaskResult 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 (*CompactTaskResult) ValidateAll added in v2.8.0 

func (m *CompactTaskResult) ValidateAll() error

ValidateAll checks the field values on CompactTaskResult 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 CompactTaskResultMultiError, or nil if none found.

type CompactTaskResultMultiError added in v2.8.0 

type CompactTaskResultMultiError []error

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

func (CompactTaskResultMultiError) AllErrors added in v2.8.0 

func (m CompactTaskResultMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CompactTaskResultMultiError) Error added in v2.8.0 

func (m CompactTaskResultMultiError) Error() string

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

type CompactTaskResultValidationError added in v2.8.0 

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

CompactTaskResultValidationError is the validation error returned by CompactTaskResult.Validate if the designated constraints aren't met.

func (CompactTaskResultValidationError) Cause added in v2.8.0 

func (e CompactTaskResultValidationError) Cause() error

Cause function returns cause value.

func (CompactTaskResultValidationError) Error added in v2.8.0 

func (e CompactTaskResultValidationError) Error() string

Error satisfies the builtin error interface

func (CompactTaskResultValidationError) ErrorName added in v2.8.0 

func (e CompactTaskResultValidationError) ErrorName() string

ErrorName returns error name.

func (CompactTaskResultValidationError) Field added in v2.8.0 

func (e CompactTaskResultValidationError) Field() string

Field function returns field value.

func (CompactTaskResultValidationError) Key added in v2.8.0 

func (e CompactTaskResultValidationError) Key() bool

Key function returns key value.

func (CompactTaskResultValidationError) Reason added in v2.8.0 

func (e CompactTaskResultValidationError) Reason() string

Reason function returns reason value.

type CompactTaskValidationError added in v2.8.0 

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

CompactTaskValidationError is the validation error returned by CompactTask.Validate if the designated constraints aren't met.

func (CompactTaskValidationError) Cause added in v2.8.0 

func (e CompactTaskValidationError) Cause() error

Cause function returns cause value.

func (CompactTaskValidationError) Error added in v2.8.0 

func (e CompactTaskValidationError) Error() string

Error satisfies the builtin error interface

func (CompactTaskValidationError) ErrorName added in v2.8.0 

func (e CompactTaskValidationError) ErrorName() string

ErrorName returns error name.

func (CompactTaskValidationError) Field added in v2.8.0 

func (e CompactTaskValidationError) Field() string

Field function returns field value.

func (CompactTaskValidationError) Key added in v2.8.0 

func (e CompactTaskValidationError) Key() bool

Key function returns key value.

func (CompactTaskValidationError) Reason added in v2.8.0 

func (e CompactTaskValidationError) Reason() string

Reason function returns reason value.

type ConcatTask 

type ConcatTask struct {
	Inputs []string `protobuf:"bytes,1,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// contains filtered or unexported fields
}

func (*ConcatTask) Descriptor deprecated 

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

Deprecated: Use ConcatTask.ProtoReflect.Descriptor instead.

func (*ConcatTask) GetInputs 

func (x *ConcatTask) GetInputs() []string

func (*ConcatTask) MarshalLogObject 

func (x *ConcatTask) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ConcatTask) ProtoMessage 

func (*ConcatTask) ProtoMessage()

func (*ConcatTask) ProtoReflect added in v2.7.0 

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

func (*ConcatTask) Reset 

func (x *ConcatTask) Reset()

func (*ConcatTask) String 

func (x *ConcatTask) String() string

func (*ConcatTask) Validate added in v2.8.0 

func (m *ConcatTask) Validate() error

Validate checks the field values on ConcatTask 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 (*ConcatTask) ValidateAll added in v2.8.0 

func (m *ConcatTask) ValidateAll() error

ValidateAll checks the field values on ConcatTask 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 ConcatTaskMultiError, or nil if none found.

type ConcatTaskMultiError added in v2.8.0 

type ConcatTaskMultiError []error

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

func (ConcatTaskMultiError) AllErrors added in v2.8.0 

func (m ConcatTaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ConcatTaskMultiError) Error added in v2.8.0 

func (m ConcatTaskMultiError) Error() string

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

type ConcatTaskResult 

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

func (*ConcatTaskResult) Descriptor deprecated 

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

Deprecated: Use ConcatTaskResult.ProtoReflect.Descriptor instead.

func (*ConcatTaskResult) GetId 

func (x *ConcatTaskResult) GetId() string

func (*ConcatTaskResult) MarshalLogObject 

func (x *ConcatTaskResult) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ConcatTaskResult) ProtoMessage 

func (*ConcatTaskResult) ProtoMessage()

func (*ConcatTaskResult) ProtoReflect added in v2.7.0 

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

func (*ConcatTaskResult) Reset 

func (x *ConcatTaskResult) Reset()

func (*ConcatTaskResult) String 

func (x *ConcatTaskResult) String() string

func (*ConcatTaskResult) Validate added in v2.8.0 

func (m *ConcatTaskResult) Validate() error

Validate checks the field values on ConcatTaskResult 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 (*ConcatTaskResult) ValidateAll added in v2.8.0 

func (m *ConcatTaskResult) ValidateAll() error

ValidateAll checks the field values on ConcatTaskResult 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 ConcatTaskResultMultiError, or nil if none found.

type ConcatTaskResultMultiError added in v2.8.0 

type ConcatTaskResultMultiError []error

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

func (ConcatTaskResultMultiError) AllErrors added in v2.8.0 

func (m ConcatTaskResultMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ConcatTaskResultMultiError) Error added in v2.8.0 

func (m ConcatTaskResultMultiError) Error() string

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

type ConcatTaskResultValidationError added in v2.8.0 

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

ConcatTaskResultValidationError is the validation error returned by ConcatTaskResult.Validate if the designated constraints aren't met.

func (ConcatTaskResultValidationError) Cause added in v2.8.0 

func (e ConcatTaskResultValidationError) Cause() error

Cause function returns cause value.

func (ConcatTaskResultValidationError) Error added in v2.8.0 

func (e ConcatTaskResultValidationError) Error() string

Error satisfies the builtin error interface

func (ConcatTaskResultValidationError) ErrorName added in v2.8.0 

func (e ConcatTaskResultValidationError) ErrorName() string

ErrorName returns error name.

func (ConcatTaskResultValidationError) Field added in v2.8.0 

func (e ConcatTaskResultValidationError) Field() string

Field function returns field value.

func (ConcatTaskResultValidationError) Key added in v2.8.0 

func (e ConcatTaskResultValidationError) Key() bool

Key function returns key value.

func (ConcatTaskResultValidationError) Reason added in v2.8.0 

func (e ConcatTaskResultValidationError) Reason() string

Reason function returns reason value.

type ConcatTaskValidationError added in v2.8.0 

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

ConcatTaskValidationError is the validation error returned by ConcatTask.Validate if the designated constraints aren't met.

func (ConcatTaskValidationError) Cause added in v2.8.0 

func (e ConcatTaskValidationError) Cause() error

Cause function returns cause value.

func (ConcatTaskValidationError) Error added in v2.8.0 

func (e ConcatTaskValidationError) Error() string

Error satisfies the builtin error interface

func (ConcatTaskValidationError) ErrorName added in v2.8.0 

func (e ConcatTaskValidationError) ErrorName() string

ErrorName returns error name.

func (ConcatTaskValidationError) Field added in v2.8.0 

func (e ConcatTaskValidationError) Field() string

Field function returns field value.

func (ConcatTaskValidationError) Key added in v2.8.0 

func (e ConcatTaskValidationError) Key() bool

Key function returns key value.

func (ConcatTaskValidationError) Reason added in v2.8.0 

func (e ConcatTaskValidationError) Reason() string

Reason function returns reason value.

type Differ 

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

Differ compares two sources and iterates over the items that are not equal.

func NewDiffer 

func NewDiffer(a, b Source) *Differ

NewDiffer creates an iterator over the differences between Sources a and b

func (*Differ) Iterate 

func (d *Differ) Iterate(ctx context.Context, cb func(aFi, bFi *pfs.FileInfo) error) error

Iterate compares the entries from `a` and `b` path wise. If one side is missing a path, cb is called with the info for the side that has the path If both sides have a path, but the content is different, cb is called with the info for both sides at once. If both sides have a path, and the content is the same, cb is not called. The info is not part of the diff.

type Env 

type Env struct {
	ObjectClient obj.Client
	Bucket       *blob.Bucket
	DB           *pachsql.DB
	EtcdPrefix   string
	EtcdClient   *etcd.Client
	TaskService  task.Service
	TxnEnv       *txnenv.TransactionEnv
	Listener     col.PostgresListener

	Auth                 PFSAuth
	GetPipelineInspector func() PipelineInspector

	StorageConfig pachconfig.StorageConfiguration
	GetPPSServer  func() pps_server.APIServer
}

Env is the dependencies needed to run the PFS API server

type ErrBranchCommitProvenanceMismatch 

type ErrBranchCommitProvenanceMismatch struct {
	Branch       *pfs.Branch
	ParentBranch *pfs.Branch
}

ErrBranchCommitProvenanceMismatch occurs when the head commit of one of the parents of the branch is not found in the direct provenance commits of the head of the branch

func (ErrBranchCommitProvenanceMismatch) Error 

func (e ErrBranchCommitProvenanceMismatch) Error() string

type ErrBranchInfoNotFound 

type ErrBranchInfoNotFound struct {
	Branch *pfs.Branch
}

ErrBranchInfoNotFound Branch info could not be found. Typically because of an incomplete deletion of a branch. This struct contains all the information that was used to demonstrate that this invariant is not being satisfied.

func (ErrBranchInfoNotFound) Error 

func (e ErrBranchInfoNotFound) Error() string

type ErrBranchProvenanceTransitivity 

type ErrBranchProvenanceTransitivity struct {
	BranchInfo     *pfs.BranchInfo
	FullProvenance []*pfs.Branch
}

ErrBranchProvenanceTransitivity Branch provenance is not transitively closed. This struct contains all the information that was used to demonstrate that this invariant is not being satisfied.

func (ErrBranchProvenanceTransitivity) Error 

func (e ErrBranchProvenanceTransitivity) Error() string

type ErrBranchSubvenanceTransitivity 

type ErrBranchSubvenanceTransitivity struct {
	BranchInfo        *pfs.BranchInfo
	MissingSubvenance *pfs.Branch
}

func (ErrBranchSubvenanceTransitivity) Error 

func (e ErrBranchSubvenanceTransitivity) Error() string

type ErrCommitAncestryBroken 

type ErrCommitAncestryBroken struct {
	Parent *pfs.Commit
	Child  *pfs.Commit
}

ErrCommitAncestryBroken indicates that a parent and child commit disagree on their relationship. This struct contains all the information that was used to demonstrate that this invariant is not being satisfied.

func (ErrCommitAncestryBroken) Error 

func (e ErrCommitAncestryBroken) Error() string

type ErrCommitInfoNotFound 

type ErrCommitInfoNotFound struct {
	Location string
	Commit   *pfs.Commit
}

ErrCommitInfoNotFound Commit info could not be found. Typically because of an incomplete deletion of a commit. This struct contains all the information that was used to demonstrate that this invariant is not being satisfied.

func (ErrCommitInfoNotFound) Error 

func (e ErrCommitInfoNotFound) Error() string

type ErrZombieData 

type ErrZombieData struct {
	Commit *pfs.Commit
	ID     string
}

func (ErrZombieData) Error 

func (e ErrZombieData) Error() string

type GetFileURLTask 

type GetFileURLTask struct {
	URL       string         `protobuf:"bytes,1,opt,name=URL,proto3" json:"URL,omitempty"`
	Fileset   string         `protobuf:"bytes,4,opt,name=Fileset,proto3" json:"Fileset,omitempty"`
	PathRange *pfs.PathRange `protobuf:"bytes,3,opt,name=path_range,json=pathRange,proto3" json:"path_range,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFileURLTask) Descriptor deprecated 

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

Deprecated: Use GetFileURLTask.ProtoReflect.Descriptor instead.

func (*GetFileURLTask) GetFileset added in v2.8.0 

func (x *GetFileURLTask) GetFileset() string

func (*GetFileURLTask) GetPathRange 

func (x *GetFileURLTask) GetPathRange() *pfs.PathRange

func (*GetFileURLTask) GetURL 

func (x *GetFileURLTask) GetURL() string

func (*GetFileURLTask) MarshalLogObject 

func (x *GetFileURLTask) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*GetFileURLTask) ProtoMessage 

func (*GetFileURLTask) ProtoMessage()

func (*GetFileURLTask) ProtoReflect added in v2.7.0 

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

func (*GetFileURLTask) Reset 

func (x *GetFileURLTask) Reset()

func (*GetFileURLTask) String 

func (x *GetFileURLTask) String() string

func (*GetFileURLTask) Validate added in v2.8.0 

func (m *GetFileURLTask) Validate() error

Validate checks the field values on GetFileURLTask 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 (*GetFileURLTask) ValidateAll added in v2.8.0 

func (m *GetFileURLTask) ValidateAll() error

ValidateAll checks the field values on GetFileURLTask 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 GetFileURLTaskMultiError, or nil if none found.

type GetFileURLTaskMultiError added in v2.8.0 

type GetFileURLTaskMultiError []error

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

func (GetFileURLTaskMultiError) AllErrors added in v2.8.0 

func (m GetFileURLTaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetFileURLTaskMultiError) Error added in v2.8.0 

func (m GetFileURLTaskMultiError) Error() string

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

type GetFileURLTaskResult 

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

func (*GetFileURLTaskResult) Descriptor deprecated 

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

Deprecated: Use GetFileURLTaskResult.ProtoReflect.Descriptor instead.

func (*GetFileURLTaskResult) MarshalLogObject 

func (x *GetFileURLTaskResult) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*GetFileURLTaskResult) ProtoMessage 

func (*GetFileURLTaskResult) ProtoMessage()

func (*GetFileURLTaskResult) ProtoReflect added in v2.7.0 

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

func (*GetFileURLTaskResult) Reset 

func (x *GetFileURLTaskResult) Reset()

func (*GetFileURLTaskResult) String 

func (x *GetFileURLTaskResult) String() string

func (*GetFileURLTaskResult) Validate added in v2.8.0 

func (m *GetFileURLTaskResult) Validate() error

Validate checks the field values on GetFileURLTaskResult 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 (*GetFileURLTaskResult) ValidateAll added in v2.8.0 

func (m *GetFileURLTaskResult) ValidateAll() error

ValidateAll checks the field values on GetFileURLTaskResult 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 GetFileURLTaskResultMultiError, or nil if none found.

type GetFileURLTaskResultMultiError added in v2.8.0 

type GetFileURLTaskResultMultiError []error

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

func (GetFileURLTaskResultMultiError) AllErrors added in v2.8.0 

func (m GetFileURLTaskResultMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetFileURLTaskResultMultiError) Error added in v2.8.0 

func (m GetFileURLTaskResultMultiError) Error() string

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

type GetFileURLTaskResultValidationError added in v2.8.0 

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

GetFileURLTaskResultValidationError is the validation error returned by GetFileURLTaskResult.Validate if the designated constraints aren't met.

func (GetFileURLTaskResultValidationError) Cause added in v2.8.0 

func (e GetFileURLTaskResultValidationError) Cause() error

Cause function returns cause value.

func (GetFileURLTaskResultValidationError) Error added in v2.8.0 

func (e GetFileURLTaskResultValidationError) Error() string

Error satisfies the builtin error interface

func (GetFileURLTaskResultValidationError) ErrorName added in v2.8.0 

func (e GetFileURLTaskResultValidationError) ErrorName() string

ErrorName returns error name.

func (GetFileURLTaskResultValidationError) Field added in v2.8.0 

func (e GetFileURLTaskResultValidationError) Field() string

Field function returns field value.

func (GetFileURLTaskResultValidationError) Key added in v2.8.0 

func (e GetFileURLTaskResultValidationError) Key() bool

Key function returns key value.

func (GetFileURLTaskResultValidationError) Reason added in v2.8.0 

func (e GetFileURLTaskResultValidationError) Reason() string

Reason function returns reason value.

type GetFileURLTaskValidationError added in v2.8.0 

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

GetFileURLTaskValidationError is the validation error returned by GetFileURLTask.Validate if the designated constraints aren't met.

func (GetFileURLTaskValidationError) Cause added in v2.8.0 

func (e GetFileURLTaskValidationError) Cause() error

Cause function returns cause value.

func (GetFileURLTaskValidationError) Error added in v2.8.0 

func (e GetFileURLTaskValidationError) Error() string

Error satisfies the builtin error interface

func (GetFileURLTaskValidationError) ErrorName added in v2.8.0 

func (e GetFileURLTaskValidationError) ErrorName() string

ErrorName returns error name.

func (GetFileURLTaskValidationError) Field added in v2.8.0 

func (e GetFileURLTaskValidationError) Field() string

Field function returns field value.

func (GetFileURLTaskValidationError) Key added in v2.8.0 

func (e GetFileURLTaskValidationError) Key() bool

Key function returns key value.

func (GetFileURLTaskValidationError) Reason added in v2.8.0 

func (e GetFileURLTaskValidationError) Reason() string

Reason function returns reason value.

type Master added in v2.8.0 

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

func NewMaster added in v2.8.0 

func NewMaster(env Env) (*Master, error)

func (*Master) Run added in v2.8.0 

func (m *Master) Run(ctx context.Context) error

type PFSAuth added in v2.8.0 

type PFSAuth interface {
	CheckRepoIsAuthorized(ctx context.Context, repo *pfs.Repo, p ...auth.Permission) error
	WhoAmI(ctx context.Context, req *auth.WhoAmIRequest) (*auth.WhoAmIResponse, error)
	GetPermissions(ctx context.Context, req *auth.GetPermissionsRequest) (*auth.GetPermissionsResponse, error)

	CheckProjectIsAuthorizedInTransaction(txnCtx *txncontext.TransactionContext, project *pfs.Project, p ...auth.Permission) error
	CheckRepoIsAuthorizedInTransaction(txnCtx *txncontext.TransactionContext, repo *pfs.Repo, p ...auth.Permission) error
	CreateRoleBindingInTransaction(txnCtx *txncontext.TransactionContext, principal string, roleSlice []string, resource *auth.Resource) error
	DeleteRoleBindingInTransaction(transactionContext *txncontext.TransactionContext, resource *auth.Resource) error
	GetPermissionsInTransaction(txnCtx *txncontext.TransactionContext, req *auth.GetPermissionsRequest) (*auth.GetPermissionsResponse, error)
}

PFSAuth contains the auth methods called by PFS. It is a subset of what the Auth Service provides.

type PathRange 

type PathRange struct {
	Lower string `protobuf:"bytes,1,opt,name=lower,proto3" json:"lower,omitempty"`
	Upper string `protobuf:"bytes,2,opt,name=upper,proto3" json:"upper,omitempty"`
	// contains filtered or unexported fields
}

func (*PathRange) Descriptor deprecated 

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

Deprecated: Use PathRange.ProtoReflect.Descriptor instead.

func (*PathRange) GetLower 

func (x *PathRange) GetLower() string

func (*PathRange) GetUpper 

func (x *PathRange) GetUpper() string

func (*PathRange) MarshalLogObject 

func (x *PathRange) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*PathRange) ProtoMessage 

func (*PathRange) ProtoMessage()

func (*PathRange) ProtoReflect added in v2.7.0 

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

func (*PathRange) Reset 

func (x *PathRange) Reset()

func (*PathRange) String 

func (x *PathRange) String() string

func (*PathRange) Validate added in v2.8.0 

func (m *PathRange) Validate() error

Validate checks the field values on PathRange 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 (*PathRange) ValidateAll added in v2.8.0 

func (m *PathRange) ValidateAll() error

ValidateAll checks the field values on PathRange 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 PathRangeMultiError, or nil if none found.

type PathRangeMultiError added in v2.8.0 

type PathRangeMultiError []error

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

func (PathRangeMultiError) AllErrors added in v2.8.0 

func (m PathRangeMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PathRangeMultiError) Error added in v2.8.0 

func (m PathRangeMultiError) Error() string

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

type PathRangeValidationError added in v2.8.0 

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

PathRangeValidationError is the validation error returned by PathRange.Validate if the designated constraints aren't met.

func (PathRangeValidationError) Cause added in v2.8.0 

func (e PathRangeValidationError) Cause() error

Cause function returns cause value.

func (PathRangeValidationError) Error added in v2.8.0 

func (e PathRangeValidationError) Error() string

Error satisfies the builtin error interface

func (PathRangeValidationError) ErrorName added in v2.8.0 

func (e PathRangeValidationError) ErrorName() string

ErrorName returns error name.

func (PathRangeValidationError) Field added in v2.8.0 

func (e PathRangeValidationError) Field() string

Field function returns field value.

func (PathRangeValidationError) Key added in v2.8.0 

func (e PathRangeValidationError) Key() bool

Key function returns key value.

func (PathRangeValidationError) Reason added in v2.8.0 

func (e PathRangeValidationError) Reason() string

Reason function returns reason value.

type PipelineInspector added in v2.8.0 

type PipelineInspector interface {
	InspectPipelineInTransaction(context.Context, *txncontext.TransactionContext, *pps.Pipeline) (*pps.PipelineInfo, error)
}

type Propagater 

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

Propagater is an object that is used to propagate PFS branches at the end of a transaction. The transactionenv package provides the interface for this and will call the Run function at the end of a transaction.

func (*Propagater) DeleteBranch 

func (t *Propagater) DeleteBranch(branch *pfs.Branch)

DeleteBranch removes a branch from the list of those needing propagation if present.

func (*Propagater) PropagateBranch 

func (t *Propagater) PropagateBranch(branch *pfs.Branch) error

PropagateBranch marks a branch as needing propagation once the transaction successfully ends. This will be performed by the Run function.

func (*Propagater) Run 

func (t *Propagater) Run(ctx context.Context) error

Run performs any final tasks and cleanup tasks in the transaction, such as propagating branches

type PutFileURLTask 

type PutFileURLTask struct {
	Dst         string   `protobuf:"bytes,1,opt,name=dst,proto3" json:"dst,omitempty"`
	Datum       string   `protobuf:"bytes,2,opt,name=datum,proto3" json:"datum,omitempty"`
	URL         string   `protobuf:"bytes,3,opt,name=URL,proto3" json:"URL,omitempty"`
	Paths       []string `protobuf:"bytes,4,rep,name=paths,proto3" json:"paths,omitempty"`
	StartOffset int64    `protobuf:"varint,5,opt,name=start_offset,json=startOffset,proto3" json:"start_offset,omitempty"`
	EndOffset   int64    `protobuf:"varint,7,opt,name=end_offset,json=endOffset,proto3" json:"end_offset,omitempty"`
	// contains filtered or unexported fields
}

func (*PutFileURLTask) Descriptor deprecated 

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

Deprecated: Use PutFileURLTask.ProtoReflect.Descriptor instead.

func (*PutFileURLTask) GetDatum 

func (x *PutFileURLTask) GetDatum() string

func (*PutFileURLTask) GetDst 

func (x *PutFileURLTask) GetDst() string

func (*PutFileURLTask) GetEndOffset 

func (x *PutFileURLTask) GetEndOffset() int64

func (*PutFileURLTask) GetPaths 

func (x *PutFileURLTask) GetPaths() []string

func (*PutFileURLTask) GetStartOffset 

func (x *PutFileURLTask) GetStartOffset() int64

func (*PutFileURLTask) GetURL 

func (x *PutFileURLTask) GetURL() string

func (*PutFileURLTask) MarshalLogObject 

func (x *PutFileURLTask) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*PutFileURLTask) ProtoMessage 

func (*PutFileURLTask) ProtoMessage()

func (*PutFileURLTask) ProtoReflect added in v2.7.0 

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

func (*PutFileURLTask) Reset 

func (x *PutFileURLTask) Reset()

func (*PutFileURLTask) String 

func (x *PutFileURLTask) String() string

func (*PutFileURLTask) Validate added in v2.8.0 

func (m *PutFileURLTask) Validate() error

Validate checks the field values on PutFileURLTask 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 (*PutFileURLTask) ValidateAll added in v2.8.0 

func (m *PutFileURLTask) ValidateAll() error

ValidateAll checks the field values on PutFileURLTask 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 PutFileURLTaskMultiError, or nil if none found.

type PutFileURLTaskMultiError added in v2.8.0 

type PutFileURLTaskMultiError []error

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

func (PutFileURLTaskMultiError) AllErrors added in v2.8.0 

func (m PutFileURLTaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PutFileURLTaskMultiError) Error added in v2.8.0 

func (m PutFileURLTaskMultiError) Error() string

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

type PutFileURLTaskResult 

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

func (*PutFileURLTaskResult) Descriptor deprecated 

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

Deprecated: Use PutFileURLTaskResult.ProtoReflect.Descriptor instead.

func (*PutFileURLTaskResult) GetId 

func (x *PutFileURLTaskResult) GetId() string

func (*PutFileURLTaskResult) MarshalLogObject 

func (x *PutFileURLTaskResult) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*PutFileURLTaskResult) ProtoMessage 

func (*PutFileURLTaskResult) ProtoMessage()

func (*PutFileURLTaskResult) ProtoReflect added in v2.7.0 

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

func (*PutFileURLTaskResult) Reset 

func (x *PutFileURLTaskResult) Reset()

func (*PutFileURLTaskResult) String 

func (x *PutFileURLTaskResult) String() string

func (*PutFileURLTaskResult) Validate added in v2.8.0 

func (m *PutFileURLTaskResult) Validate() error

Validate checks the field values on PutFileURLTaskResult 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 (*PutFileURLTaskResult) ValidateAll added in v2.8.0 

func (m *PutFileURLTaskResult) ValidateAll() error

ValidateAll checks the field values on PutFileURLTaskResult 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 PutFileURLTaskResultMultiError, or nil if none found.

type PutFileURLTaskResultMultiError added in v2.8.0 

type PutFileURLTaskResultMultiError []error

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

func (PutFileURLTaskResultMultiError) AllErrors added in v2.8.0 

func (m PutFileURLTaskResultMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PutFileURLTaskResultMultiError) Error added in v2.8.0 

func (m PutFileURLTaskResultMultiError) Error() string

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

type PutFileURLTaskResultValidationError added in v2.8.0 

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

PutFileURLTaskResultValidationError is the validation error returned by PutFileURLTaskResult.Validate if the designated constraints aren't met.

func (PutFileURLTaskResultValidationError) Cause added in v2.8.0 

func (e PutFileURLTaskResultValidationError) Cause() error

Cause function returns cause value.

func (PutFileURLTaskResultValidationError) Error added in v2.8.0 

func (e PutFileURLTaskResultValidationError) Error() string

Error satisfies the builtin error interface

func (PutFileURLTaskResultValidationError) ErrorName added in v2.8.0 

func (e PutFileURLTaskResultValidationError) ErrorName() string

ErrorName returns error name.

func (PutFileURLTaskResultValidationError) Field added in v2.8.0 

func (e PutFileURLTaskResultValidationError) Field() string

Field function returns field value.

func (PutFileURLTaskResultValidationError) Key added in v2.8.0 

func (e PutFileURLTaskResultValidationError) Key() bool

Key function returns key value.

func (PutFileURLTaskResultValidationError) Reason added in v2.8.0 

func (e PutFileURLTaskResultValidationError) Reason() string

Reason function returns reason value.

type PutFileURLTaskValidationError added in v2.8.0 

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

PutFileURLTaskValidationError is the validation error returned by PutFileURLTask.Validate if the designated constraints aren't met.

func (PutFileURLTaskValidationError) Cause added in v2.8.0 

func (e PutFileURLTaskValidationError) Cause() error

Cause function returns cause value.

func (PutFileURLTaskValidationError) Error added in v2.8.0 

func (e PutFileURLTaskValidationError) Error() string

Error satisfies the builtin error interface

func (PutFileURLTaskValidationError) ErrorName added in v2.8.0 

func (e PutFileURLTaskValidationError) ErrorName() string

ErrorName returns error name.

func (PutFileURLTaskValidationError) Field added in v2.8.0 

func (e PutFileURLTaskValidationError) Field() string

Field function returns field value.

func (PutFileURLTaskValidationError) Key added in v2.8.0 

func (e PutFileURLTaskValidationError) Key() bool

Key function returns key value.

func (PutFileURLTaskValidationError) Reason added in v2.8.0 

func (e PutFileURLTaskValidationError) Reason() string

Reason function returns reason value.

type ShardTask 

type ShardTask struct {
	Inputs    []string   `protobuf:"bytes,1,rep,name=inputs,proto3" json:"inputs,omitempty"`
	PathRange *PathRange `protobuf:"bytes,2,opt,name=path_range,json=pathRange,proto3" json:"path_range,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardTask) Descriptor deprecated 

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

Deprecated: Use ShardTask.ProtoReflect.Descriptor instead.

func (*ShardTask) GetInputs 

func (x *ShardTask) GetInputs() []string

func (*ShardTask) GetPathRange 

func (x *ShardTask) GetPathRange() *PathRange

func (*ShardTask) MarshalLogObject 

func (x *ShardTask) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ShardTask) ProtoMessage 

func (*ShardTask) ProtoMessage()

func (*ShardTask) ProtoReflect added in v2.7.0 

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

func (*ShardTask) Reset 

func (x *ShardTask) Reset()

func (*ShardTask) String 

func (x *ShardTask) String() string

func (*ShardTask) Validate added in v2.8.0 

func (m *ShardTask) Validate() error

Validate checks the field values on ShardTask 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 (*ShardTask) ValidateAll added in v2.8.0 

func (m *ShardTask) ValidateAll() error

ValidateAll checks the field values on ShardTask 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 ShardTaskMultiError, or nil if none found.

type ShardTaskMultiError added in v2.8.0 

type ShardTaskMultiError []error

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

func (ShardTaskMultiError) AllErrors added in v2.8.0 

func (m ShardTaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ShardTaskMultiError) Error added in v2.8.0 

func (m ShardTaskMultiError) Error() string

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

type ShardTaskResult 

type ShardTaskResult struct {
	CompactTasks []*CompactTask `protobuf:"bytes,1,rep,name=compact_tasks,json=compactTasks,proto3" json:"compact_tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardTaskResult) Descriptor deprecated 

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

Deprecated: Use ShardTaskResult.ProtoReflect.Descriptor instead.

func (*ShardTaskResult) GetCompactTasks 

func (x *ShardTaskResult) GetCompactTasks() []*CompactTask

func (*ShardTaskResult) MarshalLogObject 

func (x *ShardTaskResult) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ShardTaskResult) ProtoMessage 

func (*ShardTaskResult) ProtoMessage()

func (*ShardTaskResult) ProtoReflect added in v2.7.0 

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

func (*ShardTaskResult) Reset 

func (x *ShardTaskResult) Reset()

func (*ShardTaskResult) String 

func (x *ShardTaskResult) String() string

func (*ShardTaskResult) Validate added in v2.8.0 

func (m *ShardTaskResult) Validate() error

Validate checks the field values on ShardTaskResult 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 (*ShardTaskResult) ValidateAll added in v2.8.0 

func (m *ShardTaskResult) ValidateAll() error

ValidateAll checks the field values on ShardTaskResult 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 ShardTaskResultMultiError, or nil if none found.

type ShardTaskResultMultiError added in v2.8.0 

type ShardTaskResultMultiError []error

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

func (ShardTaskResultMultiError) AllErrors added in v2.8.0 

func (m ShardTaskResultMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ShardTaskResultMultiError) Error added in v2.8.0 

func (m ShardTaskResultMultiError) Error() string

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

type ShardTaskResultValidationError added in v2.8.0 

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

ShardTaskResultValidationError is the validation error returned by ShardTaskResult.Validate if the designated constraints aren't met.

func (ShardTaskResultValidationError) Cause added in v2.8.0 

func (e ShardTaskResultValidationError) Cause() error

Cause function returns cause value.

func (ShardTaskResultValidationError) Error added in v2.8.0 

func (e ShardTaskResultValidationError) Error() string

Error satisfies the builtin error interface

func (ShardTaskResultValidationError) ErrorName added in v2.8.0 

func (e ShardTaskResultValidationError) ErrorName() string

ErrorName returns error name.

func (ShardTaskResultValidationError) Field added in v2.8.0 

func (e ShardTaskResultValidationError) Field() string

Field function returns field value.

func (ShardTaskResultValidationError) Key added in v2.8.0 

func (e ShardTaskResultValidationError) Key() bool

Key function returns key value.

func (ShardTaskResultValidationError) Reason added in v2.8.0 

func (e ShardTaskResultValidationError) Reason() string

Reason function returns reason value.

type ShardTaskValidationError added in v2.8.0 

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

ShardTaskValidationError is the validation error returned by ShardTask.Validate if the designated constraints aren't met.

func (ShardTaskValidationError) Cause added in v2.8.0 

func (e ShardTaskValidationError) Cause() error

Cause function returns cause value.

func (ShardTaskValidationError) Error added in v2.8.0 

func (e ShardTaskValidationError) Error() string

Error satisfies the builtin error interface

func (ShardTaskValidationError) ErrorName added in v2.8.0 

func (e ShardTaskValidationError) ErrorName() string

ErrorName returns error name.

func (ShardTaskValidationError) Field added in v2.8.0 

func (e ShardTaskValidationError) Field() string

Field function returns field value.

func (ShardTaskValidationError) Key added in v2.8.0 

func (e ShardTaskValidationError) Key() bool

Key function returns key value.

func (ShardTaskValidationError) Reason added in v2.8.0 

func (e ShardTaskValidationError) Reason() string

Reason function returns reason value.

type Source 

type Source interface {
	// Iterate calls cb for each File in the underlying fileset.FileSet, with a FileInfo computed
	// during iteration, and the File.
	Iterate(ctx context.Context, cb func(*pfs.FileInfo, fileset.File) error) error
}

Source iterates over FileInfos generated from a fileset.FileSet

func NewErrOnEmpty 

func NewErrOnEmpty(s Source, err error) Source

NewErrOnEmpty causes iterate to return a not found error if there are no items to iterate over

func NewSource 

func NewSource(commitInfo *pfs.CommitInfo, fs fileset.FileSet, opts ...SourceOption) Source

NewSource creates a Source which emits FileInfos with the information from commit, and the entries return from fileSet.

type SourceOption 

type SourceOption func(*sourceConfig)

SourceOption configures a source.

func WithDatum 

func WithDatum(datum string) SourceOption

func WithFilter 

func WithFilter(filter func(fileset.FileSet) fileset.FileSet) SourceOption

WithFilter applies a filter to the file set after it has been set up by the source.

func WithPathRange 

func WithPathRange(pathRange *pfs.PathRange) SourceOption

func WithPrefix 

func WithPrefix(prefix string) SourceOption

type ValidateTask 

type ValidateTask struct {
	Id        string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	PathRange *PathRange `protobuf:"bytes,2,opt,name=path_range,json=pathRange,proto3" json:"path_range,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateTask) Descriptor deprecated 

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

Deprecated: Use ValidateTask.ProtoReflect.Descriptor instead.

func (*ValidateTask) GetId 

func (x *ValidateTask) GetId() string

func (*ValidateTask) GetPathRange 

func (x *ValidateTask) GetPathRange() *PathRange

func (*ValidateTask) MarshalLogObject 

func (x *ValidateTask) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ValidateTask) ProtoMessage 

func (*ValidateTask) ProtoMessage()

func (*ValidateTask) ProtoReflect added in v2.7.0 

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

func (*ValidateTask) Reset 

func (x *ValidateTask) Reset()

func (*ValidateTask) String 

func (x *ValidateTask) String() string

func (*ValidateTask) Validate added in v2.8.0 

func (m *ValidateTask) Validate() error

Validate checks the field values on ValidateTask 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 (*ValidateTask) ValidateAll added in v2.8.0 

func (m *ValidateTask) ValidateAll() error

ValidateAll checks the field values on ValidateTask 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 ValidateTaskMultiError, or nil if none found.

type ValidateTaskMultiError added in v2.8.0 

type ValidateTaskMultiError []error

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

func (ValidateTaskMultiError) AllErrors added in v2.8.0 

func (m ValidateTaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ValidateTaskMultiError) Error added in v2.8.0 

func (m ValidateTaskMultiError) Error() string

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

type ValidateTaskResult 

type ValidateTaskResult struct {
	First     *index.Index `protobuf:"bytes,1,opt,name=first,proto3" json:"first,omitempty"`
	Last      *index.Index `protobuf:"bytes,2,opt,name=last,proto3" json:"last,omitempty"`
	Error     string       `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	SizeBytes int64        `protobuf:"varint,4,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateTaskResult) Descriptor deprecated 

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

Deprecated: Use ValidateTaskResult.ProtoReflect.Descriptor instead.

func (*ValidateTaskResult) GetError 

func (x *ValidateTaskResult) GetError() string

func (*ValidateTaskResult) GetFirst 

func (x *ValidateTaskResult) GetFirst() *index.Index

func (*ValidateTaskResult) GetLast 

func (x *ValidateTaskResult) GetLast() *index.Index

func (*ValidateTaskResult) GetSizeBytes 

func (x *ValidateTaskResult) GetSizeBytes() int64

func (*ValidateTaskResult) MarshalLogObject 

func (x *ValidateTaskResult) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ValidateTaskResult) ProtoMessage 

func (*ValidateTaskResult) ProtoMessage()

func (*ValidateTaskResult) ProtoReflect added in v2.7.0 

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

func (*ValidateTaskResult) Reset 

func (x *ValidateTaskResult) Reset()

func (*ValidateTaskResult) String 

func (x *ValidateTaskResult) String() string

func (*ValidateTaskResult) Validate added in v2.8.0 

func (m *ValidateTaskResult) Validate() error

Validate checks the field values on ValidateTaskResult 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 (*ValidateTaskResult) ValidateAll added in v2.8.0 

func (m *ValidateTaskResult) ValidateAll() error

ValidateAll checks the field values on ValidateTaskResult 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 ValidateTaskResultMultiError, or nil if none found.

type ValidateTaskResultMultiError added in v2.8.0 

type ValidateTaskResultMultiError []error

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

func (ValidateTaskResultMultiError) AllErrors added in v2.8.0 

func (m ValidateTaskResultMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ValidateTaskResultMultiError) Error added in v2.8.0 

func (m ValidateTaskResultMultiError) Error() string

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

type ValidateTaskResultValidationError added in v2.8.0 

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

ValidateTaskResultValidationError is the validation error returned by ValidateTaskResult.Validate if the designated constraints aren't met.

func (ValidateTaskResultValidationError) Cause added in v2.8.0 

func (e ValidateTaskResultValidationError) Cause() error

Cause function returns cause value.

func (ValidateTaskResultValidationError) Error added in v2.8.0 

func (e ValidateTaskResultValidationError) Error() string

Error satisfies the builtin error interface

func (ValidateTaskResultValidationError) ErrorName added in v2.8.0 

func (e ValidateTaskResultValidationError) ErrorName() string

ErrorName returns error name.

func (ValidateTaskResultValidationError) Field added in v2.8.0 

func (e ValidateTaskResultValidationError) Field() string

Field function returns field value.

func (ValidateTaskResultValidationError) Key added in v2.8.0 

func (e ValidateTaskResultValidationError) Key() bool

Key function returns key value.

func (ValidateTaskResultValidationError) Reason added in v2.8.0 

func (e ValidateTaskResultValidationError) Reason() string

Reason function returns reason value.

type ValidateTaskValidationError added in v2.8.0 

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

ValidateTaskValidationError is the validation error returned by ValidateTask.Validate if the designated constraints aren't met.

func (ValidateTaskValidationError) Cause added in v2.8.0 

func (e ValidateTaskValidationError) Cause() error

Cause function returns cause value.

func (ValidateTaskValidationError) Error added in v2.8.0 

func (e ValidateTaskValidationError) Error() string

Error satisfies the builtin error interface

func (ValidateTaskValidationError) ErrorName added in v2.8.0 

func (e ValidateTaskValidationError) ErrorName() string

ErrorName returns error name.

func (ValidateTaskValidationError) Field added in v2.8.0 

func (e ValidateTaskValidationError) Field() string

Field function returns field value.

func (ValidateTaskValidationError) Key added in v2.8.0 

func (e ValidateTaskValidationError) Key() bool

Key function returns key value.

func (ValidateTaskValidationError) Reason added in v2.8.0 

func (e ValidateTaskValidationError) Reason() string

Reason function returns reason value.

type Worker added in v2.8.0 

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

func NewWorker added in v2.8.0 

func NewWorker(env WorkerEnv, config WorkerConfig) (*Worker, error)

func (*Worker) Run added in v2.8.0 

func (w *Worker) Run(ctx context.Context) error

func (*Worker) URLWorker added in v2.8.0 

func (w *Worker) URLWorker(ctx context.Context) error

type WorkerConfig added in v2.8.0 

type WorkerConfig struct {
	Storage pachconfig.StorageConfiguration
}

type WorkerEnv added in v2.8.0 

type WorkerEnv struct {
	DB          *sqlx.DB
	Bucket      *obj.Bucket
	ObjClient   obj.Client
	TaskService task.Service
}

Source Files

View all Source files

Directories

Path Synopsis

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.