admin

May 2, 2026

Changes in this version

type Admin

+ func (a *Admin) IsVoteManager(address string) bool

type Config

+ ConfigPRGitHubToken string

+ type VoteManagerChecker func(address string) bool

May 1, 2026

Changes in this version

type Admin

+ func (a *Admin) GetTrustedKeys() ([]votingconfig.TrustedKey, error)

Apr 30, 2026

Changes in this version

type Admin

+ func (a *Admin) ValidatorExists(operatorAddress string) bool

+ type ValidatorChecker func(valoper string) bool

Apr 29, 2026

Changes in this version

type PendingRegistration

+ RequestedAt int64

type PendingValidatorPublic

+ RequestedAt int64

Apr 26, 2026

Changes in this version

+ const VotingConfigRefreshInterval

+ func RunConfigRefresher(ctx context.Context, a *Admin, interval time.Duration, logger log.Logger)

Apr 24, 2026

Changes in this version

+ const PendingEvictionSweepInterval

+ const PendingRegistrationTTL

+ func RunPendingSweeper(ctx context.Context, a *Admin, interval time.Duration, logger log.Logger)

type Admin

+ func (a *Admin) IsBonded(operatorAddress string) bool

type PendingRegistration

+ FirstSeenAt int64

+ LastSeenAt int64

+ type PendingValidatorPublic struct

+ ExpiresAt int64

+ FirstSeenAt int64

+ LastSeenAt int64

+ Moniker string

+ OperatorAddress string

+ Timestamp int64

+ URL string

type Store

+ func (s *Store) EvictExpiredPending() (int64, error)

Apr 20, 2026

Changes in this version

+ func RunWatchdog(ctx context.Context, adm *Admin, interval time.Duration, logger log.Logger)

type Admin

+ func (a *Admin) RefreshConfig() (*VotingConfig, error)

type Config

+ WatchdogInterval time.Duration

Apr 20, 2026

Changes in this version

+ func RegisterUIConfigRoutes(router *mux.Router, logger log.Logger)

+ type UIConfigResponse struct

+ DevPIRControls bool

+ Mode UIMode

+ PrecomputedBaseURL string

+ type UIMode string

+ const DefaultPrecomputedBaseURL

+ const UIModeDev

+ const UIModeProd

type VotingConfig

+ SnapshotHeight *uint64

Apr 16, 2026

Changes in this version

type Admin

+ func (a *Admin) GetVotingConfig() (*VotingConfig, error)

type Config

+ ConfigURL string

Apr 15, 2026

Changes in this version

+ func AddressToValoper(address string) (string, error)

+ func RegisterRoutes(router *mux.Router, getAdmin func() *Admin, logger log.Logger)

+ func RunHealthProber(ctx context.Context, store *Store, interval time.Duration, logger log.Logger)

+ func RunStaleEvictor(ctx context.Context, store *Store, interval time.Duration, staleThreshold int, ...)

+ func VerifyArbitrarySignature(signerAddress, payload string, signatureB64, pubKeyB64 string) error

+ type Admin struct

+ AdminAddress string

+ CheckBonding BondingChecker

+ GetVoteManager VoteManagerGetter

+ Logger log.Logger

+ PIRServers []ServiceEntry

+ StaleThreshold int

+ Store *Store

+ func New(cfg Config, checkBonding BondingChecker, getVoteManager VoteManagerGetter, ...) (*Admin, error)

+ func (a *Admin) Close() error

+ func (a *Admin) Start(ctx context.Context, cfg Config) error

+ type BondingChecker func(valoperAddress string) bool

+ type Config struct

+ AdminAddress string

+ DBPath string

+ Disable bool

+ EvictInterval int

+ PIRServers string

+ ProbeInterval int

+ StaleThreshold int

+ func DefaultConfig() Config

+ type PendingRegistration struct

+ ExpiresAt int64

+ Moniker string

+ OperatorAddress string

+ PubKey string

+ Signature string

+ Timestamp int64

+ URL string

+ type ServiceEntry struct

+ Label string

+ OperatorAddress string

+ URL string

+ type Store struct

+ func NewStore(dbPath string) (*Store, error)

+ func (s *Store) BuildVotingConfig(pirServers []ServiceEntry) (*VotingConfig, error)

+ func (s *Store) CleanPendingByOperator(operatorAddress, url string) error

+ func (s *Store) Close() error

+ func (s *Store) EvictStalePulses(staleThresholdSecs int) ([]string, error)

+ func (s *Store) GetPulses() (map[string]int64, error)

+ func (s *Store) IsApproved(operatorAddress string) (bool, error)

+ func (s *Store) ListApprovedServers() ([]ServiceEntry, error)

+ func (s *Store) ListPendingRegistrations() ([]PendingRegistration, error)

+ func (s *Store) RemoveApprovedServer(operatorAddress string) (removedURL string, err error)

+ func (s *Store) RemovePendingRegistration(operatorAddress string) (*PendingRegistration, error)

+ func (s *Store) RemovePulse(url string) error

+ func (s *Store) UpsertApprovedServer(e ServiceEntry) error

+ func (s *Store) UpsertPendingRegistration(r PendingRegistration) error

+ func (s *Store) UpsertPulse(url string, pulseAt int64) error

+ type VoteManagerGetter func() string

+ type VotingConfig struct

+ PIRServers []ServiceEntry

+ Version int

+ VoteServers []ServiceEntry