pfsload

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: 34 Imported by: 0

Documentation

Index

Constants

View Source
const LoadSpecification string = `` /* 1095-byte string literal not displayed */

Variables

View Source
var File_internal_pfsload_pfsload_proto protoreflect.FileDescriptor

Functions

func Commit

func Commit(ctx context.Context, c pfs.APIClient, taskService task.Service, branch *pfs.Branch, spec *CommitSpec, seed int64, stateID string) (string, error)

func Modification

func Modification(ctx context.Context, env *Env, commit *pfs.Commit, spec *ModificationSpec) error

func NewValidatorClient

func NewValidatorClient(client Client) *validatorClient

func PutFile

func PutFile(ctx context.Context, c Client, fileSource FileSource, count int) (string, error)

func Worker

func Worker(ctx context.Context, c pfs.APIClient, taskService task.Service) error

Types

type Client

type Client interface {
	WithCreateFileSetClient(ctx context.Context, cb func(client.ModifyFile) error) (*pfs.CreateFileSetResponse, error)
	AddFileSet(ctx context.Context, commit *pfs.Commit, ID string) error
	GlobFile(ctx context.Context, commit *pfs.Commit, pattern string, cb func(*pfs.FileInfo) error) error
	WaitCommitSet(ctx context.Context, id string, cb func(*pfs.CommitInfo) error) error
}

Client is the standard interface for a load testing client. TODO: This should become the client.Client interface when we put the standard pach client behind an interface that takes a context as the first parameter for each method.

func NewPachClient

func NewPachClient(pfs pfs.APIClient) Client

type CommitSpec

type CommitSpec struct {
	Count         int64               `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Modifications []*ModificationSpec `protobuf:"bytes,2,rep,name=modifications,proto3" json:"modifications,omitempty"`
	FileSources   []*FileSourceSpec   `protobuf:"bytes,3,rep,name=file_sources,json=fileSources,proto3" json:"file_sources,omitempty"`
	Validator     *ValidatorSpec      `protobuf:"bytes,4,opt,name=validator,proto3" json:"validator,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitSpec) Descriptor deprecated

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

Deprecated: Use CommitSpec.ProtoReflect.Descriptor instead.

func (*CommitSpec) GetCount

func (x *CommitSpec) GetCount() int64

func (*CommitSpec) GetFileSources

func (x *CommitSpec) GetFileSources() []*FileSourceSpec

func (*CommitSpec) GetModifications

func (x *CommitSpec) GetModifications() []*ModificationSpec

func (*CommitSpec) GetValidator

func (x *CommitSpec) GetValidator() *ValidatorSpec

func (*CommitSpec) MarshalLogObject

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

func (*CommitSpec) ProtoMessage

func (*CommitSpec) ProtoMessage()

func (*CommitSpec) ProtoReflect added in v2.7.0

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

func (*CommitSpec) Reset

func (x *CommitSpec) Reset()

func (*CommitSpec) String

func (x *CommitSpec) String() string

func (*CommitSpec) Validate added in v2.8.0

func (m *CommitSpec) Validate() error

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

func (m *CommitSpec) ValidateAll() error

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

type CommitSpecMultiError added in v2.8.0

type CommitSpecMultiError []error

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

func (CommitSpecMultiError) AllErrors added in v2.8.0

func (m CommitSpecMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CommitSpecMultiError) Error added in v2.8.0

func (m CommitSpecMultiError) Error() string

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

type CommitSpecValidationError added in v2.8.0

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

CommitSpecValidationError is the validation error returned by CommitSpec.Validate if the designated constraints aren't met.

func (CommitSpecValidationError) Cause added in v2.8.0

func (e CommitSpecValidationError) Cause() error

Cause function returns cause value.

func (CommitSpecValidationError) Error added in v2.8.0

Error satisfies the builtin error interface

func (CommitSpecValidationError) ErrorName added in v2.8.0

func (e CommitSpecValidationError) ErrorName() string

ErrorName returns error name.

func (CommitSpecValidationError) Field added in v2.8.0

Field function returns field value.

func (CommitSpecValidationError) Key added in v2.8.0

Key function returns key value.

func (CommitSpecValidationError) Reason added in v2.8.0

func (e CommitSpecValidationError) Reason() string

Reason function returns reason value.

type Env

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

func NewEnv

func NewEnv(ctx context.Context, c pfs.APIClient, taskService task.Service, spec *CommitSpec, seed int64) (*Env, error)

func (*Env) AuthToken

func (e *Env) AuthToken() string

func (*Env) Client

func (e *Env) Client() Client

func (*Env) FileSource

func (e *Env) FileSource(name string) *FileSourceSpec

func (*Env) Seed

func (e *Env) Seed() int64

func (*Env) TaskDoer

func (e *Env) TaskDoer() task.Doer

func (*Env) Validator

func (e *Env) Validator() *Validator

type FileSource

type FileSource interface {
	Next() (*RandomFile, error)
}

func NewFileSource

func NewFileSource(spec *FileSourceSpec, random *rand.Rand) FileSource

type FileSourceSpec

type FileSourceSpec struct {
	Name   string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Random *RandomFileSourceSpec `protobuf:"bytes,2,opt,name=random,proto3" json:"random,omitempty"`
	// contains filtered or unexported fields
}

func (*FileSourceSpec) Descriptor deprecated

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

Deprecated: Use FileSourceSpec.ProtoReflect.Descriptor instead.

func (*FileSourceSpec) GetName

func (x *FileSourceSpec) GetName() string

func (*FileSourceSpec) GetRandom

func (x *FileSourceSpec) GetRandom() *RandomFileSourceSpec

func (*FileSourceSpec) MarshalLogObject

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

func (*FileSourceSpec) ProtoMessage

func (*FileSourceSpec) ProtoMessage()

func (*FileSourceSpec) ProtoReflect added in v2.7.0

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

func (*FileSourceSpec) Reset

func (x *FileSourceSpec) Reset()

func (*FileSourceSpec) String

func (x *FileSourceSpec) String() string

func (*FileSourceSpec) Validate added in v2.8.0

func (m *FileSourceSpec) Validate() error

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

func (m *FileSourceSpec) ValidateAll() error

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

type FileSourceSpecMultiError added in v2.8.0

type FileSourceSpecMultiError []error

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

func (FileSourceSpecMultiError) AllErrors added in v2.8.0

func (m FileSourceSpecMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (FileSourceSpecMultiError) Error added in v2.8.0

func (m FileSourceSpecMultiError) Error() string

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

type FileSourceSpecValidationError added in v2.8.0

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

FileSourceSpecValidationError is the validation error returned by FileSourceSpec.Validate if the designated constraints aren't met.

func (FileSourceSpecValidationError) Cause added in v2.8.0

Cause function returns cause value.

func (FileSourceSpecValidationError) Error added in v2.8.0

Error satisfies the builtin error interface

func (FileSourceSpecValidationError) ErrorName added in v2.8.0

func (e FileSourceSpecValidationError) ErrorName() string

ErrorName returns error name.

func (FileSourceSpecValidationError) Field added in v2.8.0

Field function returns field value.

func (FileSourceSpecValidationError) Key added in v2.8.0

Key function returns key value.

func (FileSourceSpecValidationError) Reason added in v2.8.0

Reason function returns reason value.

type FrequencySpec

type FrequencySpec struct {
	Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Prob  int64 `protobuf:"varint,2,opt,name=prob,proto3" json:"prob,omitempty"`
	// contains filtered or unexported fields
}

func (*FrequencySpec) Descriptor deprecated

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

Deprecated: Use FrequencySpec.ProtoReflect.Descriptor instead.

func (*FrequencySpec) GetCount

func (x *FrequencySpec) GetCount() int64

func (*FrequencySpec) GetProb

func (x *FrequencySpec) GetProb() int64

func (*FrequencySpec) MarshalLogObject

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

func (*FrequencySpec) ProtoMessage

func (*FrequencySpec) ProtoMessage()

func (*FrequencySpec) ProtoReflect added in v2.7.0

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

func (*FrequencySpec) Reset

func (x *FrequencySpec) Reset()

func (*FrequencySpec) String

func (x *FrequencySpec) String() string

func (*FrequencySpec) Validate added in v2.8.0

func (m *FrequencySpec) Validate() error

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

func (m *FrequencySpec) ValidateAll() error

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

type FrequencySpecMultiError added in v2.8.0

type FrequencySpecMultiError []error

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

func (FrequencySpecMultiError) AllErrors added in v2.8.0

func (m FrequencySpecMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (FrequencySpecMultiError) Error added in v2.8.0

func (m FrequencySpecMultiError) Error() string

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

type FrequencySpecValidationError added in v2.8.0

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

FrequencySpecValidationError is the validation error returned by FrequencySpec.Validate if the designated constraints aren't met.

func (FrequencySpecValidationError) Cause added in v2.8.0

Cause function returns cause value.

func (FrequencySpecValidationError) Error added in v2.8.0

Error satisfies the builtin error interface

func (FrequencySpecValidationError) ErrorName added in v2.8.0

func (e FrequencySpecValidationError) ErrorName() string

ErrorName returns error name.

func (FrequencySpecValidationError) Field added in v2.8.0

Field function returns field value.

func (FrequencySpecValidationError) Key added in v2.8.0

Key function returns key value.

func (FrequencySpecValidationError) Reason added in v2.8.0

Reason function returns reason value.

type ModificationSpec

type ModificationSpec struct {
	Count   int64        `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	PutFile *PutFileSpec `protobuf:"bytes,2,opt,name=put_file,json=putFile,proto3" json:"put_file,omitempty"`
	// contains filtered or unexported fields
}

func (*ModificationSpec) Descriptor deprecated

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

Deprecated: Use ModificationSpec.ProtoReflect.Descriptor instead.

func (*ModificationSpec) GetCount

func (x *ModificationSpec) GetCount() int64

func (*ModificationSpec) GetPutFile

func (x *ModificationSpec) GetPutFile() *PutFileSpec

func (*ModificationSpec) MarshalLogObject

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

func (*ModificationSpec) ProtoMessage

func (*ModificationSpec) ProtoMessage()

func (*ModificationSpec) ProtoReflect added in v2.7.0

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

func (*ModificationSpec) Reset

func (x *ModificationSpec) Reset()

func (*ModificationSpec) String

func (x *ModificationSpec) String() string

func (*ModificationSpec) Validate added in v2.8.0

func (m *ModificationSpec) Validate() error

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

func (m *ModificationSpec) ValidateAll() error

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

type ModificationSpecMultiError added in v2.8.0

type ModificationSpecMultiError []error

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

func (ModificationSpecMultiError) AllErrors added in v2.8.0

func (m ModificationSpecMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ModificationSpecMultiError) Error added in v2.8.0

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

type ModificationSpecValidationError added in v2.8.0

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

ModificationSpecValidationError is the validation error returned by ModificationSpec.Validate if the designated constraints aren't met.

func (ModificationSpecValidationError) Cause added in v2.8.0

Cause function returns cause value.

func (ModificationSpecValidationError) Error added in v2.8.0

Error satisfies the builtin error interface

func (ModificationSpecValidationError) ErrorName added in v2.8.0

ErrorName returns error name.

func (ModificationSpecValidationError) Field added in v2.8.0

Field function returns field value.

func (ModificationSpecValidationError) Key added in v2.8.0

Key function returns key value.

func (ModificationSpecValidationError) Reason added in v2.8.0

Reason function returns reason value.

type PutFileSpec

type PutFileSpec struct {
	Count  int64  `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

func (*PutFileSpec) Descriptor deprecated

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

Deprecated: Use PutFileSpec.ProtoReflect.Descriptor instead.

func (*PutFileSpec) GetCount

func (x *PutFileSpec) GetCount() int64

func (*PutFileSpec) GetSource

func (x *PutFileSpec) GetSource() string

func (*PutFileSpec) MarshalLogObject

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

func (*PutFileSpec) ProtoMessage

func (*PutFileSpec) ProtoMessage()

func (*PutFileSpec) ProtoReflect added in v2.7.0

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

func (*PutFileSpec) Reset

func (x *PutFileSpec) Reset()

func (*PutFileSpec) String

func (x *PutFileSpec) String() string

func (*PutFileSpec) Validate added in v2.8.0

func (m *PutFileSpec) Validate() error

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

func (m *PutFileSpec) ValidateAll() error

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

type PutFileSpecMultiError added in v2.8.0

type PutFileSpecMultiError []error

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

func (PutFileSpecMultiError) AllErrors added in v2.8.0

func (m PutFileSpecMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PutFileSpecMultiError) Error added in v2.8.0

func (m PutFileSpecMultiError) Error() string

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

type PutFileSpecValidationError added in v2.8.0

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

PutFileSpecValidationError is the validation error returned by PutFileSpec.Validate if the designated constraints aren't met.

func (PutFileSpecValidationError) Cause added in v2.8.0

Cause function returns cause value.

func (PutFileSpecValidationError) Error added in v2.8.0

Error satisfies the builtin error interface

func (PutFileSpecValidationError) ErrorName added in v2.8.0

func (e PutFileSpecValidationError) ErrorName() string

ErrorName returns error name.

func (PutFileSpecValidationError) Field added in v2.8.0

Field function returns field value.

func (PutFileSpecValidationError) Key added in v2.8.0

Key function returns key value.

func (PutFileSpecValidationError) Reason added in v2.8.0

Reason function returns reason value.

type PutFileTask

type PutFileTask struct {
	Count      int64           `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	FileSource *FileSourceSpec `protobuf:"bytes,2,opt,name=file_source,json=fileSource,proto3" json:"file_source,omitempty"`
	Seed       int64           `protobuf:"varint,3,opt,name=seed,proto3" json:"seed,omitempty"`
	AuthToken  string          `protobuf:"bytes,4,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"`
	// contains filtered or unexported fields
}

func (*PutFileTask) Descriptor deprecated

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

Deprecated: Use PutFileTask.ProtoReflect.Descriptor instead.

func (*PutFileTask) GetAuthToken

func (x *PutFileTask) GetAuthToken() string

func (*PutFileTask) GetCount

func (x *PutFileTask) GetCount() int64

func (*PutFileTask) GetFileSource

func (x *PutFileTask) GetFileSource() *FileSourceSpec

func (*PutFileTask) GetSeed

func (x *PutFileTask) GetSeed() int64

func (*PutFileTask) MarshalLogObject

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

func (*PutFileTask) ProtoMessage

func (*PutFileTask) ProtoMessage()

func (*PutFileTask) ProtoReflect added in v2.7.0

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

func (*PutFileTask) Reset

func (x *PutFileTask) Reset()

func (*PutFileTask) String

func (x *PutFileTask) String() string

func (*PutFileTask) Validate added in v2.8.0

func (m *PutFileTask) Validate() error

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

func (m *PutFileTask) ValidateAll() error

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

type PutFileTaskMultiError added in v2.8.0

type PutFileTaskMultiError []error

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

func (PutFileTaskMultiError) AllErrors added in v2.8.0

func (m PutFileTaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PutFileTaskMultiError) Error added in v2.8.0

func (m PutFileTaskMultiError) Error() string

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

type PutFileTaskResult

type PutFileTaskResult struct {
	FileSetId string `protobuf:"bytes,1,opt,name=file_set_id,json=fileSetId,proto3" json:"file_set_id,omitempty"`
	Hash      []byte `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*PutFileTaskResult) Descriptor deprecated

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

Deprecated: Use PutFileTaskResult.ProtoReflect.Descriptor instead.

func (*PutFileTaskResult) GetFileSetId

func (x *PutFileTaskResult) GetFileSetId() string

func (*PutFileTaskResult) GetHash

func (x *PutFileTaskResult) GetHash() []byte

func (*PutFileTaskResult) MarshalLogObject

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

func (*PutFileTaskResult) ProtoMessage

func (*PutFileTaskResult) ProtoMessage()

func (*PutFileTaskResult) ProtoReflect added in v2.7.0

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

func (*PutFileTaskResult) Reset

func (x *PutFileTaskResult) Reset()

func (*PutFileTaskResult) String

func (x *PutFileTaskResult) String() string

func (*PutFileTaskResult) Validate added in v2.8.0

func (m *PutFileTaskResult) Validate() error

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

func (m *PutFileTaskResult) ValidateAll() error

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

type PutFileTaskResultMultiError added in v2.8.0

type PutFileTaskResultMultiError []error

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

func (PutFileTaskResultMultiError) AllErrors added in v2.8.0

func (m PutFileTaskResultMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PutFileTaskResultMultiError) Error added in v2.8.0

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

type PutFileTaskResultValidationError added in v2.8.0

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

PutFileTaskResultValidationError is the validation error returned by PutFileTaskResult.Validate if the designated constraints aren't met.

func (PutFileTaskResultValidationError) Cause added in v2.8.0

Cause function returns cause value.

func (PutFileTaskResultValidationError) Error added in v2.8.0

Error satisfies the builtin error interface

func (PutFileTaskResultValidationError) ErrorName added in v2.8.0

ErrorName returns error name.

func (PutFileTaskResultValidationError) Field added in v2.8.0

Field function returns field value.

func (PutFileTaskResultValidationError) Key added in v2.8.0

Key function returns key value.

func (PutFileTaskResultValidationError) Reason added in v2.8.0

Reason function returns reason value.

type PutFileTaskValidationError added in v2.8.0

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

PutFileTaskValidationError is the validation error returned by PutFileTask.Validate if the designated constraints aren't met.

func (PutFileTaskValidationError) Cause added in v2.8.0

Cause function returns cause value.

func (PutFileTaskValidationError) Error added in v2.8.0

Error satisfies the builtin error interface

func (PutFileTaskValidationError) ErrorName added in v2.8.0

func (e PutFileTaskValidationError) ErrorName() string

ErrorName returns error name.

func (PutFileTaskValidationError) Field added in v2.8.0

Field function returns field value.

func (PutFileTaskValidationError) Key added in v2.8.0

Key function returns key value.

func (PutFileTaskValidationError) Reason added in v2.8.0

Reason function returns reason value.

type RandomDirectorySpec

type RandomDirectorySpec struct {
	Depth *SizeSpec `protobuf:"bytes,1,opt,name=depth,proto3" json:"depth,omitempty"`
	Run   int64     `protobuf:"varint,2,opt,name=run,proto3" json:"run,omitempty"`
	// contains filtered or unexported fields
}

func (*RandomDirectorySpec) Descriptor deprecated

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

Deprecated: Use RandomDirectorySpec.ProtoReflect.Descriptor instead.

func (*RandomDirectorySpec) GetDepth

func (x *RandomDirectorySpec) GetDepth() *SizeSpec

func (*RandomDirectorySpec) GetRun

func (x *RandomDirectorySpec) GetRun() int64

func (*RandomDirectorySpec) MarshalLogObject

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

func (*RandomDirectorySpec) ProtoMessage

func (*RandomDirectorySpec) ProtoMessage()

func (*RandomDirectorySpec) ProtoReflect added in v2.7.0

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

func (*RandomDirectorySpec) Reset

func (x *RandomDirectorySpec) Reset()

func (*RandomDirectorySpec) String

func (x *RandomDirectorySpec) String() string

func (*RandomDirectorySpec) Validate added in v2.8.0

func (m *RandomDirectorySpec) Validate() error

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

func (m *RandomDirectorySpec) ValidateAll() error

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

type RandomDirectorySpecMultiError added in v2.8.0

type RandomDirectorySpecMultiError []error

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

func (RandomDirectorySpecMultiError) AllErrors added in v2.8.0

func (m RandomDirectorySpecMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RandomDirectorySpecMultiError) Error added in v2.8.0

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

type RandomDirectorySpecValidationError added in v2.8.0

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

RandomDirectorySpecValidationError is the validation error returned by RandomDirectorySpec.Validate if the designated constraints aren't met.

func (RandomDirectorySpecValidationError) Cause added in v2.8.0

Cause function returns cause value.

func (RandomDirectorySpecValidationError) Error added in v2.8.0

Error satisfies the builtin error interface

func (RandomDirectorySpecValidationError) ErrorName added in v2.8.0

ErrorName returns error name.

func (RandomDirectorySpecValidationError) Field added in v2.8.0

Field function returns field value.

func (RandomDirectorySpecValidationError) Key added in v2.8.0

Key function returns key value.

func (RandomDirectorySpecValidationError) Reason added in v2.8.0

Reason function returns reason value.

type RandomFile

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

func Files

func Files(fileSource FileSource, count int) ([]*RandomFile, error)

func NewRandomFile

func NewRandomFile(path string, r io.Reader) *RandomFile

func (*RandomFile) Path

func (f *RandomFile) Path() string

func (*RandomFile) Read

func (f *RandomFile) Read(data []byte) (int, error)

type RandomFileSourceSpec

type RandomFileSourceSpec struct {
	Directory     *RandomDirectorySpec `protobuf:"bytes,1,opt,name=directory,proto3" json:"directory,omitempty"`
	Sizes         []*SizeSpec          `protobuf:"bytes,2,rep,name=sizes,proto3" json:"sizes,omitempty"`
	IncrementPath bool                 `protobuf:"varint,3,opt,name=increment_path,json=incrementPath,proto3" json:"increment_path,omitempty"`
	// contains filtered or unexported fields
}

func (*RandomFileSourceSpec) Descriptor deprecated

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

Deprecated: Use RandomFileSourceSpec.ProtoReflect.Descriptor instead.

func (*RandomFileSourceSpec) GetDirectory

func (x *RandomFileSourceSpec) GetDirectory() *RandomDirectorySpec

func (*RandomFileSourceSpec) GetIncrementPath

func (x *RandomFileSourceSpec) GetIncrementPath() bool

func (*RandomFileSourceSpec) GetSizes

func (x *RandomFileSourceSpec) GetSizes() []*SizeSpec

func (*RandomFileSourceSpec) MarshalLogObject

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

func (*RandomFileSourceSpec) ProtoMessage

func (*RandomFileSourceSpec) ProtoMessage()

func (*RandomFileSourceSpec) ProtoReflect added in v2.7.0

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

func (*RandomFileSourceSpec) Reset

func (x *RandomFileSourceSpec) Reset()

func (*RandomFileSourceSpec) String

func (x *RandomFileSourceSpec) String() string

func (*RandomFileSourceSpec) Validate added in v2.8.0

func (m *RandomFileSourceSpec) Validate() error

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

func (m *RandomFileSourceSpec) ValidateAll() error

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

type RandomFileSourceSpecMultiError added in v2.8.0

type RandomFileSourceSpecMultiError []error

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

func (RandomFileSourceSpecMultiError) AllErrors added in v2.8.0

func (m RandomFileSourceSpecMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RandomFileSourceSpecMultiError) Error added in v2.8.0

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

type RandomFileSourceSpecValidationError added in v2.8.0

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

RandomFileSourceSpecValidationError is the validation error returned by RandomFileSourceSpec.Validate if the designated constraints aren't met.

func (RandomFileSourceSpecValidationError) Cause added in v2.8.0

Cause function returns cause value.

func (RandomFileSourceSpecValidationError) Error added in v2.8.0

Error satisfies the builtin error interface

func (RandomFileSourceSpecValidationError) ErrorName added in v2.8.0

ErrorName returns error name.

func (RandomFileSourceSpecValidationError) Field added in v2.8.0

Field function returns field value.

func (RandomFileSourceSpecValidationError) Key added in v2.8.0

Key function returns key value.

func (RandomFileSourceSpecValidationError) Reason added in v2.8.0

Reason function returns reason value.

type SizeSpec

type SizeSpec struct {
	MinSize int64 `protobuf:"varint,1,opt,name=min_size,json=min,proto3" json:"min_size,omitempty"`
	MaxSize int64 `protobuf:"varint,2,opt,name=max_size,json=max,proto3" json:"max_size,omitempty"`
	Prob    int64 `protobuf:"varint,3,opt,name=prob,proto3" json:"prob,omitempty"`
	// contains filtered or unexported fields
}

func FuzzSize

func FuzzSize(specs []*SizeSpec, random *rand.Rand) (*SizeSpec, error)

func (*SizeSpec) Descriptor deprecated

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

Deprecated: Use SizeSpec.ProtoReflect.Descriptor instead.

func (*SizeSpec) GetMaxSize

func (x *SizeSpec) GetMaxSize() int64

func (*SizeSpec) GetMinSize

func (x *SizeSpec) GetMinSize() int64

func (*SizeSpec) GetProb

func (x *SizeSpec) GetProb() int64

func (*SizeSpec) MarshalLogObject

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

func (*SizeSpec) ProtoMessage

func (*SizeSpec) ProtoMessage()

func (*SizeSpec) ProtoReflect added in v2.7.0

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

func (*SizeSpec) Reset

func (x *SizeSpec) Reset()

func (*SizeSpec) String

func (x *SizeSpec) String() string

func (*SizeSpec) Validate added in v2.8.0

func (m *SizeSpec) Validate() error

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

func (m *SizeSpec) ValidateAll() error

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

type SizeSpecMultiError added in v2.8.0

type SizeSpecMultiError []error

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

func (SizeSpecMultiError) AllErrors added in v2.8.0

func (m SizeSpecMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SizeSpecMultiError) Error added in v2.8.0

func (m SizeSpecMultiError) Error() string

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

type SizeSpecValidationError added in v2.8.0

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

SizeSpecValidationError is the validation error returned by SizeSpec.Validate if the designated constraints aren't met.

func (SizeSpecValidationError) Cause added in v2.8.0

func (e SizeSpecValidationError) Cause() error

Cause function returns cause value.

func (SizeSpecValidationError) Error added in v2.8.0

func (e SizeSpecValidationError) Error() string

Error satisfies the builtin error interface

func (SizeSpecValidationError) ErrorName added in v2.8.0

func (e SizeSpecValidationError) ErrorName() string

ErrorName returns error name.

func (SizeSpecValidationError) Field added in v2.8.0

func (e SizeSpecValidationError) Field() string

Field function returns field value.

func (SizeSpecValidationError) Key added in v2.8.0

func (e SizeSpecValidationError) Key() bool

Key function returns key value.

func (SizeSpecValidationError) Reason added in v2.8.0

func (e SizeSpecValidationError) Reason() string

Reason function returns reason value.

type State

type State struct {
	Commits []*State_Commit `protobuf:"bytes,1,rep,name=commits,proto3" json:"commits,omitempty"`
	// contains filtered or unexported fields
}

func (*State) Descriptor deprecated

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

Deprecated: Use State.ProtoReflect.Descriptor instead.

func (*State) GetCommits

func (x *State) GetCommits() []*State_Commit

func (*State) MarshalLogObject

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

func (*State) ProtoMessage

func (*State) ProtoMessage()

func (*State) ProtoReflect added in v2.7.0

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

func (*State) Reset

func (x *State) Reset()

func (*State) String

func (x *State) String() string

func (*State) Validate added in v2.8.0

func (m *State) Validate() error

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

func (m *State) ValidateAll() error

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

type StateMultiError added in v2.8.0

type StateMultiError []error

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

func (StateMultiError) AllErrors added in v2.8.0

func (m StateMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StateMultiError) Error added in v2.8.0

func (m StateMultiError) Error() string

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

type StateValidationError added in v2.8.0

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

StateValidationError is the validation error returned by State.Validate if the designated constraints aren't met.

func (StateValidationError) Cause added in v2.8.0

func (e StateValidationError) Cause() error

Cause function returns cause value.

func (StateValidationError) Error added in v2.8.0

func (e StateValidationError) Error() string

Error satisfies the builtin error interface

func (StateValidationError) ErrorName added in v2.8.0

func (e StateValidationError) ErrorName() string

ErrorName returns error name.

func (StateValidationError) Field added in v2.8.0

func (e StateValidationError) Field() string

Field function returns field value.

func (StateValidationError) Key added in v2.8.0

func (e StateValidationError) Key() bool

Key function returns key value.

func (StateValidationError) Reason added in v2.8.0

func (e StateValidationError) Reason() string

Reason function returns reason value.

type State_Commit

type State_Commit struct {
	Commit *pfs.Commit `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"`
	Hash   []byte      `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*State_Commit) Descriptor deprecated

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

Deprecated: Use State_Commit.ProtoReflect.Descriptor instead.

func (*State_Commit) GetCommit

func (x *State_Commit) GetCommit() *pfs.Commit

func (*State_Commit) GetHash

func (x *State_Commit) GetHash() []byte

func (*State_Commit) MarshalLogObject

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

func (*State_Commit) ProtoMessage

func (*State_Commit) ProtoMessage()

func (*State_Commit) ProtoReflect added in v2.7.0

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

func (*State_Commit) Reset

func (x *State_Commit) Reset()

func (*State_Commit) String

func (x *State_Commit) String() string

func (*State_Commit) Validate added in v2.8.0

func (m *State_Commit) Validate() error

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

func (m *State_Commit) ValidateAll() error

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

type State_CommitMultiError added in v2.8.0

type State_CommitMultiError []error

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

func (State_CommitMultiError) AllErrors added in v2.8.0

func (m State_CommitMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (State_CommitMultiError) Error added in v2.8.0

func (m State_CommitMultiError) Error() string

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

type State_CommitValidationError added in v2.8.0

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

State_CommitValidationError is the validation error returned by State_Commit.Validate if the designated constraints aren't met.

func (State_CommitValidationError) Cause added in v2.8.0

Cause function returns cause value.

func (State_CommitValidationError) Error added in v2.8.0

Error satisfies the builtin error interface

func (State_CommitValidationError) ErrorName added in v2.8.0

func (e State_CommitValidationError) ErrorName() string

ErrorName returns error name.

func (State_CommitValidationError) Field added in v2.8.0

Field function returns field value.

func (State_CommitValidationError) Key added in v2.8.0

Key function returns key value.

func (State_CommitValidationError) Reason added in v2.8.0

Reason function returns reason value.

type Validator

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

func NewValidator

func NewValidator(spec *ValidatorSpec, random *rand.Rand) (*Validator, error)

func (*Validator) AddHash

func (v *Validator) AddHash(hash []byte)

func (*Validator) Hash

func (v *Validator) Hash() []byte

func (*Validator) SetHash

func (v *Validator) SetHash(hash []byte)

func (*Validator) Validate

func (v *Validator) Validate(ctx context.Context, client Client, commit *pfs.Commit) error

type ValidatorSpec

type ValidatorSpec struct {
	Frequency *FrequencySpec `protobuf:"bytes,1,opt,name=frequency,proto3" json:"frequency,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidatorSpec) Descriptor deprecated

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

Deprecated: Use ValidatorSpec.ProtoReflect.Descriptor instead.

func (*ValidatorSpec) GetFrequency

func (x *ValidatorSpec) GetFrequency() *FrequencySpec

func (*ValidatorSpec) MarshalLogObject

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

func (*ValidatorSpec) ProtoMessage

func (*ValidatorSpec) ProtoMessage()

func (*ValidatorSpec) ProtoReflect added in v2.7.0

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

func (*ValidatorSpec) Reset

func (x *ValidatorSpec) Reset()

func (*ValidatorSpec) String

func (x *ValidatorSpec) String() string

func (*ValidatorSpec) Validate added in v2.8.0

func (m *ValidatorSpec) Validate() error

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

func (m *ValidatorSpec) ValidateAll() error

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

type ValidatorSpecMultiError added in v2.8.0

type ValidatorSpecMultiError []error

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

func (ValidatorSpecMultiError) AllErrors added in v2.8.0

func (m ValidatorSpecMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ValidatorSpecMultiError) Error added in v2.8.0

func (m ValidatorSpecMultiError) Error() string

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

type ValidatorSpecValidationError added in v2.8.0

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

ValidatorSpecValidationError is the validation error returned by ValidatorSpec.Validate if the designated constraints aren't met.

func (ValidatorSpecValidationError) Cause added in v2.8.0

Cause function returns cause value.

func (ValidatorSpecValidationError) Error added in v2.8.0

Error satisfies the builtin error interface

func (ValidatorSpecValidationError) ErrorName added in v2.8.0

func (e ValidatorSpecValidationError) ErrorName() string

ErrorName returns error name.

func (ValidatorSpecValidationError) Field added in v2.8.0

Field function returns field value.

func (ValidatorSpecValidationError) Key added in v2.8.0

Key function returns key value.

func (ValidatorSpecValidationError) Reason added in v2.8.0

Reason function returns reason value.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL