Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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
- API
  
  Reference documentation for the pkg.go.dev API
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

pstate

package module

Go to main page

Versions in this module

v0

v0.2.0

Aug 7, 2026

Changes in this version

+ const Wire

+ var ErrGap = errors.New("pstate: change stream gap")

+ var ErrJournal = errors.New("pstate: change not journalled")

+ var ErrWire = errors.New("pstate: unsupported wire version")

+ type Change struct

+ Epoch string

+ From uint64

+ Patch Patch

+ To uint64

+ Wire int

+ type Follower struct

+ func (f *Follower) Close() error

+ func (f *Follower) Next() (Change, bool, error)

+ func (f *Follower) Position() Position

type Patch

+ func (p *Patch) UnmarshalJSON(data []byte) error

+ func (p Patch) MarshalJSON() ([]byte, error)

+ type Position struct

+ Epoch string

+ Revision uint64

+ Wire int

type Store

+ func (s *Store) Follow(from Position) (*Follower, error)

+ func (s *Store) ReadAt() (Snapshot, Position, error)

v0.1.1

Jul 25, 2026

v0.1.0

Jul 25, 2026

Changes in this version

+ var ErrClosed = errors.New("pstate: model closed")

+ type Entry struct

+ Key string

+ Value Value

+ type Model struct

+ func NewModel(initial Tree, writer Writer) *Model

+ func (m *Model) Apply(patch Patch) (Snapshot, error)

+ func (m *Model) Close() error

+ func (m *Model) Delete(key string) (Snapshot, error)

+ func (m *Model) Flush() error

+ func (m *Model) Get(key string) (Value, bool)

+ func (m *Model) LastError() error

+ func (m *Model) Len() int

+ func (m *Model) Set(key string, value Value) (Snapshot, error)

+ func (m *Model) Snapshot() Snapshot

+ type Patch struct

+ func (p Patch) Delete(key string) Patch

+ func (p Patch) Len() int

+ func (p Patch) Set(key string, value Value) Patch

+ type Query struct

+ func ParseQuery(source string) (Query, error)

+ func (q Query) Match(key string, value Value) (bool, error)

+ func (q Query) String() string

+ type Snapshot struct

+ func (s Snapshot) Get(key string) (Value, bool)

+ func (s Snapshot) Len() int

+ func (s Snapshot) Range(yield func(string, Value) bool)

+ func (s Snapshot) Tree() Tree

+ func (s Snapshot) Version() uint64

+ type Store struct

+ func Open(path string) (*Store, error)

+ func (s *Store) Apply(patch Patch) (Snapshot, error)

+ func (s *Store) Delete(key string) (Snapshot, error)

+ func (s *Store) Get(key string) (Value, bool, error)

+ func (s *Store) Path() string

+ func (s *Store) Read() (Snapshot, error)

+ func (s *Store) Set(key string, value Value) (Snapshot, error)

+ type Tree struct

+ func (t Tree) Apply(p Patch) Tree

+ func (t Tree) Delete(key string) Tree

+ func (t Tree) Get(key string) (Value, bool)

+ func (t Tree) Len() int

+ func (t Tree) Range(yield func(key string, value Value) bool)

+ func (t Tree) Set(key string, value Value) Tree

+ type Value struct

+ func EncodeValue(v any) (Value, error)

+ func MustValue(text string) Value

+ func ParseValue(data []byte) (Value, error)

+ func (v *Value) UnmarshalJSON(data []byte) error

+ func (v Value) Decode(dst any) error

+ func (v Value) Equal(other Value) bool

+ func (v Value) MarshalJSON() ([]byte, error)

+ func (v Value) Raw() []byte

+ func (v Value) String() string

+ type Writer interface

+ WriteSnapshot func(Snapshot) error

+ type WriterFunc func(Snapshot) error

+ func (f WriterFunc) WriteSnapshot(snapshot Snapshot) error