Documentation
¶
Index ¶
- type Mongo
- func (m *Mongo) Checker(ctx context.Context, state *healthcheck.CheckState) error
- func (m *Mongo) Close(ctx context.Context) error
- func (m *Mongo) CreateEvent(ctx context.Context, event *domain.Event) error
- func (m *Mongo) CreateJob(ctx context.Context, job *domain.Job) error
- func (m *Mongo) GetJob(ctx context.Context, jobID string) (*domain.Job, error)
- func (m *Mongo) GetJobsByConfig(ctx context.Context, jc *domain.JobConfig, offset, limit int) ([]*domain.Job, error)
- func (m *Mongo) GetJobsByConfigAndState(ctx context.Context, jc *domain.JobConfig, stateFilter []domain.JobState, ...) ([]*domain.Job, error)
- func (m *Mongo) Init(ctx context.Context) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Mongo ¶
type Mongo struct {
config.MongoConfig
Connection *mongodriver.MongoConnection
// contains filtered or unexported fields
}
Mongo represents a mongo connection and health client
func (*Mongo) Checker ¶
func (m *Mongo) Checker(ctx context.Context, state *healthcheck.CheckState) error
Checker is called by the healthcheck library to check the health state of this mongoDB instance
func (*Mongo) CreateEvent ¶
CreateEvent creates a new event in the database.
func (*Mongo) GetJobsByConfig ¶ added in v0.7.0
func (m *Mongo) GetJobsByConfig(ctx context.Context, jc *domain.JobConfig, offset, limit int) ([]*domain.Job, error)
GetJobsByConfig retrieves jobs based on the provided job configuration.
func (*Mongo) GetJobsByConfigAndState ¶ added in v0.7.0
func (m *Mongo) GetJobsByConfigAndState(ctx context.Context, jc *domain.JobConfig, stateFilter []domain.JobState, offset, limit int) ([]*domain.Job, error)
GetJobsByConfigAndState retrieves jobs based on the provided job configuration and states.
Source Files
Click to show internal directories.
Click to hide internal directories.