controllers

Documentation

Index

• type Indexer
  • func NewIndexer(nc *nats.Conn, vzmgrClient vzmgrpb.VZMgrServiceClient, st msgbus.Streamer, ...) (*Indexer, error)
  • func (i *Indexer) Stop()

Types

type Indexer

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

Indexer manages the state for which clusters are already being indexed.

func NewIndexer

func NewIndexer(nc *nats.Conn, vzmgrClient vzmgrpb.VZMgrServiceClient, st msgbus.Streamer, es *elastic.Client, indexName, fromShardID, toShardID string) (*Indexer, error)

NewIndexer creates a new Vizier indexer. This is a wrapper around the Vizier Watcher, which starts the indexer for any active viziers.

func (*Indexer) Stop

func (i *Indexer) Stop()

Stop stops the indexer.