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) Shutdown(ctx context.Context) error
  • func (w *Worker) StorageAddLocal(ctx context.Context, path string) error
  • func (w *Worker) StorageDetachAll(ctx context.Context) error
  • func (w *Worker) StorageDetachLocal(ctx context.Context, path string) error
  • func (w *Worker) StorageLocal(ctx context.Context) (map[storiface.ID]string, error)
  • func (w *Worker) StorageRedeclareLocal(ctx context.Context, id *storiface.ID, dropMissing bool) 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 {
	*sealer.LocalWorker

	LocalStore *paths.Local
	Storage    paths.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) Shutdown

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

func (*Worker) StorageAddLocal

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

func (*Worker) StorageDetachAll

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

func (*Worker) StorageDetachLocal

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

func (*Worker) StorageLocal

func (w *Worker) StorageLocal(ctx context.Context) (map[storiface.ID]string, error)

func (*Worker) StorageRedeclareLocal

func (w *Worker) StorageRedeclareLocal(ctx context.Context, id *storiface.ID, dropMissing bool) error

func (*Worker) Version

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

func (*Worker) WaitQuiet

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