cache

Documentation

Index

• type DataCache
  • func New() *DataCache
  • func (c *DataCache) Drop()
  • func (c *DataCache) ForEachLink(cb func(key string, link *link.Link))
  • func (c *DataCache) ForEachService(cb func(key string, svc *service.Service))
  • func (c *DataCache) UpsertLinksFromFlows(flows []*flow.Flow) []Result[*link.Link]
  • func (c *DataCache) UpsertService(newSvc *service.Service) events.EventKind
  • func (c *DataCache) UpsertServiceLink(newLink *link.Link) events.EventKind
  • func (c *DataCache) UpsertServicesFromFlows(flows []*flow.Flow) []Result[*service.Service]
• type Result

Types

type DataCache

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

func New

func New() *DataCache

func (*DataCache) Drop

func (c *DataCache) Drop()

func (*DataCache) ForEachLink

func (c *DataCache) ForEachLink(cb func(key string, link *link.Link))

func (*DataCache) ForEachService

func (c *DataCache) ForEachService(cb func(key string, svc *service.Service))

func (*DataCache) UpsertLinksFromFlows

func (c *DataCache) UpsertLinksFromFlows(
	flows []*flow.Flow,
) []Result[*link.Link]

func (*DataCache) UpsertService

func (c *DataCache) UpsertService(newSvc *service.Service) events.EventKind

func (*DataCache) UpsertServiceLink

func (c *DataCache) UpsertServiceLink(newLink *link.Link) events.EventKind

func (*DataCache) UpsertServicesFromFlows

func (c *DataCache) UpsertServicesFromFlows(
	flows []*flow.Flow,
) []Result[*service.Service]

type Result

type Result[T any] struct {
	Entry     T
	EventKind events.EventKind
}