archive

Documentation

Index

• Variables
• type Tracker
  • func New(colls *mdb.Collections, buckets *tdb.Buckets, pgClient *powc.Client, ...) (*Tracker, error)
  • func (t *Tracker) Close() error
  • func (t *Tracker) Track(ctx context.Context, dbID thread.ID, dbToken thread.Token, bucketKey string, ...) error

Variables

var (
	CheckInterval         = time.Second * 15
	JobStatusPollInterval = time.Second * 30
)

Types

type Tracker

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

func New

func New(colls *mdb.Collections, buckets *tdb.Buckets, pgClient *powc.Client, internalSession string) (*Tracker, error)

func (*Tracker) Close

func (t *Tracker) Close() error

func (*Tracker) Track

func (t *Tracker) Track(ctx context.Context, dbID thread.ID, dbToken thread.Token, bucketKey string, jid ffs.JobID, bucketRoot cid.Cid) error