solana

Documentation

Index

• func New(sc solana.Client, scResolve solana.Client, scSubmit solana.Client, ...) (accountpb.AccountServer, error)
• type AccountNotifier
  • func NewAccountNotifier() *AccountNotifier
  • func (a *AccountNotifier) AddStream(accountID string, stream *eventStream)
  • func (a *AccountNotifier) OnTransaction(txn solana.BlockTransaction)
  • func (a *AccountNotifier) RemoveStream(accountID string, stream *eventStream)

Functions

func New

func New(
	sc solana.Client,
	scResolve solana.Client,
	scSubmit solana.Client,
	hc horizon.ClientInterface,
	limiter *account.Limiter,
	accountNotifier *AccountNotifier,
	tokenAccountCache tokenaccount.Cache,
	infoCache accountinfo.Cache,
	migrator migration.Migrator,
	migrationStore migration.Store,
	mapper account.Mapper,
	mint ed25519.PublicKey,
	subsidizer ed25519.PrivateKey,
	cacheCheckFreq float32,
	createWhitelistSecret string,
) (accountpb.AccountServer, error)

Types

type AccountNotifier

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

func NewAccountNotifier

func NewAccountNotifier() *AccountNotifier

func (*AccountNotifier) AddStream

func (a *AccountNotifier) AddStream(accountID string, stream *eventStream)

AddStream adds a stream to the notifier.

func (*AccountNotifier) OnTransaction

func (a *AccountNotifier) OnTransaction(txn solana.BlockTransaction)

OnTransaction implements transaction.Notifier.OnTransaction

func (*AccountNotifier) RemoveStream

func (a *AccountNotifier) RemoveStream(accountID string, stream *eventStream)

RemoveStream removes a stream from the notifier.