consul

Documentation

Index

• type ConsulDiscoveryService
  • func NewDiscoveryService(healthCheck func() (bool, error)) (*ConsulDiscoveryService, error)
  • func (consul *ConsulDiscoveryService) AddNodeListUpdated(key string, sub chan []taskhandler.ServingService)
  • func (consul *ConsulDiscoveryService) RegisterService() error
  • func (consul *ConsulDiscoveryService) RemoveNodeListUpdated(key string)
  • func (consul *ConsulDiscoveryService) UnregisterService() error

Types

type ConsulDiscoveryService

type ConsulDiscoveryService struct {
	ListUpdatedChans map[string]chan []taskhandler.ServingService
	ServiceName      string
	ServiceID        string
	ConsulClient     *api.Client

	HealthCheckFun func() (bool, error)
	// contains filtered or unexported fields
}

func NewDiscoveryService

func NewDiscoveryService(healthCheck func() (bool, error)) (*ConsulDiscoveryService, error)

func (*ConsulDiscoveryService) AddNodeListUpdated

func (consul *ConsulDiscoveryService) AddNodeListUpdated(key string, sub chan []taskhandler.ServingService)

func (*ConsulDiscoveryService) RegisterService

func (consul *ConsulDiscoveryService) RegisterService() error

func (*ConsulDiscoveryService) RemoveNodeListUpdated

func (consul *ConsulDiscoveryService) RemoveNodeListUpdated(key string)

func (*ConsulDiscoveryService) UnregisterService

func (consul *ConsulDiscoveryService) UnregisterService() error