Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

walparser

package

Go to main page

Versions in this module

v0

v0.2.13

Oct 8, 2019

v0.2.12

Sep 4, 2019

v0.2.11

Aug 12, 2019

v0.2.10

Jul 31, 2019

v0.2.9

Apr 22, 2019

v0.2.8

Apr 5, 2019

v0.2.7

Mar 5, 2019

v0.2.6

Feb 21, 2019

v0.2.5

Feb 20, 2019

v0.2.4

Jan 22, 2019

v0.2.3

Jan 9, 2019

v0.2.2

Dec 26, 2018

v0.2.1

Dec 18, 2018

Changes in this version

+ const BkpBlockFlagMask

+ const BkpBlockForkMask

+ const BkpBlockHasData

+ const BkpBlockHasImage

+ const BkpBlockSameRel

+ const BkpBlockWillInit

+ const BkpImageApply

+ const BkpImageHasHole

+ const BkpImageIsCompressed

+ const BlockSize

+ const RmBTreeID

+ const RmBrinID

+ const RmClogID

+ const RmCommitTsID

+ const RmDBaseID

+ const RmGenericID

+ const RmGinID

+ const RmGistID

+ const RmHashID

+ const RmHeap2ID

+ const RmHeapID

+ const RmLogicalMsgID

+ const RmMultiXactID

+ const RmNextFreeID

+ const RmRelMapID

+ const RmReplOriginID

+ const RmSPGistID

+ const RmSeqID

+ const RmSmgrID

+ const RmStandbyID

+ const RmTblSpcID

+ const RmXactID

+ const RmXlogID

+ const WalPageSize

+ const WalSwitchRecordSize

+ const XLogRecordAlignment

+ const XLogRecordHeaderSize

+ const XLogSwitch

+ const XlpAllFlags

+ const XlpBkpRemovable

+ const XlpFirstIsContRecord

+ const XlpLongHeader

+ const XlrBlockIdDataLong

+ const XlrBlockIdDataShort

+ const XlrBlockIdOrigin

+ const XlrCheckConsistency

+ const XlrInfoMask

+ const XlrMaxBlockId

+ const XlrRmgrInfoMask

+ const XlrSpecialRelUpdate

+ func NewInvalidPageHeaderError() error

+ func NewNotEnoughDataToShrinkError(dataRemained int, toShrink int) error

+ func NewZeroPageHeaderError() error

+ type AlignedReader struct

+ func NewAlignedReader(source io.Reader, alignment int) *AlignedReader

+ func (reader *AlignedReader) Read(p []byte) (n int, err error)

+ func (reader *AlignedReader) ReadToAlignment() error

+ type BlockLocation struct

+ BlockNo uint32

+ RelationFileNode RelFileNode

+ func NewBlockLocation(spcNode, dbNode, relNode Oid, blockNo uint32) *BlockLocation

+ type CantSavePartialParserError struct

+ func NewCantSavePartialParserError() CantSavePartialParserError

+ func (err CantSavePartialParserError) Error() string

+ type ContinuationNotFoundError struct

+ func NewContinuationNotFoundError() ContinuationNotFoundError

+ type InconsistentBlockDataStateError struct

+ func NewInconsistentBlockDataStateError(hasData bool, dataLength uint16) InconsistentBlockDataStateError

+ func (err InconsistentBlockDataStateError) Error() string

+ type InconsistentBlockImageHoleStateError struct

+ func NewInconsistentBlockImageHoleStateError(holeOffset uint16, holeLength uint16, imageLength uint16, hasHole bool) InconsistentBlockImageHoleStateError

+ func (err InconsistentBlockImageHoleStateError) Error() string

+ type InconsistentBlockImageLengthError struct

+ func NewInconsistentBlockImageLengthError(hasHole bool, isCompressed bool, length uint16) InconsistentBlockImageLengthError

+ func (err InconsistentBlockImageLengthError) Error() string

+ type InconsistentXLogRecordTotalLengthError struct

+ func NewInconsistentXLogRecordTotalLengthError(totalRecordLength uint32) InconsistentXLogRecordTotalLengthError

+ func (err InconsistentXLogRecordTotalLengthError) Error() string

+ type InvalidPageHeaderError struct

+ func (err InvalidPageHeaderError) Error() string

+ type InvalidRecordBlockIdError struct

+ func NewInvalidRecordBlockIdError(blockId uint8) InvalidRecordBlockIdError

+ func (err InvalidRecordBlockIdError) Error() string

+ type InvalidXLogRecordResourceManagerIDError struct

+ func NewInvalidXLogRecordResourceManagerIDError(resourceManagerID uint8) InvalidXLogRecordResourceManagerIDError

+ func (err InvalidXLogRecordResourceManagerIDError) Error() string

+ type NoPrevRelFileNodeError struct

+ func NewNoPrevRelFileNodeError() NoPrevRelFileNodeError

+ func (err NoPrevRelFileNodeError) Error() string

+ type NotEnoughDataToShrinkError struct

+ func (err NotEnoughDataToShrinkError) Error() string

+ type Oid uint32

+ type OutOfOrderBlockIdError struct

+ func NewOutOfOrderBlockIdError(actualBlockId int, expectedBlockId int) OutOfOrderBlockIdError

+ func (err OutOfOrderBlockIdError) Error() string

+ type PartialPageError struct

+ func NewPartialPageError() PartialPageError

+ func (err PartialPageError) Error() string

+ type RelFileNode struct

+ DBNode Oid

+ RelNode Oid

+ SpcNode Oid

+ type ShrinkableReader struct

+ func (reader *ShrinkableReader) Read(p []byte) (n int, err error)

+ func (reader *ShrinkableReader) Shrink(length int) error

+ type TimeLineID uint32

+ type WalPageReader struct

+ func NewWalPageReader(walFileReader io.Reader) *WalPageReader

+ func (reader *WalPageReader) ReadPageData() ([]byte, error)

+ type WalParser struct

+ func LoadWalParser(reader io.Reader) (*WalParser, error)

+ func LoadWalParserFromCurrentRecordHead(currentRecordHead []byte) *WalParser

+ func NewWalParser() *WalParser

+ func (parser *WalParser) GetCurrentRecordData() []byte

+ func (parser *WalParser) Invalidate()

+ func (parser *WalParser) ParseRecordsFromPage(reader io.Reader) (prevRecordTail []byte, pageRecords []XLogRecord, err error)

+ func (parser *WalParser) Save(writer io.Writer) error

+ type XLogPage struct

+ Header XLogPageHeader

+ NextRecordHeadingData []byte

+ PrevRecordTrailingData []byte

+ Records []XLogRecord

+ type XLogPageHeader struct

+ Info uint16

+ Magic uint16

+ PageAddress XLogRecordPtr

+ RemainingDataLen uint32

+ TimeLineID TimeLineID

+ func (pageHeader *XLogPageHeader) HasContinuationRecord() bool

+ func (pageHeader *XLogPageHeader) IsLong() bool

+ func (pageHeader *XLogPageHeader) IsValid() bool

+ type XLogRecord struct

+ Blocks []XLogRecordBlock

+ Header XLogRecordHeader

+ MainData []byte

+ MainDataLen uint32

+ Origin uint16

+ func NewXLogRecord(header XLogRecordHeader) *XLogRecord

+ func ParseXLogRecordFromBytes(data []byte) (*XLogRecord, error)

+ func (record *XLogRecord) IsZero() bool

+ type XLogRecordBlock struct

+ Data []byte

+ Header XLogRecordBlockHeader

+ Image []byte

+ type XLogRecordBlockHeader struct

+ BlockId uint8

+ BlockLocation BlockLocation

+ DataLength uint16

+ ForkFlags uint8

+ ImageHeader XLogRecordBlockImageHeader

+ func NewXLogRecordBlockHeader(blockId uint8) *XLogRecordBlockHeader

+ func (blockHeader *XLogRecordBlockHeader) ForkNum() uint8

+ func (blockHeader *XLogRecordBlockHeader) HasData() bool

+ func (blockHeader *XLogRecordBlockHeader) HasImage() bool

+ func (blockHeader *XLogRecordBlockHeader) HasSameRel() bool

+ func (blockHeader *XLogRecordBlockHeader) WillInit() bool

+ type XLogRecordBlockImageHeader struct

+ HoleLength uint16

+ HoleOffset uint16

+ ImageLength uint16

+ Info uint8

+ func (imageHeader *XLogRecordBlockImageHeader) ApplyImage() bool

+ func (imageHeader *XLogRecordBlockImageHeader) HasHole() bool

+ func (imageHeader *XLogRecordBlockImageHeader) IsCompressed() bool

+ type XLogRecordHeader struct

+ Crc32Hash uint32

+ Info uint8

+ PrevRecordPtr XLogRecordPtr

+ ResourceManagerID uint8

+ TotalRecordLength uint32

+ XactID uint32

+ type XLogRecordPtr uint64

+ type ZeroPageError struct

+ func NewZeroPageError() ZeroPageError

+ func (err ZeroPageError) Error() string

+ type ZeroPageHeaderError struct

+ func (err ZeroPageHeaderError) Error() string

+ type ZeroRecordHeaderError struct

+ func NewZeroRecordHeaderError() ZeroRecordHeaderError

+ func (err ZeroRecordHeaderError) Error() string