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

crdt

package

Go to main page

Versions in this module

v0

v0.3.0

Jan 13, 2021

Changes in this version

type CommandContext

+ func (c *CommandContext) WriteConsistency(wc entity.CrdtWriteConsistency)

type Entity

+ PassivationStrategy protocol.EntityPassivationStrategy

+ func (e *Entity) Options(options ...Option)

type ORMap

+ func (m *ORMap) Entries() []*ORMapEntry

+ type ORMapEntry struct

+ Key *any.Any

+ Value CRDT

+ type Option func(s *Entity)

+ func WithPassivationStrategyTimeout(duration time.Duration) Option

v0.2.2

Jan 12, 2021

v0.2.1

Nov 15, 2020

v0.2.0

Nov 10, 2020

Changes in this version

+ var ErrCtxFailCalled = errors.New("context failed")

+ var ErrStateChanged = errors.New("CRDT change not allowed")

+ type CRDT interface

+ Delta func() *entity.CrdtDelta

+ HasDelta func() bool

+ State func() *entity.CrdtState

+ type CancelFunc func(c *CommandContext) error

+ type ChangeFunc func(c *CommandContext) (*any.Any, error)

+ type Clock uint64

+ const Custom

+ const CustomAutoIncrement

+ const Default

+ const Reverse

+ type CommandContext struct

+ CommandID CommandID

+ func (c *CommandContext) CancelFunc(f CancelFunc)

+ func (c *CommandContext) ChangeFunc(f ChangeFunc)

+ func (c *CommandContext) Command() *protocol.Command

+ func (c *CommandContext) EndStream()

+ func (c *CommandContext) Forward(forward *protocol.Forward)

+ func (c *CommandContext) SideEffect(effect *protocol.SideEffect)

+ func (c *CommandContext) Streamed() bool

+ type CommandID int64

+ func (id CommandID) Value() int64

+ type Context struct

+ Entity *Entity

+ EntityID EntityID

+ Instance EntityHandler

+ func (c *Context) CRDT() CRDT

+ func (c *Context) Delete()

+ func (c *Context) StreamCtx() context.Context

+ type Entity struct

+ EntityFunc func(id EntityID) EntityHandler

+ ServiceName ServiceName

+ type EntityHandler interface

+ Default func(ctx *Context) (CRDT, error)

+ HandleCommand func(ctx *CommandContext, name string, msg proto.Message) (*any.Any, error)

+ Set func(ctx *Context, state CRDT) error

+ type EntityID string

+ func (i EntityID) String() string

+ type Flag struct

+ func NewFlag() *Flag

+ func (f *Flag) Enable()

+ func (f *Flag) HasDelta() bool

+ func (f Flag) Delta() *entity.CrdtDelta

+ func (f Flag) State() *entity.CrdtState

+ func (f Flag) Value() bool

+ type GCounter struct

+ func NewGCounter() *GCounter

+ func (c *GCounter) Delta() *entity.CrdtDelta

+ func (c *GCounter) Increment(i uint64)

+ func (c *GCounter) State() *entity.CrdtState

+ func (c *GCounter) Value() uint64

+ func (c GCounter) HasDelta() bool

+ type GSet struct

+ func NewGSet() *GSet

+ func (s *GSet) Add(a *any.Any)

+ func (s GSet) Added() []*any.Any

+ func (s GSet) Delta() *entity.CrdtDelta

+ func (s GSet) HasDelta() bool

+ func (s GSet) Size() int

+ func (s GSet) State() *entity.CrdtState

+ func (s GSet) Value() []*any.Any

+ type LWWRegister struct

+ func NewLWWRegister(x *any.Any) *LWWRegister

+ func NewLWWRegisterWithClock(x *any.Any, c Clock, customClockValue int64) *LWWRegister

+ func (r *LWWRegister) Delta() *entity.CrdtDelta

+ func (r *LWWRegister) HasDelta() bool

+ func (r *LWWRegister) Set(x *any.Any)

+ func (r *LWWRegister) SetWithClock(x *any.Any, c Clock, customClockValue int64)

+ func (r *LWWRegister) State() *entity.CrdtState

+ func (r *LWWRegister) Value() *any.Any

+ type ORMap struct

+ func NewORMap() *ORMap

+ func (m *ORMap) Clear()

+ func (m *ORMap) Delete(key *any.Any)

+ func (m *ORMap) Delta() *entity.CrdtDelta

+ func (m *ORMap) Flag(key *any.Any) (*Flag, error)

+ func (m *ORMap) GCounter(key *any.Any) (*GCounter, error)

+ func (m *ORMap) GSet(key *any.Any) (*GSet, error)

+ func (m *ORMap) Get(key *any.Any) CRDT

+ func (m *ORMap) HasDelta() bool

+ func (m *ORMap) HasKey(x *any.Any) (hasKey bool)

+ func (m *ORMap) Keys() []*any.Any

+ func (m *ORMap) LWWRegister(key *any.Any) (*LWWRegister, error)

+ func (m *ORMap) ORMap(key *any.Any) (*ORMap, error)

+ func (m *ORMap) ORSet(key *any.Any) (*ORSet, error)

+ func (m *ORMap) PNCounter(key *any.Any) (*PNCounter, error)

+ func (m *ORMap) Set(key *any.Any, value CRDT)

+ func (m *ORMap) Size() int

+ func (m *ORMap) State() *entity.CrdtState

+ func (m *ORMap) Values() []*entity.CrdtState

+ func (m *ORMap) Vote(key *any.Any) (*Vote, error)

+ type ORSet struct

+ func NewORSet() *ORSet

+ func (s *ORSet) Add(a *any.Any)

+ func (s *ORSet) Clear()

+ func (s *ORSet) Delta() *entity.CrdtDelta

+ func (s *ORSet) HasDelta() bool

+ func (s *ORSet) Remove(a *any.Any)

+ func (s *ORSet) Size() int

+ func (s *ORSet) State() *entity.CrdtState

+ func (s ORSet) Added() []*any.Any

+ func (s ORSet) Removed() []*any.Any

+ func (s ORSet) Value() []*any.Any

+ type PNCounter struct

+ func NewPNCounter() *PNCounter

+ func (c *PNCounter) Decrement(d int64)

+ func (c *PNCounter) Delta() *entity.CrdtDelta

+ func (c *PNCounter) HasDelta() bool

+ func (c *PNCounter) Increment(i int64)

+ func (c *PNCounter) State() *entity.CrdtState

+ func (c *PNCounter) Value() int64

+ type Server struct

+ func NewServer() *Server

+ func (s *Server) Handle(stream entity.Crdt_HandleServer) error

+ func (s *Server) Register(e *Entity) error

+ type ServiceName string

+ func (sn ServiceName) String() string

+ type Vote struct

+ func NewVote() *Vote

+ func (v *Vote) All() bool

+ func (v *Vote) AtLeastOne() bool

+ func (v *Vote) Delta() *entity.CrdtDelta

+ func (v *Vote) HasDelta() bool

+ func (v *Vote) Majority() bool

+ func (v *Vote) SelfVote() bool

+ func (v *Vote) State() *entity.CrdtState

+ func (v *Vote) Vote(vote bool)

+ func (v *Vote) Voters() uint32

+ func (v *Vote) VotesFor() uint32