orchestrator

Documentation

Index

• type GravityOrchestrator
  • func NewGravityOrchestrator(logger zerolog.Logger, cosmosQueryClient gravitytypes.QueryClient, ...) GravityOrchestrator

Types

type GravityOrchestrator

type GravityOrchestrator interface {
	Start(ctx context.Context) error
	CheckForEvents(ctx context.Context, startingBlock, ethBlockConfirmationDelay uint64) (currentBlock uint64, err error)
	GetLastCheckedBlock(ctx context.Context, ethBlockConfirmationDelay uint64) (uint64, error)
	EthOracleMainLoop(ctx context.Context) error
	EthSignerMainLoop(ctx context.Context) error
	BatchRequesterLoop(ctx context.Context) error
	RelayerMainLoop(ctx context.Context) error
}

func NewGravityOrchestrator

func NewGravityOrchestrator(
	logger zerolog.Logger,
	cosmosQueryClient gravitytypes.QueryClient,
	gravityBroadcastClient sidechain.GravityBroadcastClient,
	gravityContract gravity.Contract,
	ethFrom ethcmn.Address,
	ethSignerFn keystore.SignerFn,
	ethPersonalSignFn keystore.PersonalSignFn,
	relayer relayer.GravityRelayer,
	cosmosBlockTime time.Duration,
	ethereumBlockTime time.Duration,
	batchRequesterLoopDuration time.Duration,
	ethBlocksPerLoop int64,
	bridgeStartHeight int64,
	symbolRetriever relayer.SymbolRetriever,
	oracle relayer.Oracle,
	ethMergePause bool,
	options ...func(GravityOrchestrator),
) GravityOrchestrator