eventOutput

Documentation

Index

• func WriteEvents(ffsEvents []FFSEvent, query config.FFSQuery) error
• func WriteInProgressQueries(query config.FFSQuery, inProgressQueries *[]InProgressQuery) error
• func WriteLastCompletedQuery(query config.FFSQuery, lastCompletedQuery InProgressQuery) error
• type FFSEvent
• type GeoPoint
• type InProgressQuery
  • func ReadInProgressQueries(query config.FFSQuery) ([]InProgressQuery, error)
  • func ReadLastCompletedQuery(query config.FFSQuery) (InProgressQuery, error)
• type InProgressQueryString

Functions

func WriteEvents

func WriteEvents(ffsEvents []FFSEvent, query config.FFSQuery) error

func WriteInProgressQueries

func WriteInProgressQueries(query config.FFSQuery, inProgressQueries *[]InProgressQuery) error

func WriteLastCompletedQuery

func WriteLastCompletedQuery(query config.FFSQuery, lastCompletedQuery InProgressQuery) error

Types

type FFSEvent

type FFSEvent struct {
	ffs.FileEvent
	ip_api.Location `json:",omitempty"`
	*GeoPoint       `json:"geoPoint,omitempty"`
}

type GeoPoint

type GeoPoint struct {
	Lat float32 `json:"lat,omitempty"`
	Lon float32 `json:"lon,omitempty"`
}

type InProgressQuery

type InProgressQuery struct {
	OnOrAfter  time.Time
	OnOrBefore time.Time
}

In progress query struct

func ReadInProgressQueries

func ReadInProgressQueries(query config.FFSQuery) ([]InProgressQuery, error)

func ReadLastCompletedQuery

func ReadLastCompletedQuery(query config.FFSQuery) (InProgressQuery, error)

type InProgressQueryString

type InProgressQueryString struct {
	OnOrAfter  string
	OnOrBefore string
}

In progress query struct using strings