bloom

Documentation

Index

• type Bloom
• type Check
  • func (c Check) Run() error
• type ChunkReader
  • func (t *ChunkReader) ReadAt(p []byte, off int64) (n int, err error)
• type CreateFilter
  • func (c CreateFilter) Run() error
• type Find
  • func (f Find) Run() error
• type Generate
  • func (c Generate) Run() error
• type Info
  • func (i Info) Run() error
• type Send
  • func (s Send) Run() error
• type SendClient
  • func (s SendClient) Run() error

Types

type Bloom

type Bloom struct {
	Create     CreateFilter `cmd:"" help:"create bloom filter based on a list of piece IDs"`
	Generate   Generate     `cmd:"" help:"generate bloom filter with all one"`
	Check      Check        `cmd:"" help:"checks piece ids (from file) against a bloom filter"`
	Info       Info         `cmd:"" help:"print out bloom filter metadata"`
	Send       Send         `cmd:"" help:"send bloom filter to a storagenode, with raw RPC call"`
	SendClient SendClient   `cmd:"" help:"send bloom filter to a storagenode, with piecestore client"`
	Find       Find         `cmd:"" help:"Find BF for specific nodes in the generated ZIP files"`
}

type Check

type Check struct {
	BloomFilterFile string `default:"bloom.filter"`
	PiecesFile      string `default:"pieces.txt"`
}

func (Check) Run

func (c Check) Run() error

type ChunkReader

type ChunkReader struct {
	io.ReaderAt
	// contains filtered or unexported fields
}

func (*ChunkReader) ReadAt

func (t *ChunkReader) ReadAt(p []byte, off int64) (n int, err error)

type CreateFilter

type CreateFilter struct {
	PiecesFile        string      `default:"pieces.txt"`
	FalsePositiveRate float64     `default:"0.01"`
	ExpectedElement   int64       `default:"10000000"`
	MaxMemory         memory.Size `default:"2000000"`
	Output            string      `default:"bloom.filter"`
}

func (CreateFilter) Run

func (c CreateFilter) Run() error

type Find

type Find struct {
	NodeID storj.NodeID `arg:""`
	Bucket string
	Prefix string
}

func (Find) Run

func (f Find) Run() error

type Generate

type Generate struct {
	NodeID storj.NodeID `arg:""`
	Size   memory.Size  `default:"2000000"`
	Output string       `default:"bloom.filter"`
}

func (Generate) Run

func (c Generate) Run() error

type Info

type Info struct {
	BloomFilterFile string `arg:""`
}

func (Info) Run

func (i Info) Run() error

type Send

type Send struct {
	util.DialerHelper
	URL  storj.NodeURL
	Size int `default:"4200000"`
}

func (Send) Run

func (s Send) Run() error

type SendClient

type SendClient struct {
	util.DialerHelper
	URL    storj.NodeURL
	Filter string `arg:""`
}

func (SendClient) Run

func (s SendClient) Run() error