Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ScannerHelper ¶
type ScannerHelper struct {
// contains filtered or unexported fields
}
ScannerHelper is a helper for scanner implementation.
func NewScannerHelper ¶
func NewScannerHelper(scannerName string) *ScannerHelper
NewScannerHelper creates a new ScannerHelper.
func (*ScannerHelper) Close ¶
func (s *ScannerHelper) Close() error
Close closes the scanner, block until the Finish is called.
func (*ScannerHelper) Context ¶
func (s *ScannerHelper) Context() context.Context
Context returns the context of the scanner, which will cancel when the scanner helper is closed.
func (*ScannerHelper) Done ¶
func (s *ScannerHelper) Done() <-chan struct{}
Done returns a channel that will be closed when the scanner is finished.
func (*ScannerHelper) Error ¶
func (s *ScannerHelper) Error() error
Error returns the error of the scanner.
func (*ScannerHelper) Finish ¶
func (s *ScannerHelper) Finish(err error)
Finish finishes the scanner with an error.
func (*ScannerHelper) Name ¶
func (s *ScannerHelper) Name() string
Name returns the name of the scanner.
type WALHelper ¶
type WALHelper struct {
// contains filtered or unexported fields
}
WALHelper is a helper for WAL implementation.
func NewWALHelper ¶
func NewWALHelper(opt *walimpls.OpenOption) *WALHelper
NewWALHelper creates a new WALHelper.
func (*WALHelper) Channel ¶
func (w *WALHelper) Channel() types.PChannelInfo
Channel returns the channel of the WAL.
Source Files
Click to show internal directories.
Click to hide internal directories.