straumur

type Broadcaster interface {
	Broadcast(e *Event)
	Run(ec chan error)
}

type ByDate struct{ Events }

type DataBackend interface {
	Save(e *Event) error
	GetById(id int) (*Event, error)
	Query(q Query) ([]*Event, error)
	AggregateType(q Query, s string) (map[string]int, error)
}

type DataService interface {
	Run(d DataBackend, ec chan error)
}

type Event struct {
	ID              int         `json:"id"`
	Key             string      `json:"key"`
	KeyParams       interface{} `json:"key_params"`
	Created         time.Time   `json:"created"`
	Updated         time.Time   `json:"updated"`
	Payload         interface{} `json:"payload"`
	Description     string      `json:"description"`
	Importance      int         `json:"importance"`
	Origin          string      `json:"origin"`
	Entities        []string    `json:"entities"`
	OtherReferences []string    `json:"other_references"`
	Actors          []string    `json:"actors"`
	Tags            []string    `json:"tags"`
}

type EventFeed interface {
	Updates() <-chan *Event
	Close() error
}

type Events []*Event

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

type MatchArray [2][]string

type Processor func(*Event) error

type Query struct {
	Origin          string    `url:"origin,omitempty" schema:"origin" json:"origin"`
	Key             string    `url:"key,omitempty" schema:"key" json:"key"`
	Entities        []string  `url:"entities,omitempty" schema:"entities" json:"entities"`
	OtherReferences []string  `url:"other_references,omitempty" schema:"other_references" json:"other_references"`
	Actors          []string  `url:"actors,omitempty" schema:"actors" json:"actors"`
	Tags            []string  `url:"tags,omitempty" schema:"tags" json:"tags"`
	Importance      string    `url:"importance,omitempty" schema:"importance" json:"importance"`
	From            time.Time `url:"from,omitempty" schema:"from" json:"from"`
	To              time.Time `url:"to,omitempty" schema:"to" json:"to"`
}