syncer

Documentation

Index

• type KVRow
• type Syncer
  • func New(o SyncerOpts) *Syncer
  • func (s *Syncer) Process(ctx context.Context) error
  • func (s *Syncer) Run()
  • func (s *Syncer) Stop()
• type SyncerOpts

Types

type KVRow

type KVRow struct {
	Key     []byte    `db:"key"`
	Value   []byte    `db:"value"`
	Updated time.Time `db:"updated"`
}

type Syncer

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

func New

func New(o SyncerOpts) *Syncer

func (*Syncer) Process

func (s *Syncer) Process(ctx context.Context) error

func (*Syncer) Run

func (s *Syncer) Run()

func (*Syncer) Stop

func (s *Syncer) Stop()

type SyncerOpts

type SyncerOpts struct {
	Logg  *slog.Logger
	Store *store.Store
}