cmd

Documentation

Index

• Constants
• func Execute()
• func RunApi(cmd *cobra.Command, args []string)
• func RunOrchestrator(cmd *cobra.Command, args []string)
• func RunValidate(cmd *cobra.Command, args []string)
• func RunValidateAndFix(cmd *cobra.Command, args []string)
• func RunValidationMigration(cmd *cobra.Command, args []string)
• type Migrator
  • func NewMigrator() *Migrator
  • func (m *Migrator) Close()
  • func (m *Migrator) DetermineMigrationBoundaries() (*big.Int, *big.Int)
  • func (m *Migrator) FetchBlocksFromRPC(blockNumbers []*big.Int) ([]common.BlockData, error)
  • func (m *Migrator) GetValidBlocksForRange(blockNumbers []*big.Int) []common.BlockData
  • func (m *Migrator) GetValidBlocksFromRPC(blockNumbers []*big.Int) []common.BlockData

Constants

const (
	TARGET_STORAGE_DATABASE = "temp"
	DEFAULT_RPC_BATCH_SIZE  = 200
	DEFAULT_BATCH_SIZE      = 1000
)

Functions

func Execute

func Execute()

func RunApi

func RunApi(cmd *cobra.Command, args []string)

@title Thirdweb Insight @version v0.0.1-beta @description API for querying blockchain transactions and events @license.name Apache 2.0 @license.url https://github.com/thirdweb-dev/indexer/blob/main/LICENSE @BasePath / @Security BasicAuth @securityDefinitions.basic BasicAuth

func RunOrchestrator

func RunOrchestrator(cmd *cobra.Command, args []string)

func RunValidate

func RunValidate(cmd *cobra.Command, args []string)

*

• Validates a range of blocks (end and start are inclusive) for a given chain
• First argument is the start block number
• Second argument (optional) is the end block number

func RunValidateAndFix

func RunValidateAndFix(cmd *cobra.Command, args []string)

func RunValidationMigration

func RunValidationMigration(cmd *cobra.Command, args []string)

Types

type Migrator

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

func NewMigrator

func NewMigrator() *Migrator

func (*Migrator) Close

func (m *Migrator) Close()

func (*Migrator) DetermineMigrationBoundaries

func (m *Migrator) DetermineMigrationBoundaries() (*big.Int, *big.Int)

func (*Migrator) FetchBlocksFromRPC

func (m *Migrator) FetchBlocksFromRPC(blockNumbers []*big.Int) ([]common.BlockData, error)

func (*Migrator) GetValidBlocksForRange

func (m *Migrator) GetValidBlocksForRange(blockNumbers []*big.Int) []common.BlockData

func (*Migrator) GetValidBlocksFromRPC

func (m *Migrator) GetValidBlocksFromRPC(blockNumbers []*big.Int) []common.BlockData