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 EcsDiscover
  • func NewECSDiscover(cfg config.Config) (*EcsDiscover, error)
  • func (s *EcsDiscover) Find(ctx context.Context, cfg config.Config, state DiscoverState) ([]models.Socket, error)
  • func (s *EcsDiscover) Name() string
  • func (s *EcsDiscover) SkipRun(ctx context.Context, cfg config.Config, state DiscoverState) bool
  • func (s *EcsDiscover) WaitSeconds() int64
• 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 SocketDataTag
• 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 {
	Logger *zap.Logger
}

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 EcsDiscover

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

func NewECSDiscover

func NewECSDiscover(cfg config.Config) (*EcsDiscover, error)

func (*EcsDiscover) Find

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

func (*EcsDiscover) Name

func (s *EcsDiscover) Name() string

func (*EcsDiscover) SkipRun

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

func (*EcsDiscover) WaitSeconds

func (s *EcsDiscover) WaitSeconds() int64

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 SocketDataTag

type SocketDataTag struct {
	Port             string `mapstructure:"port"`
	Type             string `mapstructure:"type"`
	Group            string `mapstructure:"group"`
	Host             string `mapstructure:"host"`
	Name             string `mapstructure:"name"`
	UpstreamUsername string `mapstructure:"upstream_username"`
	UpstreamPassword string `mapstructure:"upstream_password"`
	UpstreamType     string `mapstructure:"upstream_type"`
}

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