Versions in this module Expand all Collapse all v1 v1.7.24 Mar 25, 2020 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) AddRoutes(router *mux.Router) + 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
Go to main page