collector

Documentation

Index

• Variables
• func New(conf config.Module) (strana.Module, error)
• type Collector
• type Options
• type TrackingCollector
  • func (c *TrackingCollector) Events(eh strana.EventHandler) error
  • func (c *TrackingCollector) Logger(l *logger.Logger)
  • func (c *TrackingCollector) Routes(rtr fiber.Router) error
  • func (c *TrackingCollector) Services(s *store.SQLStore) error
  • func (c *TrackingCollector) Subscribe(fn strana.SubscriptionHandlerFunc) error

Variables

var ErrInvalidPayload = errors.New("could not collect event, invalid payload")

Functions

func New

func New(conf config.Module) (strana.Module, error)

Types

type Collector

type Collector interface {
	strana.Source
}

type Options

type Options struct {
	Type       string             `json:"type" yaml:"type" mapstructure:"type"`
	Cache      config.Cache       `json:"cache" yaml:"cache" mapstructure:"cache"`
	Processors []config.Processor `json:"processors" yaml:"processors" mapstructure:"processors"`
}

type TrackingCollector

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

func (*TrackingCollector) Events

func (c *TrackingCollector) Events(eh strana.EventHandler) error

func (*TrackingCollector) Logger

func (c *TrackingCollector) Logger(l *logger.Logger)

func (*TrackingCollector) Routes

func (c *TrackingCollector) Routes(rtr fiber.Router) error

func (*TrackingCollector) Services

func (c *TrackingCollector) Services(s *store.SQLStore) error

func (*TrackingCollector) Subscribe

func (c *TrackingCollector) Subscribe(fn strana.SubscriptionHandlerFunc) error