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(targetStartBlock, targetEndBlock *big.Int) (*big.Int, *big.Int)
  • func (m *Migrator) DetermineMigrationBoundariesForRange(rangeStart, rangeEnd *big.Int) (*big.Int, *big.Int)
  • func (m *Migrator) FetchBlocksFromRPC(blockNumbers []*big.Int) ([]common.BlockData, error)
  • func (m *Migrator) GetValidBlocksForRange(blockNumbers []*big.Int) ([]common.BlockData, error)
  • func (m *Migrator) GetValidBlocksFromRPC(blockNumbers []*big.Int) []common.BlockData

Constants

const (
	DEFAULT_BATCH_SIZE = 2000
	DEFAULT_WORKERS    = 1
)

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(targetStartBlock, targetEndBlock *big.Int) (*big.Int, *big.Int)

func (*Migrator) DetermineMigrationBoundariesForRange

func (m *Migrator) DetermineMigrationBoundariesForRange(rangeStart, rangeEnd *big.Int) (*big.Int, *big.Int)

DetermineMigrationBoundariesForRange determines the actual migration boundaries for a worker's specific range Returns nil, nil if the range is already fully migrated Fails fatally if it cannot determine boundaries (to ensure data correctness)

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, error)

func (*Migrator) GetValidBlocksFromRPC

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