status

Documentation

Index

• func NewStore(db *gorm.DB, tableName string) protocol.StatusStore
• type MultiLogger
  • func NewMultiLogger(statusLoggers []protocol.StatusLogger) *MultiLogger
  • func (m *MultiLogger) Log(entry protocol.Entry, message string) error
• type Store
  • func (s *Store) GetLatestStatusByIDandType(jobID string, jobType job.Type) (*protocol.Status, error)
  • func (s *Store) GetStatusLogByIDandType(jobID string, jobType job.Type) ([]*protocol.Status, error)
  • func (s *Store) Store(state *protocol.Status) error

Functions

func NewStore

func NewStore(db *gorm.DB, tableName string) protocol.StatusStore

NewStore to construct status store

Types

type MultiLogger

type MultiLogger struct {
	// contains filtered or unexported fields
}

MultiLogger log job status in multiple StatusLogger implementation

func NewMultiLogger

func NewMultiLogger(statusLoggers []protocol.StatusLogger) *MultiLogger

NewMultiLogger is constructor

func (*MultiLogger) Log

func (m *MultiLogger) Log(entry protocol.Entry, message string) error

Log to store map of profile id and bq job id to stdout

type Store

type Store struct {
	// contains filtered or unexported fields
}

Store to store status

func (*Store) GetLatestStatusByIDandType

func (s *Store) GetLatestStatusByIDandType(jobID string, jobType job.Type) (*protocol.Status, error)

GetLatestStatusByIDandType to get latest status of profile or audit by job Partition and job Type

func (*Store) GetStatusLogByIDandType

func (s *Store) GetStatusLogByIDandType(jobID string, jobType job.Type) ([]*protocol.Status, error)

GetStatusLogByIDandType to get status history of profile or audit by job Partition and job Type

func (*Store) Store

func (s *Store) Store(state *protocol.Status) error

Store to store status of profile or audit