snapshot

Documentation

Index

• func StrToBytes(s string) []byte
• type Collection
  • func NewCollection() *Collection
  • func (c *Collection) Watch(fn func(string, uint64, *nats.Msg)) error
• type CollectionWatcher
  • func NewCollectionWatcher(client *core.Client, domain string) *CollectionWatcher
  • func (ew *CollectionWatcher) GetCollection(name string) *Collection
  • func (ew *CollectionWatcher) RegisterCollection(name string) *Collection
  • func (ew *CollectionWatcher) UnregisterCollection(name string)
  • func (ew *CollectionWatcher) Watch(fn func(string, uint64, *nats.Msg)) error
• type Snapshot
  • func New(lifecycle fx.Lifecycle, config *configs.Config, l *zap.Logger, ...) *Snapshot
  • func (d *Snapshot) Run() error
• type SnapshotHandler
  • func NewSnapshotHandler() *SnapshotHandler

Functions

func StrToBytes

func StrToBytes(s string) []byte

Types

type Collection

type Collection struct {
	// contains filtered or unexported fields
}

func NewCollection

func NewCollection() *Collection

func (*Collection) Watch

func (c *Collection) Watch(fn func(string, uint64, *nats.Msg)) error

type CollectionWatcher

type CollectionWatcher struct {
	// contains filtered or unexported fields
}

func NewCollectionWatcher

func NewCollectionWatcher(client *core.Client, domain string) *CollectionWatcher

func (*CollectionWatcher) GetCollection

func (ew *CollectionWatcher) GetCollection(name string) *Collection

func (*CollectionWatcher) RegisterCollection

func (ew *CollectionWatcher) RegisterCollection(name string) *Collection

func (*CollectionWatcher) UnregisterCollection

func (ew *CollectionWatcher) UnregisterCollection(name string)

func (*CollectionWatcher) Watch

func (ew *CollectionWatcher) Watch(fn func(string, uint64, *nats.Msg)) error

type Snapshot

type Snapshot struct {
	// contains filtered or unexported fields
}

func New

func New(lifecycle fx.Lifecycle, config *configs.Config, l *zap.Logger, c *connector.Connector) *Snapshot

func (*Snapshot) Run

func (d *Snapshot) Run() error

type SnapshotHandler

type SnapshotHandler struct {
}

func NewSnapshotHandler

func NewSnapshotHandler() *SnapshotHandler