consul/

Aug 24, 2017

Changes in this version

+ func CreateRegionClient(c *config.Config, region string) (*api.Client, error)

+ type Cluster struct

+ ClusterClient *api.Client

+ RegionChannels *RegionChannels

+ RegionClients *RegionClients

+ func NewCluster(clusterClient *api.Client, clients *RegionClients, channels *RegionChannels) *Cluster

+ func (c *Cluster) StartWatchers()

+ type ClusterBroadcastChannels struct

+ type Connection struct

+ ID uuid.UUID

+ func NewConnection(hub *Hub, socket *websocket.Conn, consulRegion *Region, ...) *Connection

+ func (c *Connection) Debugf(format string, args ...interface{})

+ func (c *Connection) Errorf(format string, args ...interface{})

+ func (c *Connection) Handle()

+ func (c *Connection) Infof(format string, args ...interface{})

+ func (c *Connection) Warningf(format string, args ...interface{})

+ type Hub struct

+ func Initialize(cfg *config.Config) (*Hub, bool)

+ func NewHub(cluster *Cluster) *Hub

+ func (h *Hub) Handler(w http.ResponseWriter, r *http.Request)

+ func (h *Hub) Run()

+ type InternalNode struct

+ Address string

+ Checks []*api.AgentCheck

+ Node string

+ Services []*api.AgentService

+ TaggedAddresses map[string]string

+ type InternalNodes []*InternalNode

+ type InternalService struct

+ ChecksCritical int64

+ ChecksPassing int64

+ ChecksWarning int64

+ Name string

+ Nodes []string

+ type InternalServices []*InternalService

+ type Region struct

+ Client *api.Client

+ Config *config.Config

+ func NewRegion(c *config.Config, client *api.Client, channels *RegionBroadcastChannels) (*Region, error)

+ func (c *Region) StartWatchers()

+ type RegionBroadcastChannels struct

+ type RegionChannels map[string]*RegionBroadcastChannels

+ type RegionClients map[string]*Region

+ type Service struct

+ Name string

+ Nodes []string

+ Tags []string

+ type Services map[string]*Service

Aug 5, 2017

Changes in this version

+ func CreateConsulRegionClient(c *config.Config, region string) (*api.Client, error)

+ type ConsulCluster struct

+ ClusterClient *api.Client

+ RegionChannels *ConsulRegionChannels

+ RegionClients *ConsulRegionClients

+ func NewConsulCluster(clusterClient *api.Client, clients *ConsulRegionClients, ...) *ConsulCluster

+ func (c *ConsulCluster) StartWatchers()

+ type ConsulClusterBroadcastChannels struct

+ type ConsulConnection struct

+ ID uuid.UUID

+ func NewConsulConnection(hub *ConsulHub, socket *websocket.Conn, consulRegion *ConsulRegion, ...) *ConsulConnection

+ func (c *ConsulConnection) Debugf(format string, args ...interface{})

+ func (c *ConsulConnection) Errorf(format string, args ...interface{})

+ func (c *ConsulConnection) Handle()

+ func (c *ConsulConnection) Infof(format string, args ...interface{})

+ func (c *ConsulConnection) Warningf(format string, args ...interface{})

+ type ConsulHub struct

+ func InitializeConsul(cfg *config.Config) (*ConsulHub, bool)

+ func NewConsulHub(cluster *ConsulCluster) *ConsulHub

+ func (h *ConsulHub) Handler(w http.ResponseWriter, r *http.Request)

+ func (h *ConsulHub) Run()

+ type ConsulInternalNode struct

+ Address string

+ Checks []*api.AgentCheck

+ Node string

+ Services []*api.AgentService

+ TaggedAddresses map[string]string

+ type ConsulInternalNodes []*ConsulInternalNode

+ type ConsulInternalService struct

+ ChecksCritical int64

+ ChecksPassing int64

+ ChecksWarning int64

+ Name string

+ Nodes []string

+ type ConsulInternalServices []*ConsulInternalService

+ type ConsulRegion struct

+ Client *api.Client

+ Config *config.Config

+ func NewConsulRegion(c *config.Config, client *api.Client, channels *ConsulRegionBroadcastChannels) (*ConsulRegion, error)

+ func (c *ConsulRegion) StartWatchers()

+ type ConsulRegionBroadcastChannels struct

+ type ConsulRegionChannels map[string]*ConsulRegionBroadcastChannels

+ type ConsulRegionClients map[string]*ConsulRegion

+ type ConsulService struct

+ Name string

+ Nodes []string

+ Tags []string

+ type ConsulServices map[string]*ConsulService