Documentation
¶
Index ¶
- Variables
- func Run(satelliteConn *pgx.Conn, loop RangedLoop) error
- type Bucket
- type Count
- func (c *Count) Finish(ctx context.Context) error
- func (c *Count) Fork(ctx context.Context) (rangedloop.Partial, error)
- func (c *Count) Join(ctx context.Context, partial rangedloop.Partial) error
- func (c *Count) Process(ctx context.Context, segments []rangedloop.Segment) error
- func (c *Count) Start(ctx context.Context, time time.Time) error
- func (c *Count) Stats(cb func(key monkit.SeriesKey, field string, val float64))
- type FullScan
- type FullSelectedNode
- type Node
- type Object
- type PieceList
- type PieceListFork
- type Project
- type RangedLoop
- type SQLProvider
- type Segment
Constants ¶
This section is empty.
Variables ¶
View Source
var Error = errs.Class("rs")
Functions ¶
Types ¶
type Count ¶
type Count struct {
// contains filtered or unexported fields
}
type FullScan ¶
type FullScan struct {
// contains filtered or unexported fields
}
func (*FullScan) CreateRanges ¶
func (f *FullScan) CreateRanges(_ context.Context, nRanges int, batchSize int) ([]rangedloop.SegmentProvider, error)
type FullSelectedNode ¶
type FullSelectedNode struct {
nodeselection.SelectedNode
Email string
Wallet string
}
func GetParticipatingNodes ¶
func GetParticipatingNodes(ctx context.Context, db tagsql.DB) (records []*FullSelectedNode, err error)
GetParticipatingNodes returns all known participating nodes (this includes all known nodes excluding nodes that have been disqualified or gracefully exited).
type PieceList ¶ added in v1.4.0
type PieceList struct {
// contains filtered or unexported fields
}
func NewPieceList ¶ added in v1.4.0
type PieceListFork ¶ added in v1.4.0
func (*PieceListFork) Process ¶ added in v1.4.0
func (p *PieceListFork) Process(ctx context.Context, segments []rangedloop.Segment) error
type RangedLoop ¶
type RangedLoop struct {
db.WithDatabase
ScanType string `default:"full"`
ScanParam int
Parallelism int `default:"1"`
NodeID storj.NodeID
Output string
BackupBucket string
BackupDatabase string
BackupDay string
Instance string
}
func (RangedLoop) Run ¶
func (r RangedLoop) Run() error
type SQLProvider ¶
type SQLProvider struct {
// contains filtered or unexported fields
}
func (*SQLProvider) Iterate ¶
func (s *SQLProvider) Iterate(ctx context.Context, fn func([]rangedloop.Segment) error) error
func (*SQLProvider) Range ¶
func (s *SQLProvider) Range() rangedloop.UUIDRange
Click to show internal directories.
Click to hide internal directories.