query

Documentation

Index

• func GetAllQueries() []*netstorage.QueryExeInfo
• func VisitManagers(fn func(*Manager))
• type IQuery
• type Item
• type Manager
  • func NewManager(client uint64) *Manager
  • func (qm *Manager) Abort(qid uint64)
  • func (qm *Manager) Aborted(qid uint64) bool
  • func (qm *Manager) Add(qid uint64, v IQuery)
  • func (qm *Manager) Crash(qid uint64)
  • func (qm *Manager) Finish(qid uint64, v IQuery)
  • func (qm *Manager) FinishAll(qid uint64)
  • func (qm *Manager) Get(qid uint64) []IQuery
  • func (qm *Manager) GetAll() []*netstorage.QueryExeInfo
  • func (qm *Manager) IsKilled(qid uint64) bool
  • func (qm *Manager) Kill(qid uint64)
  • func (qm *Manager) SetAbortedExpire(d time.Duration)

Functions

func GetAllQueries

func GetAllQueries() []*netstorage.QueryExeInfo

func VisitManagers

func VisitManagers(fn func(*Manager))

VisitManagers can do something foreach every manager. Like get all queries.

Types

type IQuery

type IQuery interface {
	Abort()
	Crash()
	GetQueryExeInfo() *netstorage.QueryExeInfo
}

type Item

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

type Manager

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

func NewManager

func NewManager(client uint64) *Manager

func (*Manager) Abort

func (qm *Manager) Abort(qid uint64)

func (*Manager) Aborted

func (qm *Manager) Aborted(qid uint64) bool

func (*Manager) Add

func (qm *Manager) Add(qid uint64, v IQuery)

func (*Manager) Crash

func (qm *Manager) Crash(qid uint64)

func (*Manager) Finish

func (qm *Manager) Finish(qid uint64, v IQuery)

func (*Manager) FinishAll

func (qm *Manager) FinishAll(qid uint64)

func (*Manager) Get

func (qm *Manager) Get(qid uint64) []IQuery

func (*Manager) GetAll

func (qm *Manager) GetAll() []*netstorage.QueryExeInfo

GetAll return the all query exe infos keeping by a manager

func (*Manager) IsKilled

func (qm *Manager) IsKilled(qid uint64) bool

func (*Manager) Kill

func (qm *Manager) Kill(qid uint64)

func (*Manager) SetAbortedExpire

func (qm *Manager) SetAbortedExpire(d time.Duration)