Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

common

package

Go to main page

Versions in this module

v1

v1.0.1-rc1

Nov 25, 2024

v1.0.1-rc0

Nov 18, 2024

v1.0.0

Nov 13, 2024

Changes in this version

+ const BalanceAddressLabel

+ const BaseURLLabel

+ const ChainIDLabel

+ const ChainLabel

+ const ConsensusAddressLabel

+ const ErrLabel

+ const ErrorPrefix

+ const EvmChainLabel

+ const IndexPointerBlockHeightMetricName

+ const IndexPointerBlockTimestampMetricName

+ const IndexerSQLDefaultTimeout

+ const LatestBlockHeightMetricName

+ const MainnetLabel

+ const MonikerLabel

+ const Namespace

+ const OrchestratorAddressLabel

+ const PackageLabel

+ const ProposerAddressLabel

+ const RecentMissCounterMetricName

+ const Subsystem

+ const TableChainIDLabel

+ const Timeout

+ const UpgradeNameLabel

+ const ValidatorAddressLabel

+ var DefaultLabels = []string

+ var ErrCanSkip = fmt.Errorf("skip")

+ var ErrFailedBuildingLogger = fmt.Errorf("%s: failed to build logger by not found workspace string", ErrorPrefix)

+ var ErrFailedConvertTypes = fmt.Errorf("%s: failed to converting number types", ErrorPrefix)

+ var ErrFailedCreateGrpcConnection = fmt.Errorf("%s: failed to create grpc connection", ErrorPrefix)

+ var ErrFailedGatheringMiddleData = fmt.Errorf("%s: failed to gather middle data like orchestrator address or somethings", ...)

+ var ErrFailedGrpcRequest = fmt.Errorf("%s: failed to grpc request from node", ErrorPrefix)

+ var ErrFailedHttpRequest = fmt.Errorf("%s: failed to request from node", ErrorPrefix)

+ var ErrFailedJsonUnmarshal = fmt.Errorf("%s: failed to unmarshing json data", ErrorPrefix)

+ var ErrFailedToBuildPackager = errors.New("failed to build the packger").Error()

+ var ErrGotStrangeStatusCode = fmt.Errorf("%s: got strange status code in request", ErrorPrefix)

+ var ErrOutOfSwitchCases = fmt.Errorf("%s: out of switch case in router", ErrorPrefix)

+ var ErrUnDefinedApp = fmt.Errorf("%s: undefinded app name", ErrorPrefix)

+ var ErrUnDefinedSomeConfiguration = errors.New("undefinded port or something in your prometheus config file")

+ var ErrUnExpectedMethodCall = fmt.Errorf("%s: got unexpected call method", ErrorPrefix)

+ var ErrUnSupportedMethod = fmt.Errorf("%s: this is unsupported method", ErrorPrefix)

+ var ErrUnSupportedPackage = fmt.Errorf("%s: this is unsupported monitoring package", ErrorPrefix)

+ var ErrUnsetHttpSchema = fmt.Errorf("%s: failed to unset http schema for grpc connecting", ErrorPrefix)

+ var ExporterPackages = []string

+ var Health = promauto.NewGaugeVec(prometheus.GaugeOpts{ ... }, DefaultLabels)

+ var IndexPackages = []string

+ var Moniker string

+ var Ops = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, DefaultLabels)

+ var Skip = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, DefaultLabels)

+ func BuildPackageLabels(p Packager) prometheus.Labels

+ func BuildPackageLabelsWithURL(p Packager, url string) prometheus.Labels

+ func BuildRootLabels(p Packager) prometheus.Labels

+ type ClientType int

+ const API

+ const GRPC

+ const RPC

+ type CollectorLoop func(*Exporter, Packager)

+ type CollectorStart func(Packager) error

+ type CommonApp struct

+ EndPoint string

+ OptionalClient CommonClient

+ func NewCommonApp(p Packager) CommonApp

+ type CommonClient struct

+ APIClient *resty.Client

+ GRPCClient *resty.Client

+ RPCClient *resty.Client

+ func NewOptionalClient(entry *logrus.Entry) CommonClient

+ func (c *CommonClient) GetAPIEndPoint() string

+ func (c *CommonClient) GetGRPCEndPoint() string

+ func (c *CommonClient) GetRPCEndPoint() string

+ func (c *CommonClient) SetAPIEndPoint(endpoint string) *resty.Client

+ func (c *CommonClient) SetGRPCEndPoint(endpoint string) *resty.Client

+ func (c *CommonClient) SetRPCEndPoint(endpoint string) *resty.Client

+ type Endpoints struct

+ APIs []string

+ CheckAPI bool

+ CheckGRPC bool

+ CheckRPC bool

+ GRPCs []string

+ RPCs []string

+ type Exporter struct

+ ChainID string

+ ChainName string

+ Monikers []string

+ func NewExporter(p Packager) *Exporter

+ type ICollector interface

+ Start func(p Packager) error

+ type IIndexer interface

+ FetchValidatorInfoList func() error

+ Loop func(lastIndexPointerHeight int64)

+ Start func() error

+ type Indexer struct

+ ChainID string

+ ChainInfoID int64

+ ChainName string

+ Factory promauto.Factory

+ IsConsumer bool

+ Lh indexertypes.LatestHeightCache

+ Mainnet bool

+ MetricsMap map[string]prometheus.Gauge

+ MetricsVecMap map[string]*prometheus.GaugeVec

+ MonikerIDMap indexertypes.MonikerIDMap

+ Monikers []string

+ PackageLabels prometheus.Labels

+ ProtocolType string

+ RootLabels prometheus.Labels

+ Vim indexertypes.ValidatorIDMap

+ func NewIndexer(p Packager, subsystem string, chainID string) *Indexer

+ func (indexer *Indexer) FetchLatestHeight()

+ type IndexerDB struct

+ RetentionPeriod string

+ func NewIndexerDB(cfg IndexerDBConfig) (*IndexerDB, error)

+ func NewTestIndexerDB(dsn string) (*IndexerDB, error)

+ func (db *IndexerDB) CloseConn() error

+ func (db *IndexerDB) SetRetentionTime(retentionPeriod string)

+ type IndexerDBConfig struct

+ Database string

+ Host string

+ Password string

+ Port string

+ Timeout int64

+ User string

+ type Method int

+ const GET

+ const POST

+ type Mode int

+ const INVALID_APP

+ const NETWORK

+ const VALIDATOR

+ func (a Mode) String() string

+ type OptionPackager struct

+ BalanceAddresses []string

+ BalanceDenom string

+ BalanceExponent int

+ IsConsumerChain bool

+ ProviderEndPoints Endpoints

+ RetentionPeriod string

+ type Packager struct

+ ChainID string

+ ChainName string

+ Factory promauto.Factory

+ Logger *logrus.Logger

+ Mainnet bool

+ Mode Mode

+ Monikers []string

+ Package string

+ ProtocolType string

+ func NewPackager(m Mode, f promauto.Factory, l *logrus.Logger, mainnet bool, ...) (*Packager, error)

+ func (p *Packager) SetAddtionalEndpoints(providerEndpoints Endpoints) *Packager

+ func (p *Packager) SetConsumer() *Packager

+ func (p *Packager) SetIndexerDB(idxDB *IndexerDB) *Packager

+ func (p *Packager) SetInfoForBalancePackage(balanceAddresses []string, balanceDenom string, balanceExponent int) *Packager

v1.0.0-rc2

Nov 25, 2024