evtcache

Documentation

Index

• type Cache
  • func (c *Cache) GetAddresses(serviceID string) (map[string]scanner.Status, bool)
  • func (c *Cache) GetOnlineAddresses(serviceID string) ([]string, bool)
  • func (c *Cache) GetServiceID(url string) (string, bool)
  • func (c *Cache) ReadEvents(ctx context.Context, inputCh <-chan scanner.Event) error

Types

type Cache

type Cache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Cache) GetAddresses

func (c *Cache) GetAddresses(serviceID string) (map[string]scanner.Status, bool)

func (*Cache) GetOnlineAddresses

func (c *Cache) GetOnlineAddresses(serviceID string) ([]string, bool)

func (*Cache) GetServiceID

func (c *Cache) GetServiceID(url string) (string, bool)

func (*Cache) ReadEvents

func (c *Cache) ReadEvents(ctx context.Context, inputCh <-chan scanner.Event) error