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
}