discover

Documentation

Index

• type CustomParams
• type Discover
• type DiscoverState
• type DockerFinder
  • func (s *DockerFinder) Find(ctx context.Context, cfg config.Config, state DiscoverState) ([]models.Socket, error)
  • func (s *DockerFinder) Name() string
  • func (s *DockerFinder) SkipRun(ctx context.Context, cfg config.Config, state DiscoverState) bool
  • func (s *DockerFinder) WaitSeconds() int64
• type Ec2Discover
  • func NewEC2Discover(ec2API ec2iface.EC2API, cfg config.Config) *Ec2Discover
  • func (s *Ec2Discover) Find(ctx context.Context, cfg config.Config, state DiscoverState) ([]models.Socket, error)
  • func (s *Ec2Discover) Name() string
  • func (s *Ec2Discover) SkipRun(ctx context.Context, cfg config.Config, state DiscoverState) bool
  • func (s *Ec2Discover) WaitSeconds() int64
• type Ec2SocketData
• type K8Discover
  • func NewK8Discover() *K8Discover
  • func (s *K8Discover) Find(ctx context.Context, cfg config.Config, state DiscoverState) ([]models.Socket, error)
  • func (s *K8Discover) Name() string
  • func (s *K8Discover) SkipRun(ctx context.Context, cfg config.Config, state DiscoverState) bool
  • func (s *K8Discover) WaitSeconds() int64
• type NetworkFinder
  • func (s *NetworkFinder) Find(ctx context.Context, cfg config.Config, state DiscoverState) ([]models.Socket, error)
  • func (s *NetworkFinder) Name() string
  • func (s *NetworkFinder) SkipRun(ctx context.Context, cfg config.Config, state DiscoverState) bool
  • func (s *NetworkFinder) WaitSeconds() int64
• type SocketData
• type StaticSocketFinder
  • func (s *StaticSocketFinder) Find(ctx context.Context, cfg config.Config, state DiscoverState) ([]models.Socket, error)
  • func (s *StaticSocketFinder) Name() string
  • func (s *StaticSocketFinder) SkipRun(ctx context.Context, cfg config.Config, state DiscoverState) bool
  • func (s *StaticSocketFinder) WaitSeconds() int64

Types

type CustomParams

type CustomParams map[string]interface{}

type Discover

type Discover interface {
	Find(ctx context.Context, cfg config.Config, state DiscoverState) ([]models.Socket, error)
	SkipRun(ctx context.Context, cfg config.Config, state DiscoverState) bool
	WaitSeconds() int64
	Name() string
}

type DiscoverState

type DiscoverState struct {
	State     map[string]interface{}
	RunsCount int64
}

type DockerFinder

type DockerFinder struct{}

func (*DockerFinder) Find

func (s *DockerFinder) Find(ctx context.Context, cfg config.Config, state DiscoverState) ([]models.Socket, error)

func (*DockerFinder) Name

func (s *DockerFinder) Name() string

func (*DockerFinder) SkipRun

func (s *DockerFinder) SkipRun(ctx context.Context, cfg config.Config, state DiscoverState) bool

func (*DockerFinder) WaitSeconds

func (s *DockerFinder) WaitSeconds() int64

type Ec2Discover

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

func NewEC2Discover

func NewEC2Discover(ec2API ec2iface.EC2API, cfg config.Config) *Ec2Discover

func (*Ec2Discover) Find

func (s *Ec2Discover) Find(ctx context.Context, cfg config.Config, state DiscoverState) ([]models.Socket, error)

func (*Ec2Discover) Name

func (s *Ec2Discover) Name() string

func (*Ec2Discover) SkipRun

func (s *Ec2Discover) SkipRun(ctx context.Context, cfg config.Config, state DiscoverState) bool

func (*Ec2Discover) WaitSeconds

func (s *Ec2Discover) WaitSeconds() int64

type Ec2SocketData

type Ec2SocketData struct {
	Port  string `mapstructure:"port"`
	Type  string
	Group string
	Host  string
}

type K8Discover

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

func NewK8Discover

func NewK8Discover() *K8Discover

func (*K8Discover) Find

func (s *K8Discover) Find(ctx context.Context, cfg config.Config, state DiscoverState) ([]models.Socket, error)

func (*K8Discover) Name

func (s *K8Discover) Name() string

func (*K8Discover) SkipRun

func (s *K8Discover) SkipRun(ctx context.Context, cfg config.Config, state DiscoverState) bool

func (*K8Discover) WaitSeconds

func (s *K8Discover) WaitSeconds() int64

type NetworkFinder

type NetworkFinder struct{}

func (*NetworkFinder) Find

func (s *NetworkFinder) Find(ctx context.Context, cfg config.Config, state DiscoverState) ([]models.Socket, error)

func (*NetworkFinder) Name

func (s *NetworkFinder) Name() string

func (*NetworkFinder) SkipRun

func (s *NetworkFinder) SkipRun(ctx context.Context, cfg config.Config, state DiscoverState) bool

func (*NetworkFinder) WaitSeconds

func (s *NetworkFinder) WaitSeconds() int64

type SocketData

type SocketData struct {
	Port  string `mapstructure:"port"`
	Type  string
	Group string
	Host  string
}

type StaticSocketFinder

type StaticSocketFinder struct{}

func (*StaticSocketFinder) Find

func (s *StaticSocketFinder) Find(ctx context.Context, cfg config.Config, state DiscoverState) ([]models.Socket, error)

func (*StaticSocketFinder) Name

func (s *StaticSocketFinder) Name() string

func (*StaticSocketFinder) SkipRun

func (s *StaticSocketFinder) SkipRun(ctx context.Context, cfg config.Config, state DiscoverState) bool

func (*StaticSocketFinder) WaitSeconds

func (s *StaticSocketFinder) WaitSeconds() int64