Documentation
¶
Index ¶
- func CopyAll(ctx context.Context, b *Builder, it *Iterator) error
- func DebugTree(s cadata.Store, x Root)
- func HasPrefix(ctx context.Context, s cadata.Store, x Root, prefix []byte) (bool, error)
- func MarshalRoot(r Root) []byte
- func MaxKey(ctx context.Context, s cadata.Store, x Root, under []byte) ([]byte, error)
- func PointsToEntries(root Root) bool
- func PointsToIndexes(root Root) bool
- type Builder
- type Entry
- type Index
- type IndexHandler
- type Iterator
- type Mutation
- type Ref
- type Root
- type Span
- type StreamReader
- type StreamWriter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func HasPrefix ¶
HasPrefix returns true if the tree rooted at x only has keys which are prefixed with prefix
func MarshalRoot ¶
func PointsToEntries ¶
func PointsToIndexes ¶
Types ¶
type Builder ¶
type Builder struct {
// contains filtered or unexported fields
}
func NewBuilder ¶
func (*Builder) SyncedBelow ¶
type IndexHandler ¶
type Iterator ¶
type Iterator struct {
// contains filtered or unexported fields
}
func NewIterator ¶
type Mutation ¶
Mutation represents a mutation to the stream if there is nothing in the Span, Fn will be called once with nil otherwise Fn will be called once for every item in the Span.
type Root ¶
type Root struct {
Ref Ref `json:"ref"`
Depth uint8 `json:"depth"`
First []byte `json:"first,omitempty"`
}
Root is the root of the tree
type StreamReader ¶
type StreamReader struct {
// contains filtered or unexported fields
}
func NewStreamReader ¶
func (*StreamReader) SeekIndexes ¶
func (r *StreamReader) SeekIndexes(ctx context.Context, gteq []byte) error
type StreamWriter ¶
type StreamWriter struct {
// contains filtered or unexported fields
}
func NewStreamWriter ¶
func NewStreamWriter(s cadata.Store, op *gdat.Operator, avgSize, maxSize int, seed *[32]byte, onIndex IndexHandler) *StreamWriter
func (*StreamWriter) Buffered ¶
func (w *StreamWriter) Buffered() int
Click to show internal directories.
Click to hide internal directories.