Documentation ¶
Index ¶
- Constants
- Variables
- func Commit(ctx context.Context, c pfs.APIClient, taskService task.Service, ...) (string, error)
- func Modification(ctx context.Context, env *Env, commit *pfs.Commit, spec *ModificationSpec) error
- func NewValidatorClient(client Client) *validatorClient
- func PutFile(ctx context.Context, c Client, fileSource FileSource, count int) (string, error)
- func Worker(ctx context.Context, c pfs.APIClient, taskService task.Service) error
- type Client
- type CommitSpec
- func (*CommitSpec) Descriptor() ([]byte, []int)deprecated
- func (x *CommitSpec) GetCount() int64
- func (x *CommitSpec) GetFileSources() []*FileSourceSpec
- func (x *CommitSpec) GetModifications() []*ModificationSpec
- func (x *CommitSpec) GetValidator() *ValidatorSpec
- func (x *CommitSpec) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*CommitSpec) ProtoMessage()
- func (x *CommitSpec) ProtoReflect() protoreflect.Message
- func (x *CommitSpec) Reset()
- func (x *CommitSpec) String() string
- func (m *CommitSpec) Validate() error
- func (m *CommitSpec) ValidateAll() error
- type CommitSpecMultiError
- type CommitSpecValidationError
- type Env
- type FileSource
- type FileSourceSpec
- func (*FileSourceSpec) Descriptor() ([]byte, []int)deprecated
- func (x *FileSourceSpec) GetName() string
- func (x *FileSourceSpec) GetRandom() *RandomFileSourceSpec
- func (x *FileSourceSpec) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*FileSourceSpec) ProtoMessage()
- func (x *FileSourceSpec) ProtoReflect() protoreflect.Message
- func (x *FileSourceSpec) Reset()
- func (x *FileSourceSpec) String() string
- func (m *FileSourceSpec) Validate() error
- func (m *FileSourceSpec) ValidateAll() error
- type FileSourceSpecMultiError
- type FileSourceSpecValidationError
- func (e FileSourceSpecValidationError) Cause() error
- func (e FileSourceSpecValidationError) Error() string
- func (e FileSourceSpecValidationError) ErrorName() string
- func (e FileSourceSpecValidationError) Field() string
- func (e FileSourceSpecValidationError) Key() bool
- func (e FileSourceSpecValidationError) Reason() string
- type FrequencySpec
- func (*FrequencySpec) Descriptor() ([]byte, []int)deprecated
- func (x *FrequencySpec) GetCount() int64
- func (x *FrequencySpec) GetProb() int64
- func (x *FrequencySpec) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*FrequencySpec) ProtoMessage()
- func (x *FrequencySpec) ProtoReflect() protoreflect.Message
- func (x *FrequencySpec) Reset()
- func (x *FrequencySpec) String() string
- func (m *FrequencySpec) Validate() error
- func (m *FrequencySpec) ValidateAll() error
- type FrequencySpecMultiError
- type FrequencySpecValidationError
- func (e FrequencySpecValidationError) Cause() error
- func (e FrequencySpecValidationError) Error() string
- func (e FrequencySpecValidationError) ErrorName() string
- func (e FrequencySpecValidationError) Field() string
- func (e FrequencySpecValidationError) Key() bool
- func (e FrequencySpecValidationError) Reason() string
- type ModificationSpec
- func (*ModificationSpec) Descriptor() ([]byte, []int)deprecated
- func (x *ModificationSpec) GetCount() int64
- func (x *ModificationSpec) GetPutFile() *PutFileSpec
- func (x *ModificationSpec) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*ModificationSpec) ProtoMessage()
- func (x *ModificationSpec) ProtoReflect() protoreflect.Message
- func (x *ModificationSpec) Reset()
- func (x *ModificationSpec) String() string
- func (m *ModificationSpec) Validate() error
- func (m *ModificationSpec) ValidateAll() error
- type ModificationSpecMultiError
- type ModificationSpecValidationError
- func (e ModificationSpecValidationError) Cause() error
- func (e ModificationSpecValidationError) Error() string
- func (e ModificationSpecValidationError) ErrorName() string
- func (e ModificationSpecValidationError) Field() string
- func (e ModificationSpecValidationError) Key() bool
- func (e ModificationSpecValidationError) Reason() string
- type PutFileSpec
- func (*PutFileSpec) Descriptor() ([]byte, []int)deprecated
- func (x *PutFileSpec) GetCount() int64
- func (x *PutFileSpec) GetSource() string
- func (x *PutFileSpec) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*PutFileSpec) ProtoMessage()
- func (x *PutFileSpec) ProtoReflect() protoreflect.Message
- func (x *PutFileSpec) Reset()
- func (x *PutFileSpec) String() string
- func (m *PutFileSpec) Validate() error
- func (m *PutFileSpec) ValidateAll() error
- type PutFileSpecMultiError
- type PutFileSpecValidationError
- func (e PutFileSpecValidationError) Cause() error
- func (e PutFileSpecValidationError) Error() string
- func (e PutFileSpecValidationError) ErrorName() string
- func (e PutFileSpecValidationError) Field() string
- func (e PutFileSpecValidationError) Key() bool
- func (e PutFileSpecValidationError) Reason() string
- type PutFileTask
- func (*PutFileTask) Descriptor() ([]byte, []int)deprecated
- func (x *PutFileTask) GetAuthToken() string
- func (x *PutFileTask) GetCount() int64
- func (x *PutFileTask) GetFileSource() *FileSourceSpec
- func (x *PutFileTask) GetSeed() int64
- func (x *PutFileTask) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*PutFileTask) ProtoMessage()
- func (x *PutFileTask) ProtoReflect() protoreflect.Message
- func (x *PutFileTask) Reset()
- func (x *PutFileTask) String() string
- func (m *PutFileTask) Validate() error
- func (m *PutFileTask) ValidateAll() error
- type PutFileTaskMultiError
- type PutFileTaskResult
- func (*PutFileTaskResult) Descriptor() ([]byte, []int)deprecated
- func (x *PutFileTaskResult) GetFileSetId() string
- func (x *PutFileTaskResult) GetHash() []byte
- func (x *PutFileTaskResult) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*PutFileTaskResult) ProtoMessage()
- func (x *PutFileTaskResult) ProtoReflect() protoreflect.Message
- func (x *PutFileTaskResult) Reset()
- func (x *PutFileTaskResult) String() string
- func (m *PutFileTaskResult) Validate() error
- func (m *PutFileTaskResult) ValidateAll() error
- type PutFileTaskResultMultiError
- type PutFileTaskResultValidationError
- func (e PutFileTaskResultValidationError) Cause() error
- func (e PutFileTaskResultValidationError) Error() string
- func (e PutFileTaskResultValidationError) ErrorName() string
- func (e PutFileTaskResultValidationError) Field() string
- func (e PutFileTaskResultValidationError) Key() bool
- func (e PutFileTaskResultValidationError) Reason() string
- type PutFileTaskValidationError
- func (e PutFileTaskValidationError) Cause() error
- func (e PutFileTaskValidationError) Error() string
- func (e PutFileTaskValidationError) ErrorName() string
- func (e PutFileTaskValidationError) Field() string
- func (e PutFileTaskValidationError) Key() bool
- func (e PutFileTaskValidationError) Reason() string
- type RandomDirectorySpec
- func (*RandomDirectorySpec) Descriptor() ([]byte, []int)deprecated
- func (x *RandomDirectorySpec) GetDepth() *SizeSpec
- func (x *RandomDirectorySpec) GetRun() int64
- func (x *RandomDirectorySpec) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*RandomDirectorySpec) ProtoMessage()
- func (x *RandomDirectorySpec) ProtoReflect() protoreflect.Message
- func (x *RandomDirectorySpec) Reset()
- func (x *RandomDirectorySpec) String() string
- func (m *RandomDirectorySpec) Validate() error
- func (m *RandomDirectorySpec) ValidateAll() error
- type RandomDirectorySpecMultiError
- type RandomDirectorySpecValidationError
- func (e RandomDirectorySpecValidationError) Cause() error
- func (e RandomDirectorySpecValidationError) Error() string
- func (e RandomDirectorySpecValidationError) ErrorName() string
- func (e RandomDirectorySpecValidationError) Field() string
- func (e RandomDirectorySpecValidationError) Key() bool
- func (e RandomDirectorySpecValidationError) Reason() string
- type RandomFile
- type RandomFileSourceSpec
- func (*RandomFileSourceSpec) Descriptor() ([]byte, []int)deprecated
- func (x *RandomFileSourceSpec) GetDirectory() *RandomDirectorySpec
- func (x *RandomFileSourceSpec) GetIncrementPath() bool
- func (x *RandomFileSourceSpec) GetSizes() []*SizeSpec
- func (x *RandomFileSourceSpec) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*RandomFileSourceSpec) ProtoMessage()
- func (x *RandomFileSourceSpec) ProtoReflect() protoreflect.Message
- func (x *RandomFileSourceSpec) Reset()
- func (x *RandomFileSourceSpec) String() string
- func (m *RandomFileSourceSpec) Validate() error
- func (m *RandomFileSourceSpec) ValidateAll() error
- type RandomFileSourceSpecMultiError
- type RandomFileSourceSpecValidationError
- func (e RandomFileSourceSpecValidationError) Cause() error
- func (e RandomFileSourceSpecValidationError) Error() string
- func (e RandomFileSourceSpecValidationError) ErrorName() string
- func (e RandomFileSourceSpecValidationError) Field() string
- func (e RandomFileSourceSpecValidationError) Key() bool
- func (e RandomFileSourceSpecValidationError) Reason() string
- type SizeSpec
- func (*SizeSpec) Descriptor() ([]byte, []int)deprecated
- func (x *SizeSpec) GetMaxSize() int64
- func (x *SizeSpec) GetMinSize() int64
- func (x *SizeSpec) GetProb() int64
- func (x *SizeSpec) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*SizeSpec) ProtoMessage()
- func (x *SizeSpec) ProtoReflect() protoreflect.Message
- func (x *SizeSpec) Reset()
- func (x *SizeSpec) String() string
- func (m *SizeSpec) Validate() error
- func (m *SizeSpec) ValidateAll() error
- type SizeSpecMultiError
- type SizeSpecValidationError
- type State
- func (*State) Descriptor() ([]byte, []int)deprecated
- func (x *State) GetCommits() []*State_Commit
- func (x *State) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*State) ProtoMessage()
- func (x *State) ProtoReflect() protoreflect.Message
- func (x *State) Reset()
- func (x *State) String() string
- func (m *State) Validate() error
- func (m *State) ValidateAll() error
- type StateMultiError
- type StateValidationError
- type State_Commit
- func (*State_Commit) Descriptor() ([]byte, []int)deprecated
- func (x *State_Commit) GetCommit() *pfs.Commit
- func (x *State_Commit) GetHash() []byte
- func (x *State_Commit) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*State_Commit) ProtoMessage()
- func (x *State_Commit) ProtoReflect() protoreflect.Message
- func (x *State_Commit) Reset()
- func (x *State_Commit) String() string
- func (m *State_Commit) Validate() error
- func (m *State_Commit) ValidateAll() error
- type State_CommitMultiError
- type State_CommitValidationError
- func (e State_CommitValidationError) Cause() error
- func (e State_CommitValidationError) Error() string
- func (e State_CommitValidationError) ErrorName() string
- func (e State_CommitValidationError) Field() string
- func (e State_CommitValidationError) Key() bool
- func (e State_CommitValidationError) Reason() string
- type Validator
- type ValidatorSpec
- func (*ValidatorSpec) Descriptor() ([]byte, []int)deprecated
- func (x *ValidatorSpec) GetFrequency() *FrequencySpec
- func (x *ValidatorSpec) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*ValidatorSpec) ProtoMessage()
- func (x *ValidatorSpec) ProtoReflect() protoreflect.Message
- func (x *ValidatorSpec) Reset()
- func (x *ValidatorSpec) String() string
- func (m *ValidatorSpec) Validate() error
- func (m *ValidatorSpec) ValidateAll() error
- type ValidatorSpecMultiError
- type ValidatorSpecValidationError
- func (e ValidatorSpecValidationError) Cause() error
- func (e ValidatorSpecValidationError) Error() string
- func (e ValidatorSpecValidationError) ErrorName() string
- func (e ValidatorSpecValidationError) Field() string
- func (e ValidatorSpecValidationError) Key() bool
- func (e ValidatorSpecValidationError) Reason() string
Constants ¶
const LoadSpecification string = `` /* 1095-byte string literal not displayed */
Variables ¶
var File_internal_pfsload_pfsload_proto protoreflect.FileDescriptor
Functions ¶
func Modification ¶
func NewValidatorClient ¶
func NewValidatorClient(client Client) *validatorClient
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 ¶
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
func (e CommitSpecValidationError) Error() string
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
func (e CommitSpecValidationError) Field() string
Field function returns field value.
func (CommitSpecValidationError) Key ¶ added in v2.8.0
func (e CommitSpecValidationError) Key() bool
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 (*Env) FileSource ¶
func (e *Env) FileSource(name string) *FileSourceSpec
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
func (e FileSourceSpecValidationError) Cause() error
Cause function returns cause value.
func (FileSourceSpecValidationError) Error ¶ added in v2.8.0
func (e FileSourceSpecValidationError) Error() string
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
func (e FileSourceSpecValidationError) Field() string
Field function returns field value.
func (FileSourceSpecValidationError) Key ¶ added in v2.8.0
func (e FileSourceSpecValidationError) Key() bool
Key function returns key value.
func (FileSourceSpecValidationError) Reason ¶ added in v2.8.0
func (e FileSourceSpecValidationError) Reason() string
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
func (e FrequencySpecValidationError) Cause() error
Cause function returns cause value.
func (FrequencySpecValidationError) Error ¶ added in v2.8.0
func (e FrequencySpecValidationError) Error() string
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
func (e FrequencySpecValidationError) Field() string
Field function returns field value.
func (FrequencySpecValidationError) Key ¶ added in v2.8.0
func (e FrequencySpecValidationError) Key() bool
Key function returns key value.
func (FrequencySpecValidationError) Reason ¶ added in v2.8.0
func (e FrequencySpecValidationError) Reason() string
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
func (m ModificationSpecMultiError) Error() string
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
func (e ModificationSpecValidationError) Cause() error
Cause function returns cause value.
func (ModificationSpecValidationError) Error ¶ added in v2.8.0
func (e ModificationSpecValidationError) Error() string
Error satisfies the builtin error interface
func (ModificationSpecValidationError) ErrorName ¶ added in v2.8.0
func (e ModificationSpecValidationError) ErrorName() string
ErrorName returns error name.
func (ModificationSpecValidationError) Field ¶ added in v2.8.0
func (e ModificationSpecValidationError) Field() string
Field function returns field value.
func (ModificationSpecValidationError) Key ¶ added in v2.8.0
func (e ModificationSpecValidationError) Key() bool
Key function returns key value.
func (ModificationSpecValidationError) Reason ¶ added in v2.8.0
func (e ModificationSpecValidationError) Reason() string
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
func (e PutFileSpecValidationError) Cause() error
Cause function returns cause value.
func (PutFileSpecValidationError) Error ¶ added in v2.8.0
func (e PutFileSpecValidationError) Error() string
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
func (e PutFileSpecValidationError) Field() string
Field function returns field value.
func (PutFileSpecValidationError) Key ¶ added in v2.8.0
func (e PutFileSpecValidationError) Key() bool
Key function returns key value.
func (PutFileSpecValidationError) Reason ¶ added in v2.8.0
func (e PutFileSpecValidationError) Reason() string
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
func (m PutFileTaskResultMultiError) Error() string
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
func (e PutFileTaskResultValidationError) Cause() error
Cause function returns cause value.
func (PutFileTaskResultValidationError) Error ¶ added in v2.8.0
func (e PutFileTaskResultValidationError) Error() string
Error satisfies the builtin error interface
func (PutFileTaskResultValidationError) ErrorName ¶ added in v2.8.0
func (e PutFileTaskResultValidationError) ErrorName() string
ErrorName returns error name.
func (PutFileTaskResultValidationError) Field ¶ added in v2.8.0
func (e PutFileTaskResultValidationError) Field() string
Field function returns field value.
func (PutFileTaskResultValidationError) Key ¶ added in v2.8.0
func (e PutFileTaskResultValidationError) Key() bool
Key function returns key value.
func (PutFileTaskResultValidationError) Reason ¶ added in v2.8.0
func (e PutFileTaskResultValidationError) Reason() string
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
func (e PutFileTaskValidationError) Cause() error
Cause function returns cause value.
func (PutFileTaskValidationError) Error ¶ added in v2.8.0
func (e PutFileTaskValidationError) Error() string
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
func (e PutFileTaskValidationError) Field() string
Field function returns field value.
func (PutFileTaskValidationError) Key ¶ added in v2.8.0
func (e PutFileTaskValidationError) Key() bool
Key function returns key value.
func (PutFileTaskValidationError) Reason ¶ added in v2.8.0
func (e PutFileTaskValidationError) Reason() string
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
func (m RandomDirectorySpecMultiError) Error() string
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
func (e RandomDirectorySpecValidationError) Cause() error
Cause function returns cause value.
func (RandomDirectorySpecValidationError) Error ¶ added in v2.8.0
func (e RandomDirectorySpecValidationError) Error() string
Error satisfies the builtin error interface
func (RandomDirectorySpecValidationError) ErrorName ¶ added in v2.8.0
func (e RandomDirectorySpecValidationError) ErrorName() string
ErrorName returns error name.
func (RandomDirectorySpecValidationError) Field ¶ added in v2.8.0
func (e RandomDirectorySpecValidationError) Field() string
Field function returns field value.
func (RandomDirectorySpecValidationError) Key ¶ added in v2.8.0
func (e RandomDirectorySpecValidationError) Key() bool
Key function returns key value.
func (RandomDirectorySpecValidationError) Reason ¶ added in v2.8.0
func (e RandomDirectorySpecValidationError) Reason() string
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
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
func (m RandomFileSourceSpecMultiError) Error() string
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
func (e RandomFileSourceSpecValidationError) Cause() error
Cause function returns cause value.
func (RandomFileSourceSpecValidationError) Error ¶ added in v2.8.0
func (e RandomFileSourceSpecValidationError) Error() string
Error satisfies the builtin error interface
func (RandomFileSourceSpecValidationError) ErrorName ¶ added in v2.8.0
func (e RandomFileSourceSpecValidationError) ErrorName() string
ErrorName returns error name.
func (RandomFileSourceSpecValidationError) Field ¶ added in v2.8.0
func (e RandomFileSourceSpecValidationError) Field() string
Field function returns field value.
func (RandomFileSourceSpecValidationError) Key ¶ added in v2.8.0
func (e RandomFileSourceSpecValidationError) Key() bool
Key function returns key value.
func (RandomFileSourceSpecValidationError) Reason ¶ added in v2.8.0
func (e RandomFileSourceSpecValidationError) Reason() string
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 (*SizeSpec) Descriptor
deprecated
func (*SizeSpec) GetMaxSize ¶
func (*SizeSpec) GetMinSize ¶
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) Validate ¶ added in v2.8.0
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
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) 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) Validate ¶ added in v2.8.0
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
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
func (e State_CommitValidationError) Cause() error
Cause function returns cause value.
func (State_CommitValidationError) Error ¶ added in v2.8.0
func (e State_CommitValidationError) Error() string
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
func (e State_CommitValidationError) Field() string
Field function returns field value.
func (State_CommitValidationError) Key ¶ added in v2.8.0
func (e State_CommitValidationError) Key() bool
Key function returns key value.
func (State_CommitValidationError) Reason ¶ added in v2.8.0
func (e State_CommitValidationError) Reason() string
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)
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
func (e ValidatorSpecValidationError) Cause() error
Cause function returns cause value.
func (ValidatorSpecValidationError) Error ¶ added in v2.8.0
func (e ValidatorSpecValidationError) Error() string
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
func (e ValidatorSpecValidationError) Field() string
Field function returns field value.
func (ValidatorSpecValidationError) Key ¶ added in v2.8.0
func (e ValidatorSpecValidationError) Key() bool
Key function returns key value.
func (ValidatorSpecValidationError) Reason ¶ added in v2.8.0
func (e ValidatorSpecValidationError) Reason() string
Reason function returns reason value.