tracker

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) TrackArchive(ctx context.Context, dbID thread.ID, dbToken thread.Token, bucketKey string, ...) error
  • func (t *Tracker) TrackRetrieval(ctx context.Context, accKey, jobID, powToken string) error

Variables

var (
	// CheckInterval is the frequency in which new ready-to-check
	// tracked jobs are queried.
	CheckInterval = time.Second * 15
)

Types

type Tracker

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

Tracker tracks Powergate jobs to their final status. Tracked jobs corresponds to Archives or Retrievals. Depending of the case, is what logic is applied when the Job reach a final status.

func New

func New(
	colls *mdb.Collections,
	buckets *tdb.Buckets,
	pgClient *powc.Client,
	internalSession string,
	jobPollIntervalSlow time.Duration,
	jobPollIntervalFast time.Duration,
	jfe chan<- archive.JobEvent,
) (*Tracker, error)

New returns a *Tracker.

func (*Tracker) Close

func (t *Tracker) Close() error

Close closes the module gracefully.

func (*Tracker) TrackArchive

func (t *Tracker) TrackArchive(
	ctx context.Context,
	dbID thread.ID,
	dbToken thread.Token,
	bucketKey string,
	jid string,
	bucketRoot cid.Cid,
	owner thread.PubKey,
) error

TrackArchive registers a new tracking for a Job, which corresponds to an bucket Archive action.

func (*Tracker) TrackRetrieval

func (t *Tracker) TrackRetrieval(ctx context.Context, accKey, jobID, powToken string) error

TrackRetrieval registers a new tracking for a Job, which corresponds to a Retrieval.