unregistration

Documentation

Index

• type Cache
  • func NewCache(logger lager.Logger) Cache
• type Message
• type Sender
  • func NewSender(logger lager.Logger, clock clock.Clock, cache Cache, ...) Sender
  • func (s Sender) Run(signals <-chan os.Signal, ready chan<- struct{}) error

Types

type Cache

type Cache interface {
	Add([]routingtable.RegistryMessage) error
	Remove([]routingtable.RegistryMessage) error
	List() []*Message
}

func NewCache

func NewCache(logger lager.Logger) Cache

type Message

type Message struct {
	RegistryMessage routingtable.RegistryMessage
	SentCount       int
}

type Sender

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

func NewSender

func NewSender(
	logger lager.Logger,
	clock clock.Clock,
	cache Cache,
	natsEmitter emitter.NATSEmitter,
	interval time.Duration,
	sendCount int,
) Sender

func (Sender) Run

func (s Sender) Run(signals <-chan os.Signal, ready chan<- struct{}) error