aws

Documentation

Index

• type Config
  • func (c *Config) SetFilters(fs ...Filter)
  • func (c *Config) Validate() error
• type EC2DiscoveryStrategy
  • func NewEC2DiscoveryStrategy(cfg Config) (*EC2DiscoveryStrategy, error)
  • func (ds *EC2DiscoveryStrategy) DiscoverNodes(ctx context.Context) ([]hzdiscovery.Node, error)
  • func (ds *EC2DiscoveryStrategy) Start(_ context.Context, opts hzdiscovery.StrategyOptions) error
• type Filter
  • func Tag(name, value string) Filter

Types

type Config

type Config struct {
	AWS       aws.Config
	Filters   []types.Filter
	PortRange cluster.PortRange
	// contains filtered or unexported fields
}

func (*Config) SetFilters

func (c *Config) SetFilters(fs ...Filter)

func (*Config) Validate

func (c *Config) Validate() error

type EC2DiscoveryStrategy

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

func NewEC2DiscoveryStrategy

func NewEC2DiscoveryStrategy(cfg Config) (*EC2DiscoveryStrategy, error)

NewEC2DiscoveryStrategy creates a new EC2 discovery strategy.

func (*EC2DiscoveryStrategy) DiscoverNodes

func (ds *EC2DiscoveryStrategy) DiscoverNodes(ctx context.Context) ([]hzdiscovery.Node, error)

func (*EC2DiscoveryStrategy) Start

func (ds *EC2DiscoveryStrategy) Start(_ context.Context, opts hzdiscovery.StrategyOptions) error

type Filter

type Filter func(cfg *Config) error

func Tag

func Tag(name, value string) Filter