logservicedriver

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
  • func (d *LogServiceDriver) Append(e *entry.Entry) error
  • func (d *LogServiceDriver) Close() error
  • func (d *LogServiceDriver) GetCurrSeqNum() uint64
  • func (d *LogServiceDriver) GetTruncated() (lsn uint64, err error)
  • func (info LogServiceDriver) IsReplaying() bool
  • func (info LogServiceDriver) PostReplay()
  • func (info LogServiceDriver) PreReplay()
  • func (d *LogServiceDriver) Read(drlsn uint64) (*entry.Entry, error)
  • func (d *LogServiceDriver) Replay(h driver.ApplyHandle) error
  • func (d *LogServiceDriver) Truncate(lsn uint64) error
• type MetaType
• type ReplayCmd
  • func NewEmptyReplayCmd() *ReplayCmd
  • func NewReplayCmd(skipLsns map[uint64]uint64) *ReplayCmd
  • func (c *ReplayCmd) Marshal() (buf []byte, err error)
  • func (c *ReplayCmd) ReadFrom(r io.Reader) (n int64, err error)
  • func (c *ReplayCmd) Unmarshal(buf []byte) error
  • func (c *ReplayCmd) WriteTo(w io.Writer) (n int64, err error)

Constants

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

const (
	IOET_WALRecord_V1 uint16 = 1
	IOET_WALRecord    uint16 = 1000

	IOET_WALRecord_CurrVer = IOET_WALRecord_V1
)

Variables

var DefaultReadMaxSize = uint64(10)

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

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

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

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

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

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

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 {
	ClientMaxCount        int
	GetClientRetryTimeOut time.Duration

	RecordSize           int
	ReadCacheSize        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

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)