model

Documentation

Index

• type ConsulInfo
• type ServiceState
• type StateChangeMsg
• type StateWait
  • func NewStateWait() *StateWait
  • func (sw *StateWait) GetOrCreateItem(dc, svcName string) chan struct{}
  • func (sw *StateWait) Notify(dc, svcName string)

Types

type ConsulInfo

type ConsulInfo struct {
	Addresses []string `mapstructure:"addresses"`
	DC        string   `mapstructure:"dc"`
	Token     string   `mapstructure:"token"`
}

type ServiceState

type ServiceState struct {
	Index uint64
	Data  []consulapi.ServiceEntry
}

type StateChangeMsg

type StateChangeMsg struct {
	DC      string `json:"dc"`
	Service string `json:"service"`
	Index   uint64 `json:"index"`
}

type StateWait

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

func NewStateWait

func NewStateWait() *StateWait

func (*StateWait) GetOrCreateItem

func (sw *StateWait) GetOrCreateItem(dc, svcName string) chan struct{}

func (*StateWait) Notify

func (sw *StateWait) Notify(dc, svcName string)