collector

Documentation

Index

• Variables
• type AppStorage
  • func ConnectRedis(addr string, db int64) (AppStorage, error)
• type Collector
  • func NewCollector(ctx log.Interface, appStorage AppStorage, broker string, ...) Collector
• type StartError
  • func (e StartError) Error() string

Variables

var (
	// ConnectRetries says how many times the client should retry a failed connection
	ConnectRetries = 5
	// ConnectRetryDelay says how long the client should wait between retries
	ConnectRetryDelay = time.Second
)

Types

type AppStorage

type AppStorage interface {
	Add(eui types.AppEUI) error
	Remove(eui types.AppEUI) error
	SetAccessKey(eui types.AppEUI, key string) error
	GetAccessKey(eui types.AppEUI) (string, error)
	List() ([]types.AppEUI, error)
	Reset() error
	Close() error
}

AppStorage provides storage for applications

func ConnectRedis

func ConnectRedis(addr string, db int64) (AppStorage, error)

ConnectRedis connects to Redis using the specified options

type Collector

type Collector interface {
	Start() (map[types.AppEUI]collection.AppCollector, error)
	Stop()
	StopApp(eui types.AppEUI) error
}

Collector collects data from the Handler and stores it

func NewCollector

func NewCollector(ctx log.Interface, appStorage AppStorage, broker string, dataStorage collection.DataStorage, netAddr string) Collector

NewCollector creates a new collector

type StartError

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

StartError contains errors of starting applications

func (StartError) Error

func (e StartError) Error() string