storage

Documentation

Index

• type MockStore
  • func (m *MockStore) GetJobExecutionStatus(jobName string) (string, error)
  • func (m *MockStore) JobsExecutionAuditLog(...) 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) GetJobExecutionStatus

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

func (*MockStore) JobsExecutionAuditLog

func (m *MockStore) JobsExecutionAuditLog(jobSubmissionStatus, jobExecutionStatus, jobName, userEmail, jobExecutedName, imageName string, jobArgs map[string]string) error

func (*MockStore) UpdateJobsExecutionAuditLog

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

type Store

type Store interface {
	JobsExecutionAuditLog(string, string, string, string, string, string, map[string]string) error
	UpdateJobsExecutionAuditLog(string, string) error
	GetJobExecutionStatus(string) (string, error)
}

func New

func New(postgresClient postgres.Client) Store