visor

Documentation

Index

• Constants
• type GapReport
  • func (p *GapReport) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error
• type GapReportList
  • func (pl GapReportList) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error
• type ProcessingReport
  • func (p *ProcessingReport) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error
• type ProcessingReportList
  • func (pl ProcessingReportList) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error

Constants

const (
	ProcessingStatusOK    = "OK"
	ProcessingStatusInfo  = "INFO"  // Processing was successful but the task reported information in the StatusInformation column
	ProcessingStatusError = "ERROR" // one or more errors were encountered, data may be incomplete
	ProcessingStatusSkip  = "SKIP"  // no processing was attempted, a reason may be given in the StatusInformation column
)

const (
	// ProcessingStatusInformationNullRound is set byt the consensus task to indicate a null round
	ProcessingStatusInformationNullRound = "NULL_ROUND" // used by consensus task to indicate a null round

)

Types

type GapReport

type GapReport struct {
	Height int64  `pg:",pk,use_zero"`
	Task   string `pg:",pk"`
	Status string `pg:",pk,notnull"`

	// Reporter is the name of the instance that is reporting the result
	Reporter   string    `pg:",notnull"`
	ReportedAt time.Time `pg:",use_zero"`
	// contains filtered or unexported fields
}

func (*GapReport) Persist

func (p *GapReport) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error

type GapReportList

type GapReportList []*GapReport

func (GapReportList) Persist

func (pl GapReportList) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error

type ProcessingReport

type ProcessingReport struct {
	Height    int64  `pg:",pk,use_zero"`
	StateRoot string `pg:",pk,notnull"`

	// Reporter is the name of the instance that is reporting the result
	Reporter string `pg:",pk,notnull"`

	// Task is the name of the sub task that generated the report
	Task string `pg:",pk,notnull"`

	StartedAt   time.Time `pg:",pk,use_zero"`
	CompletedAt time.Time `pg:",use_zero"`

	Status            string `pg:",notnull"`
	StatusInformation string
	ErrorsDetected    interface{} `pg:",type:jsonb"`
	// contains filtered or unexported fields
}

func (*ProcessingReport) Persist

func (p *ProcessingReport) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error

type ProcessingReportList

type ProcessingReportList []*ProcessingReport

func (ProcessingReportList) Persist

func (pl ProcessingReportList) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error