replay

Documentation

Overview

Package replay implements the Tagger replay.

Index

• type Tagger
  • func NewTagger() *Tagger
  • func (t *Tagger) AccumulateTagsFor(entityID string, cardinality types.TagCardinality, tb tagset.TagsAccumulator) error
  • func (t *Tagger) GetEntity(entityID string) (*types.Entity, error)
  • func (t *Tagger) List() types.TaggerListResponse
  • func (t *Tagger) LoadState(state map[string]*pb.Entity)
  • func (t *Tagger) Standard(entityID string) ([]string, error)
  • func (t *Tagger) Start(ctx context.Context) error
  • func (t *Tagger) Stop() error
  • func (t *Tagger) Subscribe(types.TagCardinality) chan []types.EntityEvent
  • func (t *Tagger) Tag(entityID string, cardinality types.TagCardinality) ([]string, error)
  • func (t *Tagger) Unsubscribe(chan []types.EntityEvent)

Types

type Tagger

type Tagger struct {
	empty.Tagger
	// contains filtered or unexported fields
}

Tagger stores tags to entity as stored in a replay state.

func NewTagger

func NewTagger() *Tagger

NewTagger returns an allocated tagger. You still have to run Init() once the config package is ready.

func (*Tagger) AccumulateTagsFor

func (t *Tagger) AccumulateTagsFor(entityID string, cardinality types.TagCardinality, tb tagset.TagsAccumulator) error

AccumulateTagsFor returns tags for a given entity at the desired cardinality.

func (*Tagger) GetEntity

func (t *Tagger) GetEntity(entityID string) (*types.Entity, error)

GetEntity returns the entity corresponding to the specified id and an error

func (*Tagger) List

func (t *Tagger) List() types.TaggerListResponse

List returns all the entities currently stored by the tagger.

func (*Tagger) LoadState

func (t *Tagger) LoadState(state map[string]*pb.Entity)

LoadState loads the state for the tagger from the supplied map.

func (*Tagger) Standard

func (t *Tagger) Standard(entityID string) ([]string, error)

Standard returns the standard tags for a given entity.

func (*Tagger) Start

func (t *Tagger) Start(ctx context.Context) error

Start starts the connection to the replay tagger and starts watching for events.

func (*Tagger) Stop

func (t *Tagger) Stop() error

Stop closes the connection to the replay tagger and stops event collection.

func (*Tagger) Subscribe

func (t *Tagger) Subscribe(types.TagCardinality) chan []types.EntityEvent

Subscribe does nothing in the replay tagger this tagger does not respond to events.

func (*Tagger) Tag

func (t *Tagger) Tag(entityID string, cardinality types.TagCardinality) ([]string, error)

Tag returns tags for a given entity at the desired cardinality.

func (*Tagger) Unsubscribe

func (t *Tagger) Unsubscribe(chan []types.EntityEvent)

Unsubscribe does nothing in the replay tagger this tagger does not respond to events.