dbsync

Documentation

Index

• type Config
  • func (c Config) CreateQuery(t string) string
• type DbSync
  • func NewDbSync(db *sql.DB, table string, options ...Option) *DbSync
  • func (s *DbSync) Start()
  • func (s *DbSync) Stop()
• type Event
  • func (e Event) String() string
• type Option
  • func WithContext(v context.Context) Option
  • func WithDuration(v string) Option
  • func WithNotify(f func(e Event, id, v string)) Option
  • func WithPk(v string) Option
  • func WithV(v string) Option

Types

type Config

type Config struct {
	context.Context
	// contains filtered or unexported fields
}

func (Config) CreateQuery

func (c Config) CreateQuery(t string) string

type DbSync

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

func NewDbSync

func NewDbSync(db *sql.DB, table string, options ...Option) *DbSync

func (*DbSync) Start

func (s *DbSync) Start()

func (*DbSync) Stop

func (s *DbSync) Stop()

type Event

type Event int

const (
	EventCreate Event = iota
	EventDelete
	EventModify
)

func (Event) String

func (e Event) String() string

type Option

type Option func(*Config)

func WithContext

func WithContext(v context.Context) Option

func WithDuration

func WithDuration(v string) Option

func WithNotify

func WithNotify(f func(e Event, id, v string)) Option

func WithPk

func WithPk(v string) Option

func WithV

func WithV(v string) Option