Versions in this module Expand all Collapse all v1 v1.6.1 May 12, 2023 v1.6.0 May 11, 2023 v1.5.3 Apr 19, 2023 v1.5.2 Apr 18, 2023 v1.5.1 Jul 19, 2022 v1.5.0 Jul 14, 2022 v1.4.1 Jul 13, 2022 v1.4.0 Jul 5, 2022 v1.3.7 Jul 1, 2022 v1.3.6 Jun 30, 2022 v1.3.5 Jun 29, 2022 v1.3.4 Jun 27, 2022 v1.3.3 Jun 27, 2022 v1.3.2 Jun 27, 2022 v1.3.1 Jun 24, 2022 v1.3.0 Jun 24, 2022 v1.2.1 Jun 23, 2022 v1.2.0 Jun 22, 2022 v1.1.0 Jun 20, 2022 Changes in this version + const HeaderSize + func IsCorruptedData(err error) bool + type Decoder struct + func NewDecoder(ctx runtime.Context, r ReaderAtSeeker, valueOnMemory int64) *Decoder + func (d *Decoder) Close() + func (d *Decoder) Decode() (*Payload, error) + func (d *Decoder) DecodeHeader() (*Header, error) + type Encoder struct + func NewEncoder(ctx runtime.Context, w io.Writer, tempDir string, copyTempThreshold int64) *Encoder + func (e *Encoder) Close() + func (e *Encoder) Encode(key []byte, r io.Reader, expiry time.Time) (int64, error) + func (e *Encoder) Flush() error + type Header struct + Checksum uint32 + Expiry time.Time + KeySize int32 + N int64 + ValueSize int64 + type Payload struct + Checksum uint32 + Expiry time.Time + Key []byte + N int64 + Value io.Reader + ValueSize int64 + func (p *Payload) Close() error + func (p *Payload) Read(buf []byte) (int, error) + type ReaderAtSeeker interface
Go to main page