consul

Documentation

Index

• type ConsulProvider
  • func New() (*ConsulProvider, error)
  • func NewWithConfig(consulConfig *api.Config) (*ConsulProvider, error)
  • func (p *ConsulProvider) DeregisterMember() error
  • func (p *ConsulProvider) GetHealthStatus() error
  • func (p *ConsulProvider) MonitorMemberStatusChanges()
  • func (p *ConsulProvider) RegisterMember(clusterName string, address string, port int, knownKinds []string, ...) error
  • func (p *ConsulProvider) Shutdown() error
  • func (p *ConsulProvider) UpdateMemberStatusValue(statusValue cluster.MemberStatusValue) error
  • func (p *ConsulProvider) UpdateTTL()

Types

type ConsulProvider

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

func New

func New() (*ConsulProvider, error)

func NewWithConfig

func NewWithConfig(consulConfig *api.Config) (*ConsulProvider, error)

func (*ConsulProvider) DeregisterMember

func (p *ConsulProvider) DeregisterMember() error

func (*ConsulProvider) GetHealthStatus

func (p *ConsulProvider) GetHealthStatus() error

GetHealthStatus returns an error if the cluster health status has problems

func (*ConsulProvider) MonitorMemberStatusChanges

func (p *ConsulProvider) MonitorMemberStatusChanges()

func (*ConsulProvider) RegisterMember

func (p *ConsulProvider) RegisterMember(clusterName string, address string, port int, knownKinds []string,
	statusValue cluster.MemberStatusValue, serializer cluster.MemberStatusValueSerializer) error

func (*ConsulProvider) Shutdown

func (p *ConsulProvider) Shutdown() error

func (*ConsulProvider) UpdateMemberStatusValue

func (p *ConsulProvider) UpdateMemberStatusValue(statusValue cluster.MemberStatusValue) error

func (*ConsulProvider) UpdateTTL

func (p *ConsulProvider) UpdateTTL()