target

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: Oct 17, 2025 License: MIT Imports: 4 Imported by: 0

Documentation

Overview

Package target provides transaction target implementations for the bridge.

Index

Constants

This section is empty.

Variables

View Source
var (
	// ErrNodeRecordsRequired is returned when nodeRecords is empty for p2p mode
	ErrNodeRecordsRequired = errors.New("nodeRecords is required for p2p mode")
	// ErrRPCEndpointsRequired is returned when rpcEndpoints is empty for rpc mode
	ErrRPCEndpointsRequired = errors.New("rpcEndpoints is required for rpc mode")
	// ErrUnknownMode is returned when an unknown mode is specified
	ErrUnknownMode = errors.New("unknown mode")
)

Functions

This section is empty.

Types

type Config

type Config struct {
	RetryInterval   time.Duration `yaml:"retryInterval" default:"60s"`
	NodeRecords     []string      `yaml:"nodeRecords"`
	RPCEndpoints    []string      `yaml:"rpcEndpoints"`
	SendConcurrency int           `yaml:"sendConcurrency" default:"10"`
}

Config holds the target configuration.

func (*Config) Validate

func (c *Config) Validate(mode any) error

Validate validates the target configuration.

type Metrics

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

Metrics provides Prometheus metrics for target operations.

func NewMetrics

func NewMetrics(namespace string) *Metrics

NewMetrics creates a new Metrics instance.

func (*Metrics) AddTransactionByType added in v0.1.0

func (m *Metrics) AddTransactionByType(txType uint8, status string)

AddTransactionByType increments the transaction type counter.

func (*Metrics) AddTransactions

func (m *Metrics) AddTransactions(count int, status string)

AddTransactions increments the transaction counter.

func (*Metrics) SetPeers

func (m *Metrics) SetPeers(count int, status string)

SetPeers sets the peer count metric.

Directories

Path Synopsis
Package p2p provides P2P-based transaction target functionality.
Package p2p provides P2P-based transaction target functionality.
Package rpc provides RPC-based transaction target functionality.
Package rpc provides RPC-based transaction target functionality.

Jump to

Keyboard shortcuts

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