Documentation
¶
Index ¶
- Constants
- Variables
- func NewAdminHandler(adminService application.AdminService, ...) arkv1.AdminServiceServer
- func NewAppServiceHandler(version string, service application.Service, heartbeat int64) service
- func NewHealthHandler() grpchealth.HealthServer
- func NewIndexerService(indexerSvc application.IndexerService, ...) arkv1.IndexerServiceServer
- func NewSignerManagerHandler(walletSvc ports.WalletService, onLoadSigner func(addr string) error) arkv1.SignerManagerServiceServer
- func NewWalletHandler(walletService ports.WalletService) arkv1.WalletServiceServer
- func NewWalletInitializerHandler(walletService ports.WalletService, onInit, onUnlock func(string), ...) arkv1.WalletInitializerServiceServer
Constants ¶
View Source
const MaxTxFiltersPerListener = 64
MaxTxFiltersPerListener bounds the number of compiled CEL programs a single subscription can hold, preventing memory exhaustion via repeated UpdateSubscription calls.
Variables ¶
View Source
var ErrSubscriptionNotFound = errors.New("subscription not found")
ErrSubscriptionNotFound is returned by broker operations targeting a subscription id that has no live listener.
View Source
var ErrTxFiltersLimitExceeded = fmt.Errorf( "tx filters per subscription limit (%d) exceeded", MaxTxFiltersPerListener, )
ErrTxFiltersLimitExceeded is returned when an add or overwrite would push the listener's tx filter count above MaxTxFiltersPerListener.
Functions ¶
func NewAdminHandler ¶
func NewAdminHandler( adminService application.AdminService, indexerService application.IndexerService, macaroonSvc *macaroons.Service, macaroonDatadir, noteUriPrefix string, ) arkv1.AdminServiceServer
func NewAppServiceHandler ¶ added in v0.8.0
func NewAppServiceHandler(version string, service application.Service, heartbeat int64) service
func NewHealthHandler ¶
func NewHealthHandler() grpchealth.HealthServer
func NewIndexerService ¶
func NewIndexerService( indexerSvc application.IndexerService, eventsCh <-chan application.TransactionEvent, subscriptionTimeoutDuration time.Duration, heartbeat int64, ) arkv1.IndexerServiceServer
func NewSignerManagerHandler ¶ added in v0.7.1
func NewSignerManagerHandler( walletSvc ports.WalletService, onLoadSigner func(addr string) error, ) arkv1.SignerManagerServiceServer
func NewWalletHandler ¶
func NewWalletHandler(walletService ports.WalletService) arkv1.WalletServiceServer
func NewWalletInitializerHandler ¶
func NewWalletInitializerHandler( walletService ports.WalletService, onInit, onUnlock func(string), onReady func(), ) arkv1.WalletInitializerServiceServer
Types ¶
This section is empty.
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.