Documentation ¶
Index ¶
- func StartWorker()
- type Worker
- func (wd *Worker) Close(ctx context.Context, rnsclient rns.Client, co rns.CloseOp) (rns.CloseResult, error)
- func (wd *Worker) List(ctx context.Context, rnsclient rns.Client, lo rns.ListOp) (rns.ListResult, error)
- func (wd *Worker) Load(ctx context.Context, rnsclient rns.Client, lo rns.LoadOp) (rns.LoadResult, error)
- func (wd *Worker) LookupClient(clientid string) (rns.Client, error)
- func (wd *Worker) Mkdir(ctx context.Context, rnsclient rns.Client, mo rns.MkdirOp) (rns.MkdirResult, error)
- func (wd *Worker) Open(ctx context.Context, oo rns.OpenRepoOp) (rns.OpenRepoResult, rns.Client, error)
- func (wd *Worker) Remove(ctx context.Context, rnsclient rns.Client, ro rns.RemoveOp) (rns.RemoveResult, error)
- func (wd *Worker) Run() error
- func (wd *Worker) Save(ctx context.Context, rnsclient rns.Client, so rns.SaveOp) (rns.SaveResult, error)
- func (wd *Worker) Stat(ctx context.Context, rnsclient rns.Client, so rns.StatOp) (rns.StatResult, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func StartWorker ¶
func StartWorker()
Types ¶
type Worker ¶
type Worker struct { ID int Log logadapter.Logger Conn *rns.ResticNatsClient // contains filtered or unexported fields }
func (*Worker) Open ¶
func (wd *Worker) Open(ctx context.Context, oo rns.OpenRepoOp) (rns.OpenRepoResult, rns.Client, error)
Click to show internal directories.
Click to hide internal directories.