Documentation
¶
Index ¶
- func NewEventsStore(database *mongo.Database) (core.EventsStore, error)
- func NewJobsStore(database *mongo.Database) (core.JobsStore, error)
- func NewLogsStore(database *mongo.Database) core.CoolLogsStore
- func NewProjectsStore(database *mongo.Database) (core.ProjectsStore, error)
- func NewWorkersStore(database *mongo.Database) (core.WorkersStore, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewEventsStore ¶
func NewEventsStore(database *mongo.Database) (core.EventsStore, error)
NewEventsStore returns a MongoDB-based implementation of the core.EventsStore interface.
func NewJobsStore ¶
NewJobsStore returns a MongoDB-based implementation of the core.JobsStore interface.
func NewLogsStore ¶
func NewLogsStore(database *mongo.Database) core.CoolLogsStore
NewLogsStore returns a MongoDB-based implementation of the core.LogsStore interface. This implementation relies on a log aggregator having forwarded and stored log entries-- a process which necessarily introduces some latency. Callers should favor another implementation of the core.LogsStore interface and fall back on this implementation when the other fails.
func NewProjectsStore ¶
func NewProjectsStore(database *mongo.Database) (core.ProjectsStore, error)
NewProjectsStore returns a MongoDB-based implementation of the core.ProjectsStore interface.
func NewWorkersStore ¶
func NewWorkersStore(database *mongo.Database) (core.WorkersStore, error)
NewWorkersStore returns a MongoDB-based implementation of the core.WorkersStore interface.
Types ¶
This section is empty.
Source Files