registry

Documentation

Index

• type FilterRegistry
  • func NewFilterRegistry(sp *syncpool.SyncPool, bufSize int) *FilterRegistry
  • func (r *FilterRegistry) Filter(id int, data []byte) bool
  • func (r *FilterRegistry) Register(f query.Filter) int
  • func (r *FilterRegistry) Release(id int)
• type SortRegistry
  • func NewSortRegistry(sp *syncpool.SyncPool, bufSize int) *SortRegistry
  • func (r *SortRegistry) Register(s query.Sort) int
  • func (r *SortRegistry) Release(id int)
  • func (r *SortRegistry) Sort(id int, data []byte) []byte

Types

type FilterRegistry

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

func NewFilterRegistry

func NewFilterRegistry(sp *syncpool.SyncPool, bufSize int) *FilterRegistry

func (*FilterRegistry) Filter

func (r *FilterRegistry) Filter(id int, data []byte) bool

Filter could be called only between Register and Release calls, so it's safe to use concurrently

func (*FilterRegistry) Register

func (r *FilterRegistry) Register(f query.Filter) int

func (*FilterRegistry) Release

func (r *FilterRegistry) Release(id int)

type SortRegistry

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

func NewSortRegistry

func NewSortRegistry(sp *syncpool.SyncPool, bufSize int) *SortRegistry

func (*SortRegistry) Register

func (r *SortRegistry) Register(s query.Sort) int

func (*SortRegistry) Release

func (r *SortRegistry) Release(id int)

func (*SortRegistry) Sort

func (r *SortRegistry) Sort(id int, data []byte) []byte