registration

Documentation

Index

• type RegistrationManager
  • func New(runnercfg *cfg.RunnerConfig, state *run.State) *RegistrationManager
  • func (reg *RegistrationManager) RegisterWorker(workerIdentityProofMap map[string]interface{}) error
  • func (reg *RegistrationManager) SetProtocol(proto *workerproto.Protocol)
  • func (reg *RegistrationManager) UseCachedRun() error
  • func (reg *RegistrationManager) WorkerFinished() error
  • func (reg *RegistrationManager) WorkerStarted() error

Types

type RegistrationManager

type RegistrationManager struct {
	// contains filtered or unexported fields
}

func New

func New(runnercfg *cfg.RunnerConfig, state *run.State) *RegistrationManager

Make a new RegistrationManager object

func (*RegistrationManager) RegisterWorker

func (reg *RegistrationManager) RegisterWorker(workerIdentityProofMap map[string]interface{}) error

Register this worker with the worker-manager, and update the state with the results

func (*RegistrationManager) SetProtocol

func (reg *RegistrationManager) SetProtocol(proto *workerproto.Protocol)

func (*RegistrationManager) UseCachedRun

func (reg *RegistrationManager) UseCachedRun() error

func (*RegistrationManager) WorkerFinished

func (reg *RegistrationManager) WorkerFinished() error

func (*RegistrationManager) WorkerStarted

func (reg *RegistrationManager) WorkerStarted() error