pfsload

package
v2.7.0-nightly.20230519 Latest Latest
Warning

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

 Go to latest Published: May 18, 2023 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

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

Variables

View Source 
var (
	ErrInvalidLengthPfsload        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPfsload          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPfsload = fmt.Errorf("proto: unexpected end of group")
)

Functions

func Commit 

func Commit(pachClient *client.APIClient, taskService task.Service, branch *pfs.Branch, spec *CommitSpec, seed int64, stateID string) (string, error)

func Modification 

func Modification(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(pachClient *client.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(id string, cb func(*pfs.CommitInfo) error) error
	Ctx() context.Context
}

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(client *client.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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*CommitSpec) Descriptor 

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

func (*CommitSpec) GetCount 

func (m *CommitSpec) GetCount() int64

func (*CommitSpec) GetFileSources 

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

func (*CommitSpec) GetModifications 

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

func (*CommitSpec) GetValidator 

func (m *CommitSpec) GetValidator() *ValidatorSpec

func (*CommitSpec) Marshal 

func (m *CommitSpec) Marshal() (dAtA []byte, err error)

func (*CommitSpec) MarshalLogObject 

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

func (*CommitSpec) MarshalTo 

func (m *CommitSpec) MarshalTo(dAtA []byte) (int, error)

func (*CommitSpec) MarshalToSizedBuffer 

func (m *CommitSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommitSpec) ProtoMessage 

func (*CommitSpec) ProtoMessage()

func (*CommitSpec) Reset 

func (m *CommitSpec) Reset()

func (*CommitSpec) Size 

func (m *CommitSpec) Size() (n int)

func (*CommitSpec) String 

func (m *CommitSpec) String() string

func (*CommitSpec) Unmarshal 

func (m *CommitSpec) Unmarshal(dAtA []byte) error

func (*CommitSpec) XXX_DiscardUnknown 

func (m *CommitSpec) XXX_DiscardUnknown()

func (*CommitSpec) XXX_Marshal 

func (m *CommitSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitSpec) XXX_Merge 

func (m *CommitSpec) XXX_Merge(src proto.Message)

func (*CommitSpec) XXX_Size 

func (m *CommitSpec) XXX_Size() int

func (*CommitSpec) XXX_Unmarshal 

func (m *CommitSpec) XXX_Unmarshal(b []byte) error

type Env 

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

func NewEnv 

func NewEnv(pachClient *client.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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*FileSourceSpec) Descriptor 

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

func (*FileSourceSpec) GetName 

func (m *FileSourceSpec) GetName() string

func (*FileSourceSpec) GetRandom 

func (m *FileSourceSpec) GetRandom() *RandomFileSourceSpec

func (*FileSourceSpec) Marshal 

func (m *FileSourceSpec) Marshal() (dAtA []byte, err error)

func (*FileSourceSpec) MarshalLogObject 

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

func (*FileSourceSpec) MarshalTo 

func (m *FileSourceSpec) MarshalTo(dAtA []byte) (int, error)

func (*FileSourceSpec) MarshalToSizedBuffer 

func (m *FileSourceSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FileSourceSpec) ProtoMessage 

func (*FileSourceSpec) ProtoMessage()

func (*FileSourceSpec) Reset 

func (m *FileSourceSpec) Reset()

func (*FileSourceSpec) Size 

func (m *FileSourceSpec) Size() (n int)

func (*FileSourceSpec) String 

func (m *FileSourceSpec) String() string

func (*FileSourceSpec) Unmarshal 

func (m *FileSourceSpec) Unmarshal(dAtA []byte) error

func (*FileSourceSpec) XXX_DiscardUnknown 

func (m *FileSourceSpec) XXX_DiscardUnknown()

func (*FileSourceSpec) XXX_Marshal 

func (m *FileSourceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileSourceSpec) XXX_Merge 

func (m *FileSourceSpec) XXX_Merge(src proto.Message)

func (*FileSourceSpec) XXX_Size 

func (m *FileSourceSpec) XXX_Size() int

func (*FileSourceSpec) XXX_Unmarshal 

func (m *FileSourceSpec) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FrequencySpec) Descriptor 

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

func (*FrequencySpec) GetCount 

func (m *FrequencySpec) GetCount() int64

func (*FrequencySpec) GetProb 

func (m *FrequencySpec) GetProb() int64

func (*FrequencySpec) Marshal 

func (m *FrequencySpec) Marshal() (dAtA []byte, err error)

func (*FrequencySpec) MarshalLogObject 

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

func (*FrequencySpec) MarshalTo 

func (m *FrequencySpec) MarshalTo(dAtA []byte) (int, error)

func (*FrequencySpec) MarshalToSizedBuffer 

func (m *FrequencySpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FrequencySpec) ProtoMessage 

func (*FrequencySpec) ProtoMessage()

func (*FrequencySpec) Reset 

func (m *FrequencySpec) Reset()

func (*FrequencySpec) Size 

func (m *FrequencySpec) Size() (n int)

func (*FrequencySpec) String 

func (m *FrequencySpec) String() string

func (*FrequencySpec) Unmarshal 

func (m *FrequencySpec) Unmarshal(dAtA []byte) error

func (*FrequencySpec) XXX_DiscardUnknown 

func (m *FrequencySpec) XXX_DiscardUnknown()

func (*FrequencySpec) XXX_Marshal 

func (m *FrequencySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FrequencySpec) XXX_Merge 

func (m *FrequencySpec) XXX_Merge(src proto.Message)

func (*FrequencySpec) XXX_Size 

func (m *FrequencySpec) XXX_Size() int

func (*FrequencySpec) XXX_Unmarshal 

func (m *FrequencySpec) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ModificationSpec) Descriptor 

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

func (*ModificationSpec) GetCount 

func (m *ModificationSpec) GetCount() int64

func (*ModificationSpec) GetPutFile 

func (m *ModificationSpec) GetPutFile() *PutFileSpec

func (*ModificationSpec) Marshal 

func (m *ModificationSpec) Marshal() (dAtA []byte, err error)

func (*ModificationSpec) MarshalLogObject 

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

func (*ModificationSpec) MarshalTo 

func (m *ModificationSpec) MarshalTo(dAtA []byte) (int, error)

func (*ModificationSpec) MarshalToSizedBuffer 

func (m *ModificationSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ModificationSpec) ProtoMessage 

func (*ModificationSpec) ProtoMessage()

func (*ModificationSpec) Reset 

func (m *ModificationSpec) Reset()

func (*ModificationSpec) Size 

func (m *ModificationSpec) Size() (n int)

func (*ModificationSpec) String 

func (m *ModificationSpec) String() string

func (*ModificationSpec) Unmarshal 

func (m *ModificationSpec) Unmarshal(dAtA []byte) error

func (*ModificationSpec) XXX_DiscardUnknown 

func (m *ModificationSpec) XXX_DiscardUnknown()

func (*ModificationSpec) XXX_Marshal 

func (m *ModificationSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModificationSpec) XXX_Merge 

func (m *ModificationSpec) XXX_Merge(src proto.Message)

func (*ModificationSpec) XXX_Size 

func (m *ModificationSpec) XXX_Size() int

func (*ModificationSpec) XXX_Unmarshal 

func (m *ModificationSpec) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PutFileSpec) Descriptor 

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

func (*PutFileSpec) GetCount 

func (m *PutFileSpec) GetCount() int64

func (*PutFileSpec) GetSource 

func (m *PutFileSpec) GetSource() string

func (*PutFileSpec) Marshal 

func (m *PutFileSpec) Marshal() (dAtA []byte, err error)

func (*PutFileSpec) MarshalLogObject 

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

func (*PutFileSpec) MarshalTo 

func (m *PutFileSpec) MarshalTo(dAtA []byte) (int, error)

func (*PutFileSpec) MarshalToSizedBuffer 

func (m *PutFileSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PutFileSpec) ProtoMessage 

func (*PutFileSpec) ProtoMessage()

func (*PutFileSpec) Reset 

func (m *PutFileSpec) Reset()

func (*PutFileSpec) Size 

func (m *PutFileSpec) Size() (n int)

func (*PutFileSpec) String 

func (m *PutFileSpec) String() string

func (*PutFileSpec) Unmarshal 

func (m *PutFileSpec) Unmarshal(dAtA []byte) error

func (*PutFileSpec) XXX_DiscardUnknown 

func (m *PutFileSpec) XXX_DiscardUnknown()

func (*PutFileSpec) XXX_Marshal 

func (m *PutFileSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutFileSpec) XXX_Merge 

func (m *PutFileSpec) XXX_Merge(src proto.Message)

func (*PutFileSpec) XXX_Size 

func (m *PutFileSpec) XXX_Size() int

func (*PutFileSpec) XXX_Unmarshal 

func (m *PutFileSpec) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*PutFileTask) Descriptor 

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

func (*PutFileTask) GetAuthToken 

func (m *PutFileTask) GetAuthToken() string

func (*PutFileTask) GetCount 

func (m *PutFileTask) GetCount() int64

func (*PutFileTask) GetFileSource 

func (m *PutFileTask) GetFileSource() *FileSourceSpec

func (*PutFileTask) GetSeed 

func (m *PutFileTask) GetSeed() int64

func (*PutFileTask) Marshal 

func (m *PutFileTask) Marshal() (dAtA []byte, err error)

func (*PutFileTask) MarshalLogObject 

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

func (*PutFileTask) MarshalTo 

func (m *PutFileTask) MarshalTo(dAtA []byte) (int, error)

func (*PutFileTask) MarshalToSizedBuffer 

func (m *PutFileTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PutFileTask) ProtoMessage 

func (*PutFileTask) ProtoMessage()

func (*PutFileTask) Reset 

func (m *PutFileTask) Reset()

func (*PutFileTask) Size 

func (m *PutFileTask) Size() (n int)

func (*PutFileTask) String 

func (m *PutFileTask) String() string

func (*PutFileTask) Unmarshal 

func (m *PutFileTask) Unmarshal(dAtA []byte) error

func (*PutFileTask) XXX_DiscardUnknown 

func (m *PutFileTask) XXX_DiscardUnknown()

func (*PutFileTask) XXX_Marshal 

func (m *PutFileTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutFileTask) XXX_Merge 

func (m *PutFileTask) XXX_Merge(src proto.Message)

func (*PutFileTask) XXX_Size 

func (m *PutFileTask) XXX_Size() int

func (*PutFileTask) XXX_Unmarshal 

func (m *PutFileTask) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PutFileTaskResult) Descriptor 

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

func (*PutFileTaskResult) GetFileSetId 

func (m *PutFileTaskResult) GetFileSetId() string

func (*PutFileTaskResult) GetHash 

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

func (*PutFileTaskResult) Marshal 

func (m *PutFileTaskResult) Marshal() (dAtA []byte, err error)

func (*PutFileTaskResult) MarshalLogObject 

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

func (*PutFileTaskResult) MarshalTo 

func (m *PutFileTaskResult) MarshalTo(dAtA []byte) (int, error)

func (*PutFileTaskResult) MarshalToSizedBuffer 

func (m *PutFileTaskResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PutFileTaskResult) ProtoMessage 

func (*PutFileTaskResult) ProtoMessage()

func (*PutFileTaskResult) Reset 

func (m *PutFileTaskResult) Reset()

func (*PutFileTaskResult) Size 

func (m *PutFileTaskResult) Size() (n int)

func (*PutFileTaskResult) String 

func (m *PutFileTaskResult) String() string

func (*PutFileTaskResult) Unmarshal 

func (m *PutFileTaskResult) Unmarshal(dAtA []byte) error

func (*PutFileTaskResult) XXX_DiscardUnknown 

func (m *PutFileTaskResult) XXX_DiscardUnknown()

func (*PutFileTaskResult) XXX_Marshal 

func (m *PutFileTaskResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutFileTaskResult) XXX_Merge 

func (m *PutFileTaskResult) XXX_Merge(src proto.Message)

func (*PutFileTaskResult) XXX_Size 

func (m *PutFileTaskResult) XXX_Size() int

func (*PutFileTaskResult) XXX_Unmarshal 

func (m *PutFileTaskResult) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*RandomDirectorySpec) Descriptor 

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

func (*RandomDirectorySpec) GetDepth 

func (m *RandomDirectorySpec) GetDepth() *SizeSpec

func (*RandomDirectorySpec) GetRun 

func (m *RandomDirectorySpec) GetRun() int64

func (*RandomDirectorySpec) Marshal 

func (m *RandomDirectorySpec) Marshal() (dAtA []byte, err error)

func (*RandomDirectorySpec) MarshalLogObject 

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

func (*RandomDirectorySpec) MarshalTo 

func (m *RandomDirectorySpec) MarshalTo(dAtA []byte) (int, error)

func (*RandomDirectorySpec) MarshalToSizedBuffer 

func (m *RandomDirectorySpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RandomDirectorySpec) ProtoMessage 

func (*RandomDirectorySpec) ProtoMessage()

func (*RandomDirectorySpec) Reset 

func (m *RandomDirectorySpec) Reset()

func (*RandomDirectorySpec) Size 

func (m *RandomDirectorySpec) Size() (n int)

func (*RandomDirectorySpec) String 

func (m *RandomDirectorySpec) String() string

func (*RandomDirectorySpec) Unmarshal 

func (m *RandomDirectorySpec) Unmarshal(dAtA []byte) error

func (*RandomDirectorySpec) XXX_DiscardUnknown 

func (m *RandomDirectorySpec) XXX_DiscardUnknown()

func (*RandomDirectorySpec) XXX_Marshal 

func (m *RandomDirectorySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RandomDirectorySpec) XXX_Merge 

func (m *RandomDirectorySpec) XXX_Merge(src proto.Message)

func (*RandomDirectorySpec) XXX_Size 

func (m *RandomDirectorySpec) XXX_Size() int

func (*RandomDirectorySpec) XXX_Unmarshal 

func (m *RandomDirectorySpec) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*RandomFileSourceSpec) Descriptor 

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

func (*RandomFileSourceSpec) GetDirectory 

func (m *RandomFileSourceSpec) GetDirectory() *RandomDirectorySpec

func (*RandomFileSourceSpec) GetIncrementPath 

func (m *RandomFileSourceSpec) GetIncrementPath() bool

func (*RandomFileSourceSpec) GetSizes 

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

func (*RandomFileSourceSpec) Marshal 

func (m *RandomFileSourceSpec) Marshal() (dAtA []byte, err error)

func (*RandomFileSourceSpec) MarshalLogObject 

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

func (*RandomFileSourceSpec) MarshalTo 

func (m *RandomFileSourceSpec) MarshalTo(dAtA []byte) (int, error)

func (*RandomFileSourceSpec) MarshalToSizedBuffer 

func (m *RandomFileSourceSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RandomFileSourceSpec) ProtoMessage 

func (*RandomFileSourceSpec) ProtoMessage()

func (*RandomFileSourceSpec) Reset 

func (m *RandomFileSourceSpec) Reset()

func (*RandomFileSourceSpec) Size 

func (m *RandomFileSourceSpec) Size() (n int)

func (*RandomFileSourceSpec) String 

func (m *RandomFileSourceSpec) String() string

func (*RandomFileSourceSpec) Unmarshal 

func (m *RandomFileSourceSpec) Unmarshal(dAtA []byte) error

func (*RandomFileSourceSpec) XXX_DiscardUnknown 

func (m *RandomFileSourceSpec) XXX_DiscardUnknown()

func (*RandomFileSourceSpec) XXX_Marshal 

func (m *RandomFileSourceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RandomFileSourceSpec) XXX_Merge 

func (m *RandomFileSourceSpec) XXX_Merge(src proto.Message)

func (*RandomFileSourceSpec) XXX_Size 

func (m *RandomFileSourceSpec) XXX_Size() int

func (*RandomFileSourceSpec) XXX_Unmarshal 

func (m *RandomFileSourceSpec) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func FuzzSize 

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

func (*SizeSpec) Descriptor 

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

func (*SizeSpec) GetMaxSize 

func (m *SizeSpec) GetMaxSize() int64

func (*SizeSpec) GetMinSize 

func (m *SizeSpec) GetMinSize() int64

func (*SizeSpec) GetProb 

func (m *SizeSpec) GetProb() int64

func (*SizeSpec) Marshal 

func (m *SizeSpec) Marshal() (dAtA []byte, err error)

func (*SizeSpec) MarshalLogObject 

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

func (*SizeSpec) MarshalTo 

func (m *SizeSpec) MarshalTo(dAtA []byte) (int, error)

func (*SizeSpec) MarshalToSizedBuffer 

func (m *SizeSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SizeSpec) ProtoMessage 

func (*SizeSpec) ProtoMessage()

func (*SizeSpec) Reset 

func (m *SizeSpec) Reset()

func (*SizeSpec) Size 

func (m *SizeSpec) Size() (n int)

func (*SizeSpec) String 

func (m *SizeSpec) String() string

func (*SizeSpec) Unmarshal 

func (m *SizeSpec) Unmarshal(dAtA []byte) error

func (*SizeSpec) XXX_DiscardUnknown 

func (m *SizeSpec) XXX_DiscardUnknown()

func (*SizeSpec) XXX_Marshal 

func (m *SizeSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SizeSpec) XXX_Merge 

func (m *SizeSpec) XXX_Merge(src proto.Message)

func (*SizeSpec) XXX_Size 

func (m *SizeSpec) XXX_Size() int

func (*SizeSpec) XXX_Unmarshal 

func (m *SizeSpec) XXX_Unmarshal(b []byte) error

type State 

type State struct {
	Commits              []*State_Commit `protobuf:"bytes,1,rep,name=commits,proto3" json:"commits,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*State) Descriptor 

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

func (*State) GetCommits 

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

func (*State) Marshal 

func (m *State) Marshal() (dAtA []byte, err error)

func (*State) MarshalLogObject 

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

func (*State) MarshalTo 

func (m *State) MarshalTo(dAtA []byte) (int, error)

func (*State) MarshalToSizedBuffer 

func (m *State) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*State) ProtoMessage 

func (*State) ProtoMessage()

func (*State) Reset 

func (m *State) Reset()

func (*State) Size 

func (m *State) Size() (n int)

func (*State) String 

func (m *State) String() string

func (*State) Unmarshal 

func (m *State) Unmarshal(dAtA []byte) error

func (*State) XXX_DiscardUnknown 

func (m *State) XXX_DiscardUnknown()

func (*State) XXX_Marshal 

func (m *State) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*State) XXX_Merge 

func (m *State) XXX_Merge(src proto.Message)

func (*State) XXX_Size 

func (m *State) XXX_Size() int

func (*State) XXX_Unmarshal 

func (m *State) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*State_Commit) Descriptor 

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

func (*State_Commit) GetCommit 

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

func (*State_Commit) GetHash 

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

func (*State_Commit) Marshal 

func (m *State_Commit) Marshal() (dAtA []byte, err error)

func (*State_Commit) MarshalLogObject 

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

func (*State_Commit) MarshalTo 

func (m *State_Commit) MarshalTo(dAtA []byte) (int, error)

func (*State_Commit) MarshalToSizedBuffer 

func (m *State_Commit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*State_Commit) ProtoMessage 

func (*State_Commit) ProtoMessage()

func (*State_Commit) Reset 

func (m *State_Commit) Reset()

func (*State_Commit) Size 

func (m *State_Commit) Size() (n int)

func (*State_Commit) String 

func (m *State_Commit) String() string

func (*State_Commit) Unmarshal 

func (m *State_Commit) Unmarshal(dAtA []byte) error

func (*State_Commit) XXX_DiscardUnknown 

func (m *State_Commit) XXX_DiscardUnknown()

func (*State_Commit) XXX_Marshal 

func (m *State_Commit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*State_Commit) XXX_Merge 

func (m *State_Commit) XXX_Merge(src proto.Message)

func (*State_Commit) XXX_Size 

func (m *State_Commit) XXX_Size() int

func (*State_Commit) XXX_Unmarshal 

func (m *State_Commit) XXX_Unmarshal(b []byte) error

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(client Client, commit *pfs.Commit) error

type ValidatorSpec 

type ValidatorSpec struct {
	Frequency            *FrequencySpec `protobuf:"bytes,1,opt,name=frequency,proto3" json:"frequency,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ValidatorSpec) Descriptor 

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

func (*ValidatorSpec) GetFrequency 

func (m *ValidatorSpec) GetFrequency() *FrequencySpec

func (*ValidatorSpec) Marshal 

func (m *ValidatorSpec) Marshal() (dAtA []byte, err error)

func (*ValidatorSpec) MarshalLogObject 

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

func (*ValidatorSpec) MarshalTo 

func (m *ValidatorSpec) MarshalTo(dAtA []byte) (int, error)

func (*ValidatorSpec) MarshalToSizedBuffer 

func (m *ValidatorSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ValidatorSpec) ProtoMessage 

func (*ValidatorSpec) ProtoMessage()

func (*ValidatorSpec) Reset 

func (m *ValidatorSpec) Reset()

func (*ValidatorSpec) Size 

func (m *ValidatorSpec) Size() (n int)

func (*ValidatorSpec) String 

func (m *ValidatorSpec) String() string

func (*ValidatorSpec) Unmarshal 

func (m *ValidatorSpec) Unmarshal(dAtA []byte) error

func (*ValidatorSpec) XXX_DiscardUnknown 

func (m *ValidatorSpec) XXX_DiscardUnknown()

func (*ValidatorSpec) XXX_Marshal 

func (m *ValidatorSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValidatorSpec) XXX_Merge 

func (m *ValidatorSpec) XXX_Merge(src proto.Message)

func (*ValidatorSpec) XXX_Size 

func (m *ValidatorSpec) XXX_Size() int

func (*ValidatorSpec) XXX_Unmarshal 

func (m *ValidatorSpec) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

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