bucketproxy

package

v0.0.0-...-05c1de5 Latest Latest Go to latest Published: Jan 27, 2026 License: MIT Imports: 6 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/lymar/physalis

Links

Open Source Insights

Documentation ¶

Index ¶

func BucketAscend(bucket *bolt.Bucket) iter.Seq2[[]byte, []byte]
func BucketAscendGreaterOrEqual(bucket *bolt.Bucket, greaterOrEqual []byte) iter.Seq2[[]byte, []byte]
func BucketAscendLessThan(bucket *bolt.Bucket, lessThan []byte) iter.Seq2[[]byte, []byte]
func BucketAscendRange(bucket *bolt.Bucket, greaterOrEqual, lessThan []byte) iter.Seq2[[]byte, []byte]
func BucketDescend(bucket *bolt.Bucket) iter.Seq2[[]byte, []byte]
func BucketDescendGreaterThan(bucket *bolt.Bucket, greaterThan []byte) iter.Seq2[[]byte, []byte]
func BucketDescendLessOrEqual(bucket *bolt.Bucket, lessOrEqual []byte) iter.Seq2[[]byte, []byte]
func BucketDescendRange(bucket *bolt.Bucket, lessOrEqual, greaterThan []byte) iter.Seq2[[]byte, []byte]
type BucketProxy
- func New[K cmp.Ordered, V any](bucket *bolt.Bucket, serializeK func(*K) []byte, deserializeK func([]byte) K, ...) BucketProxy[K, V]

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func BucketAscend ¶

func BucketAscend(bucket *bolt.Bucket) iter.Seq2[[]byte, []byte]

func BucketAscendGreaterOrEqual ¶

func BucketAscendGreaterOrEqual(bucket *bolt.Bucket, greaterOrEqual []byte) iter.Seq2[[]byte, []byte]

func BucketAscendLessThan ¶

func BucketAscendLessThan(bucket *bolt.Bucket, lessThan []byte) iter.Seq2[[]byte, []byte]

func BucketAscendRange ¶

func BucketAscendRange(bucket *bolt.Bucket, greaterOrEqual, lessThan []byte) iter.Seq2[[]byte, []byte]

func BucketDescend ¶

func BucketDescend(bucket *bolt.Bucket) iter.Seq2[[]byte, []byte]

func BucketDescendGreaterThan ¶

func BucketDescendGreaterThan(bucket *bolt.Bucket, greaterThan []byte) iter.Seq2[[]byte, []byte]

func BucketDescendLessOrEqual ¶

func BucketDescendLessOrEqual(bucket *bolt.Bucket, lessOrEqual []byte) iter.Seq2[[]byte, []byte]

func BucketDescendRange ¶

func BucketDescendRange(bucket *bolt.Bucket, lessOrEqual, greaterThan []byte) iter.Seq2[[]byte, []byte]

Types ¶

type BucketProxy ¶

type BucketProxy[K cmp.Ordered, V any] struct {
	// contains filtered or unexported fields
}

func New ¶

func New[K cmp.Ordered, V any](
	bucket *bolt.Bucket,
	serializeK func(*K) []byte,
	deserializeK func([]byte) K,
	serializeV func(*V) []byte,
	deserializeV func([]byte) V) BucketProxy[K, V]

func (*BucketProxy[K, V]) Ascend ¶

func (bp *BucketProxy[K, V]) Ascend() iter.Seq2[K, *V]

func (*BucketProxy[K, V]) AscendGreaterOrEqual ¶

func (bp *BucketProxy[K, V]) AscendGreaterOrEqual(greaterOrEqual K) iter.Seq2[K, *V]

func (*BucketProxy[K, V]) AscendLessThan ¶

func (bp *BucketProxy[K, V]) AscendLessThan(lessThan K) iter.Seq2[K, *V]

func (*BucketProxy[K, V]) AscendRange ¶

func (bp *BucketProxy[K, V]) AscendRange(greaterOrEqual, lessThan K) iter.Seq2[K, *V]

func (*BucketProxy[K, V]) Delete ¶

func (bp *BucketProxy[K, V]) Delete(key K)

func (*BucketProxy[K, V]) Descend ¶

func (bp *BucketProxy[K, V]) Descend() iter.Seq2[K, *V]

func (*BucketProxy[K, V]) DescendGreaterThan ¶

func (bp *BucketProxy[K, V]) DescendGreaterThan(greaterThan K) iter.Seq2[K, *V]

func (*BucketProxy[K, V]) DescendLessOrEqual ¶

func (bp *BucketProxy[K, V]) DescendLessOrEqual(lessOrEqual K) iter.Seq2[K, *V]

func (*BucketProxy[K, V]) DescendRange ¶

func (bp *BucketProxy[K, V]) DescendRange(lessOrEqual, greaterThan K) iter.Seq2[K, *V]

func (*BucketProxy[K, V]) Get ¶

func (bp *BucketProxy[K, V]) Get(key K) *V

func (*BucketProxy[K, V]) Put ¶

func (bp *BucketProxy[K, V]) Put(key K, data *V)

func (*BucketProxy[K, V]) WriteProxyToDb ¶

func (bp *BucketProxy[K, V]) WriteProxyToDb() func(bucket *bolt.Bucket) error

Source Files ¶

View all Source files

bucketproxy.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL