Struct BoltTransport

bolt.go:33–46

BoltTransport implements the TransportInterface using the Bolt database.

// BoltTransport implements the TransportInterface using the Bolt database.
type BoltTransport struct {
	sync.RWMutex

	subscribers      *SubscriberList
	logger           *slog.Logger
	db               *bolt.DB
	bucketName       string
	size             uint64
	cleanupFrequency float64
	closed           chan struct{}
	closedOnce       sync.Once
	lastSeq          uint64
	lastEventID      string
}

// NewBoltTransport creates a new BoltTransport.
func NewBoltTransport(