core

type Aggregator struct {
	sync.Mutex

	EventBus chan models.Event
	StateBus chan models.SensorState
	ErrorBus chan error
	// contains filtered or unexported fields
}

type Config struct {
	NodeName string    `yaml:"name"`
	Debug    bool      `yaml:"debug"`
	Database Database  `yaml:"database"`
	Reporter *Reporter `yaml:"reports"`
	Twitter  *Twitter  `yaml:"twitter"`
	Sensors  []*Sensor `yaml:"sensors"`
}

type Database struct {
	URL        string `yaml:"url"`
	GeoIP      string `yaml:"geoip"`
	PeriodSecs int    `yaml:"period"`
}

type Parser struct {
	DatetimeFormat string         `yaml:"datetime_format"`
	Expression     string         `yaml:"expression"`
	Tokens         map[string]int `yaml:"tokens"`
	// contains filtered or unexported fields
}

type Reporter struct {
	sync.Mutex

	Enabled    bool       `yaml:"enabled"`
	PeriodSecs int        `yaml:"period"`
	Repository repository `yaml:"repository"`
	// contains filtered or unexported fields
}

type Rule struct {
	Name        string `yaml:"name"`
	Token       string `yaml:"token"`
	Description string `yaml:"description"`
	Expression  string `yaml:"expression"`
	// contains filtered or unexported fields
}

type Sensor struct {
	Name       string  `yaml:"name"`
	Enabled    bool    `yaml:"enabled"`
	Filename   string  `yaml:"filename"`
	PeriodSecs int     `yaml:"period"`
	Parser     *Parser `yaml:"parser"`
	Rules      []*Rule `yaml:"rules"`
	// contains filtered or unexported fields
}

type Tokens map[string]string

type Twitter struct {
	sync.Mutex

	Enabled        bool   `yaml:"enabled"`
	ConsumerKey    string `yaml:"consumer_key"`
	ConsumerSecret string `yaml:"consumer_secret"`
	AccessKey      string `yaml:"access_key"`
	AccessSecret   string `yaml:"access_secret"`
	// contains filtered or unexported fields
}