rhiza

package module

Go to main page

Versions in this module

v0

v0.12.3

Sep 6, 2026

v0.12.2

Sep 6, 2026

v0.12.1

Sep 6, 2026

v0.12.0

Sep 5, 2026

v0.11.0

Sep 5, 2026

Changes in this version

type Config

+ MaxConcurrentReads int

+ MaxLongPollReads int

type ReadReplica

+ func (r *ReadReplica) GraphReachable(ctx context.Context, req GraphReachableRequest) (GraphReachableResult, error)

type ReplicaConfig

+ MaxConcurrentReads int

+ MaxLongPollReads int

v0.10.2

Sep 4, 2026

v0.10.1

Sep 4, 2026

Changes in this version

+ const MutationErrorCodeExecutionFailed

+ const MutationErrorCodePreconditionFailed

v0.10.0

Sep 4, 2026

Changes in this version

+ const MaxGraphReachableBytes

+ const MaxGraphReachableDepth

+ const MaxGraphReachableResults

+ const MaxGraphReachableScannedEdges

+ const MaxLocalGraphPropertyIndexes

+ var ErrReadVersionMismatch = network.ErrReadVersionMismatch

+ func ValidateGraphReachableRequest(req GraphReachableRequest) error

type Config

+ LocalGraphNodePropertyIndexes []GraphNodePropertyIndex

+ type GraphNodePropertyIndex = types.GraphNodePropertyIndex

+ type GraphReachableNode = types.GraphReachableNode

+ type GraphReachableRequest = types.GraphReachableRequest

+ type GraphReachableResult = types.GraphReachableResult

v0.9.1

Sep 4, 2026

Changes in this version

+ const HTTPErrorCodeCommitUnknown

+ const HTTPErrorCodeDurabilityUnavailable

+ const HTTPErrorCodeInvalidRequest

+ const HTTPErrorCodeMethodNotAllowed

+ const HTTPErrorCodeNotFound

+ const HTTPErrorCodeNotReady

+ const HTTPErrorCodeOverloaded

+ const HTTPErrorCodeQuorumUnavailable

+ const HTTPErrorCodeRequestConflict

+ const MutationCommitted

+ const MutationRejected

+ const ObjectStoreProviderAzure

+ const ObjectStoreProviderFilesystem

+ const ObjectStoreProviderGCS

+ const ObjectStoreProviderS3

+ const RequestKindGraph

+ const RequestKindKV

+ const RequestKindNotify

+ const RequestKindSQL

+ const RequestStateCommitted

+ const RequestStateRejected

+ const RequestStateUnknownOrExpired

type Config

+ ObjStoreAzureClientID string

+ ObjStoreAzureClientSecret string

+ ObjStoreAzureConnectionString string

+ ObjStoreAzureStorageAccount string

+ ObjStoreAzureStorageAccountKey string

+ ObjStoreAzureTenantID string

+ ObjStoreAzureUserAssignedID string

+ ObjStoreServiceAccount string

type DB

+ func (db *DB) ExecuteReturning(ctx context.Context, req ExecuteRequest) (ExecuteResponse, error)

+ func (db *DB) ExecuteReturningOne(ctx context.Context, req ExecuteRequest) (ExecuteResponse, error)

+ func (db *DB) Migrate(ctx context.Context, migrations []Migration) error

type ExecuteResponse

+ func ExecuteReturningMapOne[T any](ctx context.Context, db *DB, req ExecuteRequest, ...) (ExecuteResponse, T, error)

+ func ExecuteReturningMap[T any](ctx context.Context, db *DB, req ExecuteRequest, ...) (ExecuteResponse, []T, error)

+ type HTTPErrorResponse = network.ErrorResponse

+ type Migration struct

+ Name string

+ Statements []SQLStatement

+ Version int64

+ type MutationStatus = types.MutationStatus

+ type NodeID = quepaxa.NodeID

+ type ReadReplica struct

+ func OpenLearner(ctx context.Context, config ReplicaConfig) (*ReadReplica, error)

+ func OpenReadReplica(ctx context.Context, config ReplicaConfig) (*ReadReplica, error)

+ func (r *ReadReplica) Close() error

+ func (r *ReadReplica) GraphChanges(ctx context.Context, req GraphStreamReadRequest) (GraphStreamReadResponse, error)

+ func (r *ReadReplica) GraphQuery(ctx context.Context, req GraphQueryRequest) (GraphResult, error)

+ func (r *ReadReplica) GraphStreamOffset(ctx context.Context, req GraphStreamOffsetRequest) (GraphStreamOffsetResponse, error)

+ func (r *ReadReplica) GraphStreamRead(ctx context.Context, req GraphStreamReadRequest) (GraphStreamReadResponse, error)

+ func (r *ReadReplica) Handler() http.Handler

+ func (r *ReadReplica) KVGet(ctx context.Context, req KVGetRequest) (KVGetResponse, error)

+ func (r *ReadReplica) ObjectStoreStats() ObjectStoreStats

+ func (r *ReadReplica) Query(ctx context.Context, req QueryRequest) (QueryResponse, error)

+ func (r *ReadReplica) Ready() bool

+ func (r *ReadReplica) RequestStatus(ctx context.Context, req RequestStatusRequest) (RequestStatusResponse, error)

+ func (r *ReadReplica) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ func (r *ReadReplica) Status() ReplicaStatus

+ func (r *ReadReplica) Sync(ctx context.Context) error

+ type ReplicaConfig struct

+ AdminToken string

+ ClusterID string

+ DataDir string

+ Members []ReplicaMember

+ ObjStoreAccessKey string

+ ObjStoreAzureClientID string

+ ObjStoreAzureClientSecret string

+ ObjStoreAzureConnectionString string

+ ObjStoreAzureStorageAccount string

+ ObjStoreAzureStorageAccountKey string

+ ObjStoreAzureTenantID string

+ ObjStoreAzureUserAssignedID string

+ ObjStoreBucket string

+ ObjStoreDir string

+ ObjStoreEndpoint string

+ ObjStoreInsecure bool

+ ObjStorePrefix string

+ ObjStoreProvider string

+ ObjStoreRegion string

+ ObjStoreRetries int

+ ObjStoreSecretKey string

+ ObjStoreServiceAccount string

+ ObjStoreSessionToken string

+ ReplicaID string

+ SyncInterval time.Duration

+ type ReplicaMember = network.PeerIdentity

+ func NewReplicaMember(clusterID string, member Member) (ReplicaMember, error)

+ type ReplicaMode string

+ const ReplicaModeLearner

+ const ReplicaModeObjectStore

+ type ReplicaStatus struct

+ AppliedSlot uint64

+ LagSlots uint64

+ LastError string

+ LastSync time.Time

+ Mode ReplicaMode

+ Source string

+ SourceTip uint64

+ type SQLRow struct

+ func (r SQLRow) Columns() []string

+ func (r SQLRow) Len() int

+ func (r SQLRow) Named(name string) (any, error)

+ func (r SQLRow) Value(index int) (any, error)

+ func (r SQLRow) Values() []any

+ type SQLStatementOutputRef = types.SQLStatementOutputRef

+ type SQLStatementResult = types.SQLStatementResult

v0.9.0

Sep 4, 2026

retracted

Changes in this version

+ var ErrGraphResourceLimit = latticedb.ErrResourceLimit

type DB

+ func (db *DB) EnsureGraphNodePropertyIndex(label, property string) error

+ func (db *DB) GraphReachable(ctx context.Context, req GraphReachabilityRequest) (GraphReachabilityResult, error)

+ func (db *DB) OpenLocalSQLReader() (*sql.DB, error)

+ func (db *DB) SpeculateSQL(ctx context.Context, fn func(*sql.Tx) error) error

+ type GraphReachabilityRequest struct

+ EdgeType string

+ MaxDepth uint32

+ MaxResults uint

+ MaxScannedEdges uint

+ NodeFilters map[string]any

+ NodeLabel string

+ ResultProperty string

+ StartLabel string

+ StartProperty string

+ StartValue any

+ type GraphReachabilityResult struct

+ ScannedEdges uint

+ Values []any

v0.8.4

Aug 30, 2026

v0.8.3

Aug 30, 2026

v0.8.2

Aug 30, 2026

v0.8.1

Aug 30, 2026

Changes in this version

+ const MaxHTTPBodyBytes

+ const MaxReplicatedMutationBytes

+ func ValidateExecuteRequest(req ExecuteRequest) error

type DB

+ func (db *DB) Ready() bool

v0.8.0

Aug 30, 2026

Changes in this version

+ const ConsistencyLinearizable

+ const ConsistencyLocal

+ const DefaultHedgeDelay

+ const ObjectStoreDurabilityAsync

+ const ObjectStoreDurabilityBeforeAck

+ var ErrCommitUnknown = network.ErrCommitUnknown

+ var ErrDurabilityUnavailable = network.ErrDurabilityUnavailable

+ var ErrInvalidRequest = network.ErrInvalidRequest

+ var ErrNotReady = network.ErrNotReady

+ var ErrQuorumUnavailable = quepaxa.ErrQuorumUnavailable

+ var ErrRequestConflict = network.ErrRequestConflict

+ type Config struct

+ AdminToken string

+ BindAddr string

+ CheckpointInterval time.Duration

+ CheckpointTailBytes int64

+ ClusterID string

+ DataDir string

+ HedgeDelay *time.Duration

+ MaxWALBytes int64

+ Members []Member

+ NodeID string

+ ObjStoreAccessKey string

+ ObjStoreBatchDelay time.Duration

+ ObjStoreBucket string

+ ObjStoreDir string

+ ObjStoreDurability ObjectStoreDurability

+ ObjStoreEndpoint string

+ ObjStoreGCGracePeriod time.Duration

+ ObjStoreGCInterval time.Duration

+ ObjStoreInsecure bool

+ ObjStorePrefix string

+ ObjStoreProvider string

+ ObjStoreRegion string

+ ObjStoreRetries int

+ ObjStoreSecretKey string

+ ObjStoreSessionToken string

+ ObjStoreSyncInterval time.Duration

+ PeerAddr string

+ type DB struct

+ func Open(ctx context.Context, config Config) (*DB, error)

+ func (db *DB) Close() error

+ func (db *DB) Execute(ctx context.Context, req ExecuteRequest) (ExecuteResponse, error)

+ func (db *DB) GraphChanges(ctx context.Context, req GraphStreamReadRequest) (GraphStreamReadResponse, error)

+ func (db *DB) GraphExecute(ctx context.Context, req GraphCommand) (GraphExecuteResponse, error)

+ func (db *DB) GraphQuery(ctx context.Context, req GraphQueryRequest) (GraphResult, error)

+ func (db *DB) GraphStreamOffset(ctx context.Context, req GraphStreamOffsetRequest) (GraphStreamOffsetResponse, error)

+ func (db *DB) GraphStreamRead(ctx context.Context, req GraphStreamReadRequest) (GraphStreamReadResponse, error)

+ func (db *DB) Handler() http.Handler

+ func (db *DB) KVCAS(ctx context.Context, req KVMutationRequest) (KVMutationResponse, error)

+ func (db *DB) KVDelete(ctx context.Context, req KVMutationRequest) (KVMutationResponse, error)

+ func (db *DB) KVGet(ctx context.Context, req KVGetRequest) (KVGetResponse, error)

+ func (db *DB) KVPut(ctx context.Context, req KVMutationRequest) (KVMutationResponse, error)

+ func (db *DB) NotificationDrops() uint64

+ func (db *DB) NotifyPublish(ctx context.Context, req NotifyCommand) (MutationReceipt, error)

+ func (db *DB) NotifySubscribe(topic string) (<-chan []byte, func(), error)

+ func (db *DB) ObjectStoreStats() (ObjectStoreStats, bool)

+ func (db *DB) Query(ctx context.Context, req QueryRequest) (QueryResponse, error)

+ func (db *DB) RequestStatus(ctx context.Context, req RequestStatusRequest) (RequestStatusResponse, error)

+ func (db *DB) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (db *DB) SetGraphStreamOffset(ctx context.Context, req GraphStreamOffsetRequest) error

+ func (db *DB) TrimGraphStream(ctx context.Context, req GraphStreamTrimRequest) error

+ type ExecuteRequest = network.ExecuteRequest

+ type ExecuteResponse = network.ExecuteResponse

+ type GraphCommand = types.GraphCommand

+ type GraphExecuteResponse = network.GraphExecuteResponse

+ type GraphQueryRequest = network.GraphQueryRequest

+ type GraphResult = types.GraphCommandResult

+ type GraphStreamEvent = types.GraphStreamEvent

+ type GraphStreamOffsetRequest = network.GraphStreamOffsetRequest

+ type GraphStreamOffsetResponse = network.GraphStreamOffsetResponse

+ type GraphStreamReadRequest = network.GraphStreamReadRequest

+ type GraphStreamReadResponse = network.GraphStreamReadResponse

+ type GraphStreamRecord = types.GraphStreamRecord

+ type GraphStreamTrimRequest = network.GraphStreamTrimRequest

+ type KVGetRequest = network.KVGetRequest

+ type KVGetResponse = network.KVGetResponse

+ type KVMutationRequest = network.KVMutationRequest

+ type KVMutationResponse = network.KVMutationResponse

+ type Member = quepaxa.Member

+ type MutationReceipt = types.MutationReceipt

+ type NotifyCommand = types.NotifyCommand

+ type ObjectStoreDurability = types.ObjectStoreDurability

+ type ObjectStoreStats = objstore.Stats

+ type QueryRequest = network.QueryRequest

+ type QueryResponse = network.QueryResponse

+ type RequestStatusRequest = network.RequestStatusRequest

+ type RequestStatusResponse = network.RequestStatusResponse

+ type SQLStatement = types.SQLStatement

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