entry

package
v0.0.0-debug-20260702 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 2, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	VersionOffset     = int(unsafe.Sizeof(uint16(0)))
	PayloadSizeOffset = VersionOffset + int(unsafe.Sizeof(IOET_WALEntry_Invalid))
	InfoSizeOffset    = VersionOffset + int(unsafe.Sizeof(IOET_WALEntry_Invalid)+unsafe.Sizeof(uint32(0)))
	DescriptorSize    = VersionOffset + int(unsafe.Sizeof(IOET_WALEntry_Invalid)+2*unsafe.Sizeof(uint32(0)))
)

type uint16 version uint16 payload size uint32 info size uint32

View Source 
const (
	IOET_WALEntry_V1              uint16 = 1
	IOET_WALEntry_Invalid         uint16 = 2000
	IOET_WALEntry_Checkpoint      uint16 = 2001
	IOET_WALEntry_PostCommit      uint16 = 2002
	IOET_WALEntry_Uncommitted     uint16 = 2003
	IOET_WALEntry_Txn             uint16 = 2004
	IOET_WALEntry_Test            uint16 = 2005
	IOET_WALEntry_CustomizedStart uint16 = 2006

	IOET_WALEntry_CurrVer = IOET_WALEntry_V1
)
View Source 
const (
	GTInvalid uint32 = iota
	GTNoop
	GTCKp
	GTInternal

	// GTFiles is used to store files, and the scenario is master-slave synchronization.
	// The logservice will read the files required for checkpoint and gc in GTFiles,
	// and then transfer them to the follower.
	GTFiles

	GTCustomized uint32 = 11
)

Variables

This section is empty.

Functions

func UnmarshalEntry added in v0.8.0 

func UnmarshalEntry(b []byte) (any, error)

Types

type Base 

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

func GetBase 

func GetBase() *Base

func (*Base) DoneWithErr 

func (b *Base) DoneWithErr(err error)

func (*Base) Duration 

func (b *Base) Duration() time.Duration

func (*Base) ExecuteGroupWalPreCallbacks 

func (b *Base) ExecuteGroupWalPreCallbacks() (err error)

func (*Base) Free 

func (b *Base) Free()

func (*Base) GetApproxPayloadSize 

func (b *Base) GetApproxPayloadSize() int64

func (*Base) GetError 

func (b *Base) GetError() error

func (*Base) GetInfo 

func (b *Base) GetInfo() any

func (*Base) GetInfoBuf 

func (b *Base) GetInfoBuf() []byte

func (Base) GetInfoSize 

func (desc Base) GetInfoSize() int

func (*Base) GetLsn added in v0.6.0 

func (b *Base) GetLsn() (gid uint32, lsn uint64)

func (Base) GetMetaBuf 

func (desc Base) GetMetaBuf() []byte

func (Base) GetMetaSize added in v0.6.0 

func (desc Base) GetMetaSize() int

func (*Base) GetPayload 

func (b *Base) GetPayload() []byte

func (Base) GetPayloadSize 

func (desc Base) GetPayloadSize() int

func (Base) GetType 

func (desc Base) GetType() Type

func (Base) GetVersion added in v0.8.0 

func (desc Base) GetVersion() uint16

func (*Base) IsPrintTime 

func (b *Base) IsPrintTime() bool

func (*Base) Marshal added in v0.6.0 

func (b *Base) Marshal() (buf []byte, err error)

func (*Base) PrepareWrite added in v0.6.0 

func (b *Base) PrepareWrite()

func (*Base) PrintTime 

func (b *Base) PrintTime()

func (*Base) ReadAt 

func (b *Base) ReadAt(r *os.File, offset int) (int, error)

func (*Base) ReadFrom 

func (b *Base) ReadFrom(r io.Reader) (int64, error)

func (Base) ReadMeta 

func (desc Base) ReadMeta(r io.Reader) (int, error)

func (*Base) RegisterGroupWalPreCallbacks 

func (b *Base) RegisterGroupWalPreCallbacks(cb func() error)

func (*Base) SetApproxPayloadSize 

func (b *Base) SetApproxPayloadSize(size int64)

func (*Base) SetInfo 

func (b *Base) SetInfo(info any)

func (*Base) SetInfoBuf 

func (b *Base) SetInfoBuf(buf []byte)

func (Base) SetInfoSize 

func (desc Base) SetInfoSize(size int)

func (*Base) SetPayload added in v0.6.0 

func (b *Base) SetPayload(buf []byte) error

func (Base) SetPayloadSize 

func (desc Base) SetPayloadSize(size int)

func (Base) SetType 

func (desc Base) SetType(t Type)

func (Base) SetVersion added in v0.8.0 

func (desc Base) SetVersion(t uint16)

func (*Base) StartTime 

func (b *Base) StartTime()

func (Base) TotalSize 

func (desc Base) TotalSize() int

func (Base) TotalSizeExpectMeta 

func (desc Base) TotalSizeExpectMeta() int

func (*Base) Unmarshal 

func (b *Base) Unmarshal(buf []byte) error

func (*Base) UnmarshalBinary added in v0.8.0 

func (b *Base) UnmarshalBinary(buf []byte) (n int64, err error)

func (*Base) UnmarshalFromNode 

func (b *Base) UnmarshalFromNode(n []byte, own bool) error

func (*Base) WaitDone 

func (b *Base) WaitDone() error

func (*Base) WriteTo 

func (b *Base) WriteTo(w io.Writer) (int64, error)

type CkpRanges 

type CkpRanges struct {
	Group   uint32
	Ranges  *common.ClosedIntervals
	Command map[uint64]CommandInfo
}

func (*CkpRanges) GetMax 

func (r *CkpRanges) GetMax() uint64

func (CkpRanges) String 

func (r CkpRanges) String() string

type CommandInfo 

type CommandInfo struct {
	CommandIds []uint32
	Size       uint32
}

type Desc 

type Desc interface {
	GetType() Type
	SetType(Type)
	GetPayloadSize() int
	SetPayloadSize(int)
	GetInfoSize() int
	SetInfoSize(int)
	GetMetaSize() int
	TotalSize() int
	GetMetaBuf() []byte
}

type Entry 

type Entry interface {
	Desc
	GetPayload() []byte
	SetInfo(any)
	GetInfo() any
	GetInfoBuf() []byte
	SetInfoBuf(buf []byte)

	SetPayload([]byte) error
	UnmarshalFromNode([]byte, bool) error

	Unmarshal(buf []byte) error
	Marshal() (buf []byte, err error)
	ReadFrom(io.Reader) (int64, error)
	UnmarshalBinary(buf []byte) (n int64, err error)
	ReadAt(r *os.File, offset int) (int, error)
	WriteTo(io.Writer) (int64, error)
	PrepareWrite()

	GetLsn() (gid uint32, lsn uint64)
	WaitDone() error
	DoneWithErr(error)
	GetError() error

	Free()

	Duration() time.Duration
	StartTime()
	PrintTime()
	IsPrintTime() bool

	RegisterGroupWalPreCallbacks(cb func() error)
	ExecuteGroupWalPreCallbacks() error

	SetApproxPayloadSize(size int64)
	GetApproxPayloadSize() int64
}

type Info 

type Info struct {
	Group       uint32
	Checkpoints []*CkpRanges
	GroupLSN    uint64

	TargetLsn uint64
	Info      any
}

func NewEmptyInfo added in v0.6.0 

func NewEmptyInfo() *Info

func (*Info) Marshal 

func (info *Info) Marshal() (buf []byte, err error)

func (*Info) ReadFrom added in v0.6.0 

func (info *Info) ReadFrom(r io.Reader) (n int64, err error)

func (*Info) ToString 

func (info *Info) ToString() string

func (*Info) Unmarshal added in v0.6.0 

func (info *Info) Unmarshal(buf []byte) error

func (*Info) WriteTo added in v0.6.0 

func (info *Info) WriteTo(w io.Writer) (n int64, err error)

type Type 

type Type = uint16

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.