application

Documentation

Index

• type NotificationService
  • func NewNotificationService(scannerSvc scanner.Service) NotificationService
• type Subscriber
• type SubscriberErrorReport
• type SubscriberEventReport
• type SubscriberID

Types

type NotificationService

type NotificationService interface {
	Start() error
	Stop()
	Subscribe(subscriber Subscriber) error
	UnSubscribe(subscriber Subscriber) error
	EventReport() chan SubscriberEventReport
	ErrorReport() chan SubscriberErrorReport
}

func NewNotificationService

func NewNotificationService(
	scannerSvc scanner.Service,
) NotificationService

type Subscriber

type Subscriber struct {
	ID               SubscriberID
	BlockHeight      int
	Events           []scanner.EventType
	WalletDescriptor string
}

type SubscriberErrorReport

type SubscriberErrorReport struct {
	SubscriberID SubscriberID
	ErrorMsg     error
}

type SubscriberEventReport

type SubscriberEventReport struct {
	SubscriberID SubscriberID
	EventType    scanner.EventType
	BlockHeight  int
	Transaction  *transaction.Transaction
	BlockHash    *chainhash.Hash
}

type SubscriberID

type SubscriberID uuid.UUID