hookdb

type Config struct {
	// BufferSize for the async event channel (default: 10000)
	BufferSize int
	// Workers is the number of async workers (default: 4)
	Workers int
}

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

type Event struct {
	Type   EventType
	Key    []byte
	Value  []byte
	Prefix []byte // Which prefix triggered this event
}

type EventType int

type Handler func(Event)

type IndexerEvent struct {
	ChainID   string    `json:"chain_id"`
	Type      string    `json:"type"` // "put" or "delete"
	Prefix    string    `json:"prefix"`
	Key       string    `json:"key"`
	Value     []byte    `json:"value,omitempty"`
	Timestamp time.Time `json:"timestamp"`
}

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

type NotifierConfig struct {
	// Endpoint is the indexer service URL (e.g., "http://localhost:8090/api/v2/events")
	Endpoint string
	// ChainID identifies this chain
	ChainID string
	// BatchSize is the max events per batch (default: 100)
	BatchSize int
	// FlushInterval is how often to flush batches (default: 100ms)
	FlushInterval time.Duration
	// Timeout for HTTP requests (default: 5s)
	Timeout time.Duration
}

type PrefixHandler struct {
	Prefix  []byte
	Handler Handler
}