persistence

package

v1.3.3 Latest Latest Go to latest Published: Jul 31, 2025 License: GPL-3.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ethpandaops/xatu

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type AvailableConsensusNodeRecord
type AvailableExecutionNodeRecord
type Client
- func NewClient(ctx context.Context, log logrus.FieldLogger, conf *Config) (*Client, error)
type Config
- func (e *Config) Validate() error
type DriverName

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrCannonLocationNotFound = errors.New("cannon location not found")

Functions ¶

This section is empty.

Types ¶

type AvailableConsensusNodeRecord ¶ added in v1.3.0

type AvailableConsensusNodeRecord struct {
	Enr             string    `db:"enr"`
	ActiveClients   int64     `db:"active_clients"`
	LastConnectTime time.Time `db:"last_connect_time"`
}

type AvailableExecutionNodeRecord ¶

type AvailableExecutionNodeRecord struct {
	Enr             string    `db:"enr"`
	ExecutionCount  int64     `db:"execution_count"`
	LastConnectTime time.Time `db:"last_connect_time"`
}

type Client ¶

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

func NewClient ¶

func NewClient(ctx context.Context, log logrus.FieldLogger, conf *Config) (*Client, error)

func (*Client) BulkInsertNodeRecordConsensus ¶ added in v1.3.2

func (c *Client) BulkInsertNodeRecordConsensus(ctx context.Context, records []*node.Consensus) error

func (*Client) CheckoutStalledConsensusNodeRecords ¶ added in v1.3.0

func (c *Client) CheckoutStalledConsensusNodeRecords(ctx context.Context, limit int) ([]*node.Record, error)

func (*Client) CheckoutStalledExecutionNodeRecords ¶

func (c *Client) CheckoutStalledExecutionNodeRecords(ctx context.Context, limit int) ([]*node.Record, error)

func (*Client) GetCannonLocationByID ¶

func (c *Client) GetCannonLocationByID(ctx context.Context, id int64) (*cannon.Location, error)

func (*Client) GetCannonLocationByNetworkIDAndType ¶

func (c *Client) GetCannonLocationByNetworkIDAndType(ctx context.Context, networkID, typ string) (*cannon.Location, error)

get by network id and type

func (*Client) InsertNodeRecordConsensus ¶ added in v1.3.0

func (c *Client) InsertNodeRecordConsensus(ctx context.Context, record *node.Consensus) error

func (*Client) InsertNodeRecordExecution ¶

func (c *Client) InsertNodeRecordExecution(ctx context.Context, record *node.Execution) error

func (*Client) InsertNodeRecords ¶

func (c *Client) InsertNodeRecords(ctx context.Context, records []*node.Record) error

func (*Client) ListAvailableConsensusNodeRecords ¶ added in v1.3.0

func (c *Client) ListAvailableConsensusNodeRecords(ctx context.Context, clientID string, ignoredNodeRecords []string, networkIds []uint64, forkDigests [][]byte, limit int) ([]*string, error)

func (*Client) ListAvailableExecutionNodeRecords ¶

func (c *Client) ListAvailableExecutionNodeRecords(ctx context.Context, clientID string, ignoredNodeRecords []string, networkIds []uint64, forkIDHashes [][]byte, capabilities []string, limit int) ([]*string, error)

func (*Client) ListNodeRecordConsensus ¶ added in v1.3.0

func (c *Client) ListNodeRecordConsensus(ctx context.Context, networkIds []uint64, forkDigests [][]byte, limit int) ([]*node.Consensus, error)

func (*Client) ListNodeRecordExecutions ¶

func (c *Client) ListNodeRecordExecutions(ctx context.Context, networkIds []uint64, forkIDHashes [][]byte, limit int) ([]*node.Execution, error)

func (*Client) Start ¶

func (c *Client) Start(ctx context.Context) error

func (*Client) Stop ¶

func (c *Client) Stop(ctx context.Context) error

func (*Client) UpdateNodeRecord ¶

func (c *Client) UpdateNodeRecord(ctx context.Context, record *node.Record) error

func (*Client) UpsertCannonLocation ¶

func (c *Client) UpsertCannonLocation(ctx context.Context, location *cannon.Location) error

func (*Client) UpsertNodeRecordActivities ¶

func (c *Client) UpsertNodeRecordActivities(ctx context.Context, activities []*node.Activity) error

type Config ¶

type Config struct {
	Enabled          bool       `yaml:"enabled" default:"false"`
	ConnectionString string     `yaml:"connectionString"`
	DriverName       DriverName `yaml:"driverName"`
	MaxIdleConns     int        `yaml:"maxIdleConns" default:"2"`
	MaxOpenConns     int        `yaml:"maxOpenConns" default:"0"`
}

func (*Config) Validate ¶

func (e *Config) Validate() error

type DriverName ¶

type DriverName string

var (
	DriverNamePostgres DriverName = "postgres"
)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
cannon
node

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