thingconsul

Documentation

Index

• type ConsulEvent
• type ConsulWatchMaker
  • func (m *ConsulWatchMaker) MakeConsulWatch(spec watchapi.ConsulWatchSpec) (*supervisor.Worker, error)
• type ConsulWatchMan
  • func NewConsulWatchMan(eventsCh chan<- ConsulEvent, watchesCh <-chan []watchapi.ConsulWatchSpec) ConsulWatchMan

Types

type ConsulEvent

type ConsulEvent struct {
	WatchId   string
	Endpoints consulwatch.Endpoints
}

type ConsulWatchMaker

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

func (*ConsulWatchMaker) MakeConsulWatch

func (m *ConsulWatchMaker) MakeConsulWatch(spec watchapi.ConsulWatchSpec) (*supervisor.Worker, error)

type ConsulWatchMan

type ConsulWatchMan interface {
	Work(*supervisor.Process) error
	NumWatched() int
	WithWatched(func(map[string]*supervisor.Worker))
}

func NewConsulWatchMan

func NewConsulWatchMan(eventsCh chan<- ConsulEvent, watchesCh <-chan []watchapi.ConsulWatchSpec) ConsulWatchMan