bootstrap

Documentation

Index

• func CreateMultiCloudKMSKeysAccount(client *grpc.Client, publicKeys []string, payer flow.Address, ftAddress string, ...) (*flow.Address, error)
• func CreateMultiKeyAccount(client *grpc.Client, keyCount int, payer flow.Address, ftAddress string, ...) (*flow.Address, []crypto.PrivateKey, error)
• func Run(ctx context.Context, cfg *config.Config, ready component.ReadyFunc) error
• func RunCreateMultiKeyAccount()
• func StartEngine(ctx context.Context, engine models.Engine, logger zerolog.Logger)
• type Bootstrap
  • func New(config *config.Config) (*Bootstrap, error)
  • func (b *Bootstrap) StartAPIServer(ctx context.Context) error
  • func (b *Bootstrap) StartEventIngestion(ctx context.Context) error
  • func (b *Bootstrap) StartMetricsServer(ctx context.Context) error
  • func (b *Bootstrap) StartProfilerServer(_ context.Context) error
  • func (b *Bootstrap) StopAPIServer()
  • func (b *Bootstrap) StopClient()
  • func (b *Bootstrap) StopDB()
  • func (b *Bootstrap) StopEventIngestion()
  • func (b *Bootstrap) StopMetricsServer()
  • func (b *Bootstrap) StopProfilerServer()
• type Publishers
• type Storages

Functions

func CreateMultiCloudKMSKeysAccount

func CreateMultiCloudKMSKeysAccount(
	client *grpc.Client,
	publicKeys []string,
	payer flow.Address,
	ftAddress string,
	flowAddress string,
	key crypto.PrivateKey,
) (*flow.Address, error)

func CreateMultiKeyAccount

func CreateMultiKeyAccount(
	client *grpc.Client,
	keyCount int,
	payer flow.Address,
	ftAddress string,
	flowAddress string,
	key crypto.PrivateKey,
) (*flow.Address, []crypto.PrivateKey, error)

CreateMultiKeyAccount is used to setup an account that can be used with key-rotation mechanism // todo parts of this are copied from flowkit and go-sdk/templates and should be refactored out once the package are migrated to Cadence 1.0

func Run

func Run(ctx context.Context, cfg *config.Config, ready component.ReadyFunc) error

Run will run complete bootstrap of the EVM gateway with all the engines. Run is a blocking call, but it does signal readiness of the service through a channel provided as an argument.

func RunCreateMultiKeyAccount

func RunCreateMultiKeyAccount()

RunCreateMultiKeyAccount command creates a new account with multiple keys, which are saved to keys.json for later use with running the gateway in a key-rotation mode (used with --coa-key-file flag).

func StartEngine

func StartEngine(
	ctx context.Context,
	engine models.Engine,
	logger zerolog.Logger,
)

StartEngine starts provided engine and panics if there are startup errors.

Types

type Bootstrap

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

func New

func New(config *config.Config) (*Bootstrap, error)

func (*Bootstrap) StartAPIServer

func (b *Bootstrap) StartAPIServer(ctx context.Context) error

func (*Bootstrap) StartEventIngestion

func (b *Bootstrap) StartEventIngestion(ctx context.Context) error

func (*Bootstrap) StartMetricsServer

func (b *Bootstrap) StartMetricsServer(ctx context.Context) error

func (*Bootstrap) StartProfilerServer

func (b *Bootstrap) StartProfilerServer(_ context.Context) error

func (*Bootstrap) StopAPIServer

func (b *Bootstrap) StopAPIServer()

func (*Bootstrap) StopClient

func (b *Bootstrap) StopClient()

func (*Bootstrap) StopDB

func (b *Bootstrap) StopDB()

func (*Bootstrap) StopEventIngestion

func (b *Bootstrap) StopEventIngestion()

func (*Bootstrap) StopMetricsServer

func (b *Bootstrap) StopMetricsServer()

func (*Bootstrap) StopProfilerServer

func (b *Bootstrap) StopProfilerServer()

type Publishers

type Publishers struct {
	Block       *models.Publisher[*models.Block]
	Transaction *models.Publisher[*gethTypes.Transaction]
	Logs        *models.Publisher[[]*gethTypes.Log]
}

type Storages

type Storages struct {
	Storage      *pebble.Storage
	Registers    *pebble.RegisterStorage
	Blocks       storage.BlockIndexer
	Transactions storage.TransactionIndexer
	Receipts     storage.ReceiptIndexer
	Traces       storage.TraceIndexer
}