state

Documentation

Index

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

Types

type DBConnector

type DBConnector interface {
	Connect() error
	SqlDB() *sql.DB
}

DBConnector provides an interface for working with the underlying DB implementations

type State

type State interface {
	Get(ctx context.Context, uuid string) (*tasks.AuthenticatedTask, error)
	GetAll(ctx context.Context) ([]*tasks.AuthenticatedTask, error)
	Update(ctx context.Context, uuid string, req *client.UpdateTaskRequest, recorder metrics.MetricsRecorder) (*tasks.AuthenticatedTask, error)
	NewStorageTask(ctx context.Context, storageTask *tasks.StorageTask) (*tasks.AuthenticatedTask, error)
	NewRetrievalTask(ctx context.Context, retrievalTask *tasks.RetrievalTask) (*tasks.AuthenticatedTask, error)
}

State provides an interface for presistence.

func NewStateDB

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

NewStateDB creates a state instance with a given driver and identity