discoverd

Documentation

Index

• func ShutdownRestServer() bool
• func StartRestServer(addr string, repo *msd.DiscoverdRepo, logger *log.Logger, ...)
• type Context
• type Discoverd
  • func Create(restAddr string, serviceTTL int, serf *serf.Serf, logOutput io.Writer) *Discoverd
  • func (s *Discoverd) AddRouter(name string, addr string, mss []string)
  • func (s *Discoverd) ListMicroApps() []api.MicroApp
  • func (s *Discoverd) ListRouters() []api.Router
  • func (s *Discoverd) RemoveRouter(addr string)
  • func (s *Discoverd) RemoveRouterByHost(name string)
  • func (d *Discoverd) Shutdown()
  • func (d *Discoverd) ShutdownCh() <-chan struct{}
  • func (s *Discoverd) UpdateRouters(rs []api.Router)

Functions

func ShutdownRestServer

func ShutdownRestServer() bool

func StartRestServer

func StartRestServer(addr string, repo *msd.DiscoverdRepo, logger *log.Logger, shutdownCh chan struct{})

Types

type Context

type Context struct {
	RestAddr   string
	Serf       *serf.Serf
	ServiceTTL int
	Logger     *log.Logger
	ShutdownCh chan struct{}
}

type Discoverd

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

func Create

func Create(restAddr string, serviceTTL int, serf *serf.Serf, logOutput io.Writer) *Discoverd

func (*Discoverd) AddRouter

func (s *Discoverd) AddRouter(name string, addr string, mss []string)

func (*Discoverd) ListMicroApps

func (s *Discoverd) ListMicroApps() []api.MicroApp

func (*Discoverd) ListRouters

func (s *Discoverd) ListRouters() []api.Router

func (*Discoverd) RemoveRouter

func (s *Discoverd) RemoveRouter(addr string)

func (*Discoverd) RemoveRouterByHost

func (s *Discoverd) RemoveRouterByHost(name string)

func (*Discoverd) Shutdown

func (d *Discoverd) Shutdown()

func (*Discoverd) ShutdownCh

func (d *Discoverd) ShutdownCh() <-chan struct{}

ShutdownCh returns a channel that can be used to wait for discoverd to shutdown.

func (*Discoverd) UpdateRouters

func (s *Discoverd) UpdateRouters(rs []api.Router)