Documentation ¶ Index ¶ type Service func New(logger *zap.Logger, leaderElection *election.Service, ...) (*Service, error) func (s *Service) Run(ctx context.Context) error func (s *Service) SubscribeOnLeader(ctx context.Context) <-chan bool func (s *Service) Wait() Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Service ¶ type Service struct { // contains filtered or unexported fields } func New ¶ func New(logger *zap.Logger, leaderElection *election.Service, slowClientReadTTL time.Duration) (*Service, error) func (*Service) Run ¶ func (s *Service) Run(ctx context.Context) error func (*Service) SubscribeOnLeader ¶ func (s *Service) SubscribeOnLeader(ctx context.Context) <-chan bool func (*Service) Wait ¶ func (s *Service) Wait() Source Files ¶ View all Source files service.go Click to show internal directories. Click to hide internal directories.