repository

Documentation

Index

• type WatcherRepository
  • func New(ds *WatcherRepository) *WatcherRepository
  • func (w *WatcherRepository) DeleteByID(dbname, coll string, id string) error
  • func (w *WatcherRepository) DeleteDoc(dbname, coll string, name string) error
  • func (w *WatcherRepository) FetchAll(c context.Context)
  • func (w *WatcherRepository) FindDoc(dbname, coll string, id string) (int64, error)
  • func (w *WatcherRepository) InsertDoc(dbname, coll string, data interface{}) error
  • func (w *WatcherRepository) Migration(c context.Context, key, dbname string)
  • func (w *WatcherRepository) Watch(c context.Context, key, dbname string)

Types

type WatcherRepository

type WatcherRepository struct {
	MongoConnect *mongo.Client
	EtcdConnect  *clientv3.Client
}

func New

func New(ds *WatcherRepository) *WatcherRepository

func (*WatcherRepository) DeleteByID

func (w *WatcherRepository) DeleteByID(dbname, coll string, id string) error

func (*WatcherRepository) DeleteDoc

func (w *WatcherRepository) DeleteDoc(dbname, coll string, name string) error

func (*WatcherRepository) FetchAll

func (w *WatcherRepository) FetchAll(c context.Context)

func (*WatcherRepository) FindDoc

func (w *WatcherRepository) FindDoc(dbname, coll string, id string) (int64, error)

func (*WatcherRepository) InsertDoc

func (w *WatcherRepository) InsertDoc(dbname, coll string, data interface{}) error

func (*WatcherRepository) Migration

func (w *WatcherRepository) Migration(c context.Context, key, dbname string)

func (*WatcherRepository) Watch

func (w *WatcherRepository) Watch(c context.Context, key, dbname string)