ipcache

Documentation

Index

• Variables
• type Endpoint
• type Port
• type State
  • func New(client *kubernetes.Clientset, syncInterval time.Duration, bufferSize int) *State
  • func (s *State) GetEndpointByIP(ip string) (*Endpoint, error)
  • func (s *State) Run()

Variables

var ErrNotFound = fmt.Errorf("ip addr not found")

Types

type Endpoint

type Endpoint struct {
	Name      string
	Namespace string
	Labels    map[string]string
	Ports     []Port
}

type Port

type Port struct {
	Name     string
	Port     uint32
	Protocol string
}

type State

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

func New

func New(client *kubernetes.Clientset, syncInterval time.Duration, bufferSize int) *State

func (*State) GetEndpointByIP

func (s *State) GetEndpointByIP(ip string) (*Endpoint, error)

func (*State) Run

func (s *State) Run()