monitor

type BalanceMonitorOpts struct {
	ChainInfo ChainInfo

	Config    GenericBalanceConfig
	Logger    logger.Logger
	Keystore  core.Keystore
	NewClient func() (aptos.AptosRpcClient, error)
}

type BeholderClient struct {
	*beholder.Client
	ProtoEmitter ProtoEmitter
}

type ChainInfo struct {
	ChainFamilyName string
	ChainID         string
	NetworkName     string
	NetworkNameFull string
}

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

type GenericBalanceClient interface {
	GetAccountBalance(addr string) (float64, error)
}

type GenericBalanceConfig struct {
	BalancePollPeriod config.Duration
}

type GenericBalanceMonitorOpts struct {
	ChainInfo           ChainInfo
	ChainNativeCurrency string

	Config                  GenericBalanceConfig
	Logger                  logger.Logger
	Keystore                core.Keystore
	NewGenericBalanceClient func() (GenericBalanceClient, error)

	// Maps a public key to an account address (optional, can return key as is)
	KeyToAccountMapper func(context.Context, string) (string, error)
}

type ProtoEmitter interface {
	// Sends message with bytes and attributes to OTel Collector
	Emit(ctx context.Context, m proto.Message, attrKVs ...any) error
	EmitWithLog(ctx context.Context, m proto.Message, attrKVs ...any) error
}

type ProtoProcessor interface {
	Process(ctx context.Context, m proto.Message, attrKVs ...any) error
}