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
)

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,
	jobPollIntervalSlow time.Duration,
	jobPollIntervalFast time.Duration,
) (*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 string,
	bucketRoot cid.Cid,
	owner thread.PubKey,
) error