status

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 20, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL