puppetdb

Documentation

Index

• type ChoriaFramework
• type DiscoverOption
  • func Collective(c string) DiscoverOption
  • func Filter(f *protocol.Filter) DiscoverOption
  • func Timeout(t time.Duration) DiscoverOption
• type PuppetDB
  • func New(fw ChoriaFramework) *PuppetDB
  • func (p *PuppetDB) Discover(_ context.Context, opts ...DiscoverOption) (n []string, err error)

Types

type ChoriaFramework

type ChoriaFramework interface {
	Logger(string) *logrus.Entry
	Configuration() *config.Config
	PQLQueryCertNames(query string) ([]string, error)
}

type DiscoverOption

type DiscoverOption func(o *dOpts)

DiscoverOption configures the broadcast discovery method

func Collective

func Collective(c string) DiscoverOption

Collective sets the collective to discover in, else main collective is used

func Filter

func Filter(f *protocol.Filter) DiscoverOption

Filter sets the filter to use for the discovery, else a blank one is used

func Timeout

func Timeout(t time.Duration) DiscoverOption

Timeout sets the discovery timeout, else the configured default is used

type PuppetDB

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

func New

func New(fw ChoriaFramework) *PuppetDB

New creates a new puppetdb discovery client

func (*PuppetDB) Discover

func (p *PuppetDB) Discover(_ context.Context, opts ...DiscoverOption) (n []string, err error)

Discover performs a broadcast discovery using the supplied filter