labels

Documentation

Index

• Constants
• Variables
• type ID
• type IterFunc
• type Pair
  • func (t Pair) String() string
  • func (t Pair) VInt64() (int64, error)
  • func (t Pair) VTime() (time.Time, error)
• type PairSet
  • func (ts PairSet) Slice() (ret []Pair)
• type Predicate
• type PredicateOp
• type Query
• type QueryBackend
• type ResultSet
  • func DoQuery(ctx context.Context, be QueryBackend, q Query) (*ResultSet, error)
• type Span

Constants

const (
	OpNone = PredicateOp("NONE")
	OpAny  = PredicateOp("ANY")

	OpEq = PredicateOp("=")
	OpLt = PredicateOp("<")
	OpGt = PredicateOp(">")

	OpContains = PredicateOp("CONTAINS")
	OpRegexp   = PredicateOp("REGEXP")

	OpIn = PredicateOp("IN")

	OpOR  = PredicateOp("OR")
	OpAND = PredicateOp("AND")
)

Variables

var ErrStopIter = fmt.Errorf("stop iteration")

Types

type ID

type ID = hcorpus.ID

type IterFunc

type IterFunc = func(id ID, key, value []byte) error

type Pair

type Pair struct {
	Key   string
	Value []byte
}

func (Pair) String

func (t Pair) String() string

func (Pair) VInt64

func (t Pair) VInt64() (int64, error)

func (Pair) VTime

func (t Pair) VTime() (time.Time, error)

type PairSet

type PairSet map[string][]byte

func (PairSet) Slice

func (ts PairSet) Slice() (ret []Pair)

type Predicate

type Predicate struct {
	Op PredicateOp `json:"op"`

	Key string `json:"key"`

	Value      string   `json:"value,omitempty"`
	Values     []string `json:"values,omitempty"`
	SubQueries []Query  `json:"sub_queries,omitempty"`

	Limit int `json:"limit"`
}

type PredicateOp

type PredicateOp string

type Query

type Query struct {
	Where Predicate `json:"where"`
	Limit int       `json:"limit"`
}

type QueryBackend

type QueryBackend interface {
	ScanForward(ctx context.Context, span Span, fn IterFunc) error
	ScanInverted(ctx context.Context, tagKey string, fn IterFunc) error
	GetValue(ctx context.Context, id ID, tagKey string) ([]byte, error)
}

type ResultSet

type ResultSet struct {
	IDs                  []ID
	Offset, Count, Total int
}

func DoQuery

func DoQuery(ctx context.Context, be QueryBackend, q Query) (*ResultSet, error)

type Span

type Span = state.ByteSpan