communicator

Documentation

Index

• type ConsulClient
  • func NewConsulClient(consulAddress string) ConsulClient
  • func (consulClient *ConsulClient) GetNodeName() string
  • func (consulClient *ConsulClient) MonitorNode(node string, serviceOut chan<- services.NodeServices, cont <-chan bool)

Types

type ConsulClient

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

ConsulClient stores information about our communication with consul

func NewConsulClient

func NewConsulClient(consulAddress string) ConsulClient

NewConsulClient will generate a new connection to consul

func (*ConsulClient) GetNodeName

func (consulClient *ConsulClient) GetNodeName() string

GetNodeName will get the node name of the consul agent we have connected to

func (*ConsulClient) MonitorNode

func (consulClient *ConsulClient) MonitorNode(node string, serviceOut chan<- services.NodeServices, cont <-chan bool)

MonitorNode will monitor consul for changes in a node and, on changes, send back a list of service for that node that match our prefix