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
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

syncbase

package

Go to main page

Versions in this module

v0

v0.1.2

Feb 6, 2025

v0.1.1

Sep 10, 2024

v0.1.0

Mar 10, 2024

Changes in this version

+ var PropagateChangesTimeout = time.Second * 20

+ func AggregateDone(events []func(chan error), done chan error)

+ type Adapter struct

+ Publisher datasync.KeyProtoValWriter

+ Watcher datasync.KeyValProtoWatcher

+ func (adapter *Adapter) Put(key string, data proto.Message) error

+ func (adapter *Adapter) Watch(resyncName string, changeChan chan datasync.ChangeEvent, ...) (datasync.WatchRegistration, error)

+ type Change struct

+ func NewChange(key string, value proto.Message, rev int64, changeType datasync.Op) *Change

+ func NewChangeBytes(key string, value []byte, rev int64, changeType datasync.Op) *Change

+ func (kv *Change) GetChangeType() datasync.Op

+ type ChangeEvent struct

+ Changes []datasync.ProtoWatchResp

+ func (ev *ChangeEvent) Done(err error)

+ func (ev *ChangeEvent) GetChanges() []datasync.ProtoWatchResp

+ func (ev *ChangeEvent) GetContext() context.Context

+ type ChangeResp struct

+ ChangeType datasync.Op

+ CurrRev int64

+ CurrVal datasync.LazyValue

+ Key string

+ PrevVal datasync.LazyValue

+ func (ev *ChangeResp) GetChangeType() datasync.Op

+ func (ev *ChangeResp) GetKey() string

+ func (ev *ChangeResp) GetPrevValue(prevVal proto.Message) (prevExists bool, err error)

+ func (ev *ChangeResp) GetRevision() int64

+ func (ev *ChangeResp) GetValue(val proto.Message) (err error)

+ type DoneCallback struct

+ Callback func(error)

+ func (ev *DoneCallback) Done(err error)

+ type DoneChannel struct

+ DoneChan chan error

+ func NewDoneChannel(doneChan chan error) *DoneChannel

+ func (ev *DoneChannel) Done(err error)

+ type KVIterator struct

+ func NewKVIterator(data []datasync.KeyVal) *KVIterator

+ func (it *KVIterator) GetNext() (kv datasync.KeyVal, allReceived bool)

+ type KeyVal struct

+ func NewKeyVal(key string, value datasync.LazyValue, rev int64) *KeyVal

+ func (kv *KeyVal) GetKey() string

+ func (kv *KeyVal) GetRevision() int64

+ type KeyValBytes struct

+ func NewKeyValBytes(key string, value []byte, rev int64) *KeyValBytes

+ func (kv *KeyValBytes) GetKey() string

+ func (kv *KeyValBytes) GetRevision() int64

+ func (kv *KeyValBytes) GetValue(message proto.Message) error

+ type PrevRevisions struct

+ func NewLatestRev() *PrevRevisions

+ func (r *PrevRevisions) Cleanup()

+ func (r *PrevRevisions) Del(key string) (found bool, prev datasync.KeyVal)

+ func (r *PrevRevisions) Get(key string) (found bool, value datasync.KeyVal)

+ func (r *PrevRevisions) ListKeys() (ret []string)

+ func (r *PrevRevisions) Put(key string, val datasync.LazyValue) (found bool, prev datasync.KeyVal, currRev int64)

+ func (r *PrevRevisions) PutWithRevision(key string, inCurrent datasync.KeyVal) (found bool, prev datasync.KeyVal)

+ type Registry struct

+ func NewRegistry() *Registry

+ func (adapter *Registry) LastRev() *PrevRevisions

+ func (adapter *Registry) PropagateChanges(ctx context.Context, txData map[string]datasync.ChangeValue) error

+ func (adapter *Registry) PropagateResync(ctx context.Context, txData map[string]datasync.ChangeValue) error

+ func (adapter *Registry) Subscriptions() map[string]*Subscription

+ func (adapter *Registry) Watch(resyncName string, changeChan chan datasync.ChangeEvent, ...) (datasync.WatchRegistration, error)

+ type ResyncEventDB struct

+ func NewResyncEventDB(ctx context.Context, its map[string]datasync.KeyValIterator) *ResyncEventDB

+ func (ev *ResyncEventDB) GetContext() context.Context

+ func (ev *ResyncEventDB) GetValues() map[string]datasync.KeyValIterator

+ type Subscription struct

+ ChangeChan chan datasync.ChangeEvent

+ CloseChan chan string

+ KeyPrefixes []string

+ ResyncChan chan datasync.ResyncEvent

+ ResyncName string

+ type WatchDataReg struct

+ ResyncName string

+ func (reg *WatchDataReg) Close() error

+ func (reg *WatchDataReg) Register(resyncName, keyPrefix string) error

+ func (reg *WatchDataReg) Unregister(keyPrefix string) error