redis

Documentation

Overview

Package redis handles the monitor capabilities of harvester using redis.

Index

• type Watcher
  • func New(client redis.UniversalClient, pollInterval time.Duration, keys []string) (*Watcher, error)
  • func (w *Watcher) Watch(ctx context.Context, ch chan<- []*change.Change) error

Types

type Watcher

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

Watcher of Redis changes.

func New

func New(client redis.UniversalClient, pollInterval time.Duration, keys []string) (*Watcher, error)

New watcher.

func (*Watcher) Watch

func (w *Watcher) Watch(ctx context.Context, ch chan<- []*change.Change) error

Watch keys and changes.