storage

Documentation

Index

• type MockStore
  • func (m *MockStore) AuditJobsExecution(jobsExecutionAuditLog *postgres.JobsExecutionAuditLog) error
  • func (m *MockStore) GetEnabledScheduledJobs() ([]postgres.JobsSchedule, error)
  • func (m *MockStore) GetJobExecutionStatus(jobName string) (string, error)
  • func (m *MockStore) GetScheduledJob(jobID string) ([]postgres.JobsSchedule, error)
  • func (m *MockStore) GetScheduledJobs() ([]postgres.JobsSchedule, error)
  • func (m *MockStore) InsertScheduledJob(jobName, tags, time, notificationEmails, userEmail, groupName string, ...) (string, error)
  • func (m *MockStore) RemoveScheduledJob(jobID string) (int64, error)
  • func (m *MockStore) UpdateJobsExecutionAuditLog(JobNameSubmittedForExecution, status string) error
• type Store
  • func New(postgresClient postgres.Client) Store

Types

type MockStore

type MockStore struct {
	mock.Mock
}

func (*MockStore) AuditJobsExecution

func (m *MockStore) AuditJobsExecution(jobsExecutionAuditLog *postgres.JobsExecutionAuditLog) error

func (*MockStore) GetEnabledScheduledJobs

func (m *MockStore) GetEnabledScheduledJobs() ([]postgres.JobsSchedule, error)

func (*MockStore) GetJobExecutionStatus

func (m *MockStore) GetJobExecutionStatus(jobName string) (string, error)

func (*MockStore) GetScheduledJob

func (m *MockStore) GetScheduledJob(jobID string) ([]postgres.JobsSchedule, error)

func (*MockStore) GetScheduledJobs

func (m *MockStore) GetScheduledJobs() ([]postgres.JobsSchedule, error)

func (*MockStore) InsertScheduledJob

func (m *MockStore) InsertScheduledJob(jobName, tags, time, notificationEmails, userEmail, groupName string, jobArgs map[string]string) (string, error)

func (*MockStore) RemoveScheduledJob

func (m *MockStore) RemoveScheduledJob(jobID string) (int64, error)

func (*MockStore) UpdateJobsExecutionAuditLog

func (m *MockStore) UpdateJobsExecutionAuditLog(JobNameSubmittedForExecution, status string) error

type Store

type Store interface {
	AuditJobsExecution(*postgres.JobsExecutionAuditLog) error
	UpdateJobsExecutionAuditLog(string, string) error
	GetJobExecutionStatus(string) (string, error)
	InsertScheduledJob(string, string, string, string, string, string, map[string]string) (string, error)
	GetScheduledJobs() ([]postgres.JobsSchedule, error)
	GetEnabledScheduledJobs() ([]postgres.JobsSchedule, error)
	GetScheduledJob(string) ([]postgres.JobsSchedule, error)
	RemoveScheduledJob(string) (int64, error)
}

func New

func New(postgresClient postgres.Client) Store