registrar

Documentation

Index

• type Registrar
  • func New(registryFile string, flushTimeout time.Duration, out successLogger) (*Registrar, error)
  • func (r *Registrar) GetStates() []file.State
  • func (r *Registrar) Init() error
  • func (r *Registrar) Run()
  • func (r *Registrar) Start() error
  • func (r *Registrar) Stop()

Types

type Registrar

type Registrar struct {
	Channel chan []file.State
	// contains filtered or unexported fields
}

func New

func New(registryFile string, flushTimeout time.Duration, out successLogger) (*Registrar, error)

func (*Registrar) GetStates

func (r *Registrar) GetStates() []file.State

GetStates return the registrar states

func (*Registrar) Init

func (r *Registrar) Init() error

Init sets up the Registrar and make sure the registry file is setup correctly

func (*Registrar) Run

func (r *Registrar) Run()

func (*Registrar) Start

func (r *Registrar) Start() error

func (*Registrar) Stop

func (r *Registrar) Stop()

Stop stops the registry. It waits until Run function finished.