repository

Documentation

Index

• type IRepository
  • func New(dao *dao.Dao) IRepository

Types

type IRepository

type IRepository interface {
	GetLastRevision(context.Context) int64
	PutEntity(context.Context, *dao.Entity) error
	GetEntity(context.Context, *dao.Entity) (*dao.Entity, error)
	DelEntity(context.Context, *dao.Entity) error
	HasEntity(context.Context, *dao.Entity) (bool, error)
	PutMapper(context.Context, *dao.Mapper) error
	GetMapper(context.Context, *dao.Mapper) (*dao.Mapper, error)
	DelMapper(context.Context, *dao.Mapper) error
	HasMapper(context.Context, *dao.Mapper) (bool, error)
	ListMapper(context.Context, int64, *dao.ListMapperReq) ([]dao.Mapper, error)
	RangeMapper(ctx context.Context, rev int64, handler dao.MapperHandler)
	WatchMapper(ctx context.Context, rev int64, handler dao.WatchMapperHandler)
	PutQueue(context.Context, *dao.Queue) error
	GetQueue(context.Context, *dao.Queue) (*dao.Queue, error)
	DelQueue(context.Context, *dao.Queue) error
	HasQueue(context.Context, *dao.Queue) (bool, error)
	RangeQueue(ctx context.Context, rev int64, handler dao.QueueHandler)
	WatchQueue(ctx context.Context, rev int64, handler dao.WatchQueueHandler)
}

func New

func New(dao *dao.Dao) IRepository