serviceindex

Documentation

Index

• type ServiceIndex
  • func NewServiceIndex() *ServiceIndex
  • func (idx *ServiceIndex) DeleteEndpointSlice(key model.ResourceKey)
  • func (idx *ServiceIndex) DeleteIPSet(id string)
  • func (idx *ServiceIndex) OnUpdate(update api.Update) (_ bool)
  • func (idx *ServiceIndex) RegisterWith(allUpdDispatcher *dispatcher.Dispatcher)
  • func (idx *ServiceIndex) UpdateEndpointSlice(es *discovery.EndpointSlice)
  • func (idx *ServiceIndex) UpdateIPSet(id string, serviceName string)
• type ServiceMatchCallback

Types

type ServiceIndex

type ServiceIndex struct {

	// Callback functions
	OnMemberAdded   ServiceMatchCallback
	OnMemberRemoved ServiceMatchCallback

	OnAlive func()
	// contains filtered or unexported fields
}

func NewServiceIndex

func NewServiceIndex() *ServiceIndex

func (*ServiceIndex) DeleteEndpointSlice

func (idx *ServiceIndex) DeleteEndpointSlice(key model.ResourceKey)

func (*ServiceIndex) DeleteIPSet

func (idx *ServiceIndex) DeleteIPSet(id string)

func (*ServiceIndex) OnUpdate

func (idx *ServiceIndex) OnUpdate(update api.Update) (_ bool)

OnUpdate makes ServiceIndex compatible with the Dispatcher. It accepts updates for endpoint slices and passes them through to the Update/Delete methods.

func (*ServiceIndex) RegisterWith

func (idx *ServiceIndex) RegisterWith(allUpdDispatcher *dispatcher.Dispatcher)

func (*ServiceIndex) UpdateEndpointSlice

func (idx *ServiceIndex) UpdateEndpointSlice(es *discovery.EndpointSlice)

func (*ServiceIndex) UpdateIPSet

func (idx *ServiceIndex) UpdateIPSet(id string, serviceName string)

type ServiceMatchCallback

type ServiceMatchCallback func(ipSetID string, member labelindex.IPSetMember)