cluster

Nov 17, 2016

Changes in this version

+ type Datastore struct

+ func NewDataStore(ctx context.Context, kvSource staert.KvSource, object Object, ...) (*Datastore, error)

+ func (d *Datastore) Begin() (Transaction, Object, error)

+ func (d *Datastore) Get() Object

+ func (d *Datastore) Load() (Object, error)

+ type LeaderListener func(elected bool) error

+ type Leadership struct

+ func NewLeadership(ctx context.Context, cluster *types.Cluster) *Leadership

+ func (l *Leadership) AddListener(listener LeaderListener)

+ func (l *Leadership) IsLeader() bool

+ func (l *Leadership) Participate(pool *safe.Pool)

+ func (l *Leadership) Resign()

+ type Listener func(Object) error

+ type Metadata struct

+ Lock string

+ Object []byte

+ func NewMetadata(object Object) *Metadata

+ func (m *Metadata) Marshall() error

+ type Object interface

+ type Store interface

+ Begin func() (Transaction, Object, error)

+ Get func() Object

+ Load func() (Object, error)

+ type Transaction interface

+ Commit func(object Object) error