watcher

Documentation

Index

• func BroadcastBulkChange(ctx context.Context, dbKey string, table string)
• func BroadcastDelete(ctx context.Context, dbKey string, table string, pk interface{})
• func BroadcastInsert(ctx context.Context, dbKey string, table string, pk interface{})
• func BroadcastUpdate(ctx context.Context, dbKey string, table string, pk interface{}, ...)
• func MakeKey(ctx context.Context, dbKey string, table string, pk interface{}) string
• type DefaultWatcher
  • func (w *DefaultWatcher) BroadcastBulkChange(ctx context.Context, dbKey string, table string)
  • func (w *DefaultWatcher) BroadcastDelete(ctx context.Context, dbKey string, table string, pk interface{})
  • func (w *DefaultWatcher) BroadcastInsert(ctx context.Context, dbKey string, table string, pk interface{})
  • func (w *DefaultWatcher) BroadcastUpdate(ctx context.Context, dbKey string, table string, pk interface{}, ...)
  • func (*DefaultWatcher) MakeKey(ctx context.Context, dbKey string, table string, pk interface{}) string
• type WatcherI

Functions

func BroadcastBulkChange

func BroadcastBulkChange(ctx context.Context, dbKey string, table string)

func BroadcastDelete

func BroadcastDelete(ctx context.Context, dbKey string, table string, pk interface{})

func BroadcastInsert

func BroadcastInsert(ctx context.Context, dbKey string, table string, pk interface{})

func BroadcastUpdate

func BroadcastUpdate(ctx context.Context, dbKey string, table string, pk interface{}, fieldKeys []string)

func MakeKey

func MakeKey(ctx context.Context, dbKey string, table string, pk interface{}) string

Types

type DefaultWatcher

type DefaultWatcher struct {
}

func (*DefaultWatcher) BroadcastBulkChange

func (w *DefaultWatcher) BroadcastBulkChange(ctx context.Context, dbKey string, table string)

func (*DefaultWatcher) BroadcastDelete

func (w *DefaultWatcher) BroadcastDelete(ctx context.Context, dbKey string, table string, pk interface{})

func (*DefaultWatcher) BroadcastInsert

func (w *DefaultWatcher) BroadcastInsert(ctx context.Context, dbKey string, table string, pk interface{})

func (*DefaultWatcher) BroadcastUpdate

func (w *DefaultWatcher) BroadcastUpdate(ctx context.Context, dbKey string, table string, pk interface{}, fieldKeys []string)

func (*DefaultWatcher) MakeKey

func (*DefaultWatcher) MakeKey(ctx context.Context, dbKey string, table string, pk interface{}) string

type WatcherI

type WatcherI interface {
	MakeKey(ctx context.Context, dbKey string, table string, pk interface{}) string
	BroadcastUpdate(ctx context.Context, dbKey string, table string, pk interface{}, fieldKeys []string)
	BroadcastInsert(ctx context.Context, dbKey string, table string, pk interface{})
	BroadcastDelete(ctx context.Context, dbKey string, table string, pk interface{})
	BroadcastBulkChange(ctx context.Context, dbKey string, table string)
}

var Watcher WatcherI

The injected watcher. See the application initialization process for Watcher creation.