kubernetes

Documentation

Index

• type Config
• type KubeDiscoverer
  • func NewKubeDiscoverer(cfg Config) (*KubeDiscoverer, error)
  • func (d *KubeDiscoverer) Discover(ctx context.Context, in chan<- []model.TargetGroup)
  • func (d *KubeDiscoverer) String() string
• type PodConfig
• type PodTarget
  • func (p PodTarget) Hash() uint64
  • func (p PodTarget) TUID() string
• type ServiceConfig
• type ServiceTarget
  • func (s ServiceTarget) Hash() uint64
  • func (s ServiceTarget) TUID() string

Types

type Config

type Config struct {
	APIServer  string         `yaml:"api_server"` // TODO: not used
	Namespaces []string       `yaml:"namespaces"`
	Pod        *PodConfig     `yaml:"pod"`
	Service    *ServiceConfig `yaml:"service"`
}

type KubeDiscoverer

type KubeDiscoverer struct {
	*logger.Logger
	// contains filtered or unexported fields
}

func NewKubeDiscoverer

func NewKubeDiscoverer(cfg Config) (*KubeDiscoverer, error)

func (*KubeDiscoverer) Discover

func (d *KubeDiscoverer) Discover(ctx context.Context, in chan<- []model.TargetGroup)

func (*KubeDiscoverer) String

func (d *KubeDiscoverer) String() string

type PodConfig

type PodConfig struct {
	Tags      string `yaml:"tags"`
	LocalMode bool   `yaml:"local_mode"`
	Selector  struct {
		Label string `yaml:"label"`
		Field string `yaml:"field"`
	} `yaml:"selector"`
}

type PodTarget

type PodTarget struct {
	model.Base `hash:"ignore"`

	Address        string
	Namespace      string
	Name           string
	Annotations    map[string]any
	Labels         map[string]any
	NodeName       string
	PodIP          string
	ControllerName string
	ControllerKind string
	ContName       string
	Image          string
	Env            map[string]any
	Port           string
	PortName       string
	PortProtocol   string
	// contains filtered or unexported fields
}

func (PodTarget) Hash

func (p PodTarget) Hash() uint64

func (PodTarget) TUID

func (p PodTarget) TUID() string

type ServiceConfig

type ServiceConfig struct {
	Tags     string `yaml:"tags"`
	Selector struct {
		Label string `yaml:"label"`
		Field string `yaml:"field"`
	} `yaml:"selector"`
}

type ServiceTarget

type ServiceTarget struct {
	model.Base `hash:"ignore"`

	Address      string
	Namespace    string
	Name         string
	Annotations  map[string]any
	Labels       map[string]any
	Port         string
	PortName     string
	PortProtocol string
	ClusterIP    string
	ExternalName string
	Type         string
	// contains filtered or unexported fields
}

func (ServiceTarget) Hash

func (s ServiceTarget) Hash() uint64

func (ServiceTarget) TUID

func (s ServiceTarget) TUID() string