sealworker

Documentation

Index

• func WorkerHandler(authv func(ctx context.Context, token string) ([]auth.Permission, error), ...) http.Handler
• type Worker
  • func (w *Worker) Discover(ctx context.Context) (apitypes.OpenRPCDocument, error)
  • func (w *Worker) Enabled(ctx context.Context) (bool, error)
  • func (w *Worker) ProcessSession(ctx context.Context) (uuid.UUID, error)
  • func (w *Worker) Session(ctx context.Context) (uuid.UUID, error)
  • func (w *Worker) SetEnabled(ctx context.Context, enabled bool) error
  • func (w *Worker) StorageAddLocal(ctx context.Context, path string) error
  • func (w *Worker) Version(context.Context) (api.Version, error)
  • func (w *Worker) WaitQuiet(ctx context.Context) error

Functions

func WorkerHandler

func WorkerHandler(authv func(ctx context.Context, token string) ([]auth.Permission, error), remote http.HandlerFunc, a api.Worker, permissioned bool) http.Handler

Types

type Worker

type Worker struct {
	*sectorstorage.LocalWorker

	LocalStore *stores.Local
	Storage    stores.LocalStorage
	// contains filtered or unexported fields
}

func (*Worker) Discover

func (w *Worker) Discover(ctx context.Context) (apitypes.OpenRPCDocument, error)

func (*Worker) Enabled

func (w *Worker) Enabled(ctx context.Context) (bool, error)

func (*Worker) ProcessSession

func (w *Worker) ProcessSession(ctx context.Context) (uuid.UUID, error)

func (*Worker) Session

func (w *Worker) Session(ctx context.Context) (uuid.UUID, error)

func (*Worker) SetEnabled

func (w *Worker) SetEnabled(ctx context.Context, enabled bool) error

func (*Worker) StorageAddLocal

func (w *Worker) StorageAddLocal(ctx context.Context, path string) error

func (*Worker) Version

func (w *Worker) Version(context.Context) (api.Version, error)

func (*Worker) WaitQuiet

func (w *Worker) WaitQuiet(ctx context.Context) error