state

Mar 7, 2022

Changes in this version

+ type SqlDatastore struct

+ func NewSqlDatastore(connector DBConnector, queries sqlds.Queries) *SqlDatastore

+ func (sds *SqlDatastore) Batch(ctx context.Context) (datastore.Batch, error)

+ func (sds *SqlDatastore) Close() error

+ func (sds *SqlDatastore) Delete(ctx context.Context, key datastore.Key) error

+ func (sds *SqlDatastore) Get(ctx context.Context, key datastore.Key) (value []byte, err error)

+ func (sds *SqlDatastore) GetSize(ctx context.Context, key datastore.Key) (size int, err error)

+ func (sds *SqlDatastore) Has(ctx context.Context, key datastore.Key) (exists bool, err error)

+ func (sds *SqlDatastore) Put(ctx context.Context, key datastore.Key, value []byte) error

+ func (sds *SqlDatastore) Query(ctx context.Context, q query.Query) (query.Results, error)

+ func (sds *SqlDatastore) Sync(ctx context.Context, prefix datastore.Key) error

Feb 9, 2022

Changes in this version

+ func NewHost(priv crypto.PrivKey, listenAddrs []multiaddr.Multiaddr) (host.Host, error)

Dec 1, 2021

Changes in this version

type Store

+ Has func(context.Context, string) (bool, error)

+ Put func(ctx context.Context, key string, content []byte) error

Sep 14, 2021

Changes in this version

type State

+ UndrainWorker func(ctx context.Context, worker string) error

Jul 1, 2021

Changes in this version

+ const ErrNoDeleteInProgressTasks

+ const ErrTaskNotFound

+ func WipeAndReset(dbConn DBConnector, migrator Migrator) error

type DBConnector

+ func NewDBConnector(driver string, conn string) (DBConnector, error)

+ type Migrator func(*sql.DB) error

+ func NewMigrator(driver string) (Migrator, error)

type State

+ Delete func(ctx context.Context, uuid string) error

Jun 18, 2021

Changes in this version

type State

+ ResetWorkerTasks func(ctx context.Context, worker string) error

Jun 8, 2021

Changes in this version

+ const ErrNotAssigned

+ const ErrWrongWorker

type DBConnector

+ Name func() string

+ RetryableError func(error) bool

+ type RecordUpdateStatus int

+ const ATTACHED_RECORD

+ const LATEST_UPDATE

+ const PREVIOUS_UPDATE

+ const UNATTACHED_RECORD

type State

+ DrainWorker func(ctx context.Context, worker string) error

+ GetHead func(ctx context.Context) (tasks.RecordUpdate, error)

+ PublishRecordsFrom func(ctx context.Context, worker string) error

+ Store func(ctx context.Context) Store

+ type Store interface

+ Get func(cid.Cid) (blockformat.Block, error)

+ Head func() (cid.Cid, error)

+ Set func(cid.Cid, []byte) error

Apr 26, 2021

Changes in this version

type State

+ AssignTask func(ctx context.Context, req client.UpdateTaskRequest) (*tasks.Task, error)

Apr 22, 2021

Changes in this version

+ type DBConnector interface

+ Connect func() error

+ SqlDB func() *sql.DB

+ type State interface

+ Get func(ctx context.Context, uuid string) (*tasks.AuthenticatedTask, error)

+ GetAll func(ctx context.Context) ([]*tasks.AuthenticatedTask, error)

+ NewRetrievalTask func(ctx context.Context, retrievalTask *tasks.RetrievalTask) (*tasks.AuthenticatedTask, error)

+ NewStorageTask func(ctx context.Context, storageTask *tasks.StorageTask) (*tasks.AuthenticatedTask, error)

+ Update func(ctx context.Context, uuid string, req *client.UpdateTaskRequest, ...) (*tasks.AuthenticatedTask, error)

+ func NewStateDB(ctx context.Context, driver, conn string, identity crypto.PrivKey) (State, error)