subscriber

Documentation

Overview

Package subscriber implements the functionality needed to subscribe to events generated by the Tagger component.

Index

• type Subscriber
  • func (s *Subscriber) EventsChan() chan []types.EntityEvent
  • func (s *Subscriber) ID() string
  • func (s *Subscriber) Unsubscribe()
• type SubscriptionManager
  • func NewSubscriptionManager(telemetryStore *telemetry.Store) SubscriptionManager

Types

type Subscriber

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

Subscriber describes a component that subscribes to the tagger Subscriber implements types.Subscription

func (*Subscriber) EventsChan

func (s *Subscriber) EventsChan() chan []types.EntityEvent

EventsChan implements #types.Subscription.EventsChan

func (*Subscriber) ID

func (s *Subscriber) ID() string

ID implements #types.Subscription.ID

func (*Subscriber) Unsubscribe

func (s *Subscriber) Unsubscribe()

Unsubscribe implements #types.Subscription.Unsubscribe

type SubscriptionManager

type SubscriptionManager interface {
	Subscribe(id string, filter *types.Filter, events []types.EntityEvent) (types.Subscription, error)
	Unsubscribe(subscriptionID string)
	Notify(events []types.EntityEvent)
}

SubscriptionManager allows processes to subscribe to entity events generated from a tagger.

func NewSubscriptionManager

func NewSubscriptionManager(telemetryStore *telemetry.Store) SubscriptionManager

NewSubscriptionManager creates and returns a new subscription manager