lookup

type ChannelListenerManagerConfig struct {
	MaxRetries        int
	RetryWaitDuration time.Duration
}

type DeliveryScanQueryByID struct {
	Delivery *fabric.Delivery
	Channel  *fabric.Channel
}

type EventsListenerManager interface {
	AddPermanentEventListener(key driver2.PKey, e events.ListenerEntry[KeyInfo]) error
	AddEventListener(key driver2.PKey, e events.ListenerEntry[KeyInfo]) error
	RemoveEventListener(key driver2.PKey, e events.ListenerEntry[KeyInfo]) error
}

type KeyInfo struct {
	Namespace driver2.Namespace
	Key       driver2.PKey
	Value     []byte
}

type Listener interface {
	// OnStatus is called when the key has been found
	OnStatus(ctx context.Context, key driver2.PKey, value []byte)
	// OnError is called when an error occurs during the search of the key
	OnError(ctx context.Context, key driver2.PKey, err error)
}

type ListenerManager interface {
	PermanentLookupListenerSupported() bool
	AddPermanentLookupListener(namespace string, key string, listener Listener) error
	AddLookupListener(namespace string, key string, startingTxID string, stopOnLastTx bool, listener Listener) error
	RemoveLookupListener(id string, listener Listener) error
}

type ListenerManagerProvider interface {
	NewManager(network, channel string) (ListenerManager, error)
}

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