repo

Documentation

Index

• type HealthCheckRepository
  • func NewHealthCheckRepository(dbHandler db.DB) (*HealthCheckRepository, error)
  • func (r *HealthCheckRepository) Get(ctx context.Context, req *http.Request) (paginate.Page, error)
  • func (r *HealthCheckRepository) GetByGuardianProverAddress(ctx context.Context, req *http.Request, address string) (paginate.Page, error)
  • func (r *HealthCheckRepository) GetMostRecentByGuardianProverAddress(ctx context.Context, req *http.Request, address string) (*guardianproverhealthcheck.HealthCheck, error)
  • func (r *HealthCheckRepository) GetUptimeByGuardianProverAddress(ctx context.Context, address string) (float64, int, error)
  • func (r *HealthCheckRepository) Save(ctx context.Context, opts *guardianproverhealthcheck.SaveHealthCheckOpts) error
• type SignedBlockRepository
  • func NewSignedBlockRepository(dbHandler db.DB) (*SignedBlockRepository, error)
  • func (r *SignedBlockRepository) GetByStartingBlockID(ctx context.Context, ...) ([]*guardianproverhealthcheck.SignedBlock, error)
  • func (r *SignedBlockRepository) GetMostRecentByGuardianProverAddress(ctx context.Context, address string) (*guardianproverhealthcheck.SignedBlock, error)
  • func (r *SignedBlockRepository) Save(ctx context.Context, opts *guardianproverhealthcheck.SaveSignedBlockOpts) error
• type StartupRepository
  • func NewStartupRepository(dbHandler db.DB) (*StartupRepository, error)
  • func (r *StartupRepository) GetByGuardianProverAddress(ctx context.Context, req *http.Request, address string) (paginate.Page, error)
  • func (r *StartupRepository) GetMostRecentByGuardianProverAddress(ctx context.Context, address string) (*guardianproverhealthcheck.Startup, error)
  • func (r *StartupRepository) Save(ctx context.Context, opts *guardianproverhealthcheck.SaveStartupOpts) error

Types

type HealthCheckRepository

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

func NewHealthCheckRepository

func NewHealthCheckRepository(dbHandler db.DB) (*HealthCheckRepository, error)

func (*HealthCheckRepository) Get

func (r *HealthCheckRepository) Get(
	ctx context.Context,
	req *http.Request,
) (paginate.Page, error)

func (*HealthCheckRepository) GetByGuardianProverAddress

func (r *HealthCheckRepository) GetByGuardianProverAddress(
	ctx context.Context,
	req *http.Request,
	address string,
) (paginate.Page, error)

func (*HealthCheckRepository) GetMostRecentByGuardianProverAddress

func (r *HealthCheckRepository) GetMostRecentByGuardianProverAddress(
	ctx context.Context,
	req *http.Request,
	address string,
) (*guardianproverhealthcheck.HealthCheck, error)

func (*HealthCheckRepository) GetUptimeByGuardianProverAddress

func (r *HealthCheckRepository) GetUptimeByGuardianProverAddress(
	ctx context.Context,
	address string,
) (float64, int, error)

func (*HealthCheckRepository) Save

func (r *HealthCheckRepository) Save(ctx context.Context, opts *guardianproverhealthcheck.SaveHealthCheckOpts) error

type SignedBlockRepository

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

func NewSignedBlockRepository

func NewSignedBlockRepository(dbHandler db.DB) (*SignedBlockRepository, error)

func (*SignedBlockRepository) GetByStartingBlockID

func (r *SignedBlockRepository) GetByStartingBlockID(
	ctx context.Context,
	opts guardianproverhealthcheck.GetSignedBlocksByStartingBlockIDOpts,
) ([]*guardianproverhealthcheck.SignedBlock, error)

func (*SignedBlockRepository) GetMostRecentByGuardianProverAddress

func (r *SignedBlockRepository) GetMostRecentByGuardianProverAddress(ctx context.Context, address string) (
	*guardianproverhealthcheck.SignedBlock,
	error)

func (*SignedBlockRepository) Save

func (r *SignedBlockRepository) Save(ctx context.Context, opts *guardianproverhealthcheck.SaveSignedBlockOpts) error

type StartupRepository

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

func NewStartupRepository

func NewStartupRepository(dbHandler db.DB) (*StartupRepository, error)

func (*StartupRepository) GetByGuardianProverAddress

func (r *StartupRepository) GetByGuardianProverAddress(
	ctx context.Context,
	req *http.Request,
	address string,
) (paginate.Page, error)

func (*StartupRepository) GetMostRecentByGuardianProverAddress

func (r *StartupRepository) GetMostRecentByGuardianProverAddress(
	ctx context.Context,
	address string,
) (*guardianproverhealthcheck.Startup, error)

func (*StartupRepository) Save

func (r *StartupRepository) Save(ctx context.Context, opts *guardianproverhealthcheck.SaveStartupOpts) error