disco

Documentation

Index

• type ConsulDiscoverer
  • func NewConsulDiscoverer(consulClient *consul.Client, basicAuth *config.BasicAuth, ...) *ConsulDiscoverer
  • func (cd *ConsulDiscoverer) RemoveKvEntry(entry *entries.SignedEntry)
  • func (cd *ConsulDiscoverer) SetKVEntry(entry *entries.SignedEntry)
• type GslocConsul
  • func NewGslocConsul(consulClient *consul.Client) *GslocConsul
  • func (c *GslocConsul) ConvertPairToSignedEntry(pair *consul.KVPair) (*entries.SignedEntry, error)
  • func (c *GslocConsul) GetEntryStatus(fqdn string) (*gslbsvc.GetEntryStatusResponse, error)
  • func (c *GslocConsul) ListEntries(prefix string, tags []string) ([]*entries.SignedEntry, error)
  • func (c *GslocConsul) ListEntriesStatus(prefix string, tags []string) ([]*gslbsvc.GetEntryStatusResponse, error)
  • func (c *GslocConsul) RetrieveSignedEntry(fqdn string) (*entries.SignedEntry, error)

Types

type ConsulDiscoverer

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

func NewConsulDiscoverer

func NewConsulDiscoverer(consulClient *consul.Client, basicAuth *config.BasicAuth, dcName, hcAddr string) *ConsulDiscoverer

func (*ConsulDiscoverer) RemoveKvEntry

func (cd *ConsulDiscoverer) RemoveKvEntry(entry *entries.SignedEntry)

func (*ConsulDiscoverer) SetKVEntry

func (cd *ConsulDiscoverer) SetKVEntry(entry *entries.SignedEntry)

type GslocConsul

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

func NewGslocConsul

func NewGslocConsul(consulClient *consul.Client) *GslocConsul

func (*GslocConsul) ConvertPairToSignedEntry

func (c *GslocConsul) ConvertPairToSignedEntry(pair *consul.KVPair) (*entries.SignedEntry, error)

func (*GslocConsul) GetEntryStatus

func (c *GslocConsul) GetEntryStatus(fqdn string) (*gslbsvc.GetEntryStatusResponse, error)

func (*GslocConsul) ListEntries

func (c *GslocConsul) ListEntries(prefix string, tags []string) ([]*entries.SignedEntry, error)

func (*GslocConsul) ListEntriesStatus

func (c *GslocConsul) ListEntriesStatus(prefix string, tags []string) ([]*gslbsvc.GetEntryStatusResponse, error)

func (*GslocConsul) RetrieveSignedEntry

func (c *GslocConsul) RetrieveSignedEntry(fqdn string) (*entries.SignedEntry, error)