logservicedriver

package

v1.0.0-rc1 Latest Latest Go to latest Published: Aug 24, 2023 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/matrixorigin/matrixone

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func RetryWithTimeout(timeoutDuration time.Duration, fn func() (shouldReturn bool)) error
type Config
- func NewDefaultConfig(clientFactory LogServiceClientFactory) *Config
- func NewTestConfig(ccfg *logservice.ClientConfig) *Config
type LogServiceClientFactory
type LogServiceDriver
- func NewLogServiceDriver(cfg *Config) *LogServiceDriver
type MetaType
type ReplayCmd
- func NewEmptyReplayCmd() *ReplayCmd
- func NewReplayCmd(skipLsns map[uint64]uint64) *ReplayCmd

Constants ¶

View Source

const (
	ReplayReadSize = mpool.MB * 64
	MaxReadSize    = mpool.MB * 64
)

View Source

const (
	IOET_WALRecord_V1 uint16 = 1
	IOET_WALRecord    uint16 = 1000

	IOET_WALRecord_CurrVer = IOET_WALRecord_V1
)

Variables ¶

View Source

var DefaultReadMaxSize = uint64(10)

View Source

var ErrAllRecordsRead = moerr.NewInternalErrorNoCtx("driver read cache: all records are read")

View Source

var ErrClientPoolClosed = moerr.NewInternalErrorNoCtx("client pool closed")

View Source

var ErrDriverLsnNotFound = moerr.NewInternalErrorNoCtx("driver info: driver lsn not found")

View Source

var ErrNoClientAvailable = moerr.NewInternalErrorNoCtx("no client available")

View Source

var ErrRecordNotFound = moerr.NewInternalErrorNoCtx("driver read cache: lsn not found")

View Source

var ErrRetryTimeOut = moerr.NewInternalErrorNoCtx("driver info: retry time out")

View Source

var ErrTooMuchPenddings = moerr.NewInternalErrorNoCtx("too much penddings")

Functions ¶

func RetryWithTimeout ¶

func RetryWithTimeout(timeoutDuration time.Duration, fn func() (shouldReturn bool)) error

Types ¶

type Config ¶

type Config struct {
	ClientPoolMaxSize     int
	ClientPoolInitSize    int
	GetClientRetryTimeOut time.Duration

	RecordSize           int
	ReadCacheSize        int
	AppenderMaxCount     int
	ReadMaxSize          uint64
	NewRecordSize        int
	NewClientDuration    time.Duration
	ClientAppendDuration time.Duration
	TruncateDuration     time.Duration
	// AppendFrequency      time.Duration
	RetryTimeout        time.Duration
	GetTruncateDuration time.Duration
	ReadDuration        time.Duration

	ClientFactory LogServiceClientFactory
}

func NewDefaultConfig ¶

func NewDefaultConfig(clientFactory LogServiceClientFactory) *Config

func NewTestConfig ¶

func NewTestConfig(ccfg *logservice.ClientConfig) *Config

type LogServiceClientFactory ¶

type LogServiceClientFactory logservice.ClientFactory

type LogServiceDriver ¶

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

func NewLogServiceDriver ¶

func NewLogServiceDriver(cfg *Config) *LogServiceDriver

func (*LogServiceDriver) Append ¶

func (d *LogServiceDriver) Append(e *entry.Entry) error

func (*LogServiceDriver) Close ¶

func (d *LogServiceDriver) Close() error

func (*LogServiceDriver) GetCurrSeqNum ¶ added in v0.7.0

func (d *LogServiceDriver) GetCurrSeqNum() uint64

func (*LogServiceDriver) GetTruncated ¶

func (d *LogServiceDriver) GetTruncated() (lsn uint64, err error)

func (LogServiceDriver) IsReplaying ¶

func (info LogServiceDriver) IsReplaying() bool

func (LogServiceDriver) PostReplay ¶

func (info LogServiceDriver) PostReplay()

func (LogServiceDriver) PreReplay ¶

func (info LogServiceDriver) PreReplay()

func (*LogServiceDriver) Read ¶

func (d *LogServiceDriver) Read(drlsn uint64) (*entry.Entry, error)

func (*LogServiceDriver) Replay ¶

func (d *LogServiceDriver) Replay(h driver.ApplyHandle) error

func (*LogServiceDriver) Truncate ¶

func (d *LogServiceDriver) Truncate(lsn uint64) error

driver lsn -> entry lsn

type MetaType ¶

type MetaType uint8

const (
	TInvalid MetaType = iota
	TNormal
	TReplay
)

type ReplayCmd ¶

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

func NewEmptyReplayCmd ¶

func NewEmptyReplayCmd() *ReplayCmd

func NewReplayCmd ¶

func NewReplayCmd(skipLsns map[uint64]uint64) *ReplayCmd

func (*ReplayCmd) Marshal ¶

func (c *ReplayCmd) Marshal() (buf []byte, err error)

func (*ReplayCmd) ReadFrom ¶

func (c *ReplayCmd) ReadFrom(r io.Reader) (n int64, err error)

func (*ReplayCmd) Unmarshal ¶

func (c *ReplayCmd) Unmarshal(buf []byte) error

func (*ReplayCmd) WriteTo ¶

func (c *ReplayCmd) WriteTo(w io.Writer) (n int64, err error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL