discovery

Documentation

Index

• type K8S
  • func NewK8S() (*K8S, error)
  • func (k8s *K8S) Start()
  • func (k8s *K8S) Stop()
  • func (k8s *K8S) Subscribe(l PodEventsListener)
• type Pod
  • func (p *Pod) Equal(other *Pod) bool
  • func (p *Pod) Running() bool
  • func (p *Pod) ServiceName() string
• type PodEvent
• type PodEventType
• type PodEventsListener
• type PodId

Types

type K8S

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

func NewK8S

func NewK8S() (*K8S, error)

func (*K8S) Start

func (k8s *K8S) Start()

func (*K8S) Stop

func (k8s *K8S) Stop()

func (*K8S) Subscribe

func (k8s *K8S) Subscribe(l PodEventsListener)

type Pod

type Pod struct {
	// update Pod.Equal when adding fields
	Id          PodId
	Phase       corev1.PodPhase
	IP          string
	Annotations map[string]string
	Ports       []int
}

func (*Pod) Equal

func (p *Pod) Equal(other *Pod) bool

func (*Pod) Running

func (p *Pod) Running() bool

func (*Pod) ServiceName

func (p *Pod) ServiceName() string

type PodEvent

type PodEvent struct {
	Type PodEventType
	Curr *Pod
	Prev *Pod
}

type PodEventType

type PodEventType int

const (
	PodEventTypeAdd PodEventType = iota
	PodEventTypeChange
	PodEventTypeDelete
)

type PodEventsListener

type PodEventsListener interface {
	ListenPodEvents(events <-chan PodEvent)
}

type PodId

type PodId struct {
	Namespace string
	Name      string
	NodeName  string
}