ip2service

Documentation

Index

• type EndpointsEventHandler
  • func (h *EndpointsEventHandler) OnAdd(obj interface{})
  • func (h *EndpointsEventHandler) OnDelete(obj interface{})
  • func (h *EndpointsEventHandler) OnUpdate(oldObj, newObj interface{})
• type IPTables
• type Router
  • func (r *Router) EnsureRoute(ip2port map[string]int32) error
• type RouterIface

Types

type EndpointsEventHandler

type EndpointsEventHandler struct {
	Logger                *zap.Logger
	ServiceName           string
	ServiceTargetPortName string
	Router                RouterIface
}

func (*EndpointsEventHandler) OnAdd

func (h *EndpointsEventHandler) OnAdd(obj interface{})

func (*EndpointsEventHandler) OnDelete

func (h *EndpointsEventHandler) OnDelete(obj interface{})

func (*EndpointsEventHandler) OnUpdate

func (h *EndpointsEventHandler) OnUpdate(oldObj, newObj interface{})

type IPTables

type IPTables interface {
	NewChain(table, chain string) error
	ListChains(table string) ([]string, error)
	Insert(table, chain string, pos int, rulespec ...string) error
	Append(table, chain string, rulespec ...string) error
	AppendUnique(table, chain string, rulespec ...string) error
	Delete(table, chain string, rulespec ...string) error
	List(table, chain string) ([]string, error)
	ClearChain(table, chain string) error
	DeleteChain(table, chain string) error
}

type Router

type Router struct {
	Logger        *zap.Logger
	Prefix        string
	InterceptIP   string
	InterceptPort int32
	IPTables      IPTables
}

func (*Router) EnsureRoute

func (r *Router) EnsureRoute(ip2port map[string]int32) error

type RouterIface

type RouterIface interface {
	EnsureRoute(ip2port map[string]int32) error
}