bootstrap

Documentation

Index

• Constants
• func NewApp(logger applogger.Logger, config *config.Config) *app
• func SetupRDbConn(config *config.Config, logger applogger.Logger) (rdb.Conn, error)
• type HTTPAPIServer
  • func NewHTTPAPIServer(logger applogger.Logger, config *config.Config) *HTTPAPIServer
  • func (server *HTTPAPIServer) RegisterRoutes(registry RouteRegistry)
  • func (server *HTTPAPIServer) Run() error
• type IndexService
  • func NewIndexService(logger applogger.Logger, rdbConn rdb.Conn, config *config.Config, ...) *IndexService
  • func (service *IndexService) Run() error
  • func (service *IndexService) RunEventStoreMode() error
  • func (service *IndexService) RunTendermintDirectMode() error
• type InfoManager
  • func NewInfoManager(logger applogger.Logger, rdbConn rdb.Conn, tendermintRPCUrl string, ...) *InfoManager
  • func (manager *InfoManager) Run()
• type RouteRegistry
• type SyncManager
  • func NewSyncManager(params SyncManagerParams, pm *utils.CosmosParserManager, ...) *SyncManager
  • func (manager *SyncManager) Run() error
  • func (manager *SyncManager) SyncBlocks(latestHeight int64, isRetry bool) error
• type SyncManagerConfig
• type SyncManagerParams

Constants

const (
	MIGRATION_TABLE_NAME    = "schema_migrations"
	MIGRATION_GITHUB_TARGET = "github://%s:%s@crypto-com/chain-indexing/migrations%s"
)

const DEFAULT_MAX_RETRY_INTERVAL = 15 * time.Minute

const DEFAULT_MAX_RETRY_TIME = MAX_RETRY_TIME_ALWAYS_RETRY

const DEFAULT_POLLING_INTERVAL = 5 * time.Second

const INFO_DEFAULT_POLLING_INTERVAL = 5 * time.Second

TODO: Move InfoManager to CronJob

const MAX_RETRY_TIME_ALWAYS_RETRY = 0

Functions

func NewApp

func NewApp(logger applogger.Logger, config *config.Config) *app

func SetupRDbConn

func SetupRDbConn(config *config.Config, logger applogger.Logger) (rdb.Conn, error)

Types

type HTTPAPIServer

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

func NewHTTPAPIServer

func NewHTTPAPIServer(logger applogger.Logger, config *config.Config) *HTTPAPIServer

func (*HTTPAPIServer) RegisterRoutes

func (server *HTTPAPIServer) RegisterRoutes(registry RouteRegistry)

func (*HTTPAPIServer) Run

func (server *HTTPAPIServer) Run() error

type IndexService

type IndexService struct {
	BlockResultEventAttributeDecodeMethod string

	GithubAPIUser  string
	GithubAPIToken string
	// contains filtered or unexported fields
}

func NewIndexService

func NewIndexService(
	logger applogger.Logger,
	rdbConn rdb.Conn,
	config *config.Config,
	projections []projection_entity.Projection,
	cronJobs []projection_entity.CronJob,
	txDecoder txdecoder.TxDecoder,
) *IndexService

NewIndexService creates a new server instance for polling and indexing

func (*IndexService) Run

func (service *IndexService) Run() error

func (*IndexService) RunEventStoreMode

func (service *IndexService) RunEventStoreMode() error

func (*IndexService) RunTendermintDirectMode

func (service *IndexService) RunTendermintDirectMode() error

type InfoManager

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

func NewInfoManager

func NewInfoManager(
	logger applogger.Logger,
	rdbConn rdb.Conn,
	tendermintRPCUrl string,
	insecureTendermintClient bool,
	strictGenesisParsing bool,
) *InfoManager

func (*InfoManager) Run

func (manager *InfoManager) Run()

type RouteRegistry

type RouteRegistry interface {
	Register(*httpapi.Server, string)
}

type SyncManager

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

func NewSyncManager

func NewSyncManager(
	params SyncManagerParams,
	pm *utils.CosmosParserManager,
	eventHandler eventhandler_interface.Handler,
) *SyncManager

NewSyncManager creates a new feed with polling for latest block starts at a specific height

func (*SyncManager) Run

func (manager *SyncManager) Run() error

Run starts the polling service for blocks

func (*SyncManager) SyncBlocks

func (manager *SyncManager) SyncBlocks(latestHeight int64, isRetry bool) error

SyncBlocks makes request to tendermint, create and dispatch notifications

type SyncManagerConfig

type SyncManagerConfig struct {
	WindowSize                            int
	TendermintRPCUrl                      string
	CosmosAppHTTPRPCURL                   string
	InsecureTendermintClient              bool
	InsecureCosmosAppClient               bool
	StrictGenesisParsing                  bool
	AccountAddressPrefix                  string
	StakingDenom                          string
	StartingBlockHeight                   int64
	BlockResultEventAttributeDecodeMethod string
}

type SyncManagerParams

type SyncManagerParams struct {
	Logger    applogger.Logger
	RDbConn   rdb.Conn
	TxDecoder txdecoder.TxDecoder

	Config SyncManagerConfig
}