ot

Documentation

Overview

Package ot represents the offset-timeline pair and its corresponding encoder and decoder.

Index

• type Value
  • func DecodeToOTValue(b []byte) (Value, error)
  • func (v Value) EncodeToBytes() ([]byte, error)

Types

type Value

type Value struct {
	Offset    int64
	Watermark int64
}

Value is used in the JetStream offset timeline bucket as the value for the given processor entity key.

func DecodeToOTValue

func DecodeToOTValue(b []byte) (Value, error)

DecodeToOTValue decodes the given byte array into a Value object.

func (Value) EncodeToBytes

func (v Value) EncodeToBytes() ([]byte, error)

EncodeToBytes encodes a Value object into byte array.