discoverers

package
v0.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 13, 2023 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AwsEc2Discoverer

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

AwsEc2Discoverer represents a discoverer for AWS EC2 resources.

func NewAwsEc2Discoverer

func NewAwsEc2Discoverer(cfg aws.Config, awsAccountId string, opts ...AwsEc2DiscovererOption) *AwsEc2Discoverer

NewEngine returns a new AwsEc2Discoverer, initialized with the given options.

func (*AwsEc2Discoverer) Discover

func (ec2d *AwsEc2Discoverer) Discover(
	ctx context.Context,
	resources chan<- []discovery.Resource,
	errors chan<- error,
)

Discover runs the AwsEc2Discoverer and closes the channels after a single run.

type AwsEc2DiscovererOption

type AwsEc2DiscovererOption func(*AwsEc2Discoverer)

AwsEc2DiscovererOption is an input option for the AwsEc2Discoverer constructor.

type AwsEcsDiscoverer

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

AwsEcsDiscoverer represents a discoverer for AWS ECS resources.

func NewAwsEcsDiscoverer

func NewAwsEcsDiscoverer(cfg aws.Config, awsAccountId string, opts ...AwsEcsDiscovererOption) *AwsEcsDiscoverer

NewAwsEcsDiscoverer returns a new AwsEcsDiscoverer, initialized with the given options.

func (*AwsEcsDiscoverer) Discover

func (ecsd *AwsEcsDiscoverer) Discover(
	ctx context.Context,
	resources chan<- []discovery.Resource,
	errors chan<- error,
)

Discover runs the AwsEcsDiscoverer and closes the channels after a single run.

type AwsEcsDiscovererOption

type AwsEcsDiscovererOption func(*AwsEcsDiscoverer)

AwsEcsDiscovererOption is an input option for the AwsEcsDiscoverer constructor.

type AwsRdsDiscoverer

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

AwsRdsDiscoverer represents a discoverer for AWS RDS resources.

func NewAwsRdsDiscoverer

func NewAwsRdsDiscoverer(cfg aws.Config, awsAccountId string, opts ...AwsRdsDiscovererOption) *AwsRdsDiscoverer

NewAwsRdsDiscoverer returns a new AwsRdsDiscoverer, initialized with the given options.

func (*AwsRdsDiscoverer) Discover

func (rdsd *AwsRdsDiscoverer) Discover(
	ctx context.Context,
	resources chan<- []discovery.Resource,
	errors chan<- error,
)

Discover runs the AwsRdsDiscoverer and closes the channels after a single run.

type AwsRdsDiscovererOption

type AwsRdsDiscovererOption func(*AwsRdsDiscoverer)

AwsRdsDiscovererOption is an input option for the AwsRdsDiscoverer constructor.

type ContinuousDiscoverer

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

ContinuousDiscoverer represents a discoverer which under-the-hood is multiple discoverers and performs continous discovery based on a configured interval.

func NewContinuousDiscoverer

func NewContinuousDiscoverer(opts ...ContinuousDiscovererOption) *ContinuousDiscoverer

NewContinuousDiscoverer returns a new ContinuousDiscoverer, initialized with the given options.

func (*ContinuousDiscoverer) Discover

func (cd *ContinuousDiscoverer) Discover(
	ctx context.Context,
	resources chan<- []discovery.Resource,
	errors chan<- error,
)

Discover runs the ContinuousDiscoverer and closes the channels after the continuous run of all the underlying discoverers is completed. This can only happen if the given context is done.

type ContinuousDiscovererOption

type ContinuousDiscovererOption func(*ContinuousDiscoverer)

ContinuousDiscovererOption is an input option for the ContinuousDiscoverer constructor.

func WithUpstreamDiscoverer

func WithUpstreamDiscoverer(discoverer discovery.Discoverer, interval time.Duration) ContinuousDiscovererOption

WithUpstreamDiscoverers is a configuration option to include additional Discoverer(s) in an MultipleUpstreamDiscoverer's discovery.

type MultipleUpstreamDiscoverer

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

MultipleUpstreamDiscoverer represents a discoverer which under-the-hood is multiple discoverers.

func NewMultipleUpstreamDiscoverer

func NewMultipleUpstreamDiscoverer(opts ...MultipleUpstreamOption) *MultipleUpstreamDiscoverer

NewMultipleUpstreamDiscoverer returns a new MultipleUpstreamDiscoverer, initialized with the given options.

func (*MultipleUpstreamDiscoverer) Discover

func (mud *MultipleUpstreamDiscoverer) Discover(
	ctx context.Context,
	resources chan<- []discovery.Resource,
	errors chan<- error,
)

Discover runs the MultipleUpstreamDiscoverer and closes the channels after a single run of all the underlying discoverers is completed.

type MultipleUpstreamOption

type MultipleUpstreamOption func(*MultipleUpstreamDiscoverer)

MultipleUpstreamOption is an input option for the MultipleUpstreamDiscoverer constructor.

func WithUpstreamDiscoverers

func WithUpstreamDiscoverers(discoverers ...discovery.Discoverer) MultipleUpstreamOption

WithUpstreamDiscoverers is a configuration option to include additional Discoverer(s) in an MultipleUpstreamDiscoverer's discovery.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL