guardianproverhealthcheck

README

Guardian Prover Health Check Service

A service that watches the guardian provers and pings them for uptime availability metrics.

Build the source

Building the taiko-client binary requires a Go compiler. Once installed, run:

make build

Configuration

Run migrations: cd migrations goose mysql "user:pass@/dbname?parseTime=true" up

To run the health check service: ENV_FILE=.env go run cmd/main.go healthchecker

To run the stats generator: ENV_FILE=.generator.env go run cmd/main.go generator

Usage

Review all available sub-commands:

bin/guardian-prover-health-check --help

Review each sub-command's command line flags:

bin/guardian-prover-health-check <sub-command> --help

Documentation

Index

• Variables
• type GetSignedBlocksByStartingBlockIDOpts
• type GuardianProver
  • func SignatureToGuardianProver(msg []byte, b64EncodedSig string, guardianProvers []GuardianProver) (*GuardianProver, error)
• type HealthCheck
• type HealthCheckRepository
• type NodeInfo
• type SaveHealthCheckOpts
• type SaveSignedBlockOpts
• type SaveStartupOpts
• type SignedBlock
• type SignedBlockRepository
• type Startup
• type StartupRepository

Variables

var (
	EventsProcessed = promauto.NewCounter(prometheus.CounterOpts{
		Name: "events_processed_ops_total",
		Help: "The total number of processed events",
	})
)

Types

type GetSignedBlocksByStartingBlockIDOpts

type GetSignedBlocksByStartingBlockIDOpts struct {
	StartingBlockID uint64
}

type GuardianProver

type GuardianProver struct {
	Address            common.Address
	ID                 *big.Int
	HealthCheckCounter prometheus.Counter
	SignedBlockCounter prometheus.Counter
}

func SignatureToGuardianProver

func SignatureToGuardianProver(
	msg []byte,
	b64EncodedSig string,
	guardianProvers []GuardianProver,
) (*GuardianProver, error)

type HealthCheck

type HealthCheck struct {
	ID               int       `json:"id"`
	GuardianProverID uint64    `json:"guardianProverId"`
	Alive            bool      `json:"alive"`
	ExpectedAddress  string    `json:"expectedAddress"`
	RecoveredAddress string    `json:"recoveredAddress"`
	SignedResponse   string    `json:"signedResponse"`
	LatestL1Block    uint64    `json:"latestL1Block"`
	LatestL2Block    uint64    `json:"latestL2Block"`
	CreatedAt        time.Time `json:"createdAt"`
}

type HealthCheckRepository

type HealthCheckRepository interface {
	Get(
		ctx context.Context,
		req *http.Request,
	) (paginate.Page, error)
	GetByGuardianProverAddress(
		ctx context.Context,
		req *http.Request,
		address string,
	) (paginate.Page, error)
	GetMostRecentByGuardianProverAddress(
		ctx context.Context,
		req *http.Request,
		address string,
	) (*HealthCheck, error)
	Save(ctx context.Context, opts *SaveHealthCheckOpts) error
	GetUptimeByGuardianProverAddress(ctx context.Context, address string) (float64, int, error)
}

type NodeInfo

type NodeInfo struct {
	Startup
	LatestL1BlockNumber uint64 `json:"latestL1BlockNumber"`
	LatestL2BlockNumber uint64 `json:"latestL2BlockNumber"`
}

type SaveHealthCheckOpts

type SaveHealthCheckOpts struct {
	GuardianProverID uint64
	Alive            bool
	ExpectedAddress  string
	RecoveredAddress string
	SignedResponse   string
	LatestL1Block    uint64
	LatestL2Block    uint64
}

type SaveSignedBlockOpts

type SaveSignedBlockOpts struct {
	GuardianProverID uint64
	BlockID          uint64
	BlockHash        string
	Signature        string
	RecoveredAddress string
}

type SaveStartupOpts

type SaveStartupOpts struct {
	GuardianProverID      uint64
	GuardianProverAddress string
	Revision              string
	GuardianVersion       string
	L1NodeVersion         string `json:"l1NodeVersion"`
	L2NodeVersion         string `json:"l2NodeVersion"`
}

type SignedBlock

type SignedBlock struct {
	GuardianProverID uint64    `json:"guardianProverID"`
	BlockID          uint64    `json:"blockID"`
	BlockHash        string    `json:"blockHash"`
	Signature        string    `json:"signature"`
	RecoveredAddress string    `json:"recoveredAddress"`
	CreatedAt        time.Time `json:"createdAt"`
}

type SignedBlockRepository

type SignedBlockRepository interface {
	Save(ctx context.Context, opts *SaveSignedBlockOpts) error
	GetByStartingBlockID(ctx context.Context, opts GetSignedBlocksByStartingBlockIDOpts) ([]*SignedBlock, error)
	GetMostRecentByGuardianProverAddress(ctx context.Context, address string) (*SignedBlock, error)
}

SignedBlockRepository defines database interaction methods to create and get signed blocks submitted by guardian provers.

type Startup

type Startup struct {
	GuardianProverID      uint64    `json:"guardianProverID"`
	GuardianProverAddress string    `json:"guardianProverAddress"`
	L1NodeVersion         string    `json:"l1NodeVersion"`
	L2NodeVersion         string    `json:"l2NodeVersion"`
	Revision              string    `json:"revision"`
	GuardianVersion       string    `json:"guardianVersion"`
	CreatedAt             time.Time `json:"createdAt"`
}

Startup represents an individual startup from a guardian prover, every time one boots up, we should receive a startup and save it in the database.

type StartupRepository

type StartupRepository interface {
	GetByGuardianProverAddress(
		ctx context.Context,
		req *http.Request,
		address string,
	) (paginate.Page, error)
	GetMostRecentByGuardianProverAddress(
		ctx context.Context,
		address string,
	) (*Startup, error)
	Save(ctx context.Context, opts *SaveStartupOpts) error
}