pbq

type Manager struct {

	// we need lock to access pbqMap, since deregister will be called inside pbq
	// and each pbq will be inside a go routine, and also entire PBQ could be managed
	// through a go routine (depends on the orchestrator)
	sync.RWMutex
	// contains filtered or unexported fields
}

type PBQ struct {
	PartitionID partition.ID
	// contains filtered or unexported fields
}

type PBQOption func(options *options) error

type ReadWriteCloser interface {
	Reader
	WriteCloser
}

type Reader interface {
	// ReadCh exposes channel to read from PBQ
	ReadCh() <-chan *window.TimedWindowRequest
	// GC does garbage collection, it deletes all the persisted data from the store
	GC() error
}

type WriteCloser interface {
	// Write writes the TimedWindowRequest to PBQ
	// persist to decide if the data should be persisted or not
	// during replay persist will be false
	Write(ctx context.Context, msg *window.TimedWindowRequest, persist bool) error
	// CloseOfBook (cob) closes PBQ, no writes will be accepted after cob
	CloseOfBook()
	// Close to handle context close on writer
	// Any pending data can be flushed to the persistent store at this point.
	Close() error
}