streaming_data

Mar 1, 2024

Changes in this version

type StreamingDataStore

+ func OpenStreamingDataStore[TK btree.Comparable](ctx context.Context, name string, trans in_red_ck.Transaction) (*StreamingDataStore[TK], error)

+ func (s *StreamingDataStore[TK]) FindChunk(ctx context.Context, key TK, chunkIndex int) (bool, error)

Feb 9, 2024

Changes in this version

+ type Encoder struct

+ func (e *Encoder[TK]) Close() error

+ func (e *Encoder[TK]) Encode(v any) error

+ func (e *Encoder[TK]) SetEscapeHTML(on bool)

+ func (e *Encoder[TK]) SetIndent(prefix, indent string)

+ type StreamingDataKey struct

+ ChunkIndex int

+ Key TK

+ func (x StreamingDataKey[TK]) Compare(other interface{}) int

+ type StreamingDataStore struct

+ func NewStreamingDataStore[TK btree.Comparable](ctx context.Context, name string, trans in_red_ck.Transaction) *StreamingDataStore[TK]

+ func (s *StreamingDataStore[TK]) Add(ctx context.Context, key TK) (*Encoder[TK], error)

+ func (s *StreamingDataStore[TK]) Count() int64

+ func (s *StreamingDataStore[TK]) FindOne(ctx context.Context, key TK) (bool, error)

+ func (s *StreamingDataStore[TK]) First(ctx context.Context) (bool, error)

+ func (s *StreamingDataStore[TK]) GetCurrentKey() TK

+ func (s *StreamingDataStore[TK]) GetCurrentValue(ctx context.Context) (*json.Decoder, error)

+ func (s *StreamingDataStore[TK]) IsUnique() bool

+ func (s *StreamingDataStore[TK]) Last(ctx context.Context) (bool, error)

+ func (s *StreamingDataStore[TK]) Next(ctx context.Context) (bool, error)

+ func (s *StreamingDataStore[TK]) Previous(ctx context.Context) (bool, error)

+ func (s *StreamingDataStore[TK]) Remove(ctx context.Context, key TK) (bool, error)

+ func (s *StreamingDataStore[TK]) RemoveCurrentItem(ctx context.Context) (bool, error)

+ func (s *StreamingDataStore[TK]) Update(ctx context.Context, key TK) (*Encoder[TK], error)

+ func (s *StreamingDataStore[TK]) UpdateCurrentItem(ctx context.Context) (*Encoder[TK], error)