filter

package
v0.0.0-...-1676ef7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 13, 2024 License: Apache-2.0 Imports: 3 Imported by: 140

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AllFilter 

type AllFilter struct{}

AllFilter is TODO

func NewAllFilter 

func NewAllFilter() AllFilter

NewAllFilter is TODO

func (*AllFilter) ConstructPBFilter 

func (f *AllFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type BinaryComparator 

type BinaryComparator pb.BinaryComparator

BinaryComparator is TODO

func NewBinaryComparator 

func NewBinaryComparator(comparable *ByteArrayComparable) *BinaryComparator

NewBinaryComparator is TODO

func (*BinaryComparator) ConstructPBComparator 

func (c *BinaryComparator) ConstructPBComparator() (*pb.Comparator, error)

ConstructPBComparator is TODO

type BinaryPrefixComparator 

type BinaryPrefixComparator pb.BinaryPrefixComparator

BinaryPrefixComparator is TODO

func NewBinaryPrefixComparator 

func NewBinaryPrefixComparator(comparable *ByteArrayComparable) *BinaryPrefixComparator

NewBinaryPrefixComparator is TODO

func (*BinaryPrefixComparator) ConstructPBComparator 

func (c *BinaryPrefixComparator) ConstructPBComparator() (*pb.Comparator, error)

ConstructPBComparator is TODO

type BitComparator 

type BitComparator pb.BitComparator

BitComparator is TODO

func NewBitComparator 

func NewBitComparator(bitwiseOp BitComparatorBitwiseOp,
	comparable *ByteArrayComparable) *BitComparator

NewBitComparator is TODO

func (*BitComparator) ConstructPBComparator 

func (c *BitComparator) ConstructPBComparator() (*pb.Comparator, error)

ConstructPBComparator is TODO

type BitComparatorBitwiseOp 

type BitComparatorBitwiseOp int32

BitComparatorBitwiseOp is TODO 

const (
	BitComparatorAND BitComparatorBitwiseOp = 1
	BitComparatorOR  BitComparatorBitwiseOp = 2
	BitComparatorXOR BitComparatorBitwiseOp = 3
)

Constants are TODO

type ByteArrayComparable 

type ByteArrayComparable pb.ByteArrayComparable

ByteArrayComparable is used across many Comparators.

func NewByteArrayComparable 

func NewByteArrayComparable(value []byte) *ByteArrayComparable

NewByteArrayComparable is TODO

type BytesBytesPair 

type BytesBytesPair pb.BytesBytesPair

BytesBytesPair is a type used in FuzzyRowFilter. Want to avoid users having to interact directly with the protobuf generated file so exposing here.

func NewBytesBytesPair 

func NewBytesBytesPair(first []byte, second []byte) *BytesBytesPair

NewBytesBytesPair is TODO

type ColumnCountGetFilter 

type ColumnCountGetFilter pb.ColumnCountGetFilter

ColumnCountGetFilter is TODO

func NewColumnCountGetFilter 

func NewColumnCountGetFilter(limit int32) *ColumnCountGetFilter

NewColumnCountGetFilter is TODO

func (*ColumnCountGetFilter) ConstructPBFilter 

func (f *ColumnCountGetFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type ColumnPaginationFilter 

type ColumnPaginationFilter pb.ColumnPaginationFilter

ColumnPaginationFilter is TODO

func NewColumnPaginationFilter 

func NewColumnPaginationFilter(limit, offset int32, columnOffset []byte) *ColumnPaginationFilter

NewColumnPaginationFilter is TODO

func (*ColumnPaginationFilter) ConstructPBFilter 

func (f *ColumnPaginationFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type ColumnPrefixFilter 

type ColumnPrefixFilter pb.ColumnPrefixFilter

ColumnPrefixFilter is TODO

func NewColumnPrefixFilter 

func NewColumnPrefixFilter(prefix []byte) *ColumnPrefixFilter

NewColumnPrefixFilter is TODO

func (*ColumnPrefixFilter) ConstructPBFilter 

func (f *ColumnPrefixFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type ColumnRangeFilter 

type ColumnRangeFilter pb.ColumnRangeFilter

ColumnRangeFilter is TODO

func NewColumnRangeFilter 

func NewColumnRangeFilter(minColumn, maxColumn []byte,
	minColumnInclusive, maxColumnInclusive bool) *ColumnRangeFilter

NewColumnRangeFilter is TODO

func (*ColumnRangeFilter) ConstructPBFilter 

func (f *ColumnRangeFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type Comparator 

type Comparator interface {
	// ConstructPBComparator creates and returns the comparator encoded in a
	// pb.Comparator type
	ConstructPBComparator() (*pb.Comparator, error)
}

Comparator is TODO

type CompareFilter 

type CompareFilter pb.CompareFilter

CompareFilter is TODO

func NewCompareFilter 

func NewCompareFilter(compareOp CompareType, comparatorObj Comparator) *CompareFilter

NewCompareFilter is TODO

func (*CompareFilter) ConstructPBFilter 

func (f *CompareFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type CompareType 

type CompareType int32

CompareType is TODO 

const (
	Less           CompareType = 0
	LessOrEqual    CompareType = 1
	Equal          CompareType = 2
	NotEqual       CompareType = 3
	GreaterOrEqual CompareType = 4
	Greater        CompareType = 5
	NoOp           CompareType = 6
)

Constants is TODO

type DependentColumnFilter 

type DependentColumnFilter pb.DependentColumnFilter

DependentColumnFilter is TODO

func NewDependentColumnFilter 

func NewDependentColumnFilter(compareFilter *CompareFilter, columnFamily, columnQualifier []byte,
	dropDependentColumn bool) *DependentColumnFilter

NewDependentColumnFilter is TODO

func (*DependentColumnFilter) ConstructPBFilter 

func (f *DependentColumnFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type FamilyFilter 

type FamilyFilter pb.FamilyFilter

FamilyFilter is TODO

func NewFamilyFilter 

func NewFamilyFilter(compareFilter *CompareFilter) *FamilyFilter

NewFamilyFilter is TODO

func (*FamilyFilter) ConstructPBFilter 

func (f *FamilyFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type Filter 

type Filter interface {
	// ConstructPBFilter creates and returns the filter encoded in a pb.Filter type
	//	- For most filters this just involves creating the special filter object,
	//	  serializing it, and then creating a standard Filter object with the name and
	//	  serialization inside.
	//	- For FilterLists this requires creating the protobuf FilterList which contains
	//	  an array []*pb.Filter (meaning we have to create, serialize, create all objects
	//	  in that array), serialize the newly created pb.FilterList and then create a
	//	  pb.Filter object containing that new serialization.
	ConstructPBFilter() (*pb.Filter, error)
}

Filter is TODO

type FirstKeyOnlyFilter 

type FirstKeyOnlyFilter struct{}

FirstKeyOnlyFilter is TODO

func NewFirstKeyOnlyFilter 

func NewFirstKeyOnlyFilter() FirstKeyOnlyFilter

NewFirstKeyOnlyFilter is TODO

func (FirstKeyOnlyFilter) ConstructPBFilter 

func (f FirstKeyOnlyFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type FirstKeyValueMatchingQualifiersFilter 

type FirstKeyValueMatchingQualifiersFilter pb.FirstKeyValueMatchingQualifiersFilter

FirstKeyValueMatchingQualifiersFilter is TODO

func NewFirstKeyValueMatchingQualifiersFilter 

func NewFirstKeyValueMatchingQualifiersFilter(
	qualifiers [][]byte) *FirstKeyValueMatchingQualifiersFilter

NewFirstKeyValueMatchingQualifiersFilter is TODO

func (*FirstKeyValueMatchingQualifiersFilter) ConstructPBFilter 

func (f *FirstKeyValueMatchingQualifiersFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type FuzzyRowFilter 

type FuzzyRowFilter pb.FuzzyRowFilter

FuzzyRowFilter is TODO

func NewFuzzyRowFilter 

func NewFuzzyRowFilter(pairs []*BytesBytesPair) *FuzzyRowFilter

NewFuzzyRowFilter is TODO

func (*FuzzyRowFilter) ConstructPBFilter 

func (f *FuzzyRowFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type InclusiveStopFilter 

type InclusiveStopFilter pb.InclusiveStopFilter

InclusiveStopFilter is TODO

func NewInclusiveStopFilter 

func NewInclusiveStopFilter(stopRowKey []byte) *InclusiveStopFilter

NewInclusiveStopFilter is TODO

func (*InclusiveStopFilter) ConstructPBFilter 

func (f *InclusiveStopFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type KeyOnlyFilter 

type KeyOnlyFilter pb.KeyOnlyFilter

KeyOnlyFilter is TODO

func NewKeyOnlyFilter 

func NewKeyOnlyFilter(lenAsVal bool) *KeyOnlyFilter

NewKeyOnlyFilter is TODO

func (*KeyOnlyFilter) ConstructPBFilter 

func (f *KeyOnlyFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type List 

type List pb.FilterList

List is TODO

func NewList 

func NewList(operator ListOperator, filters ...Filter) *List

NewList is TODO

func (*List) AddFilters 

func (f *List) AddFilters(filters ...Filter)

AddFilters is TODO

func (*List) ConstructPBFilter 

func (f *List) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type ListOperator 

type ListOperator int32

ListOperator is TODO 

const (
	MustPassAll ListOperator = 1
	MustPassOne ListOperator = 2
)

Constants is TODO

type LongComparator 

type LongComparator pb.LongComparator

LongComparator is TODO

func NewLongComparator 

func NewLongComparator(comparable *ByteArrayComparable) *LongComparator

NewLongComparator is TODO

func (*LongComparator) ConstructPBComparator 

func (c *LongComparator) ConstructPBComparator() (*pb.Comparator, error)

ConstructPBComparator is TODO

type MultiRowRangeFilter 

type MultiRowRangeFilter pb.MultiRowRangeFilter

MultiRowRangeFilter is TODO

func NewMultiRowRangeFilter 

func NewMultiRowRangeFilter(rowRangeList []*RowRange) *MultiRowRangeFilter

NewMultiRowRangeFilter is TODO

func (*MultiRowRangeFilter) ConstructPBFilter 

func (f *MultiRowRangeFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type MultipleColumnPrefixFilter 

type MultipleColumnPrefixFilter pb.MultipleColumnPrefixFilter

MultipleColumnPrefixFilter is TODO

func NewMultipleColumnPrefixFilter 

func NewMultipleColumnPrefixFilter(sortedPrefixes [][]byte) *MultipleColumnPrefixFilter

NewMultipleColumnPrefixFilter is TODO

func (*MultipleColumnPrefixFilter) ConstructPBFilter 

func (f *MultipleColumnPrefixFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type NullComparator 

type NullComparator struct{}

NullComparator is TODO

func NewNullComparator 

func NewNullComparator() NullComparator

NewNullComparator is TODO

func (NullComparator) ConstructPBComparator 

func (c NullComparator) ConstructPBComparator() (*pb.Comparator, error)

ConstructPBComparator is TODO

type PageFilter 

type PageFilter pb.PageFilter

PageFilter is TODO

func NewPageFilter 

func NewPageFilter(pageSize int64) *PageFilter

NewPageFilter is TODO

func (*PageFilter) ConstructPBFilter 

func (f *PageFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type PrefixFilter 

type PrefixFilter pb.PrefixFilter

PrefixFilter is TODO

func NewPrefixFilter 

func NewPrefixFilter(prefix []byte) *PrefixFilter

NewPrefixFilter is TODO

func (*PrefixFilter) ConstructPBFilter 

func (f *PrefixFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type QualifierFilter 

type QualifierFilter pb.QualifierFilter

QualifierFilter is TODO

func NewQualifierFilter 

func NewQualifierFilter(compareFilter *CompareFilter) *QualifierFilter

NewQualifierFilter is TODO

func (*QualifierFilter) ConstructPBFilter 

func (f *QualifierFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type RandomRowFilter 

type RandomRowFilter pb.RandomRowFilter

RandomRowFilter is TODO

func NewRandomRowFilter 

func NewRandomRowFilter(chance float32) *RandomRowFilter

NewRandomRowFilter is TODO

func (*RandomRowFilter) ConstructPBFilter 

func (f *RandomRowFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type RegexStringComparator 

type RegexStringComparator pb.RegexStringComparator

RegexStringComparator is TODO

func NewRegexStringComparator 

func NewRegexStringComparator(pattern string, patternFlags int32,
	charset, engine string) *RegexStringComparator

NewRegexStringComparator is TODO

func (*RegexStringComparator) ConstructPBComparator 

func (c *RegexStringComparator) ConstructPBComparator() (*pb.Comparator, error)

ConstructPBComparator is TODO

type RowFilter 

type RowFilter pb.RowFilter

RowFilter is TODO

func NewRowFilter 

func NewRowFilter(compareFilter *CompareFilter) *RowFilter

NewRowFilter is TODO

func (*RowFilter) ConstructPBFilter 

func (f *RowFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type RowRange 

type RowRange pb.RowRange

RowRange is TODO

func NewRowRange 

func NewRowRange(startRow, stopRow []byte, startRowInclusive, stopRowInclusive bool) *RowRange

NewRowRange is TODO

func (*RowRange) ConstructPBFilter 

func (f *RowRange) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type SingleColumnValueExcludeFilter 

type SingleColumnValueExcludeFilter pb.SingleColumnValueExcludeFilter

SingleColumnValueExcludeFilter is TODO

func NewSingleColumnValueExcludeFilter 

func NewSingleColumnValueExcludeFilter(
	filter *SingleColumnValueFilter) *SingleColumnValueExcludeFilter

NewSingleColumnValueExcludeFilter is TODO

func (*SingleColumnValueExcludeFilter) ConstructPBFilter 

func (f *SingleColumnValueExcludeFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type SingleColumnValueFilter 

type SingleColumnValueFilter pb.SingleColumnValueFilter

SingleColumnValueFilter is TODO

func NewSingleColumnValueFilter 

func NewSingleColumnValueFilter(columnFamily, columnQualifier []byte, compareOp CompareType,
	comparatorObj Comparator, filterIfMissing, latestVersionOnly bool) *SingleColumnValueFilter

NewSingleColumnValueFilter is TODO

func (*SingleColumnValueFilter) ConstructPB 

func (f *SingleColumnValueFilter) ConstructPB() (*pb.SingleColumnValueFilter, error)

ConstructPB is TODO

func (*SingleColumnValueFilter) ConstructPBFilter 

func (f *SingleColumnValueFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type SkipFilter 

type SkipFilter pb.SkipFilter

SkipFilter is TODO

func NewSkipFilter 

func NewSkipFilter(skippingFilter Filter) *SkipFilter

NewSkipFilter is TODO

func (*SkipFilter) ConstructPBFilter 

func (f *SkipFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type SubstringComparator 

type SubstringComparator pb.SubstringComparator

SubstringComparator is TODO

func NewSubstringComparator 

func NewSubstringComparator(substr string) *SubstringComparator

NewSubstringComparator is TODO

func (*SubstringComparator) ConstructPBComparator 

func (c *SubstringComparator) ConstructPBComparator() (*pb.Comparator, error)

ConstructPBComparator is TODO

type TimestampsFilter 

type TimestampsFilter pb.TimestampsFilter

TimestampsFilter is TODO

func NewTimestampsFilter 

func NewTimestampsFilter(timestamps []int64) *TimestampsFilter

NewTimestampsFilter is TODO

func (*TimestampsFilter) ConstructPBFilter 

func (f *TimestampsFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type ValueFilter 

type ValueFilter pb.ValueFilter

ValueFilter is TODO

func NewValueFilter 

func NewValueFilter(compareFilter *CompareFilter) *ValueFilter

NewValueFilter is TODO

func (*ValueFilter) ConstructPBFilter 

func (f *ValueFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type WhileMatchFilter 

type WhileMatchFilter pb.WhileMatchFilter

WhileMatchFilter is TODO

func NewWhileMatchFilter 

func NewWhileMatchFilter(matchingFilter Filter) *WhileMatchFilter

NewWhileMatchFilter is TODO

func (*WhileMatchFilter) ConstructPBFilter 

func (f *WhileMatchFilter) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

type Wrapper 

type Wrapper pb.FilterWrapper

Wrapper is TODO

func NewWrapper 

func NewWrapper(wrappedFilter Filter) *Wrapper

NewWrapper is TODO

func (*Wrapper) ConstructPBFilter 

func (f *Wrapper) ConstructPBFilter() (*pb.Filter, error)

ConstructPBFilter is TODO

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.