kase

package
v0.22.13 Latest Latest
Warning

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

 Go to latest Published: Jul 9, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Mutex_Enum_name = map[int32]string{
		0: "none",
		1: "zero",
		2: "one",
	}
	Mutex_Enum_value = map[string]int32{
		"none": 0,
		"zero": 1,
		"one":  2,
	}
)

Enum value maps for Mutex_Enum.

View Source 
var File_msg_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Add 

type Add[T any] func(r *roaring.Bitmap, id uint64, value T)

type BSI 

type BSI struct {
	Int    int64   `protobuf:"varint,1,opt,name=int,proto3" json:"int,omitempty"`
	Double float64 `protobuf:"fixed64,2,opt,name=double,proto3" json:"double,omitempty"`
	// contains filtered or unexported fields
}

func (*BSI) Descriptor deprecated 

func (*BSI) Descriptor() ([]byte, []int)

Deprecated: Use BSI.ProtoReflect.Descriptor instead.

func (*BSI) GetDouble 

func (x *BSI) GetDouble() float64

func (*BSI) GetInt 

func (x *BSI) GetInt() int64

func (*BSI) ProtoMessage 

func (*BSI) ProtoMessage()

func (*BSI) ProtoReflect 

func (x *BSI) ProtoReflect() protoreflect.Message

func (*BSI) Reset 

func (x *BSI) Reset()

func (*BSI) String 

func (x *BSI) String() string

type Blob 

type Blob struct {
	Blob []byte `protobuf:"bytes,1,opt,name=blob,proto3" json:"blob,omitempty"`
	// contains filtered or unexported fields
}

func (*Blob) Descriptor deprecated 

func (*Blob) Descriptor() ([]byte, []int)

Deprecated: Use Blob.ProtoReflect.Descriptor instead.

func (*Blob) GetBlob 

func (x *Blob) GetBlob() []byte

func (*Blob) ProtoMessage 

func (*Blob) ProtoMessage()

func (*Blob) ProtoReflect 

func (x *Blob) ProtoReflect() protoreflect.Message

func (*Blob) Reset 

func (x *Blob) Reset()

func (*Blob) String 

func (x *Blob) String() string

type BlobSet 

type BlobSet struct {
	Uint64 [][]byte `protobuf:"bytes,1,rep,name=uint64,proto3" json:"uint64,omitempty"`
	// contains filtered or unexported fields
}

func (*BlobSet) Descriptor deprecated 

func (*BlobSet) Descriptor() ([]byte, []int)

Deprecated: Use BlobSet.ProtoReflect.Descriptor instead.

func (*BlobSet) GetUint64 

func (x *BlobSet) GetUint64() [][]byte

func (*BlobSet) ProtoMessage 

func (*BlobSet) ProtoMessage()

func (*BlobSet) ProtoReflect 

func (x *BlobSet) ProtoReflect() protoreflect.Message

func (*BlobSet) Reset 

func (x *BlobSet) Reset()

func (*BlobSet) String 

func (x *BlobSet) String() string

type Bool 

type Bool struct {
	Bool bool `protobuf:"varint,1,opt,name=bool,proto3" json:"bool,omitempty"`
	// contains filtered or unexported fields
}

func (*Bool) Descriptor deprecated 

func (*Bool) Descriptor() ([]byte, []int)

Deprecated: Use Bool.ProtoReflect.Descriptor instead.

func (*Bool) GetBool 

func (x *Bool) GetBool() bool

func (*Bool) ProtoMessage 

func (*Bool) ProtoMessage()

func (*Bool) ProtoReflect 

func (x *Bool) ProtoReflect() protoreflect.Message

func (*Bool) Reset 

func (x *Bool) Reset()

func (*Bool) String 

func (x *Bool) String() string

type Extract 

type Extract[T any] func(c *rbf.Cursor, shard uint64, columns *rows.Row, f func(column uint64, value T) error) error

type Kase 

type Kase[T any] struct {
	suite.Suite
	Add     Add[T]
	Extract Extract[T]
	Source  []T
	// contains filtered or unexported fields
}

func (*Kase[T]) SetupSuite 

func (k *Kase[T]) SetupSuite()

func (*Kase[T]) TearDownSuite 

func (k *Kase[T]) TearDownSuite()

func (*Kase[T]) TestSelect 

func (k *Kase[T]) TestSelect()

func (*Kase[T]) TestSelectAll 

func (k *Kase[T]) TestSelectAll()

type Mutex 

type Mutex struct {
	Mutex Mutex_Enum `protobuf:"varint,1,opt,name=mutex,proto3,enum=kase.Mutex_Enum" json:"mutex,omitempty"`
	// contains filtered or unexported fields
}

func (*Mutex) Descriptor deprecated 

func (*Mutex) Descriptor() ([]byte, []int)

Deprecated: Use Mutex.ProtoReflect.Descriptor instead.

func (*Mutex) GetMutex 

func (x *Mutex) GetMutex() Mutex_Enum

func (*Mutex) ProtoMessage 

func (*Mutex) ProtoMessage()

func (*Mutex) ProtoReflect 

func (x *Mutex) ProtoReflect() protoreflect.Message

func (*Mutex) Reset 

func (x *Mutex) Reset()

func (*Mutex) String 

func (x *Mutex) String() string

type Mutex_Enum 

type Mutex_Enum int32
const (
	Mutex_none Mutex_Enum = 0
	Mutex_zero Mutex_Enum = 1
	Mutex_one  Mutex_Enum = 2
)

func (Mutex_Enum) Descriptor 

func (Mutex_Enum) Descriptor() protoreflect.EnumDescriptor

func (Mutex_Enum) Enum 

func (x Mutex_Enum) Enum() *Mutex_Enum

func (Mutex_Enum) EnumDescriptor deprecated 

func (Mutex_Enum) EnumDescriptor() ([]byte, []int)

Deprecated: Use Mutex_Enum.Descriptor instead.

func (Mutex_Enum) Number 

func (x Mutex_Enum) Number() protoreflect.EnumNumber

func (Mutex_Enum) String 

func (x Mutex_Enum) String() string

func (Mutex_Enum) Type 

func (Mutex_Enum) Type() protoreflect.EnumType

type String 

type String struct {
	String_ string `protobuf:"bytes,1,opt,name=string,proto3" json:"string,omitempty"`
	// contains filtered or unexported fields
}

func (*String) Descriptor deprecated 

func (*String) Descriptor() ([]byte, []int)

Deprecated: Use String.ProtoReflect.Descriptor instead.

func (*String) GetString_ 

func (x *String) GetString_() string

func (*String) ProtoMessage 

func (*String) ProtoMessage()

func (*String) ProtoReflect 

func (x *String) ProtoReflect() protoreflect.Message

func (*String) Reset 

func (x *String) Reset()

func (*String) String 

func (x *String) String() string

type StringSet 

type StringSet struct {
	String_ []string `protobuf:"bytes,1,rep,name=string,proto3" json:"string,omitempty"`
	// contains filtered or unexported fields
}

func (*StringSet) Descriptor deprecated 

func (*StringSet) Descriptor() ([]byte, []int)

Deprecated: Use StringSet.ProtoReflect.Descriptor instead.

func (*StringSet) GetString_ 

func (x *StringSet) GetString_() []string

func (*StringSet) ProtoMessage 

func (*StringSet) ProtoMessage()

func (*StringSet) ProtoReflect 

func (x *StringSet) ProtoReflect() protoreflect.Message

func (*StringSet) Reset 

func (x *StringSet) Reset()

func (*StringSet) String 

func (x *StringSet) String() string

type TimestampMS 

type TimestampMS struct {
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*TimestampMS) Descriptor deprecated 

func (*TimestampMS) Descriptor() ([]byte, []int)

Deprecated: Use TimestampMS.ProtoReflect.Descriptor instead.

func (*TimestampMS) GetTimestamp 

func (x *TimestampMS) GetTimestamp() int64

func (*TimestampMS) ProtoMessage 

func (*TimestampMS) ProtoMessage()

func (*TimestampMS) ProtoReflect 

func (x *TimestampMS) ProtoReflect() protoreflect.Message

func (*TimestampMS) Reset 

func (x *TimestampMS) Reset()

func (*TimestampMS) String 

func (x *TimestampMS) String() string

type TimestampNS 

type TimestampNS struct {
	Timestamp uint64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*TimestampNS) Descriptor deprecated 

func (*TimestampNS) Descriptor() ([]byte, []int)

Deprecated: Use TimestampNS.ProtoReflect.Descriptor instead.

func (*TimestampNS) GetTimestamp 

func (x *TimestampNS) GetTimestamp() uint64

func (*TimestampNS) ProtoMessage 

func (*TimestampNS) ProtoMessage()

func (*TimestampNS) ProtoReflect 

func (x *TimestampNS) ProtoReflect() protoreflect.Message

func (*TimestampNS) Reset 

func (x *TimestampNS) Reset()

func (*TimestampNS) String 

func (x *TimestampNS) String() string

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.