sql

type BatchReceiver interface {
	Recv(interface{})
}

type BatchSender interface {
	Send(interface{})
	Close() error
}

type DAO interface {
	dao.DAO

	DB() *sql.DB
	Prepare(string, interface{}) error
	GetStmt(string, ...interface{}) *sql.Stmt
	UseExclusion()
	Lock()
	Unlock()
}

type Enquirer interface {
	GetSubQueries() []*any.Any
	GetOperation() service.OperationType
	GetOffset() int64
	GetLimit() int64
	GetGroupBy() int32
	GetResourcePolicyQuery() *service.ResourcePolicyQuery

	fmt.Stringer
}

type Handler struct {
	dao.DAO
	// contains filtered or unexported fields
}

type PackrBox interface {
	List() []string
	Bytes(name string) []byte
}

type PackrMigrationSource struct {
	Box PackrBox

	// Path in the box to use.
	Dir string

	TablePrefix string
}

type Scanner interface {
	Scan(...interface{}) error
}