consulwatch

Documentation

Index

• type CARoot
• type CARoots
• type Certificate
• type ConnectCARootsWatcher
  • func NewConnectCARootsWatcher(consul *api.Client) (*ConnectCARootsWatcher, error)
  • func (w *ConnectCARootsWatcher) Start(ctx context.Context) error
  • func (w *ConnectCARootsWatcher) Stop()
  • func (w *ConnectCARootsWatcher) Watch(handler func(*CARoots, error))
• type ConnectLeafWatcher
  • func NewConnectLeafWatcher(consul *api.Client, service string) (*ConnectLeafWatcher, error)
  • func (w *ConnectLeafWatcher) Start(ctx context.Context) error
  • func (w *ConnectLeafWatcher) Stop()
  • func (w *ConnectLeafWatcher) Watch(handler func(*Certificate, error))
• type Endpoint
• type Endpoints
  • func (e *Endpoints) GroupByTags() map[string][]Endpoint
• type ServiceWatcher
  • func New(client *consulapi.Client, datacenter string, service string, onlyHealthy bool) (*ServiceWatcher, error)
  • func (w *ServiceWatcher) Start(ctx context.Context) error
  • func (w *ServiceWatcher) Stop()
  • func (w *ServiceWatcher) Watch(handler func(endpoints Endpoints, err error))

Types

type CARoot

type CARoot struct {
	ID     string `json:",omitempty"`
	Name   string `json:",omitempty"`
	PEM    string `json:",omitempty"`
	Active bool
}

type CARoots

type CARoots struct {
	ActiveRootID string
	TrustDomain  string
	Roots        map[string]CARoot
}

type Certificate

type Certificate struct {
	SerialNumber  string    `json:",omitempty"`
	PEM           string    `json:",omitempty"`
	PrivateKeyPEM string    `json:",omitempty"`
	Service       string    `json:",omitempty"`
	ServiceURI    string    `json:",omitempty"`
	ValidAfter    time.Time `json:",omitempty"`
	ValidBefore   time.Time `json:",omitempty"`
}

type ConnectCARootsWatcher

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

ConnectCARootsWatcher watches the Consul Connect CA roots endpoint for changes and invokes a a handler function whenever it changes.

func NewConnectCARootsWatcher

func NewConnectCARootsWatcher(consul *api.Client) (*ConnectCARootsWatcher, error)

func (*ConnectCARootsWatcher) Start

func (w *ConnectCARootsWatcher) Start(ctx context.Context) error

func (*ConnectCARootsWatcher) Stop

func (w *ConnectCARootsWatcher) Stop()

func (*ConnectCARootsWatcher) Watch

func (w *ConnectCARootsWatcher) Watch(handler func(*CARoots, error))

type ConnectLeafWatcher

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

func NewConnectLeafWatcher

func NewConnectLeafWatcher(consul *api.Client, service string) (*ConnectLeafWatcher, error)

func (*ConnectLeafWatcher) Start

func (w *ConnectLeafWatcher) Start(ctx context.Context) error

func (*ConnectLeafWatcher) Stop

func (w *ConnectLeafWatcher) Stop()

func (*ConnectLeafWatcher) Watch

func (w *ConnectLeafWatcher) Watch(handler func(*Certificate, error))

type Endpoint

type Endpoint struct {
	SystemID string   `json:""`
	ID       string   `json:""`
	Service  string   `json:""`
	Address  string   `json:""`
	Port     int      `json:""`
	Tags     []string `json:""`
}

type Endpoints

type Endpoints struct {
	Id        string     `json:""`
	Service   string     `json:""`
	Endpoints []Endpoint `json:""`
}

Endpoints contains an Array of Endpoint structs and meta information about the Service that the contained endpoints are associated with.

func (*Endpoints) GroupByTags

func (e *Endpoints) GroupByTags() map[string][]Endpoint

GroupByTags returns a map of tag name to array of Endpoint structs.

type ServiceWatcher

type ServiceWatcher struct {
	ServiceName string
	// contains filtered or unexported fields
}

func New

func New(client *consulapi.Client, datacenter string, service string, onlyHealthy bool) (*ServiceWatcher, error)

func (*ServiceWatcher) Start

func (w *ServiceWatcher) Start(ctx context.Context) error

func (*ServiceWatcher) Stop

func (w *ServiceWatcher) Stop()

func (*ServiceWatcher) Watch

func (w *ServiceWatcher) Watch(handler func(endpoints Endpoints, err error))