s4wave_world

package
v0.53.0 Latest Latest
Warning

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

Go to latest
Published: Jul 5, 2026 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source
const SRPCEngineResourceServiceServiceID = "s4wave.world.EngineResourceService"
View Source
const SRPCGraphPathQueryResourceServiceServiceID = "s4wave.world.GraphPathQueryResourceService"
View Source
const SRPCObjectIteratorResourceServiceServiceID = "s4wave.world.ObjectIteratorResourceService"
View Source
const SRPCObjectStateResourceServiceServiceID = "s4wave.world.ObjectStateResourceService"
View Source
const SRPCTxResourceServiceServiceID = "s4wave.world.TxResourceService"
View Source
const SRPCTypedObjectResourceServiceServiceID = "s4wave.world.TypedObjectResourceService"
View Source
const SRPCWatchWorldStateResourceServiceServiceID = "s4wave.world.WatchWorldStateResourceService"
View Source
const SRPCWorldStateResourceServiceServiceID = "s4wave.world.WorldStateResourceService"

Variables

View Source
var (
	GraphEdgeBucketDirection_name = map[int32]string{
		0: "GRAPH_EDGE_BUCKET_DIRECTION_UNSPECIFIED",
		1: "GRAPH_EDGE_BUCKET_DIRECTION_OUT",
		2: "GRAPH_EDGE_BUCKET_DIRECTION_IN",
		3: "GRAPH_EDGE_BUCKET_DIRECTION_BOTH",
	}
	GraphEdgeBucketDirection_value = map[string]int32{
		"GRAPH_EDGE_BUCKET_DIRECTION_UNSPECIFIED": 0,
		"GRAPH_EDGE_BUCKET_DIRECTION_OUT":         1,
		"GRAPH_EDGE_BUCKET_DIRECTION_IN":          2,
		"GRAPH_EDGE_BUCKET_DIRECTION_BOTH":        3,
	}
)

Enum value maps for GraphEdgeBucketDirection.

View Source
var (
	GraphPathDirection_name = map[int32]string{
		0: "GRAPH_PATH_DIRECTION_UNSPECIFIED",
		1: "GRAPH_PATH_DIRECTION_OUT",
		2: "GRAPH_PATH_DIRECTION_IN",
		3: "GRAPH_PATH_DIRECTION_BOTH",
	}
	GraphPathDirection_value = map[string]int32{
		"GRAPH_PATH_DIRECTION_UNSPECIFIED": 0,
		"GRAPH_PATH_DIRECTION_OUT":         1,
		"GRAPH_PATH_DIRECTION_IN":          2,
		"GRAPH_PATH_DIRECTION_BOTH":        3,
	}
)

Enum value maps for GraphPathDirection.

Functions

func NewObjectState

func NewObjectState(client *resource_client.Client, ref resource_client.ResourceRef, objectKey string) (world.ObjectState, error)

NewObjectState creates a new ObjectState resource wrapper.

func NewSRPCEngineResourceServiceHandler

func NewSRPCEngineResourceServiceHandler(impl SRPCEngineResourceServiceServer, serviceID string) srpc.Handler

NewSRPCEngineResourceServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: s4wave.world.EngineResourceService

func NewSRPCGraphPathQueryResourceServiceHandler added in v0.51.6

func NewSRPCGraphPathQueryResourceServiceHandler(impl SRPCGraphPathQueryResourceServiceServer, serviceID string) srpc.Handler

NewSRPCGraphPathQueryResourceServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: s4wave.world.GraphPathQueryResourceService

func NewSRPCObjectIteratorResourceServiceHandler

func NewSRPCObjectIteratorResourceServiceHandler(impl SRPCObjectIteratorResourceServiceServer, serviceID string) srpc.Handler

NewSRPCObjectIteratorResourceServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: s4wave.world.ObjectIteratorResourceService

func NewSRPCObjectStateResourceServiceHandler

func NewSRPCObjectStateResourceServiceHandler(impl SRPCObjectStateResourceServiceServer, serviceID string) srpc.Handler

NewSRPCObjectStateResourceServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: s4wave.world.ObjectStateResourceService

func NewSRPCTxResourceServiceHandler

func NewSRPCTxResourceServiceHandler(impl SRPCTxResourceServiceServer, serviceID string) srpc.Handler

NewSRPCTxResourceServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: s4wave.world.TxResourceService

func NewSRPCTypedObjectResourceServiceHandler

func NewSRPCTypedObjectResourceServiceHandler(impl SRPCTypedObjectResourceServiceServer, serviceID string) srpc.Handler

NewSRPCTypedObjectResourceServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: s4wave.world.TypedObjectResourceService

func NewSRPCWatchWorldStateResourceServiceHandler

func NewSRPCWatchWorldStateResourceServiceHandler(impl SRPCWatchWorldStateResourceServiceServer, serviceID string) srpc.Handler

NewSRPCWatchWorldStateResourceServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: s4wave.world.WatchWorldStateResourceService

func NewSRPCWorldStateResourceServiceHandler

func NewSRPCWorldStateResourceServiceHandler(impl SRPCWorldStateResourceServiceServer, serviceID string) srpc.Handler

NewSRPCWorldStateResourceServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: s4wave.world.WorldStateResourceService

func SRPCRegisterEngineResourceService

func SRPCRegisterEngineResourceService(mux srpc.Mux, impl SRPCEngineResourceServiceServer) error

SRPCRegisterEngineResourceService registers the implementation with the mux. Uses the default serviceID: s4wave.world.EngineResourceService

func SRPCRegisterGraphPathQueryResourceService added in v0.51.6

func SRPCRegisterGraphPathQueryResourceService(mux srpc.Mux, impl SRPCGraphPathQueryResourceServiceServer) error

SRPCRegisterGraphPathQueryResourceService registers the implementation with the mux. Uses the default serviceID: s4wave.world.GraphPathQueryResourceService

func SRPCRegisterObjectIteratorResourceService

func SRPCRegisterObjectIteratorResourceService(mux srpc.Mux, impl SRPCObjectIteratorResourceServiceServer) error

SRPCRegisterObjectIteratorResourceService registers the implementation with the mux. Uses the default serviceID: s4wave.world.ObjectIteratorResourceService

func SRPCRegisterObjectStateResourceService

func SRPCRegisterObjectStateResourceService(mux srpc.Mux, impl SRPCObjectStateResourceServiceServer) error

SRPCRegisterObjectStateResourceService registers the implementation with the mux. Uses the default serviceID: s4wave.world.ObjectStateResourceService

func SRPCRegisterTxResourceService

func SRPCRegisterTxResourceService(mux srpc.Mux, impl SRPCTxResourceServiceServer) error

SRPCRegisterTxResourceService registers the implementation with the mux. Uses the default serviceID: s4wave.world.TxResourceService

func SRPCRegisterTypedObjectResourceService

func SRPCRegisterTypedObjectResourceService(mux srpc.Mux, impl SRPCTypedObjectResourceServiceServer) error

SRPCRegisterTypedObjectResourceService registers the implementation with the mux. Uses the default serviceID: s4wave.world.TypedObjectResourceService

func SRPCRegisterWatchWorldStateResourceService

func SRPCRegisterWatchWorldStateResourceService(mux srpc.Mux, impl SRPCWatchWorldStateResourceServiceServer) error

SRPCRegisterWatchWorldStateResourceService registers the implementation with the mux. Uses the default serviceID: s4wave.world.WatchWorldStateResourceService

func SRPCRegisterWorldStateResourceService

func SRPCRegisterWorldStateResourceService(mux srpc.Mux, impl SRPCWorldStateResourceServiceServer) error

SRPCRegisterWorldStateResourceService registers the implementation with the mux. Uses the default serviceID: s4wave.world.WorldStateResourceService

Types

type AccessTypedObjectRequest

type AccessTypedObjectRequest struct {

	// ObjectKey is the key of the object to access.
	ObjectKey string `protobuf:"bytes,1,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// contains filtered or unexported fields
}

AccessTypedObjectRequest is the request type for AccessTypedObject.

func (*AccessTypedObjectRequest) CloneMessageVT

func (*AccessTypedObjectRequest) CloneVT

func (*AccessTypedObjectRequest) EqualMessageVT

func (this *AccessTypedObjectRequest) EqualMessageVT(thatMsg any) bool

func (*AccessTypedObjectRequest) EqualVT

func (*AccessTypedObjectRequest) GetObjectKey

func (x *AccessTypedObjectRequest) GetObjectKey() string

func (*AccessTypedObjectRequest) MarshalJSON

func (x *AccessTypedObjectRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the AccessTypedObjectRequest to JSON.

func (*AccessTypedObjectRequest) MarshalProtoJSON

func (x *AccessTypedObjectRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the AccessTypedObjectRequest message to JSON.

func (*AccessTypedObjectRequest) MarshalProtoText

func (x *AccessTypedObjectRequest) MarshalProtoText() string

func (*AccessTypedObjectRequest) MarshalToSizedBufferVT

func (m *AccessTypedObjectRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AccessTypedObjectRequest) MarshalToVT

func (m *AccessTypedObjectRequest) MarshalToVT(dAtA []byte) (int, error)

func (*AccessTypedObjectRequest) MarshalVT

func (m *AccessTypedObjectRequest) MarshalVT() (dAtA []byte, err error)

func (*AccessTypedObjectRequest) ProtoMessage

func (*AccessTypedObjectRequest) ProtoMessage()

func (*AccessTypedObjectRequest) Reset

func (x *AccessTypedObjectRequest) Reset()

func (*AccessTypedObjectRequest) SizeVT

func (m *AccessTypedObjectRequest) SizeVT() (n int)

func (*AccessTypedObjectRequest) String

func (x *AccessTypedObjectRequest) String() string

func (*AccessTypedObjectRequest) UnmarshalJSON

func (x *AccessTypedObjectRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the AccessTypedObjectRequest from JSON.

func (*AccessTypedObjectRequest) UnmarshalProtoJSON

func (x *AccessTypedObjectRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the AccessTypedObjectRequest message from JSON.

func (*AccessTypedObjectRequest) UnmarshalVT

func (m *AccessTypedObjectRequest) UnmarshalVT(dAtA []byte) error

type AccessTypedObjectResponse

type AccessTypedObjectResponse struct {

	// ResourceId is the ID of the typed resource.
	// The resource implements the RPC service appropriate for the object type.
	ResourceId uint32 `protobuf:"varint,1,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// TypeId is the type identifier of the object.
	TypeId string `protobuf:"bytes,2,opt,name=type_id,json=typeId,proto3" json:"typeId,omitempty"`
	// contains filtered or unexported fields
}

AccessTypedObjectResponse is the response type for AccessTypedObject.

func (*AccessTypedObjectResponse) CloneMessageVT

func (*AccessTypedObjectResponse) CloneVT

func (*AccessTypedObjectResponse) EqualMessageVT

func (this *AccessTypedObjectResponse) EqualMessageVT(thatMsg any) bool

func (*AccessTypedObjectResponse) EqualVT

func (*AccessTypedObjectResponse) GetResourceId

func (x *AccessTypedObjectResponse) GetResourceId() uint32

func (*AccessTypedObjectResponse) GetTypeId

func (x *AccessTypedObjectResponse) GetTypeId() string

func (*AccessTypedObjectResponse) MarshalJSON

func (x *AccessTypedObjectResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the AccessTypedObjectResponse to JSON.

func (*AccessTypedObjectResponse) MarshalProtoJSON

func (x *AccessTypedObjectResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the AccessTypedObjectResponse message to JSON.

func (*AccessTypedObjectResponse) MarshalProtoText

func (x *AccessTypedObjectResponse) MarshalProtoText() string

func (*AccessTypedObjectResponse) MarshalToSizedBufferVT

func (m *AccessTypedObjectResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AccessTypedObjectResponse) MarshalToVT

func (m *AccessTypedObjectResponse) MarshalToVT(dAtA []byte) (int, error)

func (*AccessTypedObjectResponse) MarshalVT

func (m *AccessTypedObjectResponse) MarshalVT() (dAtA []byte, err error)

func (*AccessTypedObjectResponse) ProtoMessage

func (*AccessTypedObjectResponse) ProtoMessage()

func (*AccessTypedObjectResponse) Reset

func (x *AccessTypedObjectResponse) Reset()

func (*AccessTypedObjectResponse) SizeVT

func (m *AccessTypedObjectResponse) SizeVT() (n int)

func (*AccessTypedObjectResponse) String

func (x *AccessTypedObjectResponse) String() string

func (*AccessTypedObjectResponse) UnmarshalJSON

func (x *AccessTypedObjectResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the AccessTypedObjectResponse from JSON.

func (*AccessTypedObjectResponse) UnmarshalProtoJSON

func (x *AccessTypedObjectResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the AccessTypedObjectResponse message from JSON.

func (*AccessTypedObjectResponse) UnmarshalVT

func (m *AccessTypedObjectResponse) UnmarshalVT(dAtA []byte) error

type AccessWorldStateRequest

type AccessWorldStateRequest struct {

	// Ref is an optional reference to access a specific object.
	// If unset, we will access the Root of the WorldState.
	Ref *bucket.ObjectRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

AccessWorldStateRequest is the request type for AccessWorldState.

func (*AccessWorldStateRequest) CloneMessageVT

func (*AccessWorldStateRequest) CloneVT

func (*AccessWorldStateRequest) EqualMessageVT

func (this *AccessWorldStateRequest) EqualMessageVT(thatMsg any) bool

func (*AccessWorldStateRequest) EqualVT

func (*AccessWorldStateRequest) GetRef

func (*AccessWorldStateRequest) MarshalJSON

func (x *AccessWorldStateRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the AccessWorldStateRequest to JSON.

func (*AccessWorldStateRequest) MarshalProtoJSON

func (x *AccessWorldStateRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the AccessWorldStateRequest message to JSON.

func (*AccessWorldStateRequest) MarshalProtoText

func (x *AccessWorldStateRequest) MarshalProtoText() string

func (*AccessWorldStateRequest) MarshalToSizedBufferVT

func (m *AccessWorldStateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AccessWorldStateRequest) MarshalToVT

func (m *AccessWorldStateRequest) MarshalToVT(dAtA []byte) (int, error)

func (*AccessWorldStateRequest) MarshalVT

func (m *AccessWorldStateRequest) MarshalVT() (dAtA []byte, err error)

func (*AccessWorldStateRequest) ProtoMessage

func (*AccessWorldStateRequest) ProtoMessage()

func (*AccessWorldStateRequest) Reset

func (x *AccessWorldStateRequest) Reset()

func (*AccessWorldStateRequest) SizeVT

func (m *AccessWorldStateRequest) SizeVT() (n int)

func (*AccessWorldStateRequest) String

func (x *AccessWorldStateRequest) String() string

func (*AccessWorldStateRequest) UnmarshalJSON

func (x *AccessWorldStateRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the AccessWorldStateRequest from JSON.

func (*AccessWorldStateRequest) UnmarshalProtoJSON

func (x *AccessWorldStateRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the AccessWorldStateRequest message from JSON.

func (*AccessWorldStateRequest) UnmarshalVT

func (m *AccessWorldStateRequest) UnmarshalVT(dAtA []byte) error

type AccessWorldStateResponse

type AccessWorldStateResponse struct {

	// ResourceId is the ID of the bucket cursor resource for accessing world state.
	ResourceId uint32 `protobuf:"varint,1,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// contains filtered or unexported fields
}

AccessWorldStateResponse is the response type for AccessWorldState.

func (*AccessWorldStateResponse) CloneMessageVT

func (*AccessWorldStateResponse) CloneVT

func (*AccessWorldStateResponse) EqualMessageVT

func (this *AccessWorldStateResponse) EqualMessageVT(thatMsg any) bool

func (*AccessWorldStateResponse) EqualVT

func (*AccessWorldStateResponse) GetResourceId

func (x *AccessWorldStateResponse) GetResourceId() uint32

func (*AccessWorldStateResponse) MarshalJSON

func (x *AccessWorldStateResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the AccessWorldStateResponse to JSON.

func (*AccessWorldStateResponse) MarshalProtoJSON

func (x *AccessWorldStateResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the AccessWorldStateResponse message to JSON.

func (*AccessWorldStateResponse) MarshalProtoText

func (x *AccessWorldStateResponse) MarshalProtoText() string

func (*AccessWorldStateResponse) MarshalToSizedBufferVT

func (m *AccessWorldStateResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AccessWorldStateResponse) MarshalToVT

func (m *AccessWorldStateResponse) MarshalToVT(dAtA []byte) (int, error)

func (*AccessWorldStateResponse) MarshalVT

func (m *AccessWorldStateResponse) MarshalVT() (dAtA []byte, err error)

func (*AccessWorldStateResponse) ProtoMessage

func (*AccessWorldStateResponse) ProtoMessage()

func (*AccessWorldStateResponse) Reset

func (x *AccessWorldStateResponse) Reset()

func (*AccessWorldStateResponse) SizeVT

func (m *AccessWorldStateResponse) SizeVT() (n int)

func (*AccessWorldStateResponse) String

func (x *AccessWorldStateResponse) String() string

func (*AccessWorldStateResponse) UnmarshalJSON

func (x *AccessWorldStateResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the AccessWorldStateResponse from JSON.

func (*AccessWorldStateResponse) UnmarshalProtoJSON

func (x *AccessWorldStateResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the AccessWorldStateResponse message from JSON.

func (*AccessWorldStateResponse) UnmarshalVT

func (m *AccessWorldStateResponse) UnmarshalVT(dAtA []byte) error

type ApplyObjectOpRequest

type ApplyObjectOpRequest struct {

	// OpTypeId is the operation type identifier.
	OpTypeId string `protobuf:"bytes,1,opt,name=op_type_id,json=opTypeId,proto3" json:"opTypeId,omitempty"`
	// OpData is the encoded operation body.
	OpData []byte `protobuf:"bytes,2,opt,name=op_data,json=opData,proto3" json:"opData,omitempty"`
	// OpSender is the peer ID of the sender applying the operation.
	OpSender string `protobuf:"bytes,3,opt,name=op_sender,json=opSender,proto3" json:"opSender,omitempty"`
	// contains filtered or unexported fields
}

ApplyObjectOpRequest is the request type for ApplyObjectOp.

func (*ApplyObjectOpRequest) CloneMessageVT

func (*ApplyObjectOpRequest) CloneVT

func (*ApplyObjectOpRequest) EqualMessageVT

func (this *ApplyObjectOpRequest) EqualMessageVT(thatMsg any) bool

func (*ApplyObjectOpRequest) EqualVT

func (this *ApplyObjectOpRequest) EqualVT(that *ApplyObjectOpRequest) bool

func (*ApplyObjectOpRequest) GetOpData

func (x *ApplyObjectOpRequest) GetOpData() []byte

func (*ApplyObjectOpRequest) GetOpSender

func (x *ApplyObjectOpRequest) GetOpSender() string

func (*ApplyObjectOpRequest) GetOpTypeId

func (x *ApplyObjectOpRequest) GetOpTypeId() string

func (*ApplyObjectOpRequest) MarshalJSON

func (x *ApplyObjectOpRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ApplyObjectOpRequest to JSON.

func (*ApplyObjectOpRequest) MarshalProtoJSON

func (x *ApplyObjectOpRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ApplyObjectOpRequest message to JSON.

func (*ApplyObjectOpRequest) MarshalProtoText

func (x *ApplyObjectOpRequest) MarshalProtoText() string

func (*ApplyObjectOpRequest) MarshalToSizedBufferVT

func (m *ApplyObjectOpRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ApplyObjectOpRequest) MarshalToVT

func (m *ApplyObjectOpRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ApplyObjectOpRequest) MarshalVT

func (m *ApplyObjectOpRequest) MarshalVT() (dAtA []byte, err error)

func (*ApplyObjectOpRequest) ParsePeerID

func (r *ApplyObjectOpRequest) ParsePeerID() (peer.ID, error)

ParsePeerID parses the op sender peer ID.

func (*ApplyObjectOpRequest) ProtoMessage

func (*ApplyObjectOpRequest) ProtoMessage()

func (*ApplyObjectOpRequest) Reset

func (x *ApplyObjectOpRequest) Reset()

func (*ApplyObjectOpRequest) SizeVT

func (m *ApplyObjectOpRequest) SizeVT() (n int)

func (*ApplyObjectOpRequest) String

func (x *ApplyObjectOpRequest) String() string

func (*ApplyObjectOpRequest) UnmarshalJSON

func (x *ApplyObjectOpRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ApplyObjectOpRequest from JSON.

func (*ApplyObjectOpRequest) UnmarshalProtoJSON

func (x *ApplyObjectOpRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ApplyObjectOpRequest message from JSON.

func (*ApplyObjectOpRequest) UnmarshalVT

func (m *ApplyObjectOpRequest) UnmarshalVT(dAtA []byte) error

type ApplyObjectOpResponse

type ApplyObjectOpResponse struct {

	// Rev is the revision number following the operation execution.
	Rev uint64 `protobuf:"varint,1,opt,name=rev,proto3" json:"rev,omitempty"`
	// SysErr indicates if the error is a transient system error.
	SysErr bool `protobuf:"varint,2,opt,name=sys_err,json=sysErr,proto3" json:"sysErr,omitempty"`
	// contains filtered or unexported fields
}

ApplyObjectOpResponse is the response type for ApplyObjectOp.

func (*ApplyObjectOpResponse) CloneMessageVT

func (*ApplyObjectOpResponse) CloneVT

func (*ApplyObjectOpResponse) EqualMessageVT

func (this *ApplyObjectOpResponse) EqualMessageVT(thatMsg any) bool

func (*ApplyObjectOpResponse) EqualVT

func (this *ApplyObjectOpResponse) EqualVT(that *ApplyObjectOpResponse) bool

func (*ApplyObjectOpResponse) GetRev

func (x *ApplyObjectOpResponse) GetRev() uint64

func (*ApplyObjectOpResponse) GetSysErr

func (x *ApplyObjectOpResponse) GetSysErr() bool

func (*ApplyObjectOpResponse) MarshalJSON

func (x *ApplyObjectOpResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ApplyObjectOpResponse to JSON.

func (*ApplyObjectOpResponse) MarshalProtoJSON

func (x *ApplyObjectOpResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ApplyObjectOpResponse message to JSON.

func (*ApplyObjectOpResponse) MarshalProtoText

func (x *ApplyObjectOpResponse) MarshalProtoText() string

func (*ApplyObjectOpResponse) MarshalToSizedBufferVT

func (m *ApplyObjectOpResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ApplyObjectOpResponse) MarshalToVT

func (m *ApplyObjectOpResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ApplyObjectOpResponse) MarshalVT

func (m *ApplyObjectOpResponse) MarshalVT() (dAtA []byte, err error)

func (*ApplyObjectOpResponse) ProtoMessage

func (*ApplyObjectOpResponse) ProtoMessage()

func (*ApplyObjectOpResponse) Reset

func (x *ApplyObjectOpResponse) Reset()

func (*ApplyObjectOpResponse) SizeVT

func (m *ApplyObjectOpResponse) SizeVT() (n int)

func (*ApplyObjectOpResponse) String

func (x *ApplyObjectOpResponse) String() string

func (*ApplyObjectOpResponse) UnmarshalJSON

func (x *ApplyObjectOpResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ApplyObjectOpResponse from JSON.

func (*ApplyObjectOpResponse) UnmarshalProtoJSON

func (x *ApplyObjectOpResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ApplyObjectOpResponse message from JSON.

func (*ApplyObjectOpResponse) UnmarshalVT

func (m *ApplyObjectOpResponse) UnmarshalVT(dAtA []byte) error

type ApplyWorldOpRequest

type ApplyWorldOpRequest struct {

	// OpTypeId is the operation type identifier.
	OpTypeId string `protobuf:"bytes,1,opt,name=op_type_id,json=opTypeId,proto3" json:"opTypeId,omitempty"`
	// OpData is the encoded operation body.
	OpData []byte `protobuf:"bytes,2,opt,name=op_data,json=opData,proto3" json:"opData,omitempty"`
	// OpSender is the peer ID of the sender applying the operation.
	OpSender string `protobuf:"bytes,3,opt,name=op_sender,json=opSender,proto3" json:"opSender,omitempty"`
	// contains filtered or unexported fields
}

ApplyWorldOpRequest is the request type for ApplyWorldOp.

func (*ApplyWorldOpRequest) CloneMessageVT

func (*ApplyWorldOpRequest) CloneVT

func (*ApplyWorldOpRequest) EqualMessageVT

func (this *ApplyWorldOpRequest) EqualMessageVT(thatMsg any) bool

func (*ApplyWorldOpRequest) EqualVT

func (this *ApplyWorldOpRequest) EqualVT(that *ApplyWorldOpRequest) bool

func (*ApplyWorldOpRequest) GetOpData

func (x *ApplyWorldOpRequest) GetOpData() []byte

func (*ApplyWorldOpRequest) GetOpSender

func (x *ApplyWorldOpRequest) GetOpSender() string

func (*ApplyWorldOpRequest) GetOpTypeId

func (x *ApplyWorldOpRequest) GetOpTypeId() string

func (*ApplyWorldOpRequest) MarshalJSON

func (x *ApplyWorldOpRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ApplyWorldOpRequest to JSON.

func (*ApplyWorldOpRequest) MarshalProtoJSON

func (x *ApplyWorldOpRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ApplyWorldOpRequest message to JSON.

func (*ApplyWorldOpRequest) MarshalProtoText

func (x *ApplyWorldOpRequest) MarshalProtoText() string

func (*ApplyWorldOpRequest) MarshalToSizedBufferVT

func (m *ApplyWorldOpRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ApplyWorldOpRequest) MarshalToVT

func (m *ApplyWorldOpRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ApplyWorldOpRequest) MarshalVT

func (m *ApplyWorldOpRequest) MarshalVT() (dAtA []byte, err error)

func (*ApplyWorldOpRequest) ParsePeerID

func (r *ApplyWorldOpRequest) ParsePeerID() (peer.ID, error)

ParsePeerID parses the op sender peer ID.

func (*ApplyWorldOpRequest) ProtoMessage

func (*ApplyWorldOpRequest) ProtoMessage()

func (*ApplyWorldOpRequest) Reset

func (x *ApplyWorldOpRequest) Reset()

func (*ApplyWorldOpRequest) SizeVT

func (m *ApplyWorldOpRequest) SizeVT() (n int)

func (*ApplyWorldOpRequest) String

func (x *ApplyWorldOpRequest) String() string

func (*ApplyWorldOpRequest) UnmarshalJSON

func (x *ApplyWorldOpRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ApplyWorldOpRequest from JSON.

func (*ApplyWorldOpRequest) UnmarshalProtoJSON

func (x *ApplyWorldOpRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ApplyWorldOpRequest message from JSON.

func (*ApplyWorldOpRequest) UnmarshalVT

func (m *ApplyWorldOpRequest) UnmarshalVT(dAtA []byte) error

type ApplyWorldOpResponse

type ApplyWorldOpResponse struct {

	// Seqno is the sequence number following the operation execution.
	Seqno uint64 `protobuf:"varint,1,opt,name=seqno,proto3" json:"seqno,omitempty"`
	// SysErr indicates if the error is a transient system error.
	SysErr bool `protobuf:"varint,2,opt,name=sys_err,json=sysErr,proto3" json:"sysErr,omitempty"`
	// contains filtered or unexported fields
}

ApplyWorldOpResponse is the response type for ApplyWorldOp.

func (*ApplyWorldOpResponse) CloneMessageVT

func (*ApplyWorldOpResponse) CloneVT

func (*ApplyWorldOpResponse) EqualMessageVT

func (this *ApplyWorldOpResponse) EqualMessageVT(thatMsg any) bool

func (*ApplyWorldOpResponse) EqualVT

func (this *ApplyWorldOpResponse) EqualVT(that *ApplyWorldOpResponse) bool

func (*ApplyWorldOpResponse) GetSeqno

func (x *ApplyWorldOpResponse) GetSeqno() uint64

func (*ApplyWorldOpResponse) GetSysErr

func (x *ApplyWorldOpResponse) GetSysErr() bool

func (*ApplyWorldOpResponse) MarshalJSON

func (x *ApplyWorldOpResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ApplyWorldOpResponse to JSON.

func (*ApplyWorldOpResponse) MarshalProtoJSON

func (x *ApplyWorldOpResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ApplyWorldOpResponse message to JSON.

func (*ApplyWorldOpResponse) MarshalProtoText

func (x *ApplyWorldOpResponse) MarshalProtoText() string

func (*ApplyWorldOpResponse) MarshalToSizedBufferVT

func (m *ApplyWorldOpResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ApplyWorldOpResponse) MarshalToVT

func (m *ApplyWorldOpResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ApplyWorldOpResponse) MarshalVT

func (m *ApplyWorldOpResponse) MarshalVT() (dAtA []byte, err error)

func (*ApplyWorldOpResponse) ProtoMessage

func (*ApplyWorldOpResponse) ProtoMessage()

func (*ApplyWorldOpResponse) Reset

func (x *ApplyWorldOpResponse) Reset()

func (*ApplyWorldOpResponse) SizeVT

func (m *ApplyWorldOpResponse) SizeVT() (n int)

func (*ApplyWorldOpResponse) String

func (x *ApplyWorldOpResponse) String() string

func (*ApplyWorldOpResponse) UnmarshalJSON

func (x *ApplyWorldOpResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ApplyWorldOpResponse from JSON.

func (*ApplyWorldOpResponse) UnmarshalProtoJSON

func (x *ApplyWorldOpResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ApplyWorldOpResponse message from JSON.

func (*ApplyWorldOpResponse) UnmarshalVT

func (m *ApplyWorldOpResponse) UnmarshalVT(dAtA []byte) error

type BuildStorageCursorRequest

type BuildStorageCursorRequest struct {
	// contains filtered or unexported fields
}

BuildStorageCursorRequest is the request type for BuildStorageCursor.

func (*BuildStorageCursorRequest) CloneMessageVT

func (*BuildStorageCursorRequest) CloneVT

func (*BuildStorageCursorRequest) EqualMessageVT

func (this *BuildStorageCursorRequest) EqualMessageVT(thatMsg any) bool

func (*BuildStorageCursorRequest) EqualVT

func (*BuildStorageCursorRequest) MarshalJSON

func (x *BuildStorageCursorRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the BuildStorageCursorRequest to JSON.

func (*BuildStorageCursorRequest) MarshalProtoJSON

func (x *BuildStorageCursorRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the BuildStorageCursorRequest message to JSON.

func (*BuildStorageCursorRequest) MarshalProtoText

func (x *BuildStorageCursorRequest) MarshalProtoText() string

func (*BuildStorageCursorRequest) MarshalToSizedBufferVT

func (m *BuildStorageCursorRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BuildStorageCursorRequest) MarshalToVT

func (m *BuildStorageCursorRequest) MarshalToVT(dAtA []byte) (int, error)

func (*BuildStorageCursorRequest) MarshalVT

func (m *BuildStorageCursorRequest) MarshalVT() (dAtA []byte, err error)

func (*BuildStorageCursorRequest) ProtoMessage

func (*BuildStorageCursorRequest) ProtoMessage()

func (*BuildStorageCursorRequest) Reset

func (x *BuildStorageCursorRequest) Reset()

func (*BuildStorageCursorRequest) SizeVT

func (m *BuildStorageCursorRequest) SizeVT() (n int)

func (*BuildStorageCursorRequest) String

func (x *BuildStorageCursorRequest) String() string

func (*BuildStorageCursorRequest) UnmarshalJSON

func (x *BuildStorageCursorRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the BuildStorageCursorRequest from JSON.

func (*BuildStorageCursorRequest) UnmarshalProtoJSON

func (x *BuildStorageCursorRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the BuildStorageCursorRequest message from JSON.

func (*BuildStorageCursorRequest) UnmarshalVT

func (m *BuildStorageCursorRequest) UnmarshalVT(dAtA []byte) error

type BuildStorageCursorResponse

type BuildStorageCursorResponse struct {

	// ResourceId is the ID of the storage cursor resource.
	ResourceId uint32 `protobuf:"varint,1,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// contains filtered or unexported fields
}

BuildStorageCursorResponse is the response type for BuildStorageCursor.

func (*BuildStorageCursorResponse) CloneMessageVT

func (*BuildStorageCursorResponse) CloneVT

func (*BuildStorageCursorResponse) EqualMessageVT

func (this *BuildStorageCursorResponse) EqualMessageVT(thatMsg any) bool

func (*BuildStorageCursorResponse) EqualVT

func (*BuildStorageCursorResponse) GetResourceId

func (x *BuildStorageCursorResponse) GetResourceId() uint32

func (*BuildStorageCursorResponse) MarshalJSON

func (x *BuildStorageCursorResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the BuildStorageCursorResponse to JSON.

func (*BuildStorageCursorResponse) MarshalProtoJSON

func (x *BuildStorageCursorResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the BuildStorageCursorResponse message to JSON.

func (*BuildStorageCursorResponse) MarshalProtoText

func (x *BuildStorageCursorResponse) MarshalProtoText() string

func (*BuildStorageCursorResponse) MarshalToSizedBufferVT

func (m *BuildStorageCursorResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BuildStorageCursorResponse) MarshalToVT

func (m *BuildStorageCursorResponse) MarshalToVT(dAtA []byte) (int, error)

func (*BuildStorageCursorResponse) MarshalVT

func (m *BuildStorageCursorResponse) MarshalVT() (dAtA []byte, err error)

func (*BuildStorageCursorResponse) ProtoMessage

func (*BuildStorageCursorResponse) ProtoMessage()

func (*BuildStorageCursorResponse) Reset

func (x *BuildStorageCursorResponse) Reset()

func (*BuildStorageCursorResponse) SizeVT

func (m *BuildStorageCursorResponse) SizeVT() (n int)

func (*BuildStorageCursorResponse) String

func (x *BuildStorageCursorResponse) String() string

func (*BuildStorageCursorResponse) UnmarshalJSON

func (x *BuildStorageCursorResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the BuildStorageCursorResponse from JSON.

func (*BuildStorageCursorResponse) UnmarshalProtoJSON

func (x *BuildStorageCursorResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the BuildStorageCursorResponse message from JSON.

func (*BuildStorageCursorResponse) UnmarshalVT

func (m *BuildStorageCursorResponse) UnmarshalVT(dAtA []byte) error

type CloseGraphPathQueryRequest added in v0.51.6

type CloseGraphPathQueryRequest struct {
	// contains filtered or unexported fields
}

CloseGraphPathQueryRequest is the request type for GraphPathQuery Close.

func (*CloseGraphPathQueryRequest) CloneMessageVT added in v0.51.6

func (*CloseGraphPathQueryRequest) CloneVT added in v0.51.6

func (*CloseGraphPathQueryRequest) EqualMessageVT added in v0.51.6

func (this *CloseGraphPathQueryRequest) EqualMessageVT(thatMsg any) bool

func (*CloseGraphPathQueryRequest) EqualVT added in v0.51.6

func (*CloseGraphPathQueryRequest) MarshalJSON added in v0.51.6

func (x *CloseGraphPathQueryRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the CloseGraphPathQueryRequest to JSON.

func (*CloseGraphPathQueryRequest) MarshalProtoJSON added in v0.51.6

func (x *CloseGraphPathQueryRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the CloseGraphPathQueryRequest message to JSON.

func (*CloseGraphPathQueryRequest) MarshalProtoText added in v0.51.6

func (x *CloseGraphPathQueryRequest) MarshalProtoText() string

func (*CloseGraphPathQueryRequest) MarshalToSizedBufferVT added in v0.51.6

func (m *CloseGraphPathQueryRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CloseGraphPathQueryRequest) MarshalToVT added in v0.51.6

func (m *CloseGraphPathQueryRequest) MarshalToVT(dAtA []byte) (int, error)

func (*CloseGraphPathQueryRequest) MarshalVT added in v0.51.6

func (m *CloseGraphPathQueryRequest) MarshalVT() (dAtA []byte, err error)

func (*CloseGraphPathQueryRequest) ProtoMessage added in v0.51.6

func (*CloseGraphPathQueryRequest) ProtoMessage()

func (*CloseGraphPathQueryRequest) Reset added in v0.51.6

func (x *CloseGraphPathQueryRequest) Reset()

func (*CloseGraphPathQueryRequest) SizeVT added in v0.51.6

func (m *CloseGraphPathQueryRequest) SizeVT() (n int)

func (*CloseGraphPathQueryRequest) String added in v0.51.6

func (x *CloseGraphPathQueryRequest) String() string

func (*CloseGraphPathQueryRequest) UnmarshalJSON added in v0.51.6

func (x *CloseGraphPathQueryRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the CloseGraphPathQueryRequest from JSON.

func (*CloseGraphPathQueryRequest) UnmarshalProtoJSON added in v0.51.6

func (x *CloseGraphPathQueryRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the CloseGraphPathQueryRequest message from JSON.

func (*CloseGraphPathQueryRequest) UnmarshalVT added in v0.51.6

func (m *CloseGraphPathQueryRequest) UnmarshalVT(dAtA []byte) error

type CloseGraphPathQueryResponse added in v0.51.6

type CloseGraphPathQueryResponse struct {
	// contains filtered or unexported fields
}

CloseGraphPathQueryResponse is the response type for GraphPathQuery Close.

func (*CloseGraphPathQueryResponse) CloneMessageVT added in v0.51.6

func (*CloseGraphPathQueryResponse) CloneVT added in v0.51.6

func (*CloseGraphPathQueryResponse) EqualMessageVT added in v0.51.6

func (this *CloseGraphPathQueryResponse) EqualMessageVT(thatMsg any) bool

func (*CloseGraphPathQueryResponse) EqualVT added in v0.51.6

func (*CloseGraphPathQueryResponse) MarshalJSON added in v0.51.6

func (x *CloseGraphPathQueryResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the CloseGraphPathQueryResponse to JSON.

func (*CloseGraphPathQueryResponse) MarshalProtoJSON added in v0.51.6

func (x *CloseGraphPathQueryResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the CloseGraphPathQueryResponse message to JSON.

func (*CloseGraphPathQueryResponse) MarshalProtoText added in v0.51.6

func (x *CloseGraphPathQueryResponse) MarshalProtoText() string

func (*CloseGraphPathQueryResponse) MarshalToSizedBufferVT added in v0.51.6

func (m *CloseGraphPathQueryResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CloseGraphPathQueryResponse) MarshalToVT added in v0.51.6

func (m *CloseGraphPathQueryResponse) MarshalToVT(dAtA []byte) (int, error)

func (*CloseGraphPathQueryResponse) MarshalVT added in v0.51.6

func (m *CloseGraphPathQueryResponse) MarshalVT() (dAtA []byte, err error)

func (*CloseGraphPathQueryResponse) ProtoMessage added in v0.51.6

func (*CloseGraphPathQueryResponse) ProtoMessage()

func (*CloseGraphPathQueryResponse) Reset added in v0.51.6

func (x *CloseGraphPathQueryResponse) Reset()

func (*CloseGraphPathQueryResponse) SizeVT added in v0.51.6

func (m *CloseGraphPathQueryResponse) SizeVT() (n int)

func (*CloseGraphPathQueryResponse) String added in v0.51.6

func (x *CloseGraphPathQueryResponse) String() string

func (*CloseGraphPathQueryResponse) UnmarshalJSON added in v0.51.6

func (x *CloseGraphPathQueryResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the CloseGraphPathQueryResponse from JSON.

func (*CloseGraphPathQueryResponse) UnmarshalProtoJSON added in v0.51.6

func (x *CloseGraphPathQueryResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the CloseGraphPathQueryResponse message from JSON.

func (*CloseGraphPathQueryResponse) UnmarshalVT added in v0.51.6

func (m *CloseGraphPathQueryResponse) UnmarshalVT(dAtA []byte) error

type CloseRequest

type CloseRequest struct {
	// contains filtered or unexported fields
}

CloseRequest is the request type for Close.

func (*CloseRequest) CloneMessageVT

func (m *CloseRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*CloseRequest) CloneVT

func (m *CloseRequest) CloneVT() *CloseRequest

func (*CloseRequest) EqualMessageVT

func (this *CloseRequest) EqualMessageVT(thatMsg any) bool

func (*CloseRequest) EqualVT

func (this *CloseRequest) EqualVT(that *CloseRequest) bool

func (*CloseRequest) MarshalJSON

func (x *CloseRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the CloseRequest to JSON.

func (*CloseRequest) MarshalProtoJSON

func (x *CloseRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the CloseRequest message to JSON.

func (*CloseRequest) MarshalProtoText

func (x *CloseRequest) MarshalProtoText() string

func (*CloseRequest) MarshalToSizedBufferVT

func (m *CloseRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CloseRequest) MarshalToVT

func (m *CloseRequest) MarshalToVT(dAtA []byte) (int, error)

func (*CloseRequest) MarshalVT

func (m *CloseRequest) MarshalVT() (dAtA []byte, err error)

func (*CloseRequest) ProtoMessage

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) Reset

func (x *CloseRequest) Reset()

func (*CloseRequest) SizeVT

func (m *CloseRequest) SizeVT() (n int)

func (*CloseRequest) String

func (x *CloseRequest) String() string

func (*CloseRequest) UnmarshalJSON

func (x *CloseRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the CloseRequest from JSON.

func (*CloseRequest) UnmarshalProtoJSON

func (x *CloseRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the CloseRequest message from JSON.

func (*CloseRequest) UnmarshalVT

func (m *CloseRequest) UnmarshalVT(dAtA []byte) error

type CloseResponse

type CloseResponse struct {
	// contains filtered or unexported fields
}

CloseResponse is the response type for Close.

func (*CloseResponse) CloneMessageVT

func (m *CloseResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*CloseResponse) CloneVT

func (m *CloseResponse) CloneVT() *CloseResponse

func (*CloseResponse) EqualMessageVT

func (this *CloseResponse) EqualMessageVT(thatMsg any) bool

func (*CloseResponse) EqualVT

func (this *CloseResponse) EqualVT(that *CloseResponse) bool

func (*CloseResponse) MarshalJSON

func (x *CloseResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the CloseResponse to JSON.

func (*CloseResponse) MarshalProtoJSON

func (x *CloseResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the CloseResponse message to JSON.

func (*CloseResponse) MarshalProtoText

func (x *CloseResponse) MarshalProtoText() string

func (*CloseResponse) MarshalToSizedBufferVT

func (m *CloseResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CloseResponse) MarshalToVT

func (m *CloseResponse) MarshalToVT(dAtA []byte) (int, error)

func (*CloseResponse) MarshalVT

func (m *CloseResponse) MarshalVT() (dAtA []byte, err error)

func (*CloseResponse) ProtoMessage

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) Reset

func (x *CloseResponse) Reset()

func (*CloseResponse) SizeVT

func (m *CloseResponse) SizeVT() (n int)

func (*CloseResponse) String

func (x *CloseResponse) String() string

func (*CloseResponse) UnmarshalJSON

func (x *CloseResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the CloseResponse from JSON.

func (*CloseResponse) UnmarshalProtoJSON

func (x *CloseResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the CloseResponse message from JSON.

func (*CloseResponse) UnmarshalVT

func (m *CloseResponse) UnmarshalVT(dAtA []byte) error

type CommitRequest

type CommitRequest struct {
	// contains filtered or unexported fields
}

CommitRequest is the request type for Commit.

func (*CommitRequest) CloneMessageVT

func (m *CommitRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*CommitRequest) CloneVT

func (m *CommitRequest) CloneVT() *CommitRequest

func (*CommitRequest) EqualMessageVT

func (this *CommitRequest) EqualMessageVT(thatMsg any) bool

func (*CommitRequest) EqualVT

func (this *CommitRequest) EqualVT(that *CommitRequest) bool

func (*CommitRequest) MarshalJSON

func (x *CommitRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the CommitRequest to JSON.

func (*CommitRequest) MarshalProtoJSON

func (x *CommitRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the CommitRequest message to JSON.

func (*CommitRequest) MarshalProtoText

func (x *CommitRequest) MarshalProtoText() string

func (*CommitRequest) MarshalToSizedBufferVT

func (m *CommitRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CommitRequest) MarshalToVT

func (m *CommitRequest) MarshalToVT(dAtA []byte) (int, error)

func (*CommitRequest) MarshalVT

func (m *CommitRequest) MarshalVT() (dAtA []byte, err error)

func (*CommitRequest) ProtoMessage

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) Reset

func (x *CommitRequest) Reset()

func (*CommitRequest) SizeVT

func (m *CommitRequest) SizeVT() (n int)

func (*CommitRequest) String

func (x *CommitRequest) String() string

func (*CommitRequest) UnmarshalJSON

func (x *CommitRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the CommitRequest from JSON.

func (*CommitRequest) UnmarshalProtoJSON

func (x *CommitRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the CommitRequest message from JSON.

func (*CommitRequest) UnmarshalVT

func (m *CommitRequest) UnmarshalVT(dAtA []byte) error

type CommitResponse

type CommitResponse struct {
	// contains filtered or unexported fields
}

CommitResponse is the response type for Commit.

func (*CommitResponse) CloneMessageVT

func (m *CommitResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*CommitResponse) CloneVT

func (m *CommitResponse) CloneVT() *CommitResponse

func (*CommitResponse) EqualMessageVT

func (this *CommitResponse) EqualMessageVT(thatMsg any) bool

func (*CommitResponse) EqualVT

func (this *CommitResponse) EqualVT(that *CommitResponse) bool

func (*CommitResponse) MarshalJSON

func (x *CommitResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the CommitResponse to JSON.

func (*CommitResponse) MarshalProtoJSON

func (x *CommitResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the CommitResponse message to JSON.

func (*CommitResponse) MarshalProtoText

func (x *CommitResponse) MarshalProtoText() string

func (*CommitResponse) MarshalToSizedBufferVT

func (m *CommitResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CommitResponse) MarshalToVT

func (m *CommitResponse) MarshalToVT(dAtA []byte) (int, error)

func (*CommitResponse) MarshalVT

func (m *CommitResponse) MarshalVT() (dAtA []byte, err error)

func (*CommitResponse) ProtoMessage

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) Reset

func (x *CommitResponse) Reset()

func (*CommitResponse) SizeVT

func (m *CommitResponse) SizeVT() (n int)

func (*CommitResponse) String

func (x *CommitResponse) String() string

func (*CommitResponse) UnmarshalJSON

func (x *CommitResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the CommitResponse from JSON.

func (*CommitResponse) UnmarshalProtoJSON

func (x *CommitResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the CommitResponse message from JSON.

func (*CommitResponse) UnmarshalVT

func (m *CommitResponse) UnmarshalVT(dAtA []byte) error

type CreateObjectRequest

type CreateObjectRequest struct {

	// ObjectKey is the unique identifier for the object within the world.
	ObjectKey string `protobuf:"bytes,1,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// RootRef is the initial reference to the object's root data.
	RootRef *bucket.ObjectRef `protobuf:"bytes,2,opt,name=root_ref,json=rootRef,proto3" json:"rootRef,omitempty"`
	// contains filtered or unexported fields
}

CreateObjectRequest is the request type for CreateObject.

func (*CreateObjectRequest) CloneMessageVT

func (*CreateObjectRequest) CloneVT

func (*CreateObjectRequest) EqualMessageVT

func (this *CreateObjectRequest) EqualMessageVT(thatMsg any) bool

func (*CreateObjectRequest) EqualVT

func (this *CreateObjectRequest) EqualVT(that *CreateObjectRequest) bool

func (*CreateObjectRequest) GetObjectKey

func (x *CreateObjectRequest) GetObjectKey() string

func (*CreateObjectRequest) GetRootRef

func (x *CreateObjectRequest) GetRootRef() *bucket.ObjectRef

func (*CreateObjectRequest) MarshalJSON

func (x *CreateObjectRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the CreateObjectRequest to JSON.

func (*CreateObjectRequest) MarshalProtoJSON

func (x *CreateObjectRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the CreateObjectRequest message to JSON.

func (*CreateObjectRequest) MarshalProtoText

func (x *CreateObjectRequest) MarshalProtoText() string

func (*CreateObjectRequest) MarshalToSizedBufferVT

func (m *CreateObjectRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateObjectRequest) MarshalToVT

func (m *CreateObjectRequest) MarshalToVT(dAtA []byte) (int, error)

func (*CreateObjectRequest) MarshalVT

func (m *CreateObjectRequest) MarshalVT() (dAtA []byte, err error)

func (*CreateObjectRequest) ProtoMessage

func (*CreateObjectRequest) ProtoMessage()

func (*CreateObjectRequest) Reset

func (x *CreateObjectRequest) Reset()

func (*CreateObjectRequest) SizeVT

func (m *CreateObjectRequest) SizeVT() (n int)

func (*CreateObjectRequest) String

func (x *CreateObjectRequest) String() string

func (*CreateObjectRequest) UnmarshalJSON

func (x *CreateObjectRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the CreateObjectRequest from JSON.

func (*CreateObjectRequest) UnmarshalProtoJSON

func (x *CreateObjectRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the CreateObjectRequest message from JSON.

func (*CreateObjectRequest) UnmarshalVT

func (m *CreateObjectRequest) UnmarshalVT(dAtA []byte) error

type CreateObjectResponse

type CreateObjectResponse struct {

	// ResourceId is the ID of the created ObjectState resource.
	ResourceId uint32 `protobuf:"varint,1,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// ObjectKey is the unique identifier of the created object.
	ObjectKey string `protobuf:"bytes,2,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// contains filtered or unexported fields
}

CreateObjectResponse is the response type for CreateObject.

func (*CreateObjectResponse) CloneMessageVT

func (*CreateObjectResponse) CloneVT

func (*CreateObjectResponse) EqualMessageVT

func (this *CreateObjectResponse) EqualMessageVT(thatMsg any) bool

func (*CreateObjectResponse) EqualVT

func (this *CreateObjectResponse) EqualVT(that *CreateObjectResponse) bool

func (*CreateObjectResponse) GetObjectKey

func (x *CreateObjectResponse) GetObjectKey() string

func (*CreateObjectResponse) GetResourceId

func (x *CreateObjectResponse) GetResourceId() uint32

func (*CreateObjectResponse) MarshalJSON

func (x *CreateObjectResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the CreateObjectResponse to JSON.

func (*CreateObjectResponse) MarshalProtoJSON

func (x *CreateObjectResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the CreateObjectResponse message to JSON.

func (*CreateObjectResponse) MarshalProtoText

func (x *CreateObjectResponse) MarshalProtoText() string

func (*CreateObjectResponse) MarshalToSizedBufferVT

func (m *CreateObjectResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateObjectResponse) MarshalToVT

func (m *CreateObjectResponse) MarshalToVT(dAtA []byte) (int, error)

func (*CreateObjectResponse) MarshalVT

func (m *CreateObjectResponse) MarshalVT() (dAtA []byte, err error)

func (*CreateObjectResponse) ProtoMessage

func (*CreateObjectResponse) ProtoMessage()

func (*CreateObjectResponse) Reset

func (x *CreateObjectResponse) Reset()

func (*CreateObjectResponse) SizeVT

func (m *CreateObjectResponse) SizeVT() (n int)

func (*CreateObjectResponse) String

func (x *CreateObjectResponse) String() string

func (*CreateObjectResponse) UnmarshalJSON

func (x *CreateObjectResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the CreateObjectResponse from JSON.

func (*CreateObjectResponse) UnmarshalProtoJSON

func (x *CreateObjectResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the CreateObjectResponse message from JSON.

func (*CreateObjectResponse) UnmarshalVT

func (m *CreateObjectResponse) UnmarshalVT(dAtA []byte) error

type DeleteGraphObjectRequest

type DeleteGraphObjectRequest struct {

	// ObjectKey is the key of the object whose graph references should be deleted.
	ObjectKey string `protobuf:"bytes,1,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// contains filtered or unexported fields
}

DeleteGraphObjectRequest is the request type for DeleteGraphObject.

func (*DeleteGraphObjectRequest) CloneMessageVT

func (*DeleteGraphObjectRequest) CloneVT

func (*DeleteGraphObjectRequest) EqualMessageVT

func (this *DeleteGraphObjectRequest) EqualMessageVT(thatMsg any) bool

func (*DeleteGraphObjectRequest) EqualVT

func (*DeleteGraphObjectRequest) GetObjectKey

func (x *DeleteGraphObjectRequest) GetObjectKey() string

func (*DeleteGraphObjectRequest) MarshalJSON

func (x *DeleteGraphObjectRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the DeleteGraphObjectRequest to JSON.

func (*DeleteGraphObjectRequest) MarshalProtoJSON

func (x *DeleteGraphObjectRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the DeleteGraphObjectRequest message to JSON.

func (*DeleteGraphObjectRequest) MarshalProtoText

func (x *DeleteGraphObjectRequest) MarshalProtoText() string

func (*DeleteGraphObjectRequest) MarshalToSizedBufferVT

func (m *DeleteGraphObjectRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteGraphObjectRequest) MarshalToVT

func (m *DeleteGraphObjectRequest) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteGraphObjectRequest) MarshalVT

func (m *DeleteGraphObjectRequest) MarshalVT() (dAtA []byte, err error)

func (*DeleteGraphObjectRequest) ProtoMessage

func (*DeleteGraphObjectRequest) ProtoMessage()

func (*DeleteGraphObjectRequest) Reset

func (x *DeleteGraphObjectRequest) Reset()

func (*DeleteGraphObjectRequest) SizeVT

func (m *DeleteGraphObjectRequest) SizeVT() (n int)

func (*DeleteGraphObjectRequest) String

func (x *DeleteGraphObjectRequest) String() string

func (*DeleteGraphObjectRequest) UnmarshalJSON

func (x *DeleteGraphObjectRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the DeleteGraphObjectRequest from JSON.

func (*DeleteGraphObjectRequest) UnmarshalProtoJSON

func (x *DeleteGraphObjectRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the DeleteGraphObjectRequest message from JSON.

func (*DeleteGraphObjectRequest) UnmarshalVT

func (m *DeleteGraphObjectRequest) UnmarshalVT(dAtA []byte) error

type DeleteGraphObjectResponse

type DeleteGraphObjectResponse struct {
	// contains filtered or unexported fields
}

DeleteGraphObjectResponse is the response type for DeleteGraphObject.

func (*DeleteGraphObjectResponse) CloneMessageVT

func (*DeleteGraphObjectResponse) CloneVT

func (*DeleteGraphObjectResponse) EqualMessageVT

func (this *DeleteGraphObjectResponse) EqualMessageVT(thatMsg any) bool

func (*DeleteGraphObjectResponse) EqualVT

func (*DeleteGraphObjectResponse) MarshalJSON

func (x *DeleteGraphObjectResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the DeleteGraphObjectResponse to JSON.

func (*DeleteGraphObjectResponse) MarshalProtoJSON

func (x *DeleteGraphObjectResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the DeleteGraphObjectResponse message to JSON.

func (*DeleteGraphObjectResponse) MarshalProtoText

func (x *DeleteGraphObjectResponse) MarshalProtoText() string

func (*DeleteGraphObjectResponse) MarshalToSizedBufferVT

func (m *DeleteGraphObjectResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteGraphObjectResponse) MarshalToVT

func (m *DeleteGraphObjectResponse) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteGraphObjectResponse) MarshalVT

func (m *DeleteGraphObjectResponse) MarshalVT() (dAtA []byte, err error)

func (*DeleteGraphObjectResponse) ProtoMessage

func (*DeleteGraphObjectResponse) ProtoMessage()

func (*DeleteGraphObjectResponse) Reset

func (x *DeleteGraphObjectResponse) Reset()

func (*DeleteGraphObjectResponse) SizeVT

func (m *DeleteGraphObjectResponse) SizeVT() (n int)

func (*DeleteGraphObjectResponse) String

func (x *DeleteGraphObjectResponse) String() string

func (*DeleteGraphObjectResponse) UnmarshalJSON

func (x *DeleteGraphObjectResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the DeleteGraphObjectResponse from JSON.

func (*DeleteGraphObjectResponse) UnmarshalProtoJSON

func (x *DeleteGraphObjectResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the DeleteGraphObjectResponse message from JSON.

func (*DeleteGraphObjectResponse) UnmarshalVT

func (m *DeleteGraphObjectResponse) UnmarshalVT(dAtA []byte) error

type DeleteGraphQuadRequest

type DeleteGraphQuadRequest struct {

	// Quad is the graph quad to remove from the store.
	Quad *quad.Quad `protobuf:"bytes,1,opt,name=quad,proto3" json:"quad,omitempty"`
	// contains filtered or unexported fields
}

DeleteGraphQuadRequest is the request type for DeleteGraphQuad.

func (*DeleteGraphQuadRequest) CloneMessageVT

func (*DeleteGraphQuadRequest) CloneVT

func (*DeleteGraphQuadRequest) EqualMessageVT

func (this *DeleteGraphQuadRequest) EqualMessageVT(thatMsg any) bool

func (*DeleteGraphQuadRequest) EqualVT

func (this *DeleteGraphQuadRequest) EqualVT(that *DeleteGraphQuadRequest) bool

func (*DeleteGraphQuadRequest) GetQuad

func (x *DeleteGraphQuadRequest) GetQuad() *quad.Quad

func (*DeleteGraphQuadRequest) MarshalJSON

func (x *DeleteGraphQuadRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the DeleteGraphQuadRequest to JSON.

func (*DeleteGraphQuadRequest) MarshalProtoJSON

func (x *DeleteGraphQuadRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the DeleteGraphQuadRequest message to JSON.

func (*DeleteGraphQuadRequest) MarshalProtoText

func (x *DeleteGraphQuadRequest) MarshalProtoText() string

func (*DeleteGraphQuadRequest) MarshalToSizedBufferVT

func (m *DeleteGraphQuadRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteGraphQuadRequest) MarshalToVT

func (m *DeleteGraphQuadRequest) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteGraphQuadRequest) MarshalVT

func (m *DeleteGraphQuadRequest) MarshalVT() (dAtA []byte, err error)

func (*DeleteGraphQuadRequest) ProtoMessage

func (*DeleteGraphQuadRequest) ProtoMessage()

func (*DeleteGraphQuadRequest) Reset

func (x *DeleteGraphQuadRequest) Reset()

func (*DeleteGraphQuadRequest) SizeVT

func (m *DeleteGraphQuadRequest) SizeVT() (n int)

func (*DeleteGraphQuadRequest) String

func (x *DeleteGraphQuadRequest) String() string

func (*DeleteGraphQuadRequest) UnmarshalJSON

func (x *DeleteGraphQuadRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the DeleteGraphQuadRequest from JSON.

func (*DeleteGraphQuadRequest) UnmarshalProtoJSON

func (x *DeleteGraphQuadRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the DeleteGraphQuadRequest message from JSON.

func (*DeleteGraphQuadRequest) UnmarshalVT

func (m *DeleteGraphQuadRequest) UnmarshalVT(dAtA []byte) error

type DeleteGraphQuadResponse

type DeleteGraphQuadResponse struct {
	// contains filtered or unexported fields
}

DeleteGraphQuadResponse is the response type for DeleteGraphQuad.

func (*DeleteGraphQuadResponse) CloneMessageVT

func (*DeleteGraphQuadResponse) CloneVT

func (*DeleteGraphQuadResponse) EqualMessageVT

func (this *DeleteGraphQuadResponse) EqualMessageVT(thatMsg any) bool

func (*DeleteGraphQuadResponse) EqualVT

func (*DeleteGraphQuadResponse) MarshalJSON

func (x *DeleteGraphQuadResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the DeleteGraphQuadResponse to JSON.

func (*DeleteGraphQuadResponse) MarshalProtoJSON

func (x *DeleteGraphQuadResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the DeleteGraphQuadResponse message to JSON.

func (*DeleteGraphQuadResponse) MarshalProtoText

func (x *DeleteGraphQuadResponse) MarshalProtoText() string

func (*DeleteGraphQuadResponse) MarshalToSizedBufferVT

func (m *DeleteGraphQuadResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteGraphQuadResponse) MarshalToVT

func (m *DeleteGraphQuadResponse) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteGraphQuadResponse) MarshalVT

func (m *DeleteGraphQuadResponse) MarshalVT() (dAtA []byte, err error)

func (*DeleteGraphQuadResponse) ProtoMessage

func (*DeleteGraphQuadResponse) ProtoMessage()

func (*DeleteGraphQuadResponse) Reset

func (x *DeleteGraphQuadResponse) Reset()

func (*DeleteGraphQuadResponse) SizeVT

func (m *DeleteGraphQuadResponse) SizeVT() (n int)

func (*DeleteGraphQuadResponse) String

func (x *DeleteGraphQuadResponse) String() string

func (*DeleteGraphQuadResponse) UnmarshalJSON

func (x *DeleteGraphQuadResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the DeleteGraphQuadResponse from JSON.

func (*DeleteGraphQuadResponse) UnmarshalProtoJSON

func (x *DeleteGraphQuadResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the DeleteGraphQuadResponse message from JSON.

func (*DeleteGraphQuadResponse) UnmarshalVT

func (m *DeleteGraphQuadResponse) UnmarshalVT(dAtA []byte) error

type DeleteObjectRequest

type DeleteObjectRequest struct {

	// ObjectKey is the unique identifier of the object to delete.
	ObjectKey string `protobuf:"bytes,1,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// contains filtered or unexported fields
}

DeleteObjectRequest is the request type for DeleteObject.

func (*DeleteObjectRequest) CloneMessageVT

func (*DeleteObjectRequest) CloneVT

func (*DeleteObjectRequest) EqualMessageVT

func (this *DeleteObjectRequest) EqualMessageVT(thatMsg any) bool

func (*DeleteObjectRequest) EqualVT

func (this *DeleteObjectRequest) EqualVT(that *DeleteObjectRequest) bool

func (*DeleteObjectRequest) GetObjectKey

func (x *DeleteObjectRequest) GetObjectKey() string

func (*DeleteObjectRequest) MarshalJSON

func (x *DeleteObjectRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the DeleteObjectRequest to JSON.

func (*DeleteObjectRequest) MarshalProtoJSON

func (x *DeleteObjectRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the DeleteObjectRequest message to JSON.

func (*DeleteObjectRequest) MarshalProtoText

func (x *DeleteObjectRequest) MarshalProtoText() string

func (*DeleteObjectRequest) MarshalToSizedBufferVT

func (m *DeleteObjectRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteObjectRequest) MarshalToVT

func (m *DeleteObjectRequest) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteObjectRequest) MarshalVT

func (m *DeleteObjectRequest) MarshalVT() (dAtA []byte, err error)

func (*DeleteObjectRequest) ProtoMessage

func (*DeleteObjectRequest) ProtoMessage()

func (*DeleteObjectRequest) Reset

func (x *DeleteObjectRequest) Reset()

func (*DeleteObjectRequest) SizeVT

func (m *DeleteObjectRequest) SizeVT() (n int)

func (*DeleteObjectRequest) String

func (x *DeleteObjectRequest) String() string

func (*DeleteObjectRequest) UnmarshalJSON

func (x *DeleteObjectRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the DeleteObjectRequest from JSON.

func (*DeleteObjectRequest) UnmarshalProtoJSON

func (x *DeleteObjectRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the DeleteObjectRequest message from JSON.

func (*DeleteObjectRequest) UnmarshalVT

func (m *DeleteObjectRequest) UnmarshalVT(dAtA []byte) error

type DeleteObjectResponse

type DeleteObjectResponse struct {

	// Deleted indicates whether the object was found and successfully deleted.
	Deleted bool `protobuf:"varint,1,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

DeleteObjectResponse is the response type for DeleteObject.

func (*DeleteObjectResponse) CloneMessageVT

func (*DeleteObjectResponse) CloneVT

func (*DeleteObjectResponse) EqualMessageVT

func (this *DeleteObjectResponse) EqualMessageVT(thatMsg any) bool

func (*DeleteObjectResponse) EqualVT

func (this *DeleteObjectResponse) EqualVT(that *DeleteObjectResponse) bool

func (*DeleteObjectResponse) GetDeleted

func (x *DeleteObjectResponse) GetDeleted() bool

func (*DeleteObjectResponse) MarshalJSON

func (x *DeleteObjectResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the DeleteObjectResponse to JSON.

func (*DeleteObjectResponse) MarshalProtoJSON

func (x *DeleteObjectResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the DeleteObjectResponse message to JSON.

func (*DeleteObjectResponse) MarshalProtoText

func (x *DeleteObjectResponse) MarshalProtoText() string

func (*DeleteObjectResponse) MarshalToSizedBufferVT

func (m *DeleteObjectResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteObjectResponse) MarshalToVT

func (m *DeleteObjectResponse) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteObjectResponse) MarshalVT

func (m *DeleteObjectResponse) MarshalVT() (dAtA []byte, err error)

func (*DeleteObjectResponse) ProtoMessage

func (*DeleteObjectResponse) ProtoMessage()

func (*DeleteObjectResponse) Reset

func (x *DeleteObjectResponse) Reset()

func (*DeleteObjectResponse) SizeVT

func (m *DeleteObjectResponse) SizeVT() (n int)

func (*DeleteObjectResponse) String

func (x *DeleteObjectResponse) String() string

func (*DeleteObjectResponse) UnmarshalJSON

func (x *DeleteObjectResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the DeleteObjectResponse from JSON.

func (*DeleteObjectResponse) UnmarshalProtoJSON

func (x *DeleteObjectResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the DeleteObjectResponse message from JSON.

func (*DeleteObjectResponse) UnmarshalVT

func (m *DeleteObjectResponse) UnmarshalVT(dAtA []byte) error

type DiscardRequest

type DiscardRequest struct {
	// contains filtered or unexported fields
}

DiscardRequest is the request type for Discard.

func (*DiscardRequest) CloneMessageVT

func (m *DiscardRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*DiscardRequest) CloneVT

func (m *DiscardRequest) CloneVT() *DiscardRequest

func (*DiscardRequest) EqualMessageVT

func (this *DiscardRequest) EqualMessageVT(thatMsg any) bool

func (*DiscardRequest) EqualVT

func (this *DiscardRequest) EqualVT(that *DiscardRequest) bool

func (*DiscardRequest) MarshalJSON

func (x *DiscardRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the DiscardRequest to JSON.

func (*DiscardRequest) MarshalProtoJSON

func (x *DiscardRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the DiscardRequest message to JSON.

func (*DiscardRequest) MarshalProtoText

func (x *DiscardRequest) MarshalProtoText() string

func (*DiscardRequest) MarshalToSizedBufferVT

func (m *DiscardRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DiscardRequest) MarshalToVT

func (m *DiscardRequest) MarshalToVT(dAtA []byte) (int, error)

func (*DiscardRequest) MarshalVT

func (m *DiscardRequest) MarshalVT() (dAtA []byte, err error)

func (*DiscardRequest) ProtoMessage

func (*DiscardRequest) ProtoMessage()

func (*DiscardRequest) Reset

func (x *DiscardRequest) Reset()

func (*DiscardRequest) SizeVT

func (m *DiscardRequest) SizeVT() (n int)

func (*DiscardRequest) String

func (x *DiscardRequest) String() string

func (*DiscardRequest) UnmarshalJSON

func (x *DiscardRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the DiscardRequest from JSON.

func (*DiscardRequest) UnmarshalProtoJSON

func (x *DiscardRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the DiscardRequest message from JSON.

func (*DiscardRequest) UnmarshalVT

func (m *DiscardRequest) UnmarshalVT(dAtA []byte) error

type DiscardResponse

type DiscardResponse struct {
	// contains filtered or unexported fields
}

DiscardResponse is the response type for Discard.

func (*DiscardResponse) CloneMessageVT

func (m *DiscardResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*DiscardResponse) CloneVT

func (m *DiscardResponse) CloneVT() *DiscardResponse

func (*DiscardResponse) EqualMessageVT

func (this *DiscardResponse) EqualMessageVT(thatMsg any) bool

func (*DiscardResponse) EqualVT

func (this *DiscardResponse) EqualVT(that *DiscardResponse) bool

func (*DiscardResponse) MarshalJSON

func (x *DiscardResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the DiscardResponse to JSON.

func (*DiscardResponse) MarshalProtoJSON

func (x *DiscardResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the DiscardResponse message to JSON.

func (*DiscardResponse) MarshalProtoText

func (x *DiscardResponse) MarshalProtoText() string

func (*DiscardResponse) MarshalToSizedBufferVT

func (m *DiscardResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DiscardResponse) MarshalToVT

func (m *DiscardResponse) MarshalToVT(dAtA []byte) (int, error)

func (*DiscardResponse) MarshalVT

func (m *DiscardResponse) MarshalVT() (dAtA []byte, err error)

func (*DiscardResponse) ProtoMessage

func (*DiscardResponse) ProtoMessage()

func (*DiscardResponse) Reset

func (x *DiscardResponse) Reset()

func (*DiscardResponse) SizeVT

func (m *DiscardResponse) SizeVT() (n int)

func (*DiscardResponse) String

func (x *DiscardResponse) String() string

func (*DiscardResponse) UnmarshalJSON

func (x *DiscardResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the DiscardResponse from JSON.

func (*DiscardResponse) UnmarshalProtoJSON

func (x *DiscardResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the DiscardResponse message from JSON.

func (*DiscardResponse) UnmarshalVT

func (m *DiscardResponse) UnmarshalVT(dAtA []byte) error

type Engine

type Engine struct {
	// contains filtered or unexported fields
}

Engine is the top-level resource for Hydra's World data structure. Engine implements a transactional world state container.

In the Go implementation (hydra/world/engine.go), Engine provides: - NewTransaction(ctx, write bool) (Tx, error) - WorldStorage for bucket cursor access (BuildStorageCursor, AccessWorldState) - WorldWaitSeqno for sequence number waiting (GetSeqno, WaitSeqno)

This Go SDK implementation wraps EngineResourceService and WatchWorldStateResourceService.

func NewEngine

func NewEngine(client *resource_client.Client, ref resource_client.ResourceRef) (*Engine, error)

NewEngine creates a new Engine resource wrapper.

func (*Engine) AccessWorldState

func (e *Engine) AccessWorldState(ctx context.Context, ref *bucket.ObjectRef) (uint32, error)

AccessWorldState builds a bucket lookup cursor with an optional ref. If the ref is empty, returns a cursor pointing to the root world state. The lookup cursor must be released when done. Returns the resource ID of the cursor.

func (*Engine) BuildStorageCursor

func (e *Engine) BuildStorageCursor(ctx context.Context) (uint32, error)

BuildStorageCursor builds a cursor to the world storage with an empty ref. The cursor should be released independently of the Engine. Be sure to call Release on the cursor resource when done. Returns the resource ID of the cursor.

func (*Engine) GetEngineInfo

func (e *Engine) GetEngineInfo(ctx context.Context) (*GetEngineInfoResponse, error)

GetEngineInfo returns information about the world engine.

func (*Engine) GetResourceRef

func (e *Engine) GetResourceRef() resource_client.ResourceRef

GetResourceRef returns the resource reference.

func (*Engine) GetSeqno

func (e *Engine) GetSeqno(ctx context.Context) (uint64, error)

GetSeqno returns the current sequence number of the world state. This is also the sequence number of the most recent change. Initializes at 0 for initial world state.

func (*Engine) GetWorldRootSnapshot added in v0.51.7

func (e *Engine) GetWorldRootSnapshot(ctx context.Context) (*WorldRootSnapshot, error)

GetWorldRootSnapshot returns the current committed World root.

func (*Engine) NewTransaction

func (e *Engine) NewTransaction(ctx context.Context, write bool) (*Tx, error)

NewTransaction creates a new transaction against the world state. Set write=true if the transaction will perform write operations. Always call Release() when done with the transaction. Note: Engine might return a read-only transaction even if write=true.

func (*Engine) Release

func (e *Engine) Release()

Release releases the resource reference.

func (*Engine) WaitSeqno

func (e *Engine) WaitSeqno(ctx context.Context, seqno uint64) (uint64, error)

WaitSeqno waits for the world state sequence number to reach or exceed the specified value. Returns the seqno when the condition is reached. If seqno == 0, this might return immediately unconditionally.

func (*Engine) WatchWorldRootSnapshots added in v0.51.7

WatchWorldRootSnapshots streams committed World root snapshots.

func (*Engine) WatchWorldState

WatchWorldState creates a streaming watch of the WorldState. Returns a stream that sends resource IDs whenever tracked resources change. The watch tracks changes across the entire engine, not just a single transaction.

type EngineInfo

type EngineInfo struct {

	// EngineId is the ID of the world engine.
	EngineId string `protobuf:"bytes,1,opt,name=engine_id,json=engineId,proto3" json:"engineId,omitempty"`
	// BucketId is the bucket ID the engine is attached to.
	BucketId string `protobuf:"bytes,2,opt,name=bucket_id,json=bucketId,proto3" json:"bucketId,omitempty"`
	// contains filtered or unexported fields
}

EngineInfo contains metadata about a world engine.

func (*EngineInfo) CloneMessageVT

func (m *EngineInfo) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*EngineInfo) CloneVT

func (m *EngineInfo) CloneVT() *EngineInfo

func (*EngineInfo) EqualMessageVT

func (this *EngineInfo) EqualMessageVT(thatMsg any) bool

func (*EngineInfo) EqualVT

func (this *EngineInfo) EqualVT(that *EngineInfo) bool

func (*EngineInfo) GetBucketId

func (x *EngineInfo) GetBucketId() string

func (*EngineInfo) GetEngineId

func (x *EngineInfo) GetEngineId() string

func (*EngineInfo) MarshalJSON

func (x *EngineInfo) MarshalJSON() ([]byte, error)

MarshalJSON marshals the EngineInfo to JSON.

func (*EngineInfo) MarshalProtoJSON

func (x *EngineInfo) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the EngineInfo message to JSON.

func (*EngineInfo) MarshalProtoText

func (x *EngineInfo) MarshalProtoText() string

func (*EngineInfo) MarshalToSizedBufferVT

func (m *EngineInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EngineInfo) MarshalToVT

func (m *EngineInfo) MarshalToVT(dAtA []byte) (int, error)

func (*EngineInfo) MarshalVT

func (m *EngineInfo) MarshalVT() (dAtA []byte, err error)

func (*EngineInfo) ProtoMessage

func (*EngineInfo) ProtoMessage()

func (*EngineInfo) Reset

func (x *EngineInfo) Reset()

func (*EngineInfo) SizeVT

func (m *EngineInfo) SizeVT() (n int)

func (*EngineInfo) String

func (x *EngineInfo) String() string

func (*EngineInfo) UnmarshalJSON

func (x *EngineInfo) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the EngineInfo from JSON.

func (*EngineInfo) UnmarshalProtoJSON

func (x *EngineInfo) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the EngineInfo message from JSON.

func (*EngineInfo) UnmarshalVT

func (m *EngineInfo) UnmarshalVT(dAtA []byte) error

type ErrRequest

type ErrRequest struct {
	// contains filtered or unexported fields
}

ErrRequest is the request type for Err.

func (*ErrRequest) CloneMessageVT

func (m *ErrRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ErrRequest) CloneVT

func (m *ErrRequest) CloneVT() *ErrRequest

func (*ErrRequest) EqualMessageVT

func (this *ErrRequest) EqualMessageVT(thatMsg any) bool

func (*ErrRequest) EqualVT

func (this *ErrRequest) EqualVT(that *ErrRequest) bool

func (*ErrRequest) MarshalJSON

func (x *ErrRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ErrRequest to JSON.

func (*ErrRequest) MarshalProtoJSON

func (x *ErrRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ErrRequest message to JSON.

func (*ErrRequest) MarshalProtoText

func (x *ErrRequest) MarshalProtoText() string

func (*ErrRequest) MarshalToSizedBufferVT

func (m *ErrRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ErrRequest) MarshalToVT

func (m *ErrRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ErrRequest) MarshalVT

func (m *ErrRequest) MarshalVT() (dAtA []byte, err error)

func (*ErrRequest) ProtoMessage

func (*ErrRequest) ProtoMessage()

func (*ErrRequest) Reset

func (x *ErrRequest) Reset()

func (*ErrRequest) SizeVT

func (m *ErrRequest) SizeVT() (n int)

func (*ErrRequest) String

func (x *ErrRequest) String() string

func (*ErrRequest) UnmarshalJSON

func (x *ErrRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ErrRequest from JSON.

func (*ErrRequest) UnmarshalProtoJSON

func (x *ErrRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ErrRequest message from JSON.

func (*ErrRequest) UnmarshalVT

func (m *ErrRequest) UnmarshalVT(dAtA []byte) error

type ErrResponse

type ErrResponse struct {

	// Error is the error message, empty if no error.
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

ErrResponse is the response type for Err.

func (*ErrResponse) CloneMessageVT

func (m *ErrResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ErrResponse) CloneVT

func (m *ErrResponse) CloneVT() *ErrResponse

func (*ErrResponse) EqualMessageVT

func (this *ErrResponse) EqualMessageVT(thatMsg any) bool

func (*ErrResponse) EqualVT

func (this *ErrResponse) EqualVT(that *ErrResponse) bool

func (*ErrResponse) GetError

func (x *ErrResponse) GetError() string

func (*ErrResponse) MarshalJSON

func (x *ErrResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ErrResponse to JSON.

func (*ErrResponse) MarshalProtoJSON

func (x *ErrResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ErrResponse message to JSON.

func (*ErrResponse) MarshalProtoText

func (x *ErrResponse) MarshalProtoText() string

func (*ErrResponse) MarshalToSizedBufferVT

func (m *ErrResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ErrResponse) MarshalToVT

func (m *ErrResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ErrResponse) MarshalVT

func (m *ErrResponse) MarshalVT() (dAtA []byte, err error)

func (*ErrResponse) ProtoMessage

func (*ErrResponse) ProtoMessage()

func (*ErrResponse) Reset

func (x *ErrResponse) Reset()

func (*ErrResponse) SizeVT

func (m *ErrResponse) SizeVT() (n int)

func (*ErrResponse) String

func (x *ErrResponse) String() string

func (*ErrResponse) UnmarshalJSON

func (x *ErrResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ErrResponse from JSON.

func (*ErrResponse) UnmarshalProtoJSON

func (x *ErrResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ErrResponse message from JSON.

func (*ErrResponse) UnmarshalVT

func (m *ErrResponse) UnmarshalVT(dAtA []byte) error

type GetEngineInfoRequest

type GetEngineInfoRequest struct {
	// contains filtered or unexported fields
}

GetEngineInfoRequest is the request type for GetEngineInfo.

func (*GetEngineInfoRequest) CloneMessageVT

func (*GetEngineInfoRequest) CloneVT

func (*GetEngineInfoRequest) EqualMessageVT

func (this *GetEngineInfoRequest) EqualMessageVT(thatMsg any) bool

func (*GetEngineInfoRequest) EqualVT

func (this *GetEngineInfoRequest) EqualVT(that *GetEngineInfoRequest) bool

func (*GetEngineInfoRequest) MarshalJSON

func (x *GetEngineInfoRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetEngineInfoRequest to JSON.

func (*GetEngineInfoRequest) MarshalProtoJSON

func (x *GetEngineInfoRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetEngineInfoRequest message to JSON.

func (*GetEngineInfoRequest) MarshalProtoText

func (x *GetEngineInfoRequest) MarshalProtoText() string

func (*GetEngineInfoRequest) MarshalToSizedBufferVT

func (m *GetEngineInfoRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetEngineInfoRequest) MarshalToVT

func (m *GetEngineInfoRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetEngineInfoRequest) MarshalVT

func (m *GetEngineInfoRequest) MarshalVT() (dAtA []byte, err error)

func (*GetEngineInfoRequest) ProtoMessage

func (*GetEngineInfoRequest) ProtoMessage()

func (*GetEngineInfoRequest) Reset

func (x *GetEngineInfoRequest) Reset()

func (*GetEngineInfoRequest) SizeVT

func (m *GetEngineInfoRequest) SizeVT() (n int)

func (*GetEngineInfoRequest) String

func (x *GetEngineInfoRequest) String() string

func (*GetEngineInfoRequest) UnmarshalJSON

func (x *GetEngineInfoRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetEngineInfoRequest from JSON.

func (*GetEngineInfoRequest) UnmarshalProtoJSON

func (x *GetEngineInfoRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetEngineInfoRequest message from JSON.

func (*GetEngineInfoRequest) UnmarshalVT

func (m *GetEngineInfoRequest) UnmarshalVT(dAtA []byte) error

type GetEngineInfoResponse

type GetEngineInfoResponse struct {

	// EngineInfo is the engine information.
	EngineInfo *EngineInfo `protobuf:"bytes,1,opt,name=engine_info,json=engineInfo,proto3" json:"engineInfo,omitempty"`
	// contains filtered or unexported fields
}

GetEngineInfoResponse is the response type for GetEngineInfo.

func (*GetEngineInfoResponse) CloneMessageVT

func (*GetEngineInfoResponse) CloneVT

func (*GetEngineInfoResponse) EqualMessageVT

func (this *GetEngineInfoResponse) EqualMessageVT(thatMsg any) bool

func (*GetEngineInfoResponse) EqualVT

func (this *GetEngineInfoResponse) EqualVT(that *GetEngineInfoResponse) bool

func (*GetEngineInfoResponse) GetEngineInfo

func (x *GetEngineInfoResponse) GetEngineInfo() *EngineInfo

func (*GetEngineInfoResponse) MarshalJSON

func (x *GetEngineInfoResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetEngineInfoResponse to JSON.

func (*GetEngineInfoResponse) MarshalProtoJSON

func (x *GetEngineInfoResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetEngineInfoResponse message to JSON.

func (*GetEngineInfoResponse) MarshalProtoText

func (x *GetEngineInfoResponse) MarshalProtoText() string

func (*GetEngineInfoResponse) MarshalToSizedBufferVT

func (m *GetEngineInfoResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetEngineInfoResponse) MarshalToVT

func (m *GetEngineInfoResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetEngineInfoResponse) MarshalVT

func (m *GetEngineInfoResponse) MarshalVT() (dAtA []byte, err error)

func (*GetEngineInfoResponse) ProtoMessage

func (*GetEngineInfoResponse) ProtoMessage()

func (*GetEngineInfoResponse) Reset

func (x *GetEngineInfoResponse) Reset()

func (*GetEngineInfoResponse) SizeVT

func (m *GetEngineInfoResponse) SizeVT() (n int)

func (*GetEngineInfoResponse) String

func (x *GetEngineInfoResponse) String() string

func (*GetEngineInfoResponse) UnmarshalJSON

func (x *GetEngineInfoResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetEngineInfoResponse from JSON.

func (*GetEngineInfoResponse) UnmarshalProtoJSON

func (x *GetEngineInfoResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetEngineInfoResponse message from JSON.

func (*GetEngineInfoResponse) UnmarshalVT

func (m *GetEngineInfoResponse) UnmarshalVT(dAtA []byte) error

type GetKeyRequest

type GetKeyRequest struct {
	// contains filtered or unexported fields
}

GetKeyRequest is the request type for GetKey.

func (*GetKeyRequest) CloneMessageVT

func (m *GetKeyRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetKeyRequest) CloneVT

func (m *GetKeyRequest) CloneVT() *GetKeyRequest

func (*GetKeyRequest) EqualMessageVT

func (this *GetKeyRequest) EqualMessageVT(thatMsg any) bool

func (*GetKeyRequest) EqualVT

func (this *GetKeyRequest) EqualVT(that *GetKeyRequest) bool

func (*GetKeyRequest) MarshalJSON

func (x *GetKeyRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetKeyRequest to JSON.

func (*GetKeyRequest) MarshalProtoJSON

func (x *GetKeyRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetKeyRequest message to JSON.

func (*GetKeyRequest) MarshalProtoText

func (x *GetKeyRequest) MarshalProtoText() string

func (*GetKeyRequest) MarshalToSizedBufferVT

func (m *GetKeyRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetKeyRequest) MarshalToVT

func (m *GetKeyRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetKeyRequest) MarshalVT

func (m *GetKeyRequest) MarshalVT() (dAtA []byte, err error)

func (*GetKeyRequest) ProtoMessage

func (*GetKeyRequest) ProtoMessage()

func (*GetKeyRequest) Reset

func (x *GetKeyRequest) Reset()

func (*GetKeyRequest) SizeVT

func (m *GetKeyRequest) SizeVT() (n int)

func (*GetKeyRequest) String

func (x *GetKeyRequest) String() string

func (*GetKeyRequest) UnmarshalJSON

func (x *GetKeyRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetKeyRequest from JSON.

func (*GetKeyRequest) UnmarshalProtoJSON

func (x *GetKeyRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetKeyRequest message from JSON.

func (*GetKeyRequest) UnmarshalVT

func (m *GetKeyRequest) UnmarshalVT(dAtA []byte) error

type GetKeyResponse

type GetKeyResponse struct {

	// ObjectKey is the unique identifier of the object within the world.
	ObjectKey string `protobuf:"bytes,1,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// contains filtered or unexported fields
}

GetKeyResponse is the response type for GetKey.

func (*GetKeyResponse) CloneMessageVT

func (m *GetKeyResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetKeyResponse) CloneVT

func (m *GetKeyResponse) CloneVT() *GetKeyResponse

func (*GetKeyResponse) EqualMessageVT

func (this *GetKeyResponse) EqualMessageVT(thatMsg any) bool

func (*GetKeyResponse) EqualVT

func (this *GetKeyResponse) EqualVT(that *GetKeyResponse) bool

func (*GetKeyResponse) GetObjectKey

func (x *GetKeyResponse) GetObjectKey() string

func (*GetKeyResponse) MarshalJSON

func (x *GetKeyResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetKeyResponse to JSON.

func (*GetKeyResponse) MarshalProtoJSON

func (x *GetKeyResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetKeyResponse message to JSON.

func (*GetKeyResponse) MarshalProtoText

func (x *GetKeyResponse) MarshalProtoText() string

func (*GetKeyResponse) MarshalToSizedBufferVT

func (m *GetKeyResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetKeyResponse) MarshalToVT

func (m *GetKeyResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetKeyResponse) MarshalVT

func (m *GetKeyResponse) MarshalVT() (dAtA []byte, err error)

func (*GetKeyResponse) ProtoMessage

func (*GetKeyResponse) ProtoMessage()

func (*GetKeyResponse) Reset

func (x *GetKeyResponse) Reset()

func (*GetKeyResponse) SizeVT

func (m *GetKeyResponse) SizeVT() (n int)

func (*GetKeyResponse) String

func (x *GetKeyResponse) String() string

func (*GetKeyResponse) UnmarshalJSON

func (x *GetKeyResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetKeyResponse from JSON.

func (*GetKeyResponse) UnmarshalProtoJSON

func (x *GetKeyResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetKeyResponse message from JSON.

func (*GetKeyResponse) UnmarshalVT

func (m *GetKeyResponse) UnmarshalVT(dAtA []byte) error

type GetObjectMetadataBatchRequest added in v0.51.6

type GetObjectMetadataBatchRequest struct {

	// ObjectKeys is the list of object keys to inspect.
	ObjectKeys []string `protobuf:"bytes,1,rep,name=object_keys,json=objectKeys,proto3" json:"objectKeys,omitempty"`
	// contains filtered or unexported fields
}

GetObjectMetadataBatchRequest is the request type for GetObjectMetadataBatch.

func (*GetObjectMetadataBatchRequest) CloneMessageVT added in v0.51.6

func (*GetObjectMetadataBatchRequest) CloneVT added in v0.51.6

func (*GetObjectMetadataBatchRequest) EqualMessageVT added in v0.51.6

func (this *GetObjectMetadataBatchRequest) EqualMessageVT(thatMsg any) bool

func (*GetObjectMetadataBatchRequest) EqualVT added in v0.51.6

func (*GetObjectMetadataBatchRequest) GetObjectKeys added in v0.51.6

func (x *GetObjectMetadataBatchRequest) GetObjectKeys() []string

func (*GetObjectMetadataBatchRequest) MarshalJSON added in v0.51.6

func (x *GetObjectMetadataBatchRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetObjectMetadataBatchRequest to JSON.

func (*GetObjectMetadataBatchRequest) MarshalProtoJSON added in v0.51.6

func (x *GetObjectMetadataBatchRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetObjectMetadataBatchRequest message to JSON.

func (*GetObjectMetadataBatchRequest) MarshalProtoText added in v0.51.6

func (x *GetObjectMetadataBatchRequest) MarshalProtoText() string

func (*GetObjectMetadataBatchRequest) MarshalToSizedBufferVT added in v0.51.6

func (m *GetObjectMetadataBatchRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetObjectMetadataBatchRequest) MarshalToVT added in v0.51.6

func (m *GetObjectMetadataBatchRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetObjectMetadataBatchRequest) MarshalVT added in v0.51.6

func (m *GetObjectMetadataBatchRequest) MarshalVT() (dAtA []byte, err error)

func (*GetObjectMetadataBatchRequest) ProtoMessage added in v0.51.6

func (*GetObjectMetadataBatchRequest) ProtoMessage()

func (*GetObjectMetadataBatchRequest) Reset added in v0.51.6

func (x *GetObjectMetadataBatchRequest) Reset()

func (*GetObjectMetadataBatchRequest) SizeVT added in v0.51.6

func (m *GetObjectMetadataBatchRequest) SizeVT() (n int)

func (*GetObjectMetadataBatchRequest) String added in v0.51.6

func (*GetObjectMetadataBatchRequest) UnmarshalJSON added in v0.51.6

func (x *GetObjectMetadataBatchRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetObjectMetadataBatchRequest from JSON.

func (*GetObjectMetadataBatchRequest) UnmarshalProtoJSON added in v0.51.6

func (x *GetObjectMetadataBatchRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetObjectMetadataBatchRequest message from JSON.

func (*GetObjectMetadataBatchRequest) UnmarshalVT added in v0.51.6

func (m *GetObjectMetadataBatchRequest) UnmarshalVT(dAtA []byte) error

type GetObjectMetadataBatchResponse added in v0.51.6

type GetObjectMetadataBatchResponse struct {

	// Metadata preserves the request object key order.
	Metadata []*ObjectMetadata `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

GetObjectMetadataBatchResponse is the response type for GetObjectMetadataBatch.

func (*GetObjectMetadataBatchResponse) CloneMessageVT added in v0.51.6

func (*GetObjectMetadataBatchResponse) CloneVT added in v0.51.6

func (*GetObjectMetadataBatchResponse) EqualMessageVT added in v0.51.6

func (this *GetObjectMetadataBatchResponse) EqualMessageVT(thatMsg any) bool

func (*GetObjectMetadataBatchResponse) EqualVT added in v0.51.6

func (*GetObjectMetadataBatchResponse) GetMetadata added in v0.51.6

func (x *GetObjectMetadataBatchResponse) GetMetadata() []*ObjectMetadata

func (*GetObjectMetadataBatchResponse) MarshalJSON added in v0.51.6

func (x *GetObjectMetadataBatchResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetObjectMetadataBatchResponse to JSON.

func (*GetObjectMetadataBatchResponse) MarshalProtoJSON added in v0.51.6

func (x *GetObjectMetadataBatchResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetObjectMetadataBatchResponse message to JSON.

func (*GetObjectMetadataBatchResponse) MarshalProtoText added in v0.51.6

func (x *GetObjectMetadataBatchResponse) MarshalProtoText() string

func (*GetObjectMetadataBatchResponse) MarshalToSizedBufferVT added in v0.51.6

func (m *GetObjectMetadataBatchResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetObjectMetadataBatchResponse) MarshalToVT added in v0.51.6

func (m *GetObjectMetadataBatchResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetObjectMetadataBatchResponse) MarshalVT added in v0.51.6

func (m *GetObjectMetadataBatchResponse) MarshalVT() (dAtA []byte, err error)

func (*GetObjectMetadataBatchResponse) ProtoMessage added in v0.51.6

func (*GetObjectMetadataBatchResponse) ProtoMessage()

func (*GetObjectMetadataBatchResponse) Reset added in v0.51.6

func (x *GetObjectMetadataBatchResponse) Reset()

func (*GetObjectMetadataBatchResponse) SizeVT added in v0.51.6

func (m *GetObjectMetadataBatchResponse) SizeVT() (n int)

func (*GetObjectMetadataBatchResponse) String added in v0.51.6

func (*GetObjectMetadataBatchResponse) UnmarshalJSON added in v0.51.6

func (x *GetObjectMetadataBatchResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetObjectMetadataBatchResponse from JSON.

func (*GetObjectMetadataBatchResponse) UnmarshalProtoJSON added in v0.51.6

func (x *GetObjectMetadataBatchResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetObjectMetadataBatchResponse message from JSON.

func (*GetObjectMetadataBatchResponse) UnmarshalVT added in v0.51.6

func (m *GetObjectMetadataBatchResponse) UnmarshalVT(dAtA []byte) error

type GetObjectRequest

type GetObjectRequest struct {

	// ObjectKey is the unique identifier of the object to retrieve.
	ObjectKey string `protobuf:"bytes,1,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// contains filtered or unexported fields
}

GetObjectRequest is the request type for GetObject.

func (*GetObjectRequest) CloneMessageVT

func (m *GetObjectRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetObjectRequest) CloneVT

func (m *GetObjectRequest) CloneVT() *GetObjectRequest

func (*GetObjectRequest) EqualMessageVT

func (this *GetObjectRequest) EqualMessageVT(thatMsg any) bool

func (*GetObjectRequest) EqualVT

func (this *GetObjectRequest) EqualVT(that *GetObjectRequest) bool

func (*GetObjectRequest) GetObjectKey

func (x *GetObjectRequest) GetObjectKey() string

func (*GetObjectRequest) MarshalJSON

func (x *GetObjectRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetObjectRequest to JSON.

func (*GetObjectRequest) MarshalProtoJSON

func (x *GetObjectRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetObjectRequest message to JSON.

func (*GetObjectRequest) MarshalProtoText

func (x *GetObjectRequest) MarshalProtoText() string

func (*GetObjectRequest) MarshalToSizedBufferVT

func (m *GetObjectRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetObjectRequest) MarshalToVT

func (m *GetObjectRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetObjectRequest) MarshalVT

func (m *GetObjectRequest) MarshalVT() (dAtA []byte, err error)

func (*GetObjectRequest) ProtoMessage

func (*GetObjectRequest) ProtoMessage()

func (*GetObjectRequest) Reset

func (x *GetObjectRequest) Reset()

func (*GetObjectRequest) SizeVT

func (m *GetObjectRequest) SizeVT() (n int)

func (*GetObjectRequest) String

func (x *GetObjectRequest) String() string

func (*GetObjectRequest) UnmarshalJSON

func (x *GetObjectRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetObjectRequest from JSON.

func (*GetObjectRequest) UnmarshalProtoJSON

func (x *GetObjectRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetObjectRequest message from JSON.

func (*GetObjectRequest) UnmarshalVT

func (m *GetObjectRequest) UnmarshalVT(dAtA []byte) error

type GetObjectResponse

type GetObjectResponse struct {

	// Found indicates whether the object exists in the world.
	Found bool `protobuf:"varint,1,opt,name=found,proto3" json:"found,omitempty"`
	// ResourceId is the ID of the ObjectState resource, if found.
	ResourceId uint32 `protobuf:"varint,2,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// ObjectKey is the unique identifier of the object, if found.
	ObjectKey string `protobuf:"bytes,3,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// contains filtered or unexported fields
}

GetObjectResponse is the response type for GetObject.

func (*GetObjectResponse) CloneMessageVT

func (m *GetObjectResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetObjectResponse) CloneVT

func (m *GetObjectResponse) CloneVT() *GetObjectResponse

func (*GetObjectResponse) EqualMessageVT

func (this *GetObjectResponse) EqualMessageVT(thatMsg any) bool

func (*GetObjectResponse) EqualVT

func (this *GetObjectResponse) EqualVT(that *GetObjectResponse) bool

func (*GetObjectResponse) GetFound

func (x *GetObjectResponse) GetFound() bool

func (*GetObjectResponse) GetObjectKey

func (x *GetObjectResponse) GetObjectKey() string

func (*GetObjectResponse) GetResourceId

func (x *GetObjectResponse) GetResourceId() uint32

func (*GetObjectResponse) MarshalJSON

func (x *GetObjectResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetObjectResponse to JSON.

func (*GetObjectResponse) MarshalProtoJSON

func (x *GetObjectResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetObjectResponse message to JSON.

func (*GetObjectResponse) MarshalProtoText

func (x *GetObjectResponse) MarshalProtoText() string

func (*GetObjectResponse) MarshalToSizedBufferVT

func (m *GetObjectResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetObjectResponse) MarshalToVT

func (m *GetObjectResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetObjectResponse) MarshalVT

func (m *GetObjectResponse) MarshalVT() (dAtA []byte, err error)

func (*GetObjectResponse) ProtoMessage

func (*GetObjectResponse) ProtoMessage()

func (*GetObjectResponse) Reset

func (x *GetObjectResponse) Reset()

func (*GetObjectResponse) SizeVT

func (m *GetObjectResponse) SizeVT() (n int)

func (*GetObjectResponse) String

func (x *GetObjectResponse) String() string

func (*GetObjectResponse) UnmarshalJSON

func (x *GetObjectResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetObjectResponse from JSON.

func (*GetObjectResponse) UnmarshalProtoJSON

func (x *GetObjectResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetObjectResponse message from JSON.

func (*GetObjectResponse) UnmarshalVT

func (m *GetObjectResponse) UnmarshalVT(dAtA []byte) error

type GetObjectRootRefsBatchRequest added in v0.51.7

type GetObjectRootRefsBatchRequest struct {

	// ObjectKeys is the list of object keys to inspect.
	ObjectKeys []string `protobuf:"bytes,1,rep,name=object_keys,json=objectKeys,proto3" json:"objectKeys,omitempty"`
	// contains filtered or unexported fields
}

GetObjectRootRefsBatchRequest is the request type for GetObjectRootRefsBatch.

func (*GetObjectRootRefsBatchRequest) CloneMessageVT added in v0.51.7

func (*GetObjectRootRefsBatchRequest) CloneVT added in v0.51.7

func (*GetObjectRootRefsBatchRequest) EqualMessageVT added in v0.51.7

func (this *GetObjectRootRefsBatchRequest) EqualMessageVT(thatMsg any) bool

func (*GetObjectRootRefsBatchRequest) EqualVT added in v0.51.7

func (*GetObjectRootRefsBatchRequest) GetObjectKeys added in v0.51.7

func (x *GetObjectRootRefsBatchRequest) GetObjectKeys() []string

func (*GetObjectRootRefsBatchRequest) MarshalJSON added in v0.51.7

func (x *GetObjectRootRefsBatchRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetObjectRootRefsBatchRequest to JSON.

func (*GetObjectRootRefsBatchRequest) MarshalProtoJSON added in v0.51.7

func (x *GetObjectRootRefsBatchRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetObjectRootRefsBatchRequest message to JSON.

func (*GetObjectRootRefsBatchRequest) MarshalProtoText added in v0.51.7

func (x *GetObjectRootRefsBatchRequest) MarshalProtoText() string

func (*GetObjectRootRefsBatchRequest) MarshalToSizedBufferVT added in v0.51.7

func (m *GetObjectRootRefsBatchRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetObjectRootRefsBatchRequest) MarshalToVT added in v0.51.7

func (m *GetObjectRootRefsBatchRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetObjectRootRefsBatchRequest) MarshalVT added in v0.51.7

func (m *GetObjectRootRefsBatchRequest) MarshalVT() (dAtA []byte, err error)

func (*GetObjectRootRefsBatchRequest) ProtoMessage added in v0.51.7

func (*GetObjectRootRefsBatchRequest) ProtoMessage()

func (*GetObjectRootRefsBatchRequest) Reset added in v0.51.7

func (x *GetObjectRootRefsBatchRequest) Reset()

func (*GetObjectRootRefsBatchRequest) SizeVT added in v0.51.7

func (m *GetObjectRootRefsBatchRequest) SizeVT() (n int)

func (*GetObjectRootRefsBatchRequest) String added in v0.51.7

func (*GetObjectRootRefsBatchRequest) UnmarshalJSON added in v0.51.7

func (x *GetObjectRootRefsBatchRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetObjectRootRefsBatchRequest from JSON.

func (*GetObjectRootRefsBatchRequest) UnmarshalProtoJSON added in v0.51.7

func (x *GetObjectRootRefsBatchRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetObjectRootRefsBatchRequest message from JSON.

func (*GetObjectRootRefsBatchRequest) UnmarshalVT added in v0.51.7

func (m *GetObjectRootRefsBatchRequest) UnmarshalVT(dAtA []byte) error

type GetObjectRootRefsBatchResponse added in v0.51.7

type GetObjectRootRefsBatchResponse struct {

	// RootRefs preserves the request object key order.
	RootRefs []*ObjectRootRef `protobuf:"bytes,1,rep,name=root_refs,json=rootRefs,proto3" json:"rootRefs,omitempty"`
	// contains filtered or unexported fields
}

GetObjectRootRefsBatchResponse is the response type for GetObjectRootRefsBatch.

func (*GetObjectRootRefsBatchResponse) CloneMessageVT added in v0.51.7

func (*GetObjectRootRefsBatchResponse) CloneVT added in v0.51.7

func (*GetObjectRootRefsBatchResponse) EqualMessageVT added in v0.51.7

func (this *GetObjectRootRefsBatchResponse) EqualMessageVT(thatMsg any) bool

func (*GetObjectRootRefsBatchResponse) EqualVT added in v0.51.7

func (*GetObjectRootRefsBatchResponse) GetRootRefs added in v0.51.7

func (x *GetObjectRootRefsBatchResponse) GetRootRefs() []*ObjectRootRef

func (*GetObjectRootRefsBatchResponse) MarshalJSON added in v0.51.7

func (x *GetObjectRootRefsBatchResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetObjectRootRefsBatchResponse to JSON.

func (*GetObjectRootRefsBatchResponse) MarshalProtoJSON added in v0.51.7

func (x *GetObjectRootRefsBatchResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetObjectRootRefsBatchResponse message to JSON.

func (*GetObjectRootRefsBatchResponse) MarshalProtoText added in v0.51.7

func (x *GetObjectRootRefsBatchResponse) MarshalProtoText() string

func (*GetObjectRootRefsBatchResponse) MarshalToSizedBufferVT added in v0.51.7

func (m *GetObjectRootRefsBatchResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetObjectRootRefsBatchResponse) MarshalToVT added in v0.51.7

func (m *GetObjectRootRefsBatchResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetObjectRootRefsBatchResponse) MarshalVT added in v0.51.7

func (m *GetObjectRootRefsBatchResponse) MarshalVT() (dAtA []byte, err error)

func (*GetObjectRootRefsBatchResponse) ProtoMessage added in v0.51.7

func (*GetObjectRootRefsBatchResponse) ProtoMessage()

func (*GetObjectRootRefsBatchResponse) Reset added in v0.51.7

func (x *GetObjectRootRefsBatchResponse) Reset()

func (*GetObjectRootRefsBatchResponse) SizeVT added in v0.51.7

func (m *GetObjectRootRefsBatchResponse) SizeVT() (n int)

func (*GetObjectRootRefsBatchResponse) String added in v0.51.7

func (*GetObjectRootRefsBatchResponse) UnmarshalJSON added in v0.51.7

func (x *GetObjectRootRefsBatchResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetObjectRootRefsBatchResponse from JSON.

func (*GetObjectRootRefsBatchResponse) UnmarshalProtoJSON added in v0.51.7

func (x *GetObjectRootRefsBatchResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetObjectRootRefsBatchResponse message from JSON.

func (*GetObjectRootRefsBatchResponse) UnmarshalVT added in v0.51.7

func (m *GetObjectRootRefsBatchResponse) UnmarshalVT(dAtA []byte) error

type GetReadOnlyRequest

type GetReadOnlyRequest struct {
	// contains filtered or unexported fields
}

GetReadOnlyRequest is the request type for GetReadOnly.

func (*GetReadOnlyRequest) CloneMessageVT

func (m *GetReadOnlyRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetReadOnlyRequest) CloneVT

func (m *GetReadOnlyRequest) CloneVT() *GetReadOnlyRequest

func (*GetReadOnlyRequest) EqualMessageVT

func (this *GetReadOnlyRequest) EqualMessageVT(thatMsg any) bool

func (*GetReadOnlyRequest) EqualVT

func (this *GetReadOnlyRequest) EqualVT(that *GetReadOnlyRequest) bool

func (*GetReadOnlyRequest) MarshalJSON

func (x *GetReadOnlyRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetReadOnlyRequest to JSON.

func (*GetReadOnlyRequest) MarshalProtoJSON

func (x *GetReadOnlyRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetReadOnlyRequest message to JSON.

func (*GetReadOnlyRequest) MarshalProtoText

func (x *GetReadOnlyRequest) MarshalProtoText() string

func (*GetReadOnlyRequest) MarshalToSizedBufferVT

func (m *GetReadOnlyRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetReadOnlyRequest) MarshalToVT

func (m *GetReadOnlyRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetReadOnlyRequest) MarshalVT

func (m *GetReadOnlyRequest) MarshalVT() (dAtA []byte, err error)

func (*GetReadOnlyRequest) ProtoMessage

func (*GetReadOnlyRequest) ProtoMessage()

func (*GetReadOnlyRequest) Reset

func (x *GetReadOnlyRequest) Reset()

func (*GetReadOnlyRequest) SizeVT

func (m *GetReadOnlyRequest) SizeVT() (n int)

func (*GetReadOnlyRequest) String

func (x *GetReadOnlyRequest) String() string

func (*GetReadOnlyRequest) UnmarshalJSON

func (x *GetReadOnlyRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetReadOnlyRequest from JSON.

func (*GetReadOnlyRequest) UnmarshalProtoJSON

func (x *GetReadOnlyRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetReadOnlyRequest message from JSON.

func (*GetReadOnlyRequest) UnmarshalVT

func (m *GetReadOnlyRequest) UnmarshalVT(dAtA []byte) error

type GetReadOnlyResponse

type GetReadOnlyResponse struct {

	// ReadOnly indicates whether the transaction is read-only.
	ReadOnly bool `protobuf:"varint,1,opt,name=read_only,json=readOnly,proto3" json:"readOnly,omitempty"`
	// contains filtered or unexported fields
}

GetReadOnlyResponse is the response type for GetReadOnly.

func (*GetReadOnlyResponse) CloneMessageVT

func (*GetReadOnlyResponse) CloneVT

func (*GetReadOnlyResponse) EqualMessageVT

func (this *GetReadOnlyResponse) EqualMessageVT(thatMsg any) bool

func (*GetReadOnlyResponse) EqualVT

func (this *GetReadOnlyResponse) EqualVT(that *GetReadOnlyResponse) bool

func (*GetReadOnlyResponse) GetReadOnly

func (x *GetReadOnlyResponse) GetReadOnly() bool

func (*GetReadOnlyResponse) MarshalJSON

func (x *GetReadOnlyResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetReadOnlyResponse to JSON.

func (*GetReadOnlyResponse) MarshalProtoJSON

func (x *GetReadOnlyResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetReadOnlyResponse message to JSON.

func (*GetReadOnlyResponse) MarshalProtoText

func (x *GetReadOnlyResponse) MarshalProtoText() string

func (*GetReadOnlyResponse) MarshalToSizedBufferVT

func (m *GetReadOnlyResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetReadOnlyResponse) MarshalToVT

func (m *GetReadOnlyResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetReadOnlyResponse) MarshalVT

func (m *GetReadOnlyResponse) MarshalVT() (dAtA []byte, err error)

func (*GetReadOnlyResponse) ProtoMessage

func (*GetReadOnlyResponse) ProtoMessage()

func (*GetReadOnlyResponse) Reset

func (x *GetReadOnlyResponse) Reset()

func (*GetReadOnlyResponse) SizeVT

func (m *GetReadOnlyResponse) SizeVT() (n int)

func (*GetReadOnlyResponse) String

func (x *GetReadOnlyResponse) String() string

func (*GetReadOnlyResponse) UnmarshalJSON

func (x *GetReadOnlyResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetReadOnlyResponse from JSON.

func (*GetReadOnlyResponse) UnmarshalProtoJSON

func (x *GetReadOnlyResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetReadOnlyResponse message from JSON.

func (*GetReadOnlyResponse) UnmarshalVT

func (m *GetReadOnlyResponse) UnmarshalVT(dAtA []byte) error

type GetRootRefRequest

type GetRootRefRequest struct {
	// contains filtered or unexported fields
}

GetRootRefRequest is the request type for GetRootRef.

func (*GetRootRefRequest) CloneMessageVT

func (m *GetRootRefRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetRootRefRequest) CloneVT

func (m *GetRootRefRequest) CloneVT() *GetRootRefRequest

func (*GetRootRefRequest) EqualMessageVT

func (this *GetRootRefRequest) EqualMessageVT(thatMsg any) bool

func (*GetRootRefRequest) EqualVT

func (this *GetRootRefRequest) EqualVT(that *GetRootRefRequest) bool

func (*GetRootRefRequest) MarshalJSON

func (x *GetRootRefRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetRootRefRequest to JSON.

func (*GetRootRefRequest) MarshalProtoJSON

func (x *GetRootRefRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetRootRefRequest message to JSON.

func (*GetRootRefRequest) MarshalProtoText

func (x *GetRootRefRequest) MarshalProtoText() string

func (*GetRootRefRequest) MarshalToSizedBufferVT

func (m *GetRootRefRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetRootRefRequest) MarshalToVT

func (m *GetRootRefRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetRootRefRequest) MarshalVT

func (m *GetRootRefRequest) MarshalVT() (dAtA []byte, err error)

func (*GetRootRefRequest) ProtoMessage

func (*GetRootRefRequest) ProtoMessage()

func (*GetRootRefRequest) Reset

func (x *GetRootRefRequest) Reset()

func (*GetRootRefRequest) SizeVT

func (m *GetRootRefRequest) SizeVT() (n int)

func (*GetRootRefRequest) String

func (x *GetRootRefRequest) String() string

func (*GetRootRefRequest) UnmarshalJSON

func (x *GetRootRefRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetRootRefRequest from JSON.

func (*GetRootRefRequest) UnmarshalProtoJSON

func (x *GetRootRefRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetRootRefRequest message from JSON.

func (*GetRootRefRequest) UnmarshalVT

func (m *GetRootRefRequest) UnmarshalVT(dAtA []byte) error

type GetRootRefResponse

type GetRootRefResponse struct {

	// RootRef is the reference to the object's root data.
	RootRef *bucket.ObjectRef `protobuf:"bytes,1,opt,name=root_ref,json=rootRef,proto3" json:"rootRef,omitempty"`
	// Rev is the revision number when this reference was retrieved.
	Rev uint64 `protobuf:"varint,2,opt,name=rev,proto3" json:"rev,omitempty"`
	// contains filtered or unexported fields
}

GetRootRefResponse is the response type for GetRootRef.

func (*GetRootRefResponse) CloneMessageVT

func (m *GetRootRefResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetRootRefResponse) CloneVT

func (m *GetRootRefResponse) CloneVT() *GetRootRefResponse

func (*GetRootRefResponse) EqualMessageVT

func (this *GetRootRefResponse) EqualMessageVT(thatMsg any) bool

func (*GetRootRefResponse) EqualVT

func (this *GetRootRefResponse) EqualVT(that *GetRootRefResponse) bool

func (*GetRootRefResponse) GetRev

func (x *GetRootRefResponse) GetRev() uint64

func (*GetRootRefResponse) GetRootRef

func (x *GetRootRefResponse) GetRootRef() *bucket.ObjectRef

func (*GetRootRefResponse) MarshalJSON

func (x *GetRootRefResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetRootRefResponse to JSON.

func (*GetRootRefResponse) MarshalProtoJSON

func (x *GetRootRefResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetRootRefResponse message to JSON.

func (*GetRootRefResponse) MarshalProtoText

func (x *GetRootRefResponse) MarshalProtoText() string

func (*GetRootRefResponse) MarshalToSizedBufferVT

func (m *GetRootRefResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetRootRefResponse) MarshalToVT

func (m *GetRootRefResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetRootRefResponse) MarshalVT

func (m *GetRootRefResponse) MarshalVT() (dAtA []byte, err error)

func (*GetRootRefResponse) ProtoMessage

func (*GetRootRefResponse) ProtoMessage()

func (*GetRootRefResponse) Reset

func (x *GetRootRefResponse) Reset()

func (*GetRootRefResponse) SizeVT

func (m *GetRootRefResponse) SizeVT() (n int)

func (*GetRootRefResponse) String

func (x *GetRootRefResponse) String() string

func (*GetRootRefResponse) UnmarshalJSON

func (x *GetRootRefResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetRootRefResponse from JSON.

func (*GetRootRefResponse) UnmarshalProtoJSON

func (x *GetRootRefResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetRootRefResponse message from JSON.

func (*GetRootRefResponse) UnmarshalVT

func (m *GetRootRefResponse) UnmarshalVT(dAtA []byte) error

type GetSeqnoRequest

type GetSeqnoRequest struct {
	// contains filtered or unexported fields
}

GetSeqnoRequest is the request type for GetSeqno.

func (*GetSeqnoRequest) CloneMessageVT

func (m *GetSeqnoRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetSeqnoRequest) CloneVT

func (m *GetSeqnoRequest) CloneVT() *GetSeqnoRequest

func (*GetSeqnoRequest) EqualMessageVT

func (this *GetSeqnoRequest) EqualMessageVT(thatMsg any) bool

func (*GetSeqnoRequest) EqualVT

func (this *GetSeqnoRequest) EqualVT(that *GetSeqnoRequest) bool

func (*GetSeqnoRequest) MarshalJSON

func (x *GetSeqnoRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetSeqnoRequest to JSON.

func (*GetSeqnoRequest) MarshalProtoJSON

func (x *GetSeqnoRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetSeqnoRequest message to JSON.

func (*GetSeqnoRequest) MarshalProtoText

func (x *GetSeqnoRequest) MarshalProtoText() string

func (*GetSeqnoRequest) MarshalToSizedBufferVT

func (m *GetSeqnoRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetSeqnoRequest) MarshalToVT

func (m *GetSeqnoRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetSeqnoRequest) MarshalVT

func (m *GetSeqnoRequest) MarshalVT() (dAtA []byte, err error)

func (*GetSeqnoRequest) ProtoMessage

func (*GetSeqnoRequest) ProtoMessage()

func (*GetSeqnoRequest) Reset

func (x *GetSeqnoRequest) Reset()

func (*GetSeqnoRequest) SizeVT

func (m *GetSeqnoRequest) SizeVT() (n int)

func (*GetSeqnoRequest) String

func (x *GetSeqnoRequest) String() string

func (*GetSeqnoRequest) UnmarshalJSON

func (x *GetSeqnoRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetSeqnoRequest from JSON.

func (*GetSeqnoRequest) UnmarshalProtoJSON

func (x *GetSeqnoRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetSeqnoRequest message from JSON.

func (*GetSeqnoRequest) UnmarshalVT

func (m *GetSeqnoRequest) UnmarshalVT(dAtA []byte) error

type GetSeqnoResponse

type GetSeqnoResponse struct {

	// Seqno is the current sequence number of the world state.
	Seqno uint64 `protobuf:"varint,1,opt,name=seqno,proto3" json:"seqno,omitempty"`
	// contains filtered or unexported fields
}

GetSeqnoResponse is the response type for GetSeqno.

func (*GetSeqnoResponse) CloneMessageVT

func (m *GetSeqnoResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetSeqnoResponse) CloneVT

func (m *GetSeqnoResponse) CloneVT() *GetSeqnoResponse

func (*GetSeqnoResponse) EqualMessageVT

func (this *GetSeqnoResponse) EqualMessageVT(thatMsg any) bool

func (*GetSeqnoResponse) EqualVT

func (this *GetSeqnoResponse) EqualVT(that *GetSeqnoResponse) bool

func (*GetSeqnoResponse) GetSeqno

func (x *GetSeqnoResponse) GetSeqno() uint64

func (*GetSeqnoResponse) MarshalJSON

func (x *GetSeqnoResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetSeqnoResponse to JSON.

func (*GetSeqnoResponse) MarshalProtoJSON

func (x *GetSeqnoResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetSeqnoResponse message to JSON.

func (*GetSeqnoResponse) MarshalProtoText

func (x *GetSeqnoResponse) MarshalProtoText() string

func (*GetSeqnoResponse) MarshalToSizedBufferVT

func (m *GetSeqnoResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetSeqnoResponse) MarshalToVT

func (m *GetSeqnoResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetSeqnoResponse) MarshalVT

func (m *GetSeqnoResponse) MarshalVT() (dAtA []byte, err error)

func (*GetSeqnoResponse) ProtoMessage

func (*GetSeqnoResponse) ProtoMessage()

func (*GetSeqnoResponse) Reset

func (x *GetSeqnoResponse) Reset()

func (*GetSeqnoResponse) SizeVT

func (m *GetSeqnoResponse) SizeVT() (n int)

func (*GetSeqnoResponse) String

func (x *GetSeqnoResponse) String() string

func (*GetSeqnoResponse) UnmarshalJSON

func (x *GetSeqnoResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetSeqnoResponse from JSON.

func (*GetSeqnoResponse) UnmarshalProtoJSON

func (x *GetSeqnoResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetSeqnoResponse message from JSON.

func (*GetSeqnoResponse) UnmarshalVT

func (m *GetSeqnoResponse) UnmarshalVT(dAtA []byte) error

type GetWorldRootSnapshotRequest added in v0.51.7

type GetWorldRootSnapshotRequest struct {
	// contains filtered or unexported fields
}

GetWorldRootSnapshotRequest is the request type for GetWorldRootSnapshot.

func (*GetWorldRootSnapshotRequest) CloneMessageVT added in v0.51.7

func (*GetWorldRootSnapshotRequest) CloneVT added in v0.51.7

func (*GetWorldRootSnapshotRequest) EqualMessageVT added in v0.51.7

func (this *GetWorldRootSnapshotRequest) EqualMessageVT(thatMsg any) bool

func (*GetWorldRootSnapshotRequest) EqualVT added in v0.51.7

func (*GetWorldRootSnapshotRequest) MarshalJSON added in v0.51.7

func (x *GetWorldRootSnapshotRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetWorldRootSnapshotRequest to JSON.

func (*GetWorldRootSnapshotRequest) MarshalProtoJSON added in v0.51.7

func (x *GetWorldRootSnapshotRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetWorldRootSnapshotRequest message to JSON.

func (*GetWorldRootSnapshotRequest) MarshalProtoText added in v0.51.7

func (x *GetWorldRootSnapshotRequest) MarshalProtoText() string

func (*GetWorldRootSnapshotRequest) MarshalToSizedBufferVT added in v0.51.7

func (m *GetWorldRootSnapshotRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetWorldRootSnapshotRequest) MarshalToVT added in v0.51.7

func (m *GetWorldRootSnapshotRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetWorldRootSnapshotRequest) MarshalVT added in v0.51.7

func (m *GetWorldRootSnapshotRequest) MarshalVT() (dAtA []byte, err error)

func (*GetWorldRootSnapshotRequest) ProtoMessage added in v0.51.7

func (*GetWorldRootSnapshotRequest) ProtoMessage()

func (*GetWorldRootSnapshotRequest) Reset added in v0.51.7

func (x *GetWorldRootSnapshotRequest) Reset()

func (*GetWorldRootSnapshotRequest) SizeVT added in v0.51.7

func (m *GetWorldRootSnapshotRequest) SizeVT() (n int)

func (*GetWorldRootSnapshotRequest) String added in v0.51.7

func (x *GetWorldRootSnapshotRequest) String() string

func (*GetWorldRootSnapshotRequest) UnmarshalJSON added in v0.51.7

func (x *GetWorldRootSnapshotRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetWorldRootSnapshotRequest from JSON.

func (*GetWorldRootSnapshotRequest) UnmarshalProtoJSON added in v0.51.7

func (x *GetWorldRootSnapshotRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetWorldRootSnapshotRequest message from JSON.

func (*GetWorldRootSnapshotRequest) UnmarshalVT added in v0.51.7

func (m *GetWorldRootSnapshotRequest) UnmarshalVT(dAtA []byte) error

type GraphEdgeBucket added in v0.51.7

type GraphEdgeBucket struct {

	// OriginObjectKey is the requested origin object key for this bucket.
	OriginObjectKey string `protobuf:"bytes,1,opt,name=origin_object_key,json=originObjectKey,proto3" json:"originObjectKey,omitempty"`
	// Outgoing contains quads where the origin is the subject.
	Outgoing []*quad.Quad `protobuf:"bytes,2,rep,name=outgoing,proto3" json:"outgoing,omitempty"`
	// Incoming contains quads where the origin is the object.
	Incoming []*quad.Quad `protobuf:"bytes,3,rep,name=incoming,proto3" json:"incoming,omitempty"`
	// OutgoingTruncated indicates more outgoing edges matched than were returned.
	OutgoingTruncated bool `protobuf:"varint,4,opt,name=outgoing_truncated,json=outgoingTruncated,proto3" json:"outgoingTruncated,omitempty"`
	// IncomingTruncated indicates more incoming edges matched than were returned.
	IncomingTruncated bool `protobuf:"varint,5,opt,name=incoming_truncated,json=incomingTruncated,proto3" json:"incomingTruncated,omitempty"`
	// contains filtered or unexported fields
}

GraphEdgeBucket contains grouped graph edges for one origin object key.

func (*GraphEdgeBucket) CloneMessageVT added in v0.51.7

func (m *GraphEdgeBucket) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GraphEdgeBucket) CloneVT added in v0.51.7

func (m *GraphEdgeBucket) CloneVT() *GraphEdgeBucket

func (*GraphEdgeBucket) EqualMessageVT added in v0.51.7

func (this *GraphEdgeBucket) EqualMessageVT(thatMsg any) bool

func (*GraphEdgeBucket) EqualVT added in v0.51.7

func (this *GraphEdgeBucket) EqualVT(that *GraphEdgeBucket) bool

func (*GraphEdgeBucket) GetIncoming added in v0.51.7

func (x *GraphEdgeBucket) GetIncoming() []*quad.Quad

func (*GraphEdgeBucket) GetIncomingTruncated added in v0.51.7

func (x *GraphEdgeBucket) GetIncomingTruncated() bool

func (*GraphEdgeBucket) GetOriginObjectKey added in v0.51.7

func (x *GraphEdgeBucket) GetOriginObjectKey() string

func (*GraphEdgeBucket) GetOutgoing added in v0.51.7

func (x *GraphEdgeBucket) GetOutgoing() []*quad.Quad

func (*GraphEdgeBucket) GetOutgoingTruncated added in v0.51.7

func (x *GraphEdgeBucket) GetOutgoingTruncated() bool

func (*GraphEdgeBucket) MarshalJSON added in v0.51.7

func (x *GraphEdgeBucket) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GraphEdgeBucket to JSON.

func (*GraphEdgeBucket) MarshalProtoJSON added in v0.51.7

func (x *GraphEdgeBucket) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GraphEdgeBucket message to JSON.

func (*GraphEdgeBucket) MarshalProtoText added in v0.51.7

func (x *GraphEdgeBucket) MarshalProtoText() string

func (*GraphEdgeBucket) MarshalToSizedBufferVT added in v0.51.7

func (m *GraphEdgeBucket) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GraphEdgeBucket) MarshalToVT added in v0.51.7

func (m *GraphEdgeBucket) MarshalToVT(dAtA []byte) (int, error)

func (*GraphEdgeBucket) MarshalVT added in v0.51.7

func (m *GraphEdgeBucket) MarshalVT() (dAtA []byte, err error)

func (*GraphEdgeBucket) ProtoMessage added in v0.51.7

func (*GraphEdgeBucket) ProtoMessage()

func (*GraphEdgeBucket) Reset added in v0.51.7

func (x *GraphEdgeBucket) Reset()

func (*GraphEdgeBucket) SizeVT added in v0.51.7

func (m *GraphEdgeBucket) SizeVT() (n int)

func (*GraphEdgeBucket) String added in v0.51.7

func (x *GraphEdgeBucket) String() string

func (*GraphEdgeBucket) UnmarshalJSON added in v0.51.7

func (x *GraphEdgeBucket) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GraphEdgeBucket from JSON.

func (*GraphEdgeBucket) UnmarshalProtoJSON added in v0.51.7

func (x *GraphEdgeBucket) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GraphEdgeBucket message from JSON.

func (*GraphEdgeBucket) UnmarshalVT added in v0.51.7

func (m *GraphEdgeBucket) UnmarshalVT(dAtA []byte) error

type GraphEdgeBucketDirection added in v0.51.7

type GraphEdgeBucketDirection int32

GraphEdgeBucketDirection indicates which edge directions to list.

const (
	// GRAPH_EDGE_BUCKET_DIRECTION_UNSPECIFIED lists incoming and outgoing edges.
	GraphEdgeBucketDirection_GRAPH_EDGE_BUCKET_DIRECTION_UNSPECIFIED GraphEdgeBucketDirection = 0
	// GRAPH_EDGE_BUCKET_DIRECTION_OUT lists only outgoing edges.
	GraphEdgeBucketDirection_GRAPH_EDGE_BUCKET_DIRECTION_OUT GraphEdgeBucketDirection = 1
	// GRAPH_EDGE_BUCKET_DIRECTION_IN lists only incoming edges.
	GraphEdgeBucketDirection_GRAPH_EDGE_BUCKET_DIRECTION_IN GraphEdgeBucketDirection = 2
	// GRAPH_EDGE_BUCKET_DIRECTION_BOTH lists incoming and outgoing edges.
	GraphEdgeBucketDirection_GRAPH_EDGE_BUCKET_DIRECTION_BOTH GraphEdgeBucketDirection = 3
)

func (GraphEdgeBucketDirection) Enum added in v0.51.7

func (GraphEdgeBucketDirection) MarshalJSON added in v0.51.7

func (x GraphEdgeBucketDirection) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GraphEdgeBucketDirection to JSON.

func (GraphEdgeBucketDirection) MarshalProtoJSON added in v0.51.7

func (x GraphEdgeBucketDirection) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GraphEdgeBucketDirection to JSON.

func (GraphEdgeBucketDirection) MarshalProtoText added in v0.51.7

func (x GraphEdgeBucketDirection) MarshalProtoText() string

func (GraphEdgeBucketDirection) MarshalText added in v0.51.7

func (x GraphEdgeBucketDirection) MarshalText() ([]byte, error)

MarshalText marshals the GraphEdgeBucketDirection to text.

func (GraphEdgeBucketDirection) String added in v0.51.7

func (x GraphEdgeBucketDirection) String() string

func (*GraphEdgeBucketDirection) UnmarshalJSON added in v0.51.7

func (x *GraphEdgeBucketDirection) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GraphEdgeBucketDirection from JSON.

func (*GraphEdgeBucketDirection) UnmarshalProtoJSON added in v0.51.7

func (x *GraphEdgeBucketDirection) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GraphEdgeBucketDirection from JSON.

func (*GraphEdgeBucketDirection) UnmarshalText added in v0.51.7

func (x *GraphEdgeBucketDirection) UnmarshalText(b []byte) error

UnmarshalText unmarshals the GraphEdgeBucketDirection from text.

type GraphPathDirection added in v0.51.6

type GraphPathDirection int32

GraphPathDirection indicates which side of the current object key to follow.

const (
	// GRAPH_PATH_DIRECTION_UNSPECIFIED is invalid.
	GraphPathDirection_GRAPH_PATH_DIRECTION_UNSPECIFIED GraphPathDirection = 0
	// GRAPH_PATH_DIRECTION_OUT follows quads where the current key is the subject.
	GraphPathDirection_GRAPH_PATH_DIRECTION_OUT GraphPathDirection = 1
	// GRAPH_PATH_DIRECTION_IN follows quads where the current key is the object.
	GraphPathDirection_GRAPH_PATH_DIRECTION_IN GraphPathDirection = 2
	// GRAPH_PATH_DIRECTION_BOTH follows incoming and outgoing quads.
	GraphPathDirection_GRAPH_PATH_DIRECTION_BOTH GraphPathDirection = 3
)

func (GraphPathDirection) Enum added in v0.51.6

func (GraphPathDirection) MarshalJSON added in v0.51.6

func (x GraphPathDirection) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GraphPathDirection to JSON.

func (GraphPathDirection) MarshalProtoJSON added in v0.51.6

func (x GraphPathDirection) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GraphPathDirection to JSON.

func (GraphPathDirection) MarshalProtoText added in v0.51.6

func (x GraphPathDirection) MarshalProtoText() string

func (GraphPathDirection) MarshalText added in v0.51.6

func (x GraphPathDirection) MarshalText() ([]byte, error)

MarshalText marshals the GraphPathDirection to text.

func (GraphPathDirection) String added in v0.51.6

func (x GraphPathDirection) String() string

func (*GraphPathDirection) UnmarshalJSON added in v0.51.6

func (x *GraphPathDirection) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GraphPathDirection from JSON.

func (*GraphPathDirection) UnmarshalProtoJSON added in v0.51.6

func (x *GraphPathDirection) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GraphPathDirection from JSON.

func (*GraphPathDirection) UnmarshalText added in v0.51.6

func (x *GraphPathDirection) UnmarshalText(b []byte) error

UnmarshalText unmarshals the GraphPathDirection from text.

type GraphPathStep added in v0.51.6

type GraphPathStep struct {

	// Direction is the edge direction to follow.
	Direction GraphPathDirection `protobuf:"varint,1,opt,name=direction,proto3" json:"direction,omitempty"`
	// Predicate is the graph predicate to match.
	Predicate string `protobuf:"bytes,2,opt,name=predicate,proto3" json:"predicate,omitempty"`
	// Limit is the maximum number of quads to inspect for each current object key.
	Limit uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

GraphPathStep is one bounded predicate traversal step.

func (*GraphPathStep) CloneMessageVT added in v0.51.6

func (m *GraphPathStep) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GraphPathStep) CloneVT added in v0.51.6

func (m *GraphPathStep) CloneVT() *GraphPathStep

func (*GraphPathStep) EqualMessageVT added in v0.51.6

func (this *GraphPathStep) EqualMessageVT(thatMsg any) bool

func (*GraphPathStep) EqualVT added in v0.51.6

func (this *GraphPathStep) EqualVT(that *GraphPathStep) bool

func (*GraphPathStep) GetDirection added in v0.51.6

func (x *GraphPathStep) GetDirection() GraphPathDirection

func (*GraphPathStep) GetLimit added in v0.51.6

func (x *GraphPathStep) GetLimit() uint32

func (*GraphPathStep) GetPredicate added in v0.51.6

func (x *GraphPathStep) GetPredicate() string

func (*GraphPathStep) MarshalJSON added in v0.51.6

func (x *GraphPathStep) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GraphPathStep to JSON.

func (*GraphPathStep) MarshalProtoJSON added in v0.51.6

func (x *GraphPathStep) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GraphPathStep message to JSON.

func (*GraphPathStep) MarshalProtoText added in v0.51.6

func (x *GraphPathStep) MarshalProtoText() string

func (*GraphPathStep) MarshalToSizedBufferVT added in v0.51.6

func (m *GraphPathStep) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GraphPathStep) MarshalToVT added in v0.51.6

func (m *GraphPathStep) MarshalToVT(dAtA []byte) (int, error)

func (*GraphPathStep) MarshalVT added in v0.51.6

func (m *GraphPathStep) MarshalVT() (dAtA []byte, err error)

func (*GraphPathStep) ProtoMessage added in v0.51.6

func (*GraphPathStep) ProtoMessage()

func (*GraphPathStep) Reset added in v0.51.6

func (x *GraphPathStep) Reset()

func (*GraphPathStep) SizeVT added in v0.51.6

func (m *GraphPathStep) SizeVT() (n int)

func (*GraphPathStep) String added in v0.51.6

func (x *GraphPathStep) String() string

func (*GraphPathStep) UnmarshalJSON added in v0.51.6

func (x *GraphPathStep) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GraphPathStep from JSON.

func (*GraphPathStep) UnmarshalProtoJSON added in v0.51.6

func (x *GraphPathStep) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GraphPathStep message from JSON.

func (*GraphPathStep) UnmarshalVT added in v0.51.6

func (m *GraphPathStep) UnmarshalVT(dAtA []byte) error

type IncrementRevRequest

type IncrementRevRequest struct {
	// contains filtered or unexported fields
}

IncrementRevRequest is the request type for IncrementRev.

func (*IncrementRevRequest) CloneMessageVT

func (*IncrementRevRequest) CloneVT

func (*IncrementRevRequest) EqualMessageVT

func (this *IncrementRevRequest) EqualMessageVT(thatMsg any) bool

func (*IncrementRevRequest) EqualVT

func (this *IncrementRevRequest) EqualVT(that *IncrementRevRequest) bool

func (*IncrementRevRequest) MarshalJSON

func (x *IncrementRevRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the IncrementRevRequest to JSON.

func (*IncrementRevRequest) MarshalProtoJSON

func (x *IncrementRevRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the IncrementRevRequest message to JSON.

func (*IncrementRevRequest) MarshalProtoText

func (x *IncrementRevRequest) MarshalProtoText() string

func (*IncrementRevRequest) MarshalToSizedBufferVT

func (m *IncrementRevRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*IncrementRevRequest) MarshalToVT

func (m *IncrementRevRequest) MarshalToVT(dAtA []byte) (int, error)

func (*IncrementRevRequest) MarshalVT

func (m *IncrementRevRequest) MarshalVT() (dAtA []byte, err error)

func (*IncrementRevRequest) ProtoMessage

func (*IncrementRevRequest) ProtoMessage()

func (*IncrementRevRequest) Reset

func (x *IncrementRevRequest) Reset()

func (*IncrementRevRequest) SizeVT

func (m *IncrementRevRequest) SizeVT() (n int)

func (*IncrementRevRequest) String

func (x *IncrementRevRequest) String() string

func (*IncrementRevRequest) UnmarshalJSON

func (x *IncrementRevRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the IncrementRevRequest from JSON.

func (*IncrementRevRequest) UnmarshalProtoJSON

func (x *IncrementRevRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the IncrementRevRequest message from JSON.

func (*IncrementRevRequest) UnmarshalVT

func (m *IncrementRevRequest) UnmarshalVT(dAtA []byte) error

type IncrementRevResponse

type IncrementRevResponse struct {

	// Rev is the revision number after the increment.
	Rev uint64 `protobuf:"varint,1,opt,name=rev,proto3" json:"rev,omitempty"`
	// contains filtered or unexported fields
}

IncrementRevResponse is the response type for IncrementRev.

func (*IncrementRevResponse) CloneMessageVT

func (*IncrementRevResponse) CloneVT

func (*IncrementRevResponse) EqualMessageVT

func (this *IncrementRevResponse) EqualMessageVT(thatMsg any) bool

func (*IncrementRevResponse) EqualVT

func (this *IncrementRevResponse) EqualVT(that *IncrementRevResponse) bool

func (*IncrementRevResponse) GetRev

func (x *IncrementRevResponse) GetRev() uint64

func (*IncrementRevResponse) MarshalJSON

func (x *IncrementRevResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the IncrementRevResponse to JSON.

func (*IncrementRevResponse) MarshalProtoJSON

func (x *IncrementRevResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the IncrementRevResponse message to JSON.

func (*IncrementRevResponse) MarshalProtoText

func (x *IncrementRevResponse) MarshalProtoText() string

func (*IncrementRevResponse) MarshalToSizedBufferVT

func (m *IncrementRevResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*IncrementRevResponse) MarshalToVT

func (m *IncrementRevResponse) MarshalToVT(dAtA []byte) (int, error)

func (*IncrementRevResponse) MarshalVT

func (m *IncrementRevResponse) MarshalVT() (dAtA []byte, err error)

func (*IncrementRevResponse) ProtoMessage

func (*IncrementRevResponse) ProtoMessage()

func (*IncrementRevResponse) Reset

func (x *IncrementRevResponse) Reset()

func (*IncrementRevResponse) SizeVT

func (m *IncrementRevResponse) SizeVT() (n int)

func (*IncrementRevResponse) String

func (x *IncrementRevResponse) String() string

func (*IncrementRevResponse) UnmarshalJSON

func (x *IncrementRevResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the IncrementRevResponse from JSON.

func (*IncrementRevResponse) UnmarshalProtoJSON

func (x *IncrementRevResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the IncrementRevResponse message from JSON.

func (*IncrementRevResponse) UnmarshalVT

func (m *IncrementRevResponse) UnmarshalVT(dAtA []byte) error

type IterateObjectsRequest

type IterateObjectsRequest struct {

	// Prefix filters objects to those whose keys start with this string.
	// Empty prefix returns all objects.
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// Reversed indicates whether to return results in descending order.
	Reversed bool `protobuf:"varint,2,opt,name=reversed,proto3" json:"reversed,omitempty"`
	// contains filtered or unexported fields
}

IterateObjectsRequest is the request type for IterateObjects.

func (*IterateObjectsRequest) CloneMessageVT

func (*IterateObjectsRequest) CloneVT

func (*IterateObjectsRequest) EqualMessageVT

func (this *IterateObjectsRequest) EqualMessageVT(thatMsg any) bool

func (*IterateObjectsRequest) EqualVT

func (this *IterateObjectsRequest) EqualVT(that *IterateObjectsRequest) bool

func (*IterateObjectsRequest) GetPrefix

func (x *IterateObjectsRequest) GetPrefix() string

func (*IterateObjectsRequest) GetReversed

func (x *IterateObjectsRequest) GetReversed() bool

func (*IterateObjectsRequest) MarshalJSON

func (x *IterateObjectsRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the IterateObjectsRequest to JSON.

func (*IterateObjectsRequest) MarshalProtoJSON

func (x *IterateObjectsRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the IterateObjectsRequest message to JSON.

func (*IterateObjectsRequest) MarshalProtoText

func (x *IterateObjectsRequest) MarshalProtoText() string

func (*IterateObjectsRequest) MarshalToSizedBufferVT

func (m *IterateObjectsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*IterateObjectsRequest) MarshalToVT

func (m *IterateObjectsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*IterateObjectsRequest) MarshalVT

func (m *IterateObjectsRequest) MarshalVT() (dAtA []byte, err error)

func (*IterateObjectsRequest) ProtoMessage

func (*IterateObjectsRequest) ProtoMessage()

func (*IterateObjectsRequest) Reset

func (x *IterateObjectsRequest) Reset()

func (*IterateObjectsRequest) SizeVT

func (m *IterateObjectsRequest) SizeVT() (n int)

func (*IterateObjectsRequest) String

func (x *IterateObjectsRequest) String() string

func (*IterateObjectsRequest) UnmarshalJSON

func (x *IterateObjectsRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the IterateObjectsRequest from JSON.

func (*IterateObjectsRequest) UnmarshalProtoJSON

func (x *IterateObjectsRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the IterateObjectsRequest message from JSON.

func (*IterateObjectsRequest) UnmarshalVT

func (m *IterateObjectsRequest) UnmarshalVT(dAtA []byte) error

type IterateObjectsResponse

type IterateObjectsResponse struct {

	// ResourceId is the ID of the ObjectIterator resource.
	ResourceId uint32 `protobuf:"varint,1,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// contains filtered or unexported fields
}

IterateObjectsResponse is the response type for IterateObjects.

func (*IterateObjectsResponse) CloneMessageVT

func (*IterateObjectsResponse) CloneVT

func (*IterateObjectsResponse) EqualMessageVT

func (this *IterateObjectsResponse) EqualMessageVT(thatMsg any) bool

func (*IterateObjectsResponse) EqualVT

func (this *IterateObjectsResponse) EqualVT(that *IterateObjectsResponse) bool

func (*IterateObjectsResponse) GetResourceId

func (x *IterateObjectsResponse) GetResourceId() uint32

func (*IterateObjectsResponse) MarshalJSON

func (x *IterateObjectsResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the IterateObjectsResponse to JSON.

func (*IterateObjectsResponse) MarshalProtoJSON

func (x *IterateObjectsResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the IterateObjectsResponse message to JSON.

func (*IterateObjectsResponse) MarshalProtoText

func (x *IterateObjectsResponse) MarshalProtoText() string

func (*IterateObjectsResponse) MarshalToSizedBufferVT

func (m *IterateObjectsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*IterateObjectsResponse) MarshalToVT

func (m *IterateObjectsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*IterateObjectsResponse) MarshalVT

func (m *IterateObjectsResponse) MarshalVT() (dAtA []byte, err error)

func (*IterateObjectsResponse) ProtoMessage

func (*IterateObjectsResponse) ProtoMessage()

func (*IterateObjectsResponse) Reset

func (x *IterateObjectsResponse) Reset()

func (*IterateObjectsResponse) SizeVT

func (m *IterateObjectsResponse) SizeVT() (n int)

func (*IterateObjectsResponse) String

func (x *IterateObjectsResponse) String() string

func (*IterateObjectsResponse) UnmarshalJSON

func (x *IterateObjectsResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the IterateObjectsResponse from JSON.

func (*IterateObjectsResponse) UnmarshalProtoJSON

func (x *IterateObjectsResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the IterateObjectsResponse message from JSON.

func (*IterateObjectsResponse) UnmarshalVT

func (m *IterateObjectsResponse) UnmarshalVT(dAtA []byte) error

type KeyRequest

type KeyRequest struct {
	// contains filtered or unexported fields
}

KeyRequest is the request type for Key.

func (*KeyRequest) CloneMessageVT

func (m *KeyRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*KeyRequest) CloneVT

func (m *KeyRequest) CloneVT() *KeyRequest

func (*KeyRequest) EqualMessageVT

func (this *KeyRequest) EqualMessageVT(thatMsg any) bool

func (*KeyRequest) EqualVT

func (this *KeyRequest) EqualVT(that *KeyRequest) bool

func (*KeyRequest) MarshalJSON

func (x *KeyRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the KeyRequest to JSON.

func (*KeyRequest) MarshalProtoJSON

func (x *KeyRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the KeyRequest message to JSON.

func (*KeyRequest) MarshalProtoText

func (x *KeyRequest) MarshalProtoText() string

func (*KeyRequest) MarshalToSizedBufferVT

func (m *KeyRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*KeyRequest) MarshalToVT

func (m *KeyRequest) MarshalToVT(dAtA []byte) (int, error)

func (*KeyRequest) MarshalVT

func (m *KeyRequest) MarshalVT() (dAtA []byte, err error)

func (*KeyRequest) ProtoMessage

func (*KeyRequest) ProtoMessage()

func (*KeyRequest) Reset

func (x *KeyRequest) Reset()

func (*KeyRequest) SizeVT

func (m *KeyRequest) SizeVT() (n int)

func (*KeyRequest) String

func (x *KeyRequest) String() string

func (*KeyRequest) UnmarshalJSON

func (x *KeyRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the KeyRequest from JSON.

func (*KeyRequest) UnmarshalProtoJSON

func (x *KeyRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the KeyRequest message from JSON.

func (*KeyRequest) UnmarshalVT

func (m *KeyRequest) UnmarshalVT(dAtA []byte) error

type KeyResponse

type KeyResponse struct {

	// ObjectKey is the current entry key, or empty if not valid.
	ObjectKey string `protobuf:"bytes,1,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// contains filtered or unexported fields
}

KeyResponse is the response type for Key.

func (*KeyResponse) CloneMessageVT

func (m *KeyResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*KeyResponse) CloneVT

func (m *KeyResponse) CloneVT() *KeyResponse

func (*KeyResponse) EqualMessageVT

func (this *KeyResponse) EqualMessageVT(thatMsg any) bool

func (*KeyResponse) EqualVT

func (this *KeyResponse) EqualVT(that *KeyResponse) bool

func (*KeyResponse) GetObjectKey

func (x *KeyResponse) GetObjectKey() string

func (*KeyResponse) MarshalJSON

func (x *KeyResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the KeyResponse to JSON.

func (*KeyResponse) MarshalProtoJSON

func (x *KeyResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the KeyResponse message to JSON.

func (*KeyResponse) MarshalProtoText

func (x *KeyResponse) MarshalProtoText() string

func (*KeyResponse) MarshalToSizedBufferVT

func (m *KeyResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*KeyResponse) MarshalToVT

func (m *KeyResponse) MarshalToVT(dAtA []byte) (int, error)

func (*KeyResponse) MarshalVT

func (m *KeyResponse) MarshalVT() (dAtA []byte, err error)

func (*KeyResponse) ProtoMessage

func (*KeyResponse) ProtoMessage()

func (*KeyResponse) Reset

func (x *KeyResponse) Reset()

func (*KeyResponse) SizeVT

func (m *KeyResponse) SizeVT() (n int)

func (*KeyResponse) String

func (x *KeyResponse) String() string

func (*KeyResponse) UnmarshalJSON

func (x *KeyResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the KeyResponse from JSON.

func (*KeyResponse) UnmarshalProtoJSON

func (x *KeyResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the KeyResponse message from JSON.

func (*KeyResponse) UnmarshalVT

func (m *KeyResponse) UnmarshalVT(dAtA []byte) error

type ListGraphEdgeBucketsRequest added in v0.51.7

type ListGraphEdgeBucketsRequest struct {

	// OriginObjectKeys are object keys whose graph edges should be grouped.
	// The response contains one bucket per requested origin in request order.
	OriginObjectKeys []string `protobuf:"bytes,1,rep,name=origin_object_keys,json=originObjectKeys,proto3" json:"originObjectKeys,omitempty"`
	// Predicate optionally restricts the grouped edges.
	Predicate string `protobuf:"bytes,2,opt,name=predicate,proto3" json:"predicate,omitempty"`
	// LimitPerOrigin is the maximum edge count returned per origin direction.
	// It must be non-zero.
	LimitPerOrigin uint32 `protobuf:"varint,3,opt,name=limit_per_origin,json=limitPerOrigin,proto3" json:"limitPerOrigin,omitempty"`
	// Direction selects which edge directions are included.
	// Unspecified means both incoming and outgoing.
	Direction GraphEdgeBucketDirection `protobuf:"varint,4,opt,name=direction,proto3" json:"direction,omitempty"`
	// contains filtered or unexported fields
}

ListGraphEdgeBucketsRequest lists grouped inbound/outbound graph edges for origin object keys.

func (*ListGraphEdgeBucketsRequest) CloneMessageVT added in v0.51.7

func (*ListGraphEdgeBucketsRequest) CloneVT added in v0.51.7

func (*ListGraphEdgeBucketsRequest) EqualMessageVT added in v0.51.7

func (this *ListGraphEdgeBucketsRequest) EqualMessageVT(thatMsg any) bool

func (*ListGraphEdgeBucketsRequest) EqualVT added in v0.51.7

func (*ListGraphEdgeBucketsRequest) GetDirection added in v0.51.7

func (*ListGraphEdgeBucketsRequest) GetLimitPerOrigin added in v0.51.7

func (x *ListGraphEdgeBucketsRequest) GetLimitPerOrigin() uint32

func (*ListGraphEdgeBucketsRequest) GetOriginObjectKeys added in v0.51.7

func (x *ListGraphEdgeBucketsRequest) GetOriginObjectKeys() []string

func (*ListGraphEdgeBucketsRequest) GetPredicate added in v0.51.7

func (x *ListGraphEdgeBucketsRequest) GetPredicate() string

func (*ListGraphEdgeBucketsRequest) MarshalJSON added in v0.51.7

func (x *ListGraphEdgeBucketsRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ListGraphEdgeBucketsRequest to JSON.

func (*ListGraphEdgeBucketsRequest) MarshalProtoJSON added in v0.51.7

func (x *ListGraphEdgeBucketsRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ListGraphEdgeBucketsRequest message to JSON.

func (*ListGraphEdgeBucketsRequest) MarshalProtoText added in v0.51.7

func (x *ListGraphEdgeBucketsRequest) MarshalProtoText() string

func (*ListGraphEdgeBucketsRequest) MarshalToSizedBufferVT added in v0.51.7

func (m *ListGraphEdgeBucketsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListGraphEdgeBucketsRequest) MarshalToVT added in v0.51.7

func (m *ListGraphEdgeBucketsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ListGraphEdgeBucketsRequest) MarshalVT added in v0.51.7

func (m *ListGraphEdgeBucketsRequest) MarshalVT() (dAtA []byte, err error)

func (*ListGraphEdgeBucketsRequest) ProtoMessage added in v0.51.7

func (*ListGraphEdgeBucketsRequest) ProtoMessage()

func (*ListGraphEdgeBucketsRequest) Reset added in v0.51.7

func (x *ListGraphEdgeBucketsRequest) Reset()

func (*ListGraphEdgeBucketsRequest) SizeVT added in v0.51.7

func (m *ListGraphEdgeBucketsRequest) SizeVT() (n int)

func (*ListGraphEdgeBucketsRequest) String added in v0.51.7

func (x *ListGraphEdgeBucketsRequest) String() string

func (*ListGraphEdgeBucketsRequest) UnmarshalJSON added in v0.51.7

func (x *ListGraphEdgeBucketsRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ListGraphEdgeBucketsRequest from JSON.

func (*ListGraphEdgeBucketsRequest) UnmarshalProtoJSON added in v0.51.7

func (x *ListGraphEdgeBucketsRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ListGraphEdgeBucketsRequest message from JSON.

func (*ListGraphEdgeBucketsRequest) UnmarshalVT added in v0.51.7

func (m *ListGraphEdgeBucketsRequest) UnmarshalVT(dAtA []byte) error

type ListGraphEdgeBucketsResponse added in v0.51.7

type ListGraphEdgeBucketsResponse struct {

	// Buckets preserves the request origin order.
	Buckets []*GraphEdgeBucket `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"`
	// contains filtered or unexported fields
}

ListGraphEdgeBucketsResponse returns grouped graph edge buckets.

func (*ListGraphEdgeBucketsResponse) CloneMessageVT added in v0.51.7

func (*ListGraphEdgeBucketsResponse) CloneVT added in v0.51.7

func (*ListGraphEdgeBucketsResponse) EqualMessageVT added in v0.51.7

func (this *ListGraphEdgeBucketsResponse) EqualMessageVT(thatMsg any) bool

func (*ListGraphEdgeBucketsResponse) EqualVT added in v0.51.7

func (*ListGraphEdgeBucketsResponse) GetBuckets added in v0.51.7

func (x *ListGraphEdgeBucketsResponse) GetBuckets() []*GraphEdgeBucket

func (*ListGraphEdgeBucketsResponse) MarshalJSON added in v0.51.7

func (x *ListGraphEdgeBucketsResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ListGraphEdgeBucketsResponse to JSON.

func (*ListGraphEdgeBucketsResponse) MarshalProtoJSON added in v0.51.7

func (x *ListGraphEdgeBucketsResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ListGraphEdgeBucketsResponse message to JSON.

func (*ListGraphEdgeBucketsResponse) MarshalProtoText added in v0.51.7

func (x *ListGraphEdgeBucketsResponse) MarshalProtoText() string

func (*ListGraphEdgeBucketsResponse) MarshalToSizedBufferVT added in v0.51.7

func (m *ListGraphEdgeBucketsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListGraphEdgeBucketsResponse) MarshalToVT added in v0.51.7

func (m *ListGraphEdgeBucketsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ListGraphEdgeBucketsResponse) MarshalVT added in v0.51.7

func (m *ListGraphEdgeBucketsResponse) MarshalVT() (dAtA []byte, err error)

func (*ListGraphEdgeBucketsResponse) ProtoMessage added in v0.51.7

func (*ListGraphEdgeBucketsResponse) ProtoMessage()

func (*ListGraphEdgeBucketsResponse) Reset added in v0.51.7

func (x *ListGraphEdgeBucketsResponse) Reset()

func (*ListGraphEdgeBucketsResponse) SizeVT added in v0.51.7

func (m *ListGraphEdgeBucketsResponse) SizeVT() (n int)

func (*ListGraphEdgeBucketsResponse) String added in v0.51.7

func (*ListGraphEdgeBucketsResponse) UnmarshalJSON added in v0.51.7

func (x *ListGraphEdgeBucketsResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ListGraphEdgeBucketsResponse from JSON.

func (*ListGraphEdgeBucketsResponse) UnmarshalProtoJSON added in v0.51.7

func (x *ListGraphEdgeBucketsResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ListGraphEdgeBucketsResponse message from JSON.

func (*ListGraphEdgeBucketsResponse) UnmarshalVT added in v0.51.7

func (m *ListGraphEdgeBucketsResponse) UnmarshalVT(dAtA []byte) error

type ListObjectsWithTypeRequest

type ListObjectsWithTypeRequest struct {

	// TypeId is the type identifier to match.
	TypeId string `protobuf:"bytes,1,opt,name=type_id,json=typeId,proto3" json:"typeId,omitempty"`
	// contains filtered or unexported fields
}

ListObjectsWithTypeRequest is the request type for ListObjectsWithType.

func (*ListObjectsWithTypeRequest) CloneMessageVT

func (*ListObjectsWithTypeRequest) CloneVT

func (*ListObjectsWithTypeRequest) EqualMessageVT

func (this *ListObjectsWithTypeRequest) EqualMessageVT(thatMsg any) bool

func (*ListObjectsWithTypeRequest) EqualVT

func (*ListObjectsWithTypeRequest) GetTypeId

func (x *ListObjectsWithTypeRequest) GetTypeId() string

func (*ListObjectsWithTypeRequest) MarshalJSON

func (x *ListObjectsWithTypeRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ListObjectsWithTypeRequest to JSON.

func (*ListObjectsWithTypeRequest) MarshalProtoJSON

func (x *ListObjectsWithTypeRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ListObjectsWithTypeRequest message to JSON.

func (*ListObjectsWithTypeRequest) MarshalProtoText

func (x *ListObjectsWithTypeRequest) MarshalProtoText() string

func (*ListObjectsWithTypeRequest) MarshalToSizedBufferVT

func (m *ListObjectsWithTypeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListObjectsWithTypeRequest) MarshalToVT

func (m *ListObjectsWithTypeRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ListObjectsWithTypeRequest) MarshalVT

func (m *ListObjectsWithTypeRequest) MarshalVT() (dAtA []byte, err error)

func (*ListObjectsWithTypeRequest) ProtoMessage

func (*ListObjectsWithTypeRequest) ProtoMessage()

func (*ListObjectsWithTypeRequest) Reset

func (x *ListObjectsWithTypeRequest) Reset()

func (*ListObjectsWithTypeRequest) SizeVT

func (m *ListObjectsWithTypeRequest) SizeVT() (n int)

func (*ListObjectsWithTypeRequest) String

func (x *ListObjectsWithTypeRequest) String() string

func (*ListObjectsWithTypeRequest) UnmarshalJSON

func (x *ListObjectsWithTypeRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ListObjectsWithTypeRequest from JSON.

func (*ListObjectsWithTypeRequest) UnmarshalProtoJSON

func (x *ListObjectsWithTypeRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ListObjectsWithTypeRequest message from JSON.

func (*ListObjectsWithTypeRequest) UnmarshalVT

func (m *ListObjectsWithTypeRequest) UnmarshalVT(dAtA []byte) error

type ListObjectsWithTypeResponse

type ListObjectsWithTypeResponse struct {

	// ObjectKeys is the list of object keys with the given type.
	ObjectKeys []string `protobuf:"bytes,1,rep,name=object_keys,json=objectKeys,proto3" json:"objectKeys,omitempty"`
	// contains filtered or unexported fields
}

ListObjectsWithTypeResponse is the response type for ListObjectsWithType.

func (*ListObjectsWithTypeResponse) CloneMessageVT

func (*ListObjectsWithTypeResponse) CloneVT

func (*ListObjectsWithTypeResponse) EqualMessageVT

func (this *ListObjectsWithTypeResponse) EqualMessageVT(thatMsg any) bool

func (*ListObjectsWithTypeResponse) EqualVT

func (*ListObjectsWithTypeResponse) GetObjectKeys

func (x *ListObjectsWithTypeResponse) GetObjectKeys() []string

func (*ListObjectsWithTypeResponse) MarshalJSON

func (x *ListObjectsWithTypeResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ListObjectsWithTypeResponse to JSON.

func (*ListObjectsWithTypeResponse) MarshalProtoJSON

func (x *ListObjectsWithTypeResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ListObjectsWithTypeResponse message to JSON.

func (*ListObjectsWithTypeResponse) MarshalProtoText

func (x *ListObjectsWithTypeResponse) MarshalProtoText() string

func (*ListObjectsWithTypeResponse) MarshalToSizedBufferVT

func (m *ListObjectsWithTypeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListObjectsWithTypeResponse) MarshalToVT

func (m *ListObjectsWithTypeResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ListObjectsWithTypeResponse) MarshalVT

func (m *ListObjectsWithTypeResponse) MarshalVT() (dAtA []byte, err error)

func (*ListObjectsWithTypeResponse) ProtoMessage

func (*ListObjectsWithTypeResponse) ProtoMessage()

func (*ListObjectsWithTypeResponse) Reset

func (x *ListObjectsWithTypeResponse) Reset()

func (*ListObjectsWithTypeResponse) SizeVT

func (m *ListObjectsWithTypeResponse) SizeVT() (n int)

func (*ListObjectsWithTypeResponse) String

func (x *ListObjectsWithTypeResponse) String() string

func (*ListObjectsWithTypeResponse) UnmarshalJSON

func (x *ListObjectsWithTypeResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ListObjectsWithTypeResponse from JSON.

func (*ListObjectsWithTypeResponse) UnmarshalProtoJSON

func (x *ListObjectsWithTypeResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ListObjectsWithTypeResponse message from JSON.

func (*ListObjectsWithTypeResponse) UnmarshalVT

func (m *ListObjectsWithTypeResponse) UnmarshalVT(dAtA []byte) error

type LookupGraphQuadsBatchRequest added in v0.51.6

type LookupGraphQuadsBatchRequest struct {

	// Filters is the bounded list of subject/predicate or object/predicate
	// filters to evaluate server-side.
	Filters []*quad.Quad `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
	// LimitPerFilter is the maximum number of quads returned for each filter.
	// It must be non-zero.
	LimitPerFilter uint32 `protobuf:"varint,2,opt,name=limit_per_filter,json=limitPerFilter,proto3" json:"limitPerFilter,omitempty"`
	// contains filtered or unexported fields
}

LookupGraphQuadsBatchRequest is the request type for LookupGraphQuadsBatch.

func (*LookupGraphQuadsBatchRequest) CloneMessageVT added in v0.51.6

func (*LookupGraphQuadsBatchRequest) CloneVT added in v0.51.6

func (*LookupGraphQuadsBatchRequest) EqualMessageVT added in v0.51.6

func (this *LookupGraphQuadsBatchRequest) EqualMessageVT(thatMsg any) bool

func (*LookupGraphQuadsBatchRequest) EqualVT added in v0.51.6

func (*LookupGraphQuadsBatchRequest) GetFilters added in v0.51.6

func (x *LookupGraphQuadsBatchRequest) GetFilters() []*quad.Quad

func (*LookupGraphQuadsBatchRequest) GetLimitPerFilter added in v0.51.6

func (x *LookupGraphQuadsBatchRequest) GetLimitPerFilter() uint32

func (*LookupGraphQuadsBatchRequest) MarshalJSON added in v0.51.6

func (x *LookupGraphQuadsBatchRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the LookupGraphQuadsBatchRequest to JSON.

func (*LookupGraphQuadsBatchRequest) MarshalProtoJSON added in v0.51.6

func (x *LookupGraphQuadsBatchRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the LookupGraphQuadsBatchRequest message to JSON.

func (*LookupGraphQuadsBatchRequest) MarshalProtoText added in v0.51.6

func (x *LookupGraphQuadsBatchRequest) MarshalProtoText() string

func (*LookupGraphQuadsBatchRequest) MarshalToSizedBufferVT added in v0.51.6

func (m *LookupGraphQuadsBatchRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LookupGraphQuadsBatchRequest) MarshalToVT added in v0.51.6

func (m *LookupGraphQuadsBatchRequest) MarshalToVT(dAtA []byte) (int, error)

func (*LookupGraphQuadsBatchRequest) MarshalVT added in v0.51.6

func (m *LookupGraphQuadsBatchRequest) MarshalVT() (dAtA []byte, err error)

func (*LookupGraphQuadsBatchRequest) ProtoMessage added in v0.51.6

func (*LookupGraphQuadsBatchRequest) ProtoMessage()

func (*LookupGraphQuadsBatchRequest) Reset added in v0.51.6

func (x *LookupGraphQuadsBatchRequest) Reset()

func (*LookupGraphQuadsBatchRequest) SizeVT added in v0.51.6

func (m *LookupGraphQuadsBatchRequest) SizeVT() (n int)

func (*LookupGraphQuadsBatchRequest) String added in v0.51.6

func (*LookupGraphQuadsBatchRequest) UnmarshalJSON added in v0.51.6

func (x *LookupGraphQuadsBatchRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the LookupGraphQuadsBatchRequest from JSON.

func (*LookupGraphQuadsBatchRequest) UnmarshalProtoJSON added in v0.51.6

func (x *LookupGraphQuadsBatchRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the LookupGraphQuadsBatchRequest message from JSON.

func (*LookupGraphQuadsBatchRequest) UnmarshalVT added in v0.51.6

func (m *LookupGraphQuadsBatchRequest) UnmarshalVT(dAtA []byte) error

type LookupGraphQuadsBatchResponse added in v0.51.6

type LookupGraphQuadsBatchResponse struct {

	// Results preserves the request filter order.
	Results []*LookupGraphQuadsBatchResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

LookupGraphQuadsBatchResponse is the response type for LookupGraphQuadsBatch.

func (*LookupGraphQuadsBatchResponse) CloneMessageVT added in v0.51.6

func (*LookupGraphQuadsBatchResponse) CloneVT added in v0.51.6

func (*LookupGraphQuadsBatchResponse) EqualMessageVT added in v0.51.6

func (this *LookupGraphQuadsBatchResponse) EqualMessageVT(thatMsg any) bool

func (*LookupGraphQuadsBatchResponse) EqualVT added in v0.51.6

func (*LookupGraphQuadsBatchResponse) GetResults added in v0.51.6

func (*LookupGraphQuadsBatchResponse) MarshalJSON added in v0.51.6

func (x *LookupGraphQuadsBatchResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the LookupGraphQuadsBatchResponse to JSON.

func (*LookupGraphQuadsBatchResponse) MarshalProtoJSON added in v0.51.6

func (x *LookupGraphQuadsBatchResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the LookupGraphQuadsBatchResponse message to JSON.

func (*LookupGraphQuadsBatchResponse) MarshalProtoText added in v0.51.6

func (x *LookupGraphQuadsBatchResponse) MarshalProtoText() string

func (*LookupGraphQuadsBatchResponse) MarshalToSizedBufferVT added in v0.51.6

func (m *LookupGraphQuadsBatchResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LookupGraphQuadsBatchResponse) MarshalToVT added in v0.51.6

func (m *LookupGraphQuadsBatchResponse) MarshalToVT(dAtA []byte) (int, error)

func (*LookupGraphQuadsBatchResponse) MarshalVT added in v0.51.6

func (m *LookupGraphQuadsBatchResponse) MarshalVT() (dAtA []byte, err error)

func (*LookupGraphQuadsBatchResponse) ProtoMessage added in v0.51.6

func (*LookupGraphQuadsBatchResponse) ProtoMessage()

func (*LookupGraphQuadsBatchResponse) Reset added in v0.51.6

func (x *LookupGraphQuadsBatchResponse) Reset()

func (*LookupGraphQuadsBatchResponse) SizeVT added in v0.51.6

func (m *LookupGraphQuadsBatchResponse) SizeVT() (n int)

func (*LookupGraphQuadsBatchResponse) String added in v0.51.6

func (*LookupGraphQuadsBatchResponse) UnmarshalJSON added in v0.51.6

func (x *LookupGraphQuadsBatchResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the LookupGraphQuadsBatchResponse from JSON.

func (*LookupGraphQuadsBatchResponse) UnmarshalProtoJSON added in v0.51.6

func (x *LookupGraphQuadsBatchResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the LookupGraphQuadsBatchResponse message from JSON.

func (*LookupGraphQuadsBatchResponse) UnmarshalVT added in v0.51.6

func (m *LookupGraphQuadsBatchResponse) UnmarshalVT(dAtA []byte) error

type LookupGraphQuadsBatchResult added in v0.51.6

type LookupGraphQuadsBatchResult struct {

	// Quads is the list of graph quads matching one filter.
	Quads []*quad.Quad `protobuf:"bytes,1,rep,name=quads,proto3" json:"quads,omitempty"`
	// contains filtered or unexported fields
}

LookupGraphQuadsBatchResult is one filtered graph lookup result.

func (*LookupGraphQuadsBatchResult) CloneMessageVT added in v0.51.6

func (*LookupGraphQuadsBatchResult) CloneVT added in v0.51.6

func (*LookupGraphQuadsBatchResult) EqualMessageVT added in v0.51.6

func (this *LookupGraphQuadsBatchResult) EqualMessageVT(thatMsg any) bool

func (*LookupGraphQuadsBatchResult) EqualVT added in v0.51.6

func (*LookupGraphQuadsBatchResult) GetQuads added in v0.51.6

func (x *LookupGraphQuadsBatchResult) GetQuads() []*quad.Quad

func (*LookupGraphQuadsBatchResult) MarshalJSON added in v0.51.6

func (x *LookupGraphQuadsBatchResult) MarshalJSON() ([]byte, error)

MarshalJSON marshals the LookupGraphQuadsBatchResult to JSON.

func (*LookupGraphQuadsBatchResult) MarshalProtoJSON added in v0.51.6

func (x *LookupGraphQuadsBatchResult) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the LookupGraphQuadsBatchResult message to JSON.

func (*LookupGraphQuadsBatchResult) MarshalProtoText added in v0.51.6

func (x *LookupGraphQuadsBatchResult) MarshalProtoText() string

func (*LookupGraphQuadsBatchResult) MarshalToSizedBufferVT added in v0.51.6

func (m *LookupGraphQuadsBatchResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LookupGraphQuadsBatchResult) MarshalToVT added in v0.51.6

func (m *LookupGraphQuadsBatchResult) MarshalToVT(dAtA []byte) (int, error)

func (*LookupGraphQuadsBatchResult) MarshalVT added in v0.51.6

func (m *LookupGraphQuadsBatchResult) MarshalVT() (dAtA []byte, err error)

func (*LookupGraphQuadsBatchResult) ProtoMessage added in v0.51.6

func (*LookupGraphQuadsBatchResult) ProtoMessage()

func (*LookupGraphQuadsBatchResult) Reset added in v0.51.6

func (x *LookupGraphQuadsBatchResult) Reset()

func (*LookupGraphQuadsBatchResult) SizeVT added in v0.51.6

func (m *LookupGraphQuadsBatchResult) SizeVT() (n int)

func (*LookupGraphQuadsBatchResult) String added in v0.51.6

func (x *LookupGraphQuadsBatchResult) String() string

func (*LookupGraphQuadsBatchResult) UnmarshalJSON added in v0.51.6

func (x *LookupGraphQuadsBatchResult) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the LookupGraphQuadsBatchResult from JSON.

func (*LookupGraphQuadsBatchResult) UnmarshalProtoJSON added in v0.51.6

func (x *LookupGraphQuadsBatchResult) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the LookupGraphQuadsBatchResult message from JSON.

func (*LookupGraphQuadsBatchResult) UnmarshalVT added in v0.51.6

func (m *LookupGraphQuadsBatchResult) UnmarshalVT(dAtA []byte) error

type LookupGraphQuadsRequest

type LookupGraphQuadsRequest struct {

	// Filter specifies the criteria for matching quads.
	// Empty fields in the filter match any value for that field.
	Filter *quad.Quad `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// Limit restricts the maximum number of quads to return.
	// Zero means no limit.
	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

LookupGraphQuadsRequest is the request type for LookupGraphQuads.

func (*LookupGraphQuadsRequest) CloneMessageVT

func (*LookupGraphQuadsRequest) CloneVT

func (*LookupGraphQuadsRequest) EqualMessageVT

func (this *LookupGraphQuadsRequest) EqualMessageVT(thatMsg any) bool

func (*LookupGraphQuadsRequest) EqualVT

func (*LookupGraphQuadsRequest) GetFilter

func (x *LookupGraphQuadsRequest) GetFilter() *quad.Quad

func (*LookupGraphQuadsRequest) GetLimit

func (x *LookupGraphQuadsRequest) GetLimit() uint32

func (*LookupGraphQuadsRequest) MarshalJSON

func (x *LookupGraphQuadsRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the LookupGraphQuadsRequest to JSON.

func (*LookupGraphQuadsRequest) MarshalProtoJSON

func (x *LookupGraphQuadsRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the LookupGraphQuadsRequest message to JSON.

func (*LookupGraphQuadsRequest) MarshalProtoText

func (x *LookupGraphQuadsRequest) MarshalProtoText() string

func (*LookupGraphQuadsRequest) MarshalToSizedBufferVT

func (m *LookupGraphQuadsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LookupGraphQuadsRequest) MarshalToVT

func (m *LookupGraphQuadsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*LookupGraphQuadsRequest) MarshalVT

func (m *LookupGraphQuadsRequest) MarshalVT() (dAtA []byte, err error)

func (*LookupGraphQuadsRequest) ProtoMessage

func (*LookupGraphQuadsRequest) ProtoMessage()

func (*LookupGraphQuadsRequest) Reset

func (x *LookupGraphQuadsRequest) Reset()

func (*LookupGraphQuadsRequest) SizeVT

func (m *LookupGraphQuadsRequest) SizeVT() (n int)

func (*LookupGraphQuadsRequest) String

func (x *LookupGraphQuadsRequest) String() string

func (*LookupGraphQuadsRequest) UnmarshalJSON

func (x *LookupGraphQuadsRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the LookupGraphQuadsRequest from JSON.

func (*LookupGraphQuadsRequest) UnmarshalProtoJSON

func (x *LookupGraphQuadsRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the LookupGraphQuadsRequest message from JSON.

func (*LookupGraphQuadsRequest) UnmarshalVT

func (m *LookupGraphQuadsRequest) UnmarshalVT(dAtA []byte) error

type LookupGraphQuadsResponse

type LookupGraphQuadsResponse struct {

	// Quads is the list of graph quads matching the filter criteria.
	Quads []*quad.Quad `protobuf:"bytes,1,rep,name=quads,proto3" json:"quads,omitempty"`
	// contains filtered or unexported fields
}

LookupGraphQuadsResponse is the response type for LookupGraphQuads.

func (*LookupGraphQuadsResponse) CloneMessageVT

func (*LookupGraphQuadsResponse) CloneVT

func (*LookupGraphQuadsResponse) EqualMessageVT

func (this *LookupGraphQuadsResponse) EqualMessageVT(thatMsg any) bool

func (*LookupGraphQuadsResponse) EqualVT

func (*LookupGraphQuadsResponse) GetQuads

func (x *LookupGraphQuadsResponse) GetQuads() []*quad.Quad

func (*LookupGraphQuadsResponse) MarshalJSON

func (x *LookupGraphQuadsResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the LookupGraphQuadsResponse to JSON.

func (*LookupGraphQuadsResponse) MarshalProtoJSON

func (x *LookupGraphQuadsResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the LookupGraphQuadsResponse message to JSON.

func (*LookupGraphQuadsResponse) MarshalProtoText

func (x *LookupGraphQuadsResponse) MarshalProtoText() string

func (*LookupGraphQuadsResponse) MarshalToSizedBufferVT

func (m *LookupGraphQuadsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LookupGraphQuadsResponse) MarshalToVT

func (m *LookupGraphQuadsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*LookupGraphQuadsResponse) MarshalVT

func (m *LookupGraphQuadsResponse) MarshalVT() (dAtA []byte, err error)

func (*LookupGraphQuadsResponse) ProtoMessage

func (*LookupGraphQuadsResponse) ProtoMessage()

func (*LookupGraphQuadsResponse) Reset

func (x *LookupGraphQuadsResponse) Reset()

func (*LookupGraphQuadsResponse) SizeVT

func (m *LookupGraphQuadsResponse) SizeVT() (n int)

func (*LookupGraphQuadsResponse) String

func (x *LookupGraphQuadsResponse) String() string

func (*LookupGraphQuadsResponse) UnmarshalJSON

func (x *LookupGraphQuadsResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the LookupGraphQuadsResponse from JSON.

func (*LookupGraphQuadsResponse) UnmarshalProtoJSON

func (x *LookupGraphQuadsResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the LookupGraphQuadsResponse message from JSON.

func (*LookupGraphQuadsResponse) UnmarshalVT

func (m *LookupGraphQuadsResponse) UnmarshalVT(dAtA []byte) error

type NewTransactionRequest

type NewTransactionRequest struct {

	// Write indicates whether this transaction will perform write operations.
	Write bool `protobuf:"varint,1,opt,name=write,proto3" json:"write,omitempty"`
	// contains filtered or unexported fields
}

NewTransactionRequest is the request type for NewTransaction.

func (*NewTransactionRequest) CloneMessageVT

func (*NewTransactionRequest) CloneVT

func (*NewTransactionRequest) EqualMessageVT

func (this *NewTransactionRequest) EqualMessageVT(thatMsg any) bool

func (*NewTransactionRequest) EqualVT

func (this *NewTransactionRequest) EqualVT(that *NewTransactionRequest) bool

func (*NewTransactionRequest) GetWrite

func (x *NewTransactionRequest) GetWrite() bool

func (*NewTransactionRequest) MarshalJSON

func (x *NewTransactionRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the NewTransactionRequest to JSON.

func (*NewTransactionRequest) MarshalProtoJSON

func (x *NewTransactionRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the NewTransactionRequest message to JSON.

func (*NewTransactionRequest) MarshalProtoText

func (x *NewTransactionRequest) MarshalProtoText() string

func (*NewTransactionRequest) MarshalToSizedBufferVT

func (m *NewTransactionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*NewTransactionRequest) MarshalToVT

func (m *NewTransactionRequest) MarshalToVT(dAtA []byte) (int, error)

func (*NewTransactionRequest) MarshalVT

func (m *NewTransactionRequest) MarshalVT() (dAtA []byte, err error)

func (*NewTransactionRequest) ProtoMessage

func (*NewTransactionRequest) ProtoMessage()

func (*NewTransactionRequest) Reset

func (x *NewTransactionRequest) Reset()

func (*NewTransactionRequest) SizeVT

func (m *NewTransactionRequest) SizeVT() (n int)

func (*NewTransactionRequest) String

func (x *NewTransactionRequest) String() string

func (*NewTransactionRequest) UnmarshalJSON

func (x *NewTransactionRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the NewTransactionRequest from JSON.

func (*NewTransactionRequest) UnmarshalProtoJSON

func (x *NewTransactionRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the NewTransactionRequest message from JSON.

func (*NewTransactionRequest) UnmarshalVT

func (m *NewTransactionRequest) UnmarshalVT(dAtA []byte) error

type NewTransactionResponse

type NewTransactionResponse struct {

	// ResourceId is the ID of the created Tx resource.
	ResourceId uint32 `protobuf:"varint,1,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// ReadOnly indicates whether the transaction is read-only.
	ReadOnly bool `protobuf:"varint,2,opt,name=read_only,json=readOnly,proto3" json:"readOnly,omitempty"`
	// contains filtered or unexported fields
}

NewTransactionResponse is the response type for NewTransaction.

func (*NewTransactionResponse) CloneMessageVT

func (*NewTransactionResponse) CloneVT

func (*NewTransactionResponse) EqualMessageVT

func (this *NewTransactionResponse) EqualMessageVT(thatMsg any) bool

func (*NewTransactionResponse) EqualVT

func (this *NewTransactionResponse) EqualVT(that *NewTransactionResponse) bool

func (*NewTransactionResponse) GetReadOnly

func (x *NewTransactionResponse) GetReadOnly() bool

func (*NewTransactionResponse) GetResourceId

func (x *NewTransactionResponse) GetResourceId() uint32

func (*NewTransactionResponse) MarshalJSON

func (x *NewTransactionResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the NewTransactionResponse to JSON.

func (*NewTransactionResponse) MarshalProtoJSON

func (x *NewTransactionResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the NewTransactionResponse message to JSON.

func (*NewTransactionResponse) MarshalProtoText

func (x *NewTransactionResponse) MarshalProtoText() string

func (*NewTransactionResponse) MarshalToSizedBufferVT

func (m *NewTransactionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*NewTransactionResponse) MarshalToVT

func (m *NewTransactionResponse) MarshalToVT(dAtA []byte) (int, error)

func (*NewTransactionResponse) MarshalVT

func (m *NewTransactionResponse) MarshalVT() (dAtA []byte, err error)

func (*NewTransactionResponse) ProtoMessage

func (*NewTransactionResponse) ProtoMessage()

func (*NewTransactionResponse) Reset

func (x *NewTransactionResponse) Reset()

func (*NewTransactionResponse) SizeVT

func (m *NewTransactionResponse) SizeVT() (n int)

func (*NewTransactionResponse) String

func (x *NewTransactionResponse) String() string

func (*NewTransactionResponse) UnmarshalJSON

func (x *NewTransactionResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the NewTransactionResponse from JSON.

func (*NewTransactionResponse) UnmarshalProtoJSON

func (x *NewTransactionResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the NewTransactionResponse message from JSON.

func (*NewTransactionResponse) UnmarshalVT

func (m *NewTransactionResponse) UnmarshalVT(dAtA []byte) error

type NextGraphPathQueryRequest added in v0.51.6

type NextGraphPathQueryRequest struct {
	// contains filtered or unexported fields
}

NextGraphPathQueryRequest is the request type for GraphPathQuery Next.

func (*NextGraphPathQueryRequest) CloneMessageVT added in v0.51.6

func (*NextGraphPathQueryRequest) CloneVT added in v0.51.6

func (*NextGraphPathQueryRequest) EqualMessageVT added in v0.51.6

func (this *NextGraphPathQueryRequest) EqualMessageVT(thatMsg any) bool

func (*NextGraphPathQueryRequest) EqualVT added in v0.51.6

func (*NextGraphPathQueryRequest) MarshalJSON added in v0.51.6

func (x *NextGraphPathQueryRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the NextGraphPathQueryRequest to JSON.

func (*NextGraphPathQueryRequest) MarshalProtoJSON added in v0.51.6

func (x *NextGraphPathQueryRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the NextGraphPathQueryRequest message to JSON.

func (*NextGraphPathQueryRequest) MarshalProtoText added in v0.51.6

func (x *NextGraphPathQueryRequest) MarshalProtoText() string

func (*NextGraphPathQueryRequest) MarshalToSizedBufferVT added in v0.51.6

func (m *NextGraphPathQueryRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*NextGraphPathQueryRequest) MarshalToVT added in v0.51.6

func (m *NextGraphPathQueryRequest) MarshalToVT(dAtA []byte) (int, error)

func (*NextGraphPathQueryRequest) MarshalVT added in v0.51.6

func (m *NextGraphPathQueryRequest) MarshalVT() (dAtA []byte, err error)

func (*NextGraphPathQueryRequest) ProtoMessage added in v0.51.6

func (*NextGraphPathQueryRequest) ProtoMessage()

func (*NextGraphPathQueryRequest) Reset added in v0.51.6

func (x *NextGraphPathQueryRequest) Reset()

func (*NextGraphPathQueryRequest) SizeVT added in v0.51.6

func (m *NextGraphPathQueryRequest) SizeVT() (n int)

func (*NextGraphPathQueryRequest) String added in v0.51.6

func (x *NextGraphPathQueryRequest) String() string

func (*NextGraphPathQueryRequest) UnmarshalJSON added in v0.51.6

func (x *NextGraphPathQueryRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the NextGraphPathQueryRequest from JSON.

func (*NextGraphPathQueryRequest) UnmarshalProtoJSON added in v0.51.6

func (x *NextGraphPathQueryRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the NextGraphPathQueryRequest message from JSON.

func (*NextGraphPathQueryRequest) UnmarshalVT added in v0.51.6

func (m *NextGraphPathQueryRequest) UnmarshalVT(dAtA []byte) error

type NextGraphPathQueryResponse added in v0.51.6

type NextGraphPathQueryResponse struct {

	// ObjectKeys is the next page of reached object keys.
	ObjectKeys []string `protobuf:"bytes,1,rep,name=object_keys,json=objectKeys,proto3" json:"objectKeys,omitempty"`
	// Quads is the traversed graph quads when requested.
	Quads []*quad.Quad `protobuf:"bytes,2,rep,name=quads,proto3" json:"quads,omitempty"`
	// Done indicates the resource has no more result pages.
	Done bool `protobuf:"varint,3,opt,name=done,proto3" json:"done,omitempty"`
	// contains filtered or unexported fields
}

NextGraphPathQueryResponse is one page of graph path query results.

func (*NextGraphPathQueryResponse) CloneMessageVT added in v0.51.6

func (*NextGraphPathQueryResponse) CloneVT added in v0.51.6

func (*NextGraphPathQueryResponse) EqualMessageVT added in v0.51.6

func (this *NextGraphPathQueryResponse) EqualMessageVT(thatMsg any) bool

func (*NextGraphPathQueryResponse) EqualVT added in v0.51.6

func (*NextGraphPathQueryResponse) GetDone added in v0.51.6

func (x *NextGraphPathQueryResponse) GetDone() bool

func (*NextGraphPathQueryResponse) GetObjectKeys added in v0.51.6

func (x *NextGraphPathQueryResponse) GetObjectKeys() []string

func (*NextGraphPathQueryResponse) GetQuads added in v0.51.6

func (x *NextGraphPathQueryResponse) GetQuads() []*quad.Quad

func (*NextGraphPathQueryResponse) MarshalJSON added in v0.51.6

func (x *NextGraphPathQueryResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the NextGraphPathQueryResponse to JSON.

func (*NextGraphPathQueryResponse) MarshalProtoJSON added in v0.51.6

func (x *NextGraphPathQueryResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the NextGraphPathQueryResponse message to JSON.

func (*NextGraphPathQueryResponse) MarshalProtoText added in v0.51.6

func (x *NextGraphPathQueryResponse) MarshalProtoText() string

func (*NextGraphPathQueryResponse) MarshalToSizedBufferVT added in v0.51.6

func (m *NextGraphPathQueryResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*NextGraphPathQueryResponse) MarshalToVT added in v0.51.6

func (m *NextGraphPathQueryResponse) MarshalToVT(dAtA []byte) (int, error)

func (*NextGraphPathQueryResponse) MarshalVT added in v0.51.6

func (m *NextGraphPathQueryResponse) MarshalVT() (dAtA []byte, err error)

func (*NextGraphPathQueryResponse) ProtoMessage added in v0.51.6

func (*NextGraphPathQueryResponse) ProtoMessage()

func (*NextGraphPathQueryResponse) Reset added in v0.51.6

func (x *NextGraphPathQueryResponse) Reset()

func (*NextGraphPathQueryResponse) SizeVT added in v0.51.6

func (m *NextGraphPathQueryResponse) SizeVT() (n int)

func (*NextGraphPathQueryResponse) String added in v0.51.6

func (x *NextGraphPathQueryResponse) String() string

func (*NextGraphPathQueryResponse) UnmarshalJSON added in v0.51.6

func (x *NextGraphPathQueryResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the NextGraphPathQueryResponse from JSON.

func (*NextGraphPathQueryResponse) UnmarshalProtoJSON added in v0.51.6

func (x *NextGraphPathQueryResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the NextGraphPathQueryResponse message from JSON.

func (*NextGraphPathQueryResponse) UnmarshalVT added in v0.51.6

func (m *NextGraphPathQueryResponse) UnmarshalVT(dAtA []byte) error

type NextRequest

type NextRequest struct {
	// contains filtered or unexported fields
}

NextRequest is the request type for Next.

func (*NextRequest) CloneMessageVT

func (m *NextRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*NextRequest) CloneVT

func (m *NextRequest) CloneVT() *NextRequest

func (*NextRequest) EqualMessageVT

func (this *NextRequest) EqualMessageVT(thatMsg any) bool

func (*NextRequest) EqualVT

func (this *NextRequest) EqualVT(that *NextRequest) bool

func (*NextRequest) MarshalJSON

func (x *NextRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the NextRequest to JSON.

func (*NextRequest) MarshalProtoJSON

func (x *NextRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the NextRequest message to JSON.

func (*NextRequest) MarshalProtoText

func (x *NextRequest) MarshalProtoText() string

func (*NextRequest) MarshalToSizedBufferVT

func (m *NextRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*NextRequest) MarshalToVT

func (m *NextRequest) MarshalToVT(dAtA []byte) (int, error)

func (*NextRequest) MarshalVT

func (m *NextRequest) MarshalVT() (dAtA []byte, err error)

func (*NextRequest) ProtoMessage

func (*NextRequest) ProtoMessage()

func (*NextRequest) Reset

func (x *NextRequest) Reset()

func (*NextRequest) SizeVT

func (m *NextRequest) SizeVT() (n int)

func (*NextRequest) String

func (x *NextRequest) String() string

func (*NextRequest) UnmarshalJSON

func (x *NextRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the NextRequest from JSON.

func (*NextRequest) UnmarshalProtoJSON

func (x *NextRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the NextRequest message from JSON.

func (*NextRequest) UnmarshalVT

func (m *NextRequest) UnmarshalVT(dAtA []byte) error

type NextResponse

type NextResponse struct {

	// Valid indicates if the iterator points to a valid entry after advancing.
	Valid bool `protobuf:"varint,1,opt,name=valid,proto3" json:"valid,omitempty"`
	// contains filtered or unexported fields
}

NextResponse is the response type for Next.

func (*NextResponse) CloneMessageVT

func (m *NextResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*NextResponse) CloneVT

func (m *NextResponse) CloneVT() *NextResponse

func (*NextResponse) EqualMessageVT

func (this *NextResponse) EqualMessageVT(thatMsg any) bool

func (*NextResponse) EqualVT

func (this *NextResponse) EqualVT(that *NextResponse) bool

func (*NextResponse) GetValid

func (x *NextResponse) GetValid() bool

func (*NextResponse) MarshalJSON

func (x *NextResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the NextResponse to JSON.

func (*NextResponse) MarshalProtoJSON

func (x *NextResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the NextResponse message to JSON.

func (*NextResponse) MarshalProtoText

func (x *NextResponse) MarshalProtoText() string

func (*NextResponse) MarshalToSizedBufferVT

func (m *NextResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*NextResponse) MarshalToVT

func (m *NextResponse) MarshalToVT(dAtA []byte) (int, error)

func (*NextResponse) MarshalVT

func (m *NextResponse) MarshalVT() (dAtA []byte, err error)

func (*NextResponse) ProtoMessage

func (*NextResponse) ProtoMessage()

func (*NextResponse) Reset

func (x *NextResponse) Reset()

func (*NextResponse) SizeVT

func (m *NextResponse) SizeVT() (n int)

func (*NextResponse) String

func (x *NextResponse) String() string

func (*NextResponse) UnmarshalJSON

func (x *NextResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the NextResponse from JSON.

func (*NextResponse) UnmarshalProtoJSON

func (x *NextResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the NextResponse message from JSON.

func (*NextResponse) UnmarshalVT

func (m *NextResponse) UnmarshalVT(dAtA []byte) error

type ObjectMetadata added in v0.51.6

type ObjectMetadata struct {

	// ObjectKey is the object key.
	ObjectKey string `protobuf:"bytes,1,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// TypeId is the object type identifier, if present.
	TypeId string `protobuf:"bytes,2,opt,name=type_id,json=typeId,proto3" json:"typeId,omitempty"`
	// ParentObjectKey is the parent object key, if present.
	ParentObjectKey string `protobuf:"bytes,3,opt,name=parent_object_key,json=parentObjectKey,proto3" json:"parentObjectKey,omitempty"`
	// contains filtered or unexported fields
}

ObjectMetadata contains graph metadata for one object key.

func (*ObjectMetadata) CloneMessageVT added in v0.51.6

func (m *ObjectMetadata) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ObjectMetadata) CloneVT added in v0.51.6

func (m *ObjectMetadata) CloneVT() *ObjectMetadata

func (*ObjectMetadata) EqualMessageVT added in v0.51.6

func (this *ObjectMetadata) EqualMessageVT(thatMsg any) bool

func (*ObjectMetadata) EqualVT added in v0.51.6

func (this *ObjectMetadata) EqualVT(that *ObjectMetadata) bool

func (*ObjectMetadata) GetObjectKey added in v0.51.6

func (x *ObjectMetadata) GetObjectKey() string

func (*ObjectMetadata) GetParentObjectKey added in v0.51.6

func (x *ObjectMetadata) GetParentObjectKey() string

func (*ObjectMetadata) GetTypeId added in v0.51.6

func (x *ObjectMetadata) GetTypeId() string

func (*ObjectMetadata) MarshalJSON added in v0.51.6

func (x *ObjectMetadata) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ObjectMetadata to JSON.

func (*ObjectMetadata) MarshalProtoJSON added in v0.51.6

func (x *ObjectMetadata) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ObjectMetadata message to JSON.

func (*ObjectMetadata) MarshalProtoText added in v0.51.6

func (x *ObjectMetadata) MarshalProtoText() string

func (*ObjectMetadata) MarshalToSizedBufferVT added in v0.51.6

func (m *ObjectMetadata) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ObjectMetadata) MarshalToVT added in v0.51.6

func (m *ObjectMetadata) MarshalToVT(dAtA []byte) (int, error)

func (*ObjectMetadata) MarshalVT added in v0.51.6

func (m *ObjectMetadata) MarshalVT() (dAtA []byte, err error)

func (*ObjectMetadata) ProtoMessage added in v0.51.6

func (*ObjectMetadata) ProtoMessage()

func (*ObjectMetadata) Reset added in v0.51.6

func (x *ObjectMetadata) Reset()

func (*ObjectMetadata) SizeVT added in v0.51.6

func (m *ObjectMetadata) SizeVT() (n int)

func (*ObjectMetadata) String added in v0.51.6

func (x *ObjectMetadata) String() string

func (*ObjectMetadata) UnmarshalJSON added in v0.51.6

func (x *ObjectMetadata) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ObjectMetadata from JSON.

func (*ObjectMetadata) UnmarshalProtoJSON added in v0.51.6

func (x *ObjectMetadata) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ObjectMetadata message from JSON.

func (*ObjectMetadata) UnmarshalVT added in v0.51.6

func (m *ObjectMetadata) UnmarshalVT(dAtA []byte) error

type ObjectRootRef added in v0.51.7

type ObjectRootRef struct {

	// ObjectKey is the object key.
	ObjectKey string `protobuf:"bytes,1,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// RootRef is the current object root reference, if the object exists.
	RootRef *bucket.ObjectRef `protobuf:"bytes,2,opt,name=root_ref,json=rootRef,proto3" json:"rootRef,omitempty"`
	// Rev is the object revision.
	Rev uint64 `protobuf:"varint,3,opt,name=rev,proto3" json:"rev,omitempty"`
	// Exists indicates whether the object key exists.
	Exists bool `protobuf:"varint,4,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

ObjectRootRef contains root reference metadata for one object key.

func (*ObjectRootRef) CloneMessageVT added in v0.51.7

func (m *ObjectRootRef) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ObjectRootRef) CloneVT added in v0.51.7

func (m *ObjectRootRef) CloneVT() *ObjectRootRef

func (*ObjectRootRef) EqualMessageVT added in v0.51.7

func (this *ObjectRootRef) EqualMessageVT(thatMsg any) bool

func (*ObjectRootRef) EqualVT added in v0.51.7

func (this *ObjectRootRef) EqualVT(that *ObjectRootRef) bool

func (*ObjectRootRef) GetExists added in v0.51.7

func (x *ObjectRootRef) GetExists() bool

func (*ObjectRootRef) GetObjectKey added in v0.51.7

func (x *ObjectRootRef) GetObjectKey() string

func (*ObjectRootRef) GetRev added in v0.51.7

func (x *ObjectRootRef) GetRev() uint64

func (*ObjectRootRef) GetRootRef added in v0.51.7

func (x *ObjectRootRef) GetRootRef() *bucket.ObjectRef

func (*ObjectRootRef) MarshalJSON added in v0.51.7

func (x *ObjectRootRef) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ObjectRootRef to JSON.

func (*ObjectRootRef) MarshalProtoJSON added in v0.51.7

func (x *ObjectRootRef) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ObjectRootRef message to JSON.

func (*ObjectRootRef) MarshalProtoText added in v0.51.7

func (x *ObjectRootRef) MarshalProtoText() string

func (*ObjectRootRef) MarshalToSizedBufferVT added in v0.51.7

func (m *ObjectRootRef) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ObjectRootRef) MarshalToVT added in v0.51.7

func (m *ObjectRootRef) MarshalToVT(dAtA []byte) (int, error)

func (*ObjectRootRef) MarshalVT added in v0.51.7

func (m *ObjectRootRef) MarshalVT() (dAtA []byte, err error)

func (*ObjectRootRef) ProtoMessage added in v0.51.7

func (*ObjectRootRef) ProtoMessage()

func (*ObjectRootRef) Reset added in v0.51.7

func (x *ObjectRootRef) Reset()

func (*ObjectRootRef) SizeVT added in v0.51.7

func (m *ObjectRootRef) SizeVT() (n int)

func (*ObjectRootRef) String added in v0.51.7

func (x *ObjectRootRef) String() string

func (*ObjectRootRef) UnmarshalJSON added in v0.51.7

func (x *ObjectRootRef) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ObjectRootRef from JSON.

func (*ObjectRootRef) UnmarshalProtoJSON added in v0.51.7

func (x *ObjectRootRef) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ObjectRootRef message from JSON.

func (*ObjectRootRef) UnmarshalVT added in v0.51.7

func (m *ObjectRootRef) UnmarshalVT(dAtA []byte) error

type ObjectState

type ObjectState struct {
	// contains filtered or unexported fields
}

ObjectState wraps ObjectStateResourceService and implements world.ObjectState. Represents a handle to an object in the store.

In the Go implementation (hydra/world/object-state.go), ObjectState provides: - GetKey() string - GetRootRef(ctx) (*bucket.ObjectRef, uint64, error) - SetRootRef(ctx, *bucket.ObjectRef) (uint64, error) - AccessWorldState(ctx, *bucket.ObjectRef, callback) error - ApplyObjectOp(ctx, Operation, peer.ID) (rev, sysErr, error) - IncrementRev(ctx) (uint64, error) - WaitRev(ctx, uint64, ignoreNotFound bool) (uint64, error)

This RPC-based implementation wraps ObjectStateResourceService.

func (*ObjectState) AccessWorldState

func (os *ObjectState) AccessWorldState(ctx context.Context, ref *bucket.ObjectRef, cb func(*bucket_lookup.Cursor) error) error

AccessWorldState builds a bucket lookup cursor with an optional ref. If the ref is empty, will default to the object RootRef. If the ref Bucket ID is empty, uses the same bucket + volume as the world. The lookup cursor will be released after cb returns.

func (*ObjectState) ApplyObjectOp

func (os *ObjectState) ApplyObjectOp(ctx context.Context, op world.Operation, sender peer.ID) (uint64, bool, error)

ApplyObjectOp applies a batch operation at the object level. The handling of the operation is operation-type specific. Returns the revision following the operation execution. If nil is returned for the error, implies success. If sysErr is set, the error is treated as a transient system error.

func (*ObjectState) GetKey

func (os *ObjectState) GetKey() string

GetKey returns the key this state object is for. Returns stored metadata without RPC call.

func (*ObjectState) GetResourceRef

func (os *ObjectState) GetResourceRef() resource_client.ResourceRef

GetResourceRef returns the resource reference.

func (*ObjectState) GetRootRef

func (os *ObjectState) GetRootRef(ctx context.Context) (*bucket.ObjectRef, uint64, error)

GetRootRef returns the root reference. Returns the revision number.

func (*ObjectState) IncrementRev

func (os *ObjectState) IncrementRev(ctx context.Context) (uint64, error)

IncrementRev increments the revision of the object. Returns revision just after the change was applied.

func (*ObjectState) Release

func (os *ObjectState) Release()

Release releases the resource reference.

func (*ObjectState) SetRootRef

func (os *ObjectState) SetRootRef(ctx context.Context, rootRef *bucket.ObjectRef) (uint64, error)

SetRootRef changes the root reference of the object. Increments the revision of the object if changed. Returns revision just after the change was applied.

func (*ObjectState) WaitRev

func (os *ObjectState) WaitRev(ctx context.Context, rev uint64, ignoreNotFound bool) (uint64, error)

WaitRev waits until the object rev is >= the specified. Returns ErrObjectNotFound if the object is deleted. If ignoreNotFound is set, waits for the object to exist. Returns the new rev.

type QueryGraphPathRequest added in v0.51.6

type QueryGraphPathRequest struct {

	// StartKeys is the list of object keys where traversal starts.
	StartKeys []string `protobuf:"bytes,1,rep,name=start_keys,json=startKeys,proto3" json:"startKeys,omitempty"`
	// Steps is the bounded traversal to execute server-side.
	Steps []*GraphPathStep `protobuf:"bytes,2,rep,name=steps,proto3" json:"steps,omitempty"`
	// ResultLimit is the maximum number of object keys returned.
	// It must be non-zero.
	ResultLimit uint32 `protobuf:"varint,3,opt,name=result_limit,json=resultLimit,proto3" json:"resultLimit,omitempty"`
	// IncludeQuads includes traversed quads in result pages.
	IncludeQuads bool `protobuf:"varint,4,opt,name=include_quads,json=includeQuads,proto3" json:"includeQuads,omitempty"`
	// PageSize is the maximum number of object keys returned by one Next call.
	// If unset, the server uses ResultLimit.
	PageSize uint32 `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"pageSize,omitempty"`
	// contains filtered or unexported fields
}

QueryGraphPathRequest is the request type for QueryGraphPath.

func (*QueryGraphPathRequest) CloneMessageVT added in v0.51.6

func (*QueryGraphPathRequest) CloneVT added in v0.51.6

func (*QueryGraphPathRequest) EqualMessageVT added in v0.51.6

func (this *QueryGraphPathRequest) EqualMessageVT(thatMsg any) bool

func (*QueryGraphPathRequest) EqualVT added in v0.51.6

func (this *QueryGraphPathRequest) EqualVT(that *QueryGraphPathRequest) bool

func (*QueryGraphPathRequest) GetIncludeQuads added in v0.51.6

func (x *QueryGraphPathRequest) GetIncludeQuads() bool

func (*QueryGraphPathRequest) GetPageSize added in v0.51.6

func (x *QueryGraphPathRequest) GetPageSize() uint32

func (*QueryGraphPathRequest) GetResultLimit added in v0.51.6

func (x *QueryGraphPathRequest) GetResultLimit() uint32

func (*QueryGraphPathRequest) GetStartKeys added in v0.51.6

func (x *QueryGraphPathRequest) GetStartKeys() []string

func (*QueryGraphPathRequest) GetSteps added in v0.51.6

func (x *QueryGraphPathRequest) GetSteps() []*GraphPathStep

func (*QueryGraphPathRequest) MarshalJSON added in v0.51.6

func (x *QueryGraphPathRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the QueryGraphPathRequest to JSON.

func (*QueryGraphPathRequest) MarshalProtoJSON added in v0.51.6

func (x *QueryGraphPathRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the QueryGraphPathRequest message to JSON.

func (*QueryGraphPathRequest) MarshalProtoText added in v0.51.6

func (x *QueryGraphPathRequest) MarshalProtoText() string

func (*QueryGraphPathRequest) MarshalToSizedBufferVT added in v0.51.6

func (m *QueryGraphPathRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueryGraphPathRequest) MarshalToVT added in v0.51.6

func (m *QueryGraphPathRequest) MarshalToVT(dAtA []byte) (int, error)

func (*QueryGraphPathRequest) MarshalVT added in v0.51.6

func (m *QueryGraphPathRequest) MarshalVT() (dAtA []byte, err error)

func (*QueryGraphPathRequest) ProtoMessage added in v0.51.6

func (*QueryGraphPathRequest) ProtoMessage()

func (*QueryGraphPathRequest) Reset added in v0.51.6

func (x *QueryGraphPathRequest) Reset()

func (*QueryGraphPathRequest) SizeVT added in v0.51.6

func (m *QueryGraphPathRequest) SizeVT() (n int)

func (*QueryGraphPathRequest) String added in v0.51.6

func (x *QueryGraphPathRequest) String() string

func (*QueryGraphPathRequest) UnmarshalJSON added in v0.51.6

func (x *QueryGraphPathRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the QueryGraphPathRequest from JSON.

func (*QueryGraphPathRequest) UnmarshalProtoJSON added in v0.51.6

func (x *QueryGraphPathRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the QueryGraphPathRequest message from JSON.

func (*QueryGraphPathRequest) UnmarshalVT added in v0.51.6

func (m *QueryGraphPathRequest) UnmarshalVT(dAtA []byte) error

type QueryGraphPathResponse added in v0.51.6

type QueryGraphPathResponse struct {

	// ResourceId is the ID of the GraphPathQuery resource.
	ResourceId uint32 `protobuf:"varint,1,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// contains filtered or unexported fields
}

QueryGraphPathResponse is the response type for QueryGraphPath.

func (*QueryGraphPathResponse) CloneMessageVT added in v0.51.6

func (*QueryGraphPathResponse) CloneVT added in v0.51.6

func (*QueryGraphPathResponse) EqualMessageVT added in v0.51.6

func (this *QueryGraphPathResponse) EqualMessageVT(thatMsg any) bool

func (*QueryGraphPathResponse) EqualVT added in v0.51.6

func (this *QueryGraphPathResponse) EqualVT(that *QueryGraphPathResponse) bool

func (*QueryGraphPathResponse) GetResourceId added in v0.51.6

func (x *QueryGraphPathResponse) GetResourceId() uint32

func (*QueryGraphPathResponse) MarshalJSON added in v0.51.6

func (x *QueryGraphPathResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the QueryGraphPathResponse to JSON.

func (*QueryGraphPathResponse) MarshalProtoJSON added in v0.51.6

func (x *QueryGraphPathResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the QueryGraphPathResponse message to JSON.

func (*QueryGraphPathResponse) MarshalProtoText added in v0.51.6

func (x *QueryGraphPathResponse) MarshalProtoText() string

func (*QueryGraphPathResponse) MarshalToSizedBufferVT added in v0.51.6

func (m *QueryGraphPathResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueryGraphPathResponse) MarshalToVT added in v0.51.6

func (m *QueryGraphPathResponse) MarshalToVT(dAtA []byte) (int, error)

func (*QueryGraphPathResponse) MarshalVT added in v0.51.6

func (m *QueryGraphPathResponse) MarshalVT() (dAtA []byte, err error)

func (*QueryGraphPathResponse) ProtoMessage added in v0.51.6

func (*QueryGraphPathResponse) ProtoMessage()

func (*QueryGraphPathResponse) Reset added in v0.51.6

func (x *QueryGraphPathResponse) Reset()

func (*QueryGraphPathResponse) SizeVT added in v0.51.6

func (m *QueryGraphPathResponse) SizeVT() (n int)

func (*QueryGraphPathResponse) String added in v0.51.6

func (x *QueryGraphPathResponse) String() string

func (*QueryGraphPathResponse) UnmarshalJSON added in v0.51.6

func (x *QueryGraphPathResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the QueryGraphPathResponse from JSON.

func (*QueryGraphPathResponse) UnmarshalProtoJSON added in v0.51.6

func (x *QueryGraphPathResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the QueryGraphPathResponse message from JSON.

func (*QueryGraphPathResponse) UnmarshalVT added in v0.51.6

func (m *QueryGraphPathResponse) UnmarshalVT(dAtA []byte) error

type RenameObjectRequest

type RenameObjectRequest struct {

	// OldObjectKey is the object key to rename.
	OldObjectKey string `protobuf:"bytes,1,opt,name=old_object_key,json=oldObjectKey,proto3" json:"oldObjectKey,omitempty"`
	// NewObjectKey is the new object key.
	NewObjectKey string `protobuf:"bytes,2,opt,name=new_object_key,json=newObjectKey,proto3" json:"newObjectKey,omitempty"`
	// Descendants renames objects under old_object_key + "/" to the new prefix.
	Descendants bool `protobuf:"varint,3,opt,name=descendants,proto3" json:"descendants,omitempty"`
	// contains filtered or unexported fields
}

RenameObjectRequest is the request type for RenameObject.

func (*RenameObjectRequest) CloneMessageVT

func (*RenameObjectRequest) CloneVT

func (*RenameObjectRequest) EqualMessageVT

func (this *RenameObjectRequest) EqualMessageVT(thatMsg any) bool

func (*RenameObjectRequest) EqualVT

func (this *RenameObjectRequest) EqualVT(that *RenameObjectRequest) bool

func (*RenameObjectRequest) GetDescendants

func (x *RenameObjectRequest) GetDescendants() bool

func (*RenameObjectRequest) GetNewObjectKey

func (x *RenameObjectRequest) GetNewObjectKey() string

func (*RenameObjectRequest) GetOldObjectKey

func (x *RenameObjectRequest) GetOldObjectKey() string

func (*RenameObjectRequest) MarshalJSON

func (x *RenameObjectRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the RenameObjectRequest to JSON.

func (*RenameObjectRequest) MarshalProtoJSON

func (x *RenameObjectRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the RenameObjectRequest message to JSON.

func (*RenameObjectRequest) MarshalProtoText

func (x *RenameObjectRequest) MarshalProtoText() string

func (*RenameObjectRequest) MarshalToSizedBufferVT

func (m *RenameObjectRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RenameObjectRequest) MarshalToVT

func (m *RenameObjectRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RenameObjectRequest) MarshalVT

func (m *RenameObjectRequest) MarshalVT() (dAtA []byte, err error)

func (*RenameObjectRequest) ProtoMessage

func (*RenameObjectRequest) ProtoMessage()

func (*RenameObjectRequest) Reset

func (x *RenameObjectRequest) Reset()

func (*RenameObjectRequest) SizeVT

func (m *RenameObjectRequest) SizeVT() (n int)

func (*RenameObjectRequest) String

func (x *RenameObjectRequest) String() string

func (*RenameObjectRequest) UnmarshalJSON

func (x *RenameObjectRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the RenameObjectRequest from JSON.

func (*RenameObjectRequest) UnmarshalProtoJSON

func (x *RenameObjectRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the RenameObjectRequest message from JSON.

func (*RenameObjectRequest) UnmarshalVT

func (m *RenameObjectRequest) UnmarshalVT(dAtA []byte) error

type RenameObjectResponse

type RenameObjectResponse struct {

	// ResourceId is the ID of the renamed ObjectState resource.
	ResourceId uint32 `protobuf:"varint,1,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// ObjectKey is the unique identifier of the renamed object.
	ObjectKey string `protobuf:"bytes,2,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// contains filtered or unexported fields
}

RenameObjectResponse is the response type for RenameObject.

func (*RenameObjectResponse) CloneMessageVT

func (*RenameObjectResponse) CloneVT

func (*RenameObjectResponse) EqualMessageVT

func (this *RenameObjectResponse) EqualMessageVT(thatMsg any) bool

func (*RenameObjectResponse) EqualVT

func (this *RenameObjectResponse) EqualVT(that *RenameObjectResponse) bool

func (*RenameObjectResponse) GetObjectKey

func (x *RenameObjectResponse) GetObjectKey() string

func (*RenameObjectResponse) GetResourceId

func (x *RenameObjectResponse) GetResourceId() uint32

func (*RenameObjectResponse) MarshalJSON

func (x *RenameObjectResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the RenameObjectResponse to JSON.

func (*RenameObjectResponse) MarshalProtoJSON

func (x *RenameObjectResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the RenameObjectResponse message to JSON.

func (*RenameObjectResponse) MarshalProtoText

func (x *RenameObjectResponse) MarshalProtoText() string

func (*RenameObjectResponse) MarshalToSizedBufferVT

func (m *RenameObjectResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RenameObjectResponse) MarshalToVT

func (m *RenameObjectResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RenameObjectResponse) MarshalVT

func (m *RenameObjectResponse) MarshalVT() (dAtA []byte, err error)

func (*RenameObjectResponse) ProtoMessage

func (*RenameObjectResponse) ProtoMessage()

func (*RenameObjectResponse) Reset

func (x *RenameObjectResponse) Reset()

func (*RenameObjectResponse) SizeVT

func (m *RenameObjectResponse) SizeVT() (n int)

func (*RenameObjectResponse) String

func (x *RenameObjectResponse) String() string

func (*RenameObjectResponse) UnmarshalJSON

func (x *RenameObjectResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the RenameObjectResponse from JSON.

func (*RenameObjectResponse) UnmarshalProtoJSON

func (x *RenameObjectResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the RenameObjectResponse message from JSON.

func (*RenameObjectResponse) UnmarshalVT

func (m *RenameObjectResponse) UnmarshalVT(dAtA []byte) error

type SRPCEngineResourceServiceClient

type SRPCEngineResourceServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	GetEngineInfo(ctx context.Context, in *GetEngineInfoRequest) (*GetEngineInfoResponse, error)

	GetWorldRootSnapshot(ctx context.Context, in *GetWorldRootSnapshotRequest) (*WorldRootSnapshot, error)

	WatchWorldRootSnapshots(ctx context.Context, in *WatchWorldRootSnapshotsRequest) (SRPCEngineResourceService_WatchWorldRootSnapshotsClient, error)

	NewTransaction(ctx context.Context, in *NewTransactionRequest) (*NewTransactionResponse, error)

	Sync(ctx context.Context, in *SyncRequest) (*SyncResponse, error)

	GetSeqno(ctx context.Context, in *GetSeqnoRequest) (*GetSeqnoResponse, error)

	WaitSeqno(ctx context.Context, in *WaitSeqnoRequest) (*WaitSeqnoResponse, error)

	BuildStorageCursor(ctx context.Context, in *BuildStorageCursorRequest) (*BuildStorageCursorResponse, error)

	AccessWorldState(ctx context.Context, in *AccessWorldStateRequest) (*AccessWorldStateResponse, error)
}

func NewSRPCEngineResourceServiceClient

func NewSRPCEngineResourceServiceClient(cc srpc.Client) SRPCEngineResourceServiceClient

func NewSRPCEngineResourceServiceClientWithServiceID

func NewSRPCEngineResourceServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCEngineResourceServiceClient

type SRPCEngineResourceServiceHandler

type SRPCEngineResourceServiceHandler struct {
	// contains filtered or unexported fields
}

func (SRPCEngineResourceServiceHandler) GetMethodIDs

func (SRPCEngineResourceServiceHandler) GetMethodIDs() []string

func (*SRPCEngineResourceServiceHandler) GetServiceID

func (d *SRPCEngineResourceServiceHandler) GetServiceID() string

func (*SRPCEngineResourceServiceHandler) InvokeMethod

func (d *SRPCEngineResourceServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCEngineResourceServiceHandler) InvokeMethod_AccessWorldState

func (SRPCEngineResourceServiceHandler) InvokeMethod_AccessWorldState(impl SRPCEngineResourceServiceServer, strm srpc.Stream) error

func (SRPCEngineResourceServiceHandler) InvokeMethod_BuildStorageCursor

func (SRPCEngineResourceServiceHandler) InvokeMethod_BuildStorageCursor(impl SRPCEngineResourceServiceServer, strm srpc.Stream) error

func (SRPCEngineResourceServiceHandler) InvokeMethod_GetEngineInfo

func (SRPCEngineResourceServiceHandler) InvokeMethod_GetEngineInfo(impl SRPCEngineResourceServiceServer, strm srpc.Stream) error

func (SRPCEngineResourceServiceHandler) InvokeMethod_GetSeqno

func (SRPCEngineResourceServiceHandler) InvokeMethod_GetWorldRootSnapshot added in v0.51.7

func (SRPCEngineResourceServiceHandler) InvokeMethod_GetWorldRootSnapshot(impl SRPCEngineResourceServiceServer, strm srpc.Stream) error

func (SRPCEngineResourceServiceHandler) InvokeMethod_NewTransaction

func (SRPCEngineResourceServiceHandler) InvokeMethod_NewTransaction(impl SRPCEngineResourceServiceServer, strm srpc.Stream) error

func (SRPCEngineResourceServiceHandler) InvokeMethod_Sync added in v0.52.0

func (SRPCEngineResourceServiceHandler) InvokeMethod_WaitSeqno

func (SRPCEngineResourceServiceHandler) InvokeMethod_WatchWorldRootSnapshots added in v0.51.7

func (SRPCEngineResourceServiceHandler) InvokeMethod_WatchWorldRootSnapshots(impl SRPCEngineResourceServiceServer, strm srpc.Stream) error

type SRPCEngineResourceService_AccessWorldStateStream

type SRPCEngineResourceService_AccessWorldStateStream interface {
	srpc.Stream
}

type SRPCEngineResourceService_BuildStorageCursorStream

type SRPCEngineResourceService_BuildStorageCursorStream interface {
	srpc.Stream
}

type SRPCEngineResourceService_GetEngineInfoStream

type SRPCEngineResourceService_GetEngineInfoStream interface {
	srpc.Stream
}

type SRPCEngineResourceService_GetSeqnoStream

type SRPCEngineResourceService_GetSeqnoStream interface {
	srpc.Stream
}

type SRPCEngineResourceService_GetWorldRootSnapshotStream added in v0.51.7

type SRPCEngineResourceService_GetWorldRootSnapshotStream interface {
	srpc.Stream
}

type SRPCEngineResourceService_NewTransactionStream

type SRPCEngineResourceService_NewTransactionStream interface {
	srpc.Stream
}

type SRPCEngineResourceService_SyncStream added in v0.52.0

type SRPCEngineResourceService_SyncStream interface {
	srpc.Stream
}

type SRPCEngineResourceService_WaitSeqnoStream

type SRPCEngineResourceService_WaitSeqnoStream interface {
	srpc.Stream
}

type SRPCEngineResourceService_WatchWorldRootSnapshotsClient added in v0.51.7

type SRPCEngineResourceService_WatchWorldRootSnapshotsClient interface {
	srpc.Stream
	Recv() (*WorldRootSnapshot, error)
	RecvTo(*WorldRootSnapshot) error
}

type SRPCEngineResourceService_WatchWorldRootSnapshotsStream added in v0.51.7

type SRPCEngineResourceService_WatchWorldRootSnapshotsStream interface {
	srpc.Stream
	Send(*WorldRootSnapshot) error
	SendAndClose(*WorldRootSnapshot) error
}

type SRPCGraphPathQueryResourceServiceClient added in v0.51.6

type SRPCGraphPathQueryResourceServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	Next(ctx context.Context, in *NextGraphPathQueryRequest) (*NextGraphPathQueryResponse, error)

	Close(ctx context.Context, in *CloseGraphPathQueryRequest) (*CloseGraphPathQueryResponse, error)
}

func NewSRPCGraphPathQueryResourceServiceClient added in v0.51.6

func NewSRPCGraphPathQueryResourceServiceClient(cc srpc.Client) SRPCGraphPathQueryResourceServiceClient

func NewSRPCGraphPathQueryResourceServiceClientWithServiceID added in v0.51.6

func NewSRPCGraphPathQueryResourceServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCGraphPathQueryResourceServiceClient

type SRPCGraphPathQueryResourceServiceHandler added in v0.51.6

type SRPCGraphPathQueryResourceServiceHandler struct {
	// contains filtered or unexported fields
}

func (SRPCGraphPathQueryResourceServiceHandler) GetMethodIDs added in v0.51.6

func (*SRPCGraphPathQueryResourceServiceHandler) GetServiceID added in v0.51.6

func (*SRPCGraphPathQueryResourceServiceHandler) InvokeMethod added in v0.51.6

func (d *SRPCGraphPathQueryResourceServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCGraphPathQueryResourceServiceHandler) InvokeMethod_Close added in v0.51.6

func (SRPCGraphPathQueryResourceServiceHandler) InvokeMethod_Next added in v0.51.6

type SRPCGraphPathQueryResourceService_CloseStream added in v0.51.6

type SRPCGraphPathQueryResourceService_CloseStream interface {
	srpc.Stream
}

type SRPCGraphPathQueryResourceService_NextStream added in v0.51.6

type SRPCGraphPathQueryResourceService_NextStream interface {
	srpc.Stream
}

type SRPCObjectIteratorResourceServiceClient

type SRPCObjectIteratorResourceServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	Err(ctx context.Context, in *ErrRequest) (*ErrResponse, error)

	Valid(ctx context.Context, in *ValidRequest) (*ValidResponse, error)

	Key(ctx context.Context, in *KeyRequest) (*KeyResponse, error)

	Next(ctx context.Context, in *NextRequest) (*NextResponse, error)

	Seek(ctx context.Context, in *SeekRequest) (*SeekResponse, error)

	Close(ctx context.Context, in *CloseRequest) (*CloseResponse, error)
}

func NewSRPCObjectIteratorResourceServiceClient

func NewSRPCObjectIteratorResourceServiceClient(cc srpc.Client) SRPCObjectIteratorResourceServiceClient

func NewSRPCObjectIteratorResourceServiceClientWithServiceID

func NewSRPCObjectIteratorResourceServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCObjectIteratorResourceServiceClient

type SRPCObjectIteratorResourceServiceHandler

type SRPCObjectIteratorResourceServiceHandler struct {
	// contains filtered or unexported fields
}

func (SRPCObjectIteratorResourceServiceHandler) GetMethodIDs

func (*SRPCObjectIteratorResourceServiceHandler) GetServiceID

func (*SRPCObjectIteratorResourceServiceHandler) InvokeMethod

func (d *SRPCObjectIteratorResourceServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCObjectIteratorResourceServiceHandler) InvokeMethod_Close

func (SRPCObjectIteratorResourceServiceHandler) InvokeMethod_Err

func (SRPCObjectIteratorResourceServiceHandler) InvokeMethod_Key

func (SRPCObjectIteratorResourceServiceHandler) InvokeMethod_Next

func (SRPCObjectIteratorResourceServiceHandler) InvokeMethod_Seek

func (SRPCObjectIteratorResourceServiceHandler) InvokeMethod_Valid

type SRPCObjectIteratorResourceService_CloseStream

type SRPCObjectIteratorResourceService_CloseStream interface {
	srpc.Stream
}

type SRPCObjectIteratorResourceService_ErrStream

type SRPCObjectIteratorResourceService_ErrStream interface {
	srpc.Stream
}

type SRPCObjectIteratorResourceService_KeyStream

type SRPCObjectIteratorResourceService_KeyStream interface {
	srpc.Stream
}

type SRPCObjectIteratorResourceService_NextStream

type SRPCObjectIteratorResourceService_NextStream interface {
	srpc.Stream
}

type SRPCObjectIteratorResourceService_SeekStream

type SRPCObjectIteratorResourceService_SeekStream interface {
	srpc.Stream
}

type SRPCObjectIteratorResourceService_ValidStream

type SRPCObjectIteratorResourceService_ValidStream interface {
	srpc.Stream
}

type SRPCObjectStateResourceServiceClient

type SRPCObjectStateResourceServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	GetKey(ctx context.Context, in *GetKeyRequest) (*GetKeyResponse, error)

	GetRootRef(ctx context.Context, in *GetRootRefRequest) (*GetRootRefResponse, error)

	SetRootRef(ctx context.Context, in *SetRootRefRequest) (*SetRootRefResponse, error)

	AccessWorldState(ctx context.Context, in *AccessWorldStateRequest) (*AccessWorldStateResponse, error)

	ApplyObjectOp(ctx context.Context, in *ApplyObjectOpRequest) (*ApplyObjectOpResponse, error)

	IncrementRev(ctx context.Context, in *IncrementRevRequest) (*IncrementRevResponse, error)

	WaitRev(ctx context.Context, in *WaitRevRequest) (*WaitRevResponse, error)
}

func NewSRPCObjectStateResourceServiceClient

func NewSRPCObjectStateResourceServiceClient(cc srpc.Client) SRPCObjectStateResourceServiceClient

func NewSRPCObjectStateResourceServiceClientWithServiceID

func NewSRPCObjectStateResourceServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCObjectStateResourceServiceClient

type SRPCObjectStateResourceServiceHandler

type SRPCObjectStateResourceServiceHandler struct {
	// contains filtered or unexported fields
}

func (SRPCObjectStateResourceServiceHandler) GetMethodIDs

func (*SRPCObjectStateResourceServiceHandler) GetServiceID

func (*SRPCObjectStateResourceServiceHandler) InvokeMethod

func (d *SRPCObjectStateResourceServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCObjectStateResourceServiceHandler) InvokeMethod_AccessWorldState

func (SRPCObjectStateResourceServiceHandler) InvokeMethod_ApplyObjectOp

func (SRPCObjectStateResourceServiceHandler) InvokeMethod_GetKey

func (SRPCObjectStateResourceServiceHandler) InvokeMethod_GetRootRef

func (SRPCObjectStateResourceServiceHandler) InvokeMethod_IncrementRev

func (SRPCObjectStateResourceServiceHandler) InvokeMethod_SetRootRef

func (SRPCObjectStateResourceServiceHandler) InvokeMethod_WaitRev

type SRPCObjectStateResourceService_AccessWorldStateStream

type SRPCObjectStateResourceService_AccessWorldStateStream interface {
	srpc.Stream
}

type SRPCObjectStateResourceService_ApplyObjectOpStream

type SRPCObjectStateResourceService_ApplyObjectOpStream interface {
	srpc.Stream
}

type SRPCObjectStateResourceService_GetKeyStream

type SRPCObjectStateResourceService_GetKeyStream interface {
	srpc.Stream
}

type SRPCObjectStateResourceService_GetRootRefStream

type SRPCObjectStateResourceService_GetRootRefStream interface {
	srpc.Stream
}

type SRPCObjectStateResourceService_IncrementRevStream

type SRPCObjectStateResourceService_IncrementRevStream interface {
	srpc.Stream
}

type SRPCObjectStateResourceService_SetRootRefStream

type SRPCObjectStateResourceService_SetRootRefStream interface {
	srpc.Stream
}

type SRPCObjectStateResourceService_WaitRevStream

type SRPCObjectStateResourceService_WaitRevStream interface {
	srpc.Stream
}

type SRPCTxResourceServiceClient

type SRPCTxResourceServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	Commit(ctx context.Context, in *CommitRequest) (*CommitResponse, error)

	Discard(ctx context.Context, in *DiscardRequest) (*DiscardResponse, error)
}

func NewSRPCTxResourceServiceClient

func NewSRPCTxResourceServiceClient(cc srpc.Client) SRPCTxResourceServiceClient

func NewSRPCTxResourceServiceClientWithServiceID

func NewSRPCTxResourceServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCTxResourceServiceClient

type SRPCTxResourceServiceHandler

type SRPCTxResourceServiceHandler struct {
	// contains filtered or unexported fields
}

func (SRPCTxResourceServiceHandler) GetMethodIDs

func (SRPCTxResourceServiceHandler) GetMethodIDs() []string

func (*SRPCTxResourceServiceHandler) GetServiceID

func (d *SRPCTxResourceServiceHandler) GetServiceID() string

func (*SRPCTxResourceServiceHandler) InvokeMethod

func (d *SRPCTxResourceServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCTxResourceServiceHandler) InvokeMethod_Commit

func (SRPCTxResourceServiceHandler) InvokeMethod_Discard

type SRPCTxResourceServiceServer

type SRPCTxResourceServiceServer interface {
	Commit(context.Context, *CommitRequest) (*CommitResponse, error)

	Discard(context.Context, *DiscardRequest) (*DiscardResponse, error)
}

type SRPCTxResourceService_CommitStream

type SRPCTxResourceService_CommitStream interface {
	srpc.Stream
}

type SRPCTxResourceService_DiscardStream

type SRPCTxResourceService_DiscardStream interface {
	srpc.Stream
}

type SRPCTypedObjectResourceServiceClient

type SRPCTypedObjectResourceServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	AccessTypedObject(ctx context.Context, in *AccessTypedObjectRequest) (*AccessTypedObjectResponse, error)
}

func NewSRPCTypedObjectResourceServiceClient

func NewSRPCTypedObjectResourceServiceClient(cc srpc.Client) SRPCTypedObjectResourceServiceClient

func NewSRPCTypedObjectResourceServiceClientWithServiceID

func NewSRPCTypedObjectResourceServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCTypedObjectResourceServiceClient

type SRPCTypedObjectResourceServiceHandler

type SRPCTypedObjectResourceServiceHandler struct {
	// contains filtered or unexported fields
}

func (SRPCTypedObjectResourceServiceHandler) GetMethodIDs

func (*SRPCTypedObjectResourceServiceHandler) GetServiceID

func (*SRPCTypedObjectResourceServiceHandler) InvokeMethod

func (d *SRPCTypedObjectResourceServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCTypedObjectResourceServiceHandler) InvokeMethod_AccessTypedObject

type SRPCTypedObjectResourceServiceServer

type SRPCTypedObjectResourceServiceServer interface {
	AccessTypedObject(context.Context, *AccessTypedObjectRequest) (*AccessTypedObjectResponse, error)
}

type SRPCTypedObjectResourceService_AccessTypedObjectStream

type SRPCTypedObjectResourceService_AccessTypedObjectStream interface {
	srpc.Stream
}

type SRPCWatchWorldStateResourceServiceClient

type SRPCWatchWorldStateResourceServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	WatchWorldState(ctx context.Context, in *WatchWorldStateRequest) (SRPCWatchWorldStateResourceService_WatchWorldStateClient, error)
}

func NewSRPCWatchWorldStateResourceServiceClient

func NewSRPCWatchWorldStateResourceServiceClient(cc srpc.Client) SRPCWatchWorldStateResourceServiceClient

func NewSRPCWatchWorldStateResourceServiceClientWithServiceID

func NewSRPCWatchWorldStateResourceServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCWatchWorldStateResourceServiceClient

type SRPCWatchWorldStateResourceServiceHandler

type SRPCWatchWorldStateResourceServiceHandler struct {
	// contains filtered or unexported fields
}

func (SRPCWatchWorldStateResourceServiceHandler) GetMethodIDs

func (*SRPCWatchWorldStateResourceServiceHandler) GetServiceID

func (*SRPCWatchWorldStateResourceServiceHandler) InvokeMethod

func (d *SRPCWatchWorldStateResourceServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCWatchWorldStateResourceServiceHandler) InvokeMethod_WatchWorldState

type SRPCWatchWorldStateResourceServiceServer

type SRPCWatchWorldStateResourceServiceServer interface {
	WatchWorldState(*WatchWorldStateRequest, SRPCWatchWorldStateResourceService_WatchWorldStateStream) error
}

type SRPCWatchWorldStateResourceService_WatchWorldStateClient

type SRPCWatchWorldStateResourceService_WatchWorldStateClient interface {
	srpc.Stream
	Recv() (*WatchWorldStateResponse, error)
	RecvTo(*WatchWorldStateResponse) error
}

type SRPCWatchWorldStateResourceService_WatchWorldStateStream

type SRPCWatchWorldStateResourceService_WatchWorldStateStream interface {
	srpc.Stream
	Send(*WatchWorldStateResponse) error
	SendAndClose(*WatchWorldStateResponse) error
}

type SRPCWorldStateResourceServiceClient

type SRPCWorldStateResourceServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	GetReadOnly(ctx context.Context, in *GetReadOnlyRequest) (*GetReadOnlyResponse, error)

	Sync(ctx context.Context, in *SyncRequest) (*SyncResponse, error)

	GetSeqno(ctx context.Context, in *GetSeqnoRequest) (*GetSeqnoResponse, error)

	WaitSeqno(ctx context.Context, in *WaitSeqnoRequest) (*WaitSeqnoResponse, error)

	BuildStorageCursor(ctx context.Context, in *BuildStorageCursorRequest) (*BuildStorageCursorResponse, error)

	AccessWorldState(ctx context.Context, in *AccessWorldStateRequest) (*AccessWorldStateResponse, error)

	CreateObject(ctx context.Context, in *CreateObjectRequest) (*CreateObjectResponse, error)

	GetObject(ctx context.Context, in *GetObjectRequest) (*GetObjectResponse, error)

	IterateObjects(ctx context.Context, in *IterateObjectsRequest) (*IterateObjectsResponse, error)

	RenameObject(ctx context.Context, in *RenameObjectRequest) (*RenameObjectResponse, error)

	DeleteObject(ctx context.Context, in *DeleteObjectRequest) (*DeleteObjectResponse, error)

	SetGraphQuad(ctx context.Context, in *SetGraphQuadRequest) (*SetGraphQuadResponse, error)

	DeleteGraphQuad(ctx context.Context, in *DeleteGraphQuadRequest) (*DeleteGraphQuadResponse, error)

	LookupGraphQuads(ctx context.Context, in *LookupGraphQuadsRequest) (*LookupGraphQuadsResponse, error)

	LookupGraphQuadsBatch(ctx context.Context, in *LookupGraphQuadsBatchRequest) (*LookupGraphQuadsBatchResponse, error)

	ListGraphEdgeBuckets(ctx context.Context, in *ListGraphEdgeBucketsRequest) (*ListGraphEdgeBucketsResponse, error)

	ListObjectsWithType(ctx context.Context, in *ListObjectsWithTypeRequest) (*ListObjectsWithTypeResponse, error)

	GetObjectRootRefsBatch(ctx context.Context, in *GetObjectRootRefsBatchRequest) (*GetObjectRootRefsBatchResponse, error)

	GetObjectMetadataBatch(ctx context.Context, in *GetObjectMetadataBatchRequest) (*GetObjectMetadataBatchResponse, error)

	QueryGraphPath(ctx context.Context, in *QueryGraphPathRequest) (*QueryGraphPathResponse, error)

	DeleteGraphObject(ctx context.Context, in *DeleteGraphObjectRequest) (*DeleteGraphObjectResponse, error)

	ApplyWorldOp(ctx context.Context, in *ApplyWorldOpRequest) (*ApplyWorldOpResponse, error)
}

func NewSRPCWorldStateResourceServiceClient

func NewSRPCWorldStateResourceServiceClient(cc srpc.Client) SRPCWorldStateResourceServiceClient

func NewSRPCWorldStateResourceServiceClientWithServiceID

func NewSRPCWorldStateResourceServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCWorldStateResourceServiceClient

type SRPCWorldStateResourceServiceHandler

type SRPCWorldStateResourceServiceHandler struct {
	// contains filtered or unexported fields
}

func (SRPCWorldStateResourceServiceHandler) GetMethodIDs

func (*SRPCWorldStateResourceServiceHandler) GetServiceID

func (d *SRPCWorldStateResourceServiceHandler) GetServiceID() string

func (*SRPCWorldStateResourceServiceHandler) InvokeMethod

func (d *SRPCWorldStateResourceServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_AccessWorldState

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_ApplyWorldOp

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_BuildStorageCursor

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_CreateObject

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_DeleteGraphObject

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_DeleteGraphQuad

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_DeleteObject

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_GetObject

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_GetObjectMetadataBatch added in v0.51.6

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_GetObjectMetadataBatch(impl SRPCWorldStateResourceServiceServer, strm srpc.Stream) error

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_GetObjectRootRefsBatch added in v0.51.7

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_GetObjectRootRefsBatch(impl SRPCWorldStateResourceServiceServer, strm srpc.Stream) error

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_GetReadOnly

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_GetSeqno

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_IterateObjects

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_ListGraphEdgeBuckets added in v0.51.7

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_ListGraphEdgeBuckets(impl SRPCWorldStateResourceServiceServer, strm srpc.Stream) error

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_ListObjectsWithType

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_ListObjectsWithType(impl SRPCWorldStateResourceServiceServer, strm srpc.Stream) error

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_LookupGraphQuads

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_LookupGraphQuadsBatch added in v0.51.6

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_LookupGraphQuadsBatch(impl SRPCWorldStateResourceServiceServer, strm srpc.Stream) error

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_QueryGraphPath added in v0.51.6

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_RenameObject

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_SetGraphQuad

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_Sync added in v0.52.0

func (SRPCWorldStateResourceServiceHandler) InvokeMethod_WaitSeqno

type SRPCWorldStateResourceServiceServer

type SRPCWorldStateResourceServiceServer interface {
	GetReadOnly(context.Context, *GetReadOnlyRequest) (*GetReadOnlyResponse, error)

	Sync(context.Context, *SyncRequest) (*SyncResponse, error)

	GetSeqno(context.Context, *GetSeqnoRequest) (*GetSeqnoResponse, error)

	WaitSeqno(context.Context, *WaitSeqnoRequest) (*WaitSeqnoResponse, error)

	BuildStorageCursor(context.Context, *BuildStorageCursorRequest) (*BuildStorageCursorResponse, error)

	AccessWorldState(context.Context, *AccessWorldStateRequest) (*AccessWorldStateResponse, error)

	CreateObject(context.Context, *CreateObjectRequest) (*CreateObjectResponse, error)

	GetObject(context.Context, *GetObjectRequest) (*GetObjectResponse, error)

	IterateObjects(context.Context, *IterateObjectsRequest) (*IterateObjectsResponse, error)

	RenameObject(context.Context, *RenameObjectRequest) (*RenameObjectResponse, error)

	DeleteObject(context.Context, *DeleteObjectRequest) (*DeleteObjectResponse, error)

	SetGraphQuad(context.Context, *SetGraphQuadRequest) (*SetGraphQuadResponse, error)

	DeleteGraphQuad(context.Context, *DeleteGraphQuadRequest) (*DeleteGraphQuadResponse, error)

	LookupGraphQuads(context.Context, *LookupGraphQuadsRequest) (*LookupGraphQuadsResponse, error)

	LookupGraphQuadsBatch(context.Context, *LookupGraphQuadsBatchRequest) (*LookupGraphQuadsBatchResponse, error)

	ListGraphEdgeBuckets(context.Context, *ListGraphEdgeBucketsRequest) (*ListGraphEdgeBucketsResponse, error)

	ListObjectsWithType(context.Context, *ListObjectsWithTypeRequest) (*ListObjectsWithTypeResponse, error)

	GetObjectRootRefsBatch(context.Context, *GetObjectRootRefsBatchRequest) (*GetObjectRootRefsBatchResponse, error)

	GetObjectMetadataBatch(context.Context, *GetObjectMetadataBatchRequest) (*GetObjectMetadataBatchResponse, error)

	QueryGraphPath(context.Context, *QueryGraphPathRequest) (*QueryGraphPathResponse, error)

	DeleteGraphObject(context.Context, *DeleteGraphObjectRequest) (*DeleteGraphObjectResponse, error)

	ApplyWorldOp(context.Context, *ApplyWorldOpRequest) (*ApplyWorldOpResponse, error)
}

type SRPCWorldStateResourceService_AccessWorldStateStream

type SRPCWorldStateResourceService_AccessWorldStateStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_ApplyWorldOpStream

type SRPCWorldStateResourceService_ApplyWorldOpStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_BuildStorageCursorStream

type SRPCWorldStateResourceService_BuildStorageCursorStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_CreateObjectStream

type SRPCWorldStateResourceService_CreateObjectStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_DeleteGraphObjectStream

type SRPCWorldStateResourceService_DeleteGraphObjectStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_DeleteGraphQuadStream

type SRPCWorldStateResourceService_DeleteGraphQuadStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_DeleteObjectStream

type SRPCWorldStateResourceService_DeleteObjectStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_GetObjectMetadataBatchStream added in v0.51.6

type SRPCWorldStateResourceService_GetObjectMetadataBatchStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_GetObjectRootRefsBatchStream added in v0.51.7

type SRPCWorldStateResourceService_GetObjectRootRefsBatchStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_GetObjectStream

type SRPCWorldStateResourceService_GetObjectStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_GetReadOnlyStream

type SRPCWorldStateResourceService_GetReadOnlyStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_GetSeqnoStream

type SRPCWorldStateResourceService_GetSeqnoStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_IterateObjectsStream

type SRPCWorldStateResourceService_IterateObjectsStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_ListGraphEdgeBucketsStream added in v0.51.7

type SRPCWorldStateResourceService_ListGraphEdgeBucketsStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_ListObjectsWithTypeStream

type SRPCWorldStateResourceService_ListObjectsWithTypeStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_LookupGraphQuadsBatchStream added in v0.51.6

type SRPCWorldStateResourceService_LookupGraphQuadsBatchStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_LookupGraphQuadsStream

type SRPCWorldStateResourceService_LookupGraphQuadsStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_QueryGraphPathStream added in v0.51.6

type SRPCWorldStateResourceService_QueryGraphPathStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_RenameObjectStream

type SRPCWorldStateResourceService_RenameObjectStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_SetGraphQuadStream

type SRPCWorldStateResourceService_SetGraphQuadStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_SyncStream added in v0.52.0

type SRPCWorldStateResourceService_SyncStream interface {
	srpc.Stream
}

type SRPCWorldStateResourceService_WaitSeqnoStream

type SRPCWorldStateResourceService_WaitSeqnoStream interface {
	srpc.Stream
}

type SeekRequest

type SeekRequest struct {

	// ObjectKey is the key to seek to, or empty to seek to beginning (or end if reversed).
	ObjectKey string `protobuf:"bytes,1,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// contains filtered or unexported fields
}

SeekRequest is the request type for Seek.

func (*SeekRequest) CloneMessageVT

func (m *SeekRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SeekRequest) CloneVT

func (m *SeekRequest) CloneVT() *SeekRequest

func (*SeekRequest) EqualMessageVT

func (this *SeekRequest) EqualMessageVT(thatMsg any) bool

func (*SeekRequest) EqualVT

func (this *SeekRequest) EqualVT(that *SeekRequest) bool

func (*SeekRequest) GetObjectKey

func (x *SeekRequest) GetObjectKey() string

func (*SeekRequest) MarshalJSON

func (x *SeekRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SeekRequest to JSON.

func (*SeekRequest) MarshalProtoJSON

func (x *SeekRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SeekRequest message to JSON.

func (*SeekRequest) MarshalProtoText

func (x *SeekRequest) MarshalProtoText() string

func (*SeekRequest) MarshalToSizedBufferVT

func (m *SeekRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SeekRequest) MarshalToVT

func (m *SeekRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SeekRequest) MarshalVT

func (m *SeekRequest) MarshalVT() (dAtA []byte, err error)

func (*SeekRequest) ProtoMessage

func (*SeekRequest) ProtoMessage()

func (*SeekRequest) Reset

func (x *SeekRequest) Reset()

func (*SeekRequest) SizeVT

func (m *SeekRequest) SizeVT() (n int)

func (*SeekRequest) String

func (x *SeekRequest) String() string

func (*SeekRequest) UnmarshalJSON

func (x *SeekRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SeekRequest from JSON.

func (*SeekRequest) UnmarshalProtoJSON

func (x *SeekRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SeekRequest message from JSON.

func (*SeekRequest) UnmarshalVT

func (m *SeekRequest) UnmarshalVT(dAtA []byte) error

type SeekResponse

type SeekResponse struct {
	// contains filtered or unexported fields
}

SeekResponse is the response type for Seek.

func (*SeekResponse) CloneMessageVT

func (m *SeekResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SeekResponse) CloneVT

func (m *SeekResponse) CloneVT() *SeekResponse

func (*SeekResponse) EqualMessageVT

func (this *SeekResponse) EqualMessageVT(thatMsg any) bool

func (*SeekResponse) EqualVT

func (this *SeekResponse) EqualVT(that *SeekResponse) bool

func (*SeekResponse) MarshalJSON

func (x *SeekResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SeekResponse to JSON.

func (*SeekResponse) MarshalProtoJSON

func (x *SeekResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SeekResponse message to JSON.

func (*SeekResponse) MarshalProtoText

func (x *SeekResponse) MarshalProtoText() string

func (*SeekResponse) MarshalToSizedBufferVT

func (m *SeekResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SeekResponse) MarshalToVT

func (m *SeekResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SeekResponse) MarshalVT

func (m *SeekResponse) MarshalVT() (dAtA []byte, err error)

func (*SeekResponse) ProtoMessage

func (*SeekResponse) ProtoMessage()

func (*SeekResponse) Reset

func (x *SeekResponse) Reset()

func (*SeekResponse) SizeVT

func (m *SeekResponse) SizeVT() (n int)

func (*SeekResponse) String

func (x *SeekResponse) String() string

func (*SeekResponse) UnmarshalJSON

func (x *SeekResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SeekResponse from JSON.

func (*SeekResponse) UnmarshalProtoJSON

func (x *SeekResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SeekResponse message from JSON.

func (*SeekResponse) UnmarshalVT

func (m *SeekResponse) UnmarshalVT(dAtA []byte) error

type SetGraphQuadRequest

type SetGraphQuadRequest struct {

	// Quad is the graph quad to add or update in the store.
	Quad *quad.Quad `protobuf:"bytes,1,opt,name=quad,proto3" json:"quad,omitempty"`
	// contains filtered or unexported fields
}

SetGraphQuadRequest is the request type for SetGraphQuad.

func (*SetGraphQuadRequest) CloneMessageVT

func (*SetGraphQuadRequest) CloneVT

func (*SetGraphQuadRequest) EqualMessageVT

func (this *SetGraphQuadRequest) EqualMessageVT(thatMsg any) bool

func (*SetGraphQuadRequest) EqualVT

func (this *SetGraphQuadRequest) EqualVT(that *SetGraphQuadRequest) bool

func (*SetGraphQuadRequest) GetQuad

func (x *SetGraphQuadRequest) GetQuad() *quad.Quad

func (*SetGraphQuadRequest) MarshalJSON

func (x *SetGraphQuadRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SetGraphQuadRequest to JSON.

func (*SetGraphQuadRequest) MarshalProtoJSON

func (x *SetGraphQuadRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SetGraphQuadRequest message to JSON.

func (*SetGraphQuadRequest) MarshalProtoText

func (x *SetGraphQuadRequest) MarshalProtoText() string

func (*SetGraphQuadRequest) MarshalToSizedBufferVT

func (m *SetGraphQuadRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetGraphQuadRequest) MarshalToVT

func (m *SetGraphQuadRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SetGraphQuadRequest) MarshalVT

func (m *SetGraphQuadRequest) MarshalVT() (dAtA []byte, err error)

func (*SetGraphQuadRequest) ProtoMessage

func (*SetGraphQuadRequest) ProtoMessage()

func (*SetGraphQuadRequest) Reset

func (x *SetGraphQuadRequest) Reset()

func (*SetGraphQuadRequest) SizeVT

func (m *SetGraphQuadRequest) SizeVT() (n int)

func (*SetGraphQuadRequest) String

func (x *SetGraphQuadRequest) String() string

func (*SetGraphQuadRequest) UnmarshalJSON

func (x *SetGraphQuadRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SetGraphQuadRequest from JSON.

func (*SetGraphQuadRequest) UnmarshalProtoJSON

func (x *SetGraphQuadRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SetGraphQuadRequest message from JSON.

func (*SetGraphQuadRequest) UnmarshalVT

func (m *SetGraphQuadRequest) UnmarshalVT(dAtA []byte) error

type SetGraphQuadResponse

type SetGraphQuadResponse struct {
	// contains filtered or unexported fields
}

SetGraphQuadResponse is the response type for SetGraphQuad.

func (*SetGraphQuadResponse) CloneMessageVT

func (*SetGraphQuadResponse) CloneVT

func (*SetGraphQuadResponse) EqualMessageVT

func (this *SetGraphQuadResponse) EqualMessageVT(thatMsg any) bool

func (*SetGraphQuadResponse) EqualVT

func (this *SetGraphQuadResponse) EqualVT(that *SetGraphQuadResponse) bool

func (*SetGraphQuadResponse) MarshalJSON

func (x *SetGraphQuadResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SetGraphQuadResponse to JSON.

func (*SetGraphQuadResponse) MarshalProtoJSON

func (x *SetGraphQuadResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SetGraphQuadResponse message to JSON.

func (*SetGraphQuadResponse) MarshalProtoText

func (x *SetGraphQuadResponse) MarshalProtoText() string

func (*SetGraphQuadResponse) MarshalToSizedBufferVT

func (m *SetGraphQuadResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetGraphQuadResponse) MarshalToVT

func (m *SetGraphQuadResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SetGraphQuadResponse) MarshalVT

func (m *SetGraphQuadResponse) MarshalVT() (dAtA []byte, err error)

func (*SetGraphQuadResponse) ProtoMessage

func (*SetGraphQuadResponse) ProtoMessage()

func (*SetGraphQuadResponse) Reset

func (x *SetGraphQuadResponse) Reset()

func (*SetGraphQuadResponse) SizeVT

func (m *SetGraphQuadResponse) SizeVT() (n int)

func (*SetGraphQuadResponse) String

func (x *SetGraphQuadResponse) String() string

func (*SetGraphQuadResponse) UnmarshalJSON

func (x *SetGraphQuadResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SetGraphQuadResponse from JSON.

func (*SetGraphQuadResponse) UnmarshalProtoJSON

func (x *SetGraphQuadResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SetGraphQuadResponse message from JSON.

func (*SetGraphQuadResponse) UnmarshalVT

func (m *SetGraphQuadResponse) UnmarshalVT(dAtA []byte) error

type SetRootRefRequest

type SetRootRefRequest struct {

	// RootRef is the new reference to set as the object's root data.
	RootRef *bucket.ObjectRef `protobuf:"bytes,1,opt,name=root_ref,json=rootRef,proto3" json:"rootRef,omitempty"`
	// contains filtered or unexported fields
}

SetRootRefRequest is the request type for SetRootRef.

func (*SetRootRefRequest) CloneMessageVT

func (m *SetRootRefRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SetRootRefRequest) CloneVT

func (m *SetRootRefRequest) CloneVT() *SetRootRefRequest

func (*SetRootRefRequest) EqualMessageVT

func (this *SetRootRefRequest) EqualMessageVT(thatMsg any) bool

func (*SetRootRefRequest) EqualVT

func (this *SetRootRefRequest) EqualVT(that *SetRootRefRequest) bool

func (*SetRootRefRequest) GetRootRef

func (x *SetRootRefRequest) GetRootRef() *bucket.ObjectRef

func (*SetRootRefRequest) MarshalJSON

func (x *SetRootRefRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SetRootRefRequest to JSON.

func (*SetRootRefRequest) MarshalProtoJSON

func (x *SetRootRefRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SetRootRefRequest message to JSON.

func (*SetRootRefRequest) MarshalProtoText

func (x *SetRootRefRequest) MarshalProtoText() string

func (*SetRootRefRequest) MarshalToSizedBufferVT

func (m *SetRootRefRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetRootRefRequest) MarshalToVT

func (m *SetRootRefRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SetRootRefRequest) MarshalVT

func (m *SetRootRefRequest) MarshalVT() (dAtA []byte, err error)

func (*SetRootRefRequest) ProtoMessage

func (*SetRootRefRequest) ProtoMessage()

func (*SetRootRefRequest) Reset

func (x *SetRootRefRequest) Reset()

func (*SetRootRefRequest) SizeVT

func (m *SetRootRefRequest) SizeVT() (n int)

func (*SetRootRefRequest) String

func (x *SetRootRefRequest) String() string

func (*SetRootRefRequest) UnmarshalJSON

func (x *SetRootRefRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SetRootRefRequest from JSON.

func (*SetRootRefRequest) UnmarshalProtoJSON

func (x *SetRootRefRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SetRootRefRequest message from JSON.

func (*SetRootRefRequest) UnmarshalVT

func (m *SetRootRefRequest) UnmarshalVT(dAtA []byte) error

type SetRootRefResponse

type SetRootRefResponse struct {

	// Rev is the revision number after the update.
	Rev uint64 `protobuf:"varint,1,opt,name=rev,proto3" json:"rev,omitempty"`
	// contains filtered or unexported fields
}

SetRootRefResponse is the response type for SetRootRef.

func (*SetRootRefResponse) CloneMessageVT

func (m *SetRootRefResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SetRootRefResponse) CloneVT

func (m *SetRootRefResponse) CloneVT() *SetRootRefResponse

func (*SetRootRefResponse) EqualMessageVT

func (this *SetRootRefResponse) EqualMessageVT(thatMsg any) bool

func (*SetRootRefResponse) EqualVT

func (this *SetRootRefResponse) EqualVT(that *SetRootRefResponse) bool

func (*SetRootRefResponse) GetRev

func (x *SetRootRefResponse) GetRev() uint64

func (*SetRootRefResponse) MarshalJSON

func (x *SetRootRefResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SetRootRefResponse to JSON.

func (*SetRootRefResponse) MarshalProtoJSON

func (x *SetRootRefResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SetRootRefResponse message to JSON.

func (*SetRootRefResponse) MarshalProtoText

func (x *SetRootRefResponse) MarshalProtoText() string

func (*SetRootRefResponse) MarshalToSizedBufferVT

func (m *SetRootRefResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetRootRefResponse) MarshalToVT

func (m *SetRootRefResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SetRootRefResponse) MarshalVT

func (m *SetRootRefResponse) MarshalVT() (dAtA []byte, err error)

func (*SetRootRefResponse) ProtoMessage

func (*SetRootRefResponse) ProtoMessage()

func (*SetRootRefResponse) Reset

func (x *SetRootRefResponse) Reset()

func (*SetRootRefResponse) SizeVT

func (m *SetRootRefResponse) SizeVT() (n int)

func (*SetRootRefResponse) String

func (x *SetRootRefResponse) String() string

func (*SetRootRefResponse) UnmarshalJSON

func (x *SetRootRefResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SetRootRefResponse from JSON.

func (*SetRootRefResponse) UnmarshalProtoJSON

func (x *SetRootRefResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SetRootRefResponse message from JSON.

func (*SetRootRefResponse) UnmarshalVT

func (m *SetRootRefResponse) UnmarshalVT(dAtA []byte) error

type SyncRequest added in v0.52.0

type SyncRequest struct {
	// contains filtered or unexported fields
}

SyncRequest is the request type for Sync.

func (*SyncRequest) CloneMessageVT added in v0.52.0

func (m *SyncRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SyncRequest) CloneVT added in v0.52.0

func (m *SyncRequest) CloneVT() *SyncRequest

func (*SyncRequest) EqualMessageVT added in v0.52.0

func (this *SyncRequest) EqualMessageVT(thatMsg any) bool

func (*SyncRequest) EqualVT added in v0.52.0

func (this *SyncRequest) EqualVT(that *SyncRequest) bool

func (*SyncRequest) MarshalJSON added in v0.52.0

func (x *SyncRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SyncRequest to JSON.

func (*SyncRequest) MarshalProtoJSON added in v0.52.0

func (x *SyncRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SyncRequest message to JSON.

func (*SyncRequest) MarshalProtoText added in v0.52.0

func (x *SyncRequest) MarshalProtoText() string

func (*SyncRequest) MarshalToSizedBufferVT added in v0.52.0

func (m *SyncRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SyncRequest) MarshalToVT added in v0.52.0

func (m *SyncRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SyncRequest) MarshalVT added in v0.52.0

func (m *SyncRequest) MarshalVT() (dAtA []byte, err error)

func (*SyncRequest) ProtoMessage added in v0.52.0

func (*SyncRequest) ProtoMessage()

func (*SyncRequest) Reset added in v0.52.0

func (x *SyncRequest) Reset()

func (*SyncRequest) SizeVT added in v0.52.0

func (m *SyncRequest) SizeVT() (n int)

func (*SyncRequest) String added in v0.52.0

func (x *SyncRequest) String() string

func (*SyncRequest) UnmarshalJSON added in v0.52.0

func (x *SyncRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SyncRequest from JSON.

func (*SyncRequest) UnmarshalProtoJSON added in v0.52.0

func (x *SyncRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SyncRequest message from JSON.

func (*SyncRequest) UnmarshalVT added in v0.52.0

func (m *SyncRequest) UnmarshalVT(dAtA []byte) error

type SyncResponse added in v0.52.0

type SyncResponse struct {

	// Fenced indicates whether a durability fence was applied.
	Fenced bool `protobuf:"varint,1,opt,name=fenced,proto3" json:"fenced,omitempty"`
	// contains filtered or unexported fields
}

SyncResponse is the response type for Sync.

func (*SyncResponse) CloneMessageVT added in v0.52.0

func (m *SyncResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SyncResponse) CloneVT added in v0.52.0

func (m *SyncResponse) CloneVT() *SyncResponse

func (*SyncResponse) EqualMessageVT added in v0.52.0

func (this *SyncResponse) EqualMessageVT(thatMsg any) bool

func (*SyncResponse) EqualVT added in v0.52.0

func (this *SyncResponse) EqualVT(that *SyncResponse) bool

func (*SyncResponse) GetFenced added in v0.52.0

func (x *SyncResponse) GetFenced() bool

func (*SyncResponse) MarshalJSON added in v0.52.0

func (x *SyncResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SyncResponse to JSON.

func (*SyncResponse) MarshalProtoJSON added in v0.52.0

func (x *SyncResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SyncResponse message to JSON.

func (*SyncResponse) MarshalProtoText added in v0.52.0

func (x *SyncResponse) MarshalProtoText() string

func (*SyncResponse) MarshalToSizedBufferVT added in v0.52.0

func (m *SyncResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SyncResponse) MarshalToVT added in v0.52.0

func (m *SyncResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SyncResponse) MarshalVT added in v0.52.0

func (m *SyncResponse) MarshalVT() (dAtA []byte, err error)

func (*SyncResponse) ProtoMessage added in v0.52.0

func (*SyncResponse) ProtoMessage()

func (*SyncResponse) Reset added in v0.52.0

func (x *SyncResponse) Reset()

func (*SyncResponse) SizeVT added in v0.52.0

func (m *SyncResponse) SizeVT() (n int)

func (*SyncResponse) String added in v0.52.0

func (x *SyncResponse) String() string

func (*SyncResponse) UnmarshalJSON added in v0.52.0

func (x *SyncResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SyncResponse from JSON.

func (*SyncResponse) UnmarshalProtoJSON added in v0.52.0

func (x *SyncResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SyncResponse message from JSON.

func (*SyncResponse) UnmarshalVT added in v0.52.0

func (m *SyncResponse) UnmarshalVT(dAtA []byte) error

type TrackedWorldStateSnapshot

type TrackedWorldStateSnapshot struct {

	// ObjectAccesses is the list of object accesses that were tracked.
	ObjectAccesses []*TrackedWorldStateSnapshot_ObjectAccess `protobuf:"bytes,1,rep,name=object_accesses,json=objectAccesses,proto3" json:"objectAccesses,omitempty"`
	// HasQuadAccess indicates if any quad queries were performed.
	HasQuadAccess bool `protobuf:"varint,2,opt,name=has_quad_access,json=hasQuadAccess,proto3" json:"hasQuadAccess,omitempty"`
	// InitialSeqno is the world seqno when tracking started.
	InitialSeqno uint64 `protobuf:"varint,3,opt,name=initial_seqno,json=initialSeqno,proto3" json:"initialSeqno,omitempty"`
	// contains filtered or unexported fields
}

TrackedWorldStateSnapshot is an immutable snapshot of tracked WorldState accesses. Used internally to coordinate change detection with StateRoutineContainer.

func (*TrackedWorldStateSnapshot) CloneMessageVT

func (*TrackedWorldStateSnapshot) CloneVT

func (*TrackedWorldStateSnapshot) EqualMessageVT

func (this *TrackedWorldStateSnapshot) EqualMessageVT(thatMsg any) bool

func (*TrackedWorldStateSnapshot) EqualVT

func (*TrackedWorldStateSnapshot) GetHasQuadAccess

func (x *TrackedWorldStateSnapshot) GetHasQuadAccess() bool

func (*TrackedWorldStateSnapshot) GetInitialSeqno

func (x *TrackedWorldStateSnapshot) GetInitialSeqno() uint64

func (*TrackedWorldStateSnapshot) GetObjectAccesses

func (*TrackedWorldStateSnapshot) MarshalJSON

func (x *TrackedWorldStateSnapshot) MarshalJSON() ([]byte, error)

MarshalJSON marshals the TrackedWorldStateSnapshot to JSON.

func (*TrackedWorldStateSnapshot) MarshalProtoJSON

func (x *TrackedWorldStateSnapshot) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the TrackedWorldStateSnapshot message to JSON.

func (*TrackedWorldStateSnapshot) MarshalProtoText

func (x *TrackedWorldStateSnapshot) MarshalProtoText() string

func (*TrackedWorldStateSnapshot) MarshalToSizedBufferVT

func (m *TrackedWorldStateSnapshot) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TrackedWorldStateSnapshot) MarshalToVT

func (m *TrackedWorldStateSnapshot) MarshalToVT(dAtA []byte) (int, error)

func (*TrackedWorldStateSnapshot) MarshalVT

func (m *TrackedWorldStateSnapshot) MarshalVT() (dAtA []byte, err error)

func (*TrackedWorldStateSnapshot) ProtoMessage

func (*TrackedWorldStateSnapshot) ProtoMessage()

func (*TrackedWorldStateSnapshot) Reset

func (x *TrackedWorldStateSnapshot) Reset()

func (*TrackedWorldStateSnapshot) SizeVT

func (m *TrackedWorldStateSnapshot) SizeVT() (n int)

func (*TrackedWorldStateSnapshot) String

func (x *TrackedWorldStateSnapshot) String() string

func (*TrackedWorldStateSnapshot) UnmarshalJSON

func (x *TrackedWorldStateSnapshot) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the TrackedWorldStateSnapshot from JSON.

func (*TrackedWorldStateSnapshot) UnmarshalProtoJSON

func (x *TrackedWorldStateSnapshot) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the TrackedWorldStateSnapshot message from JSON.

func (*TrackedWorldStateSnapshot) UnmarshalVT

func (m *TrackedWorldStateSnapshot) UnmarshalVT(dAtA []byte) error

type TrackedWorldStateSnapshot_ObjectAccess

type TrackedWorldStateSnapshot_ObjectAccess struct {

	// Key is the object key that was accessed.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Rev is the revision of the object at access time.
	Rev uint64 `protobuf:"varint,2,opt,name=rev,proto3" json:"rev,omitempty"`
	// contains filtered or unexported fields
}

ObjectAccess represents a tracked object access.

func (*TrackedWorldStateSnapshot_ObjectAccess) CloneMessageVT

func (*TrackedWorldStateSnapshot_ObjectAccess) CloneVT

func (*TrackedWorldStateSnapshot_ObjectAccess) EqualMessageVT

func (this *TrackedWorldStateSnapshot_ObjectAccess) EqualMessageVT(thatMsg any) bool

func (*TrackedWorldStateSnapshot_ObjectAccess) EqualVT

func (*TrackedWorldStateSnapshot_ObjectAccess) GetKey

func (*TrackedWorldStateSnapshot_ObjectAccess) GetRev

func (*TrackedWorldStateSnapshot_ObjectAccess) MarshalJSON

func (x *TrackedWorldStateSnapshot_ObjectAccess) MarshalJSON() ([]byte, error)

MarshalJSON marshals the TrackedWorldStateSnapshot_ObjectAccess to JSON.

func (*TrackedWorldStateSnapshot_ObjectAccess) MarshalProtoJSON

MarshalProtoJSON marshals the TrackedWorldStateSnapshot_ObjectAccess message to JSON.

func (*TrackedWorldStateSnapshot_ObjectAccess) MarshalProtoText

func (x *TrackedWorldStateSnapshot_ObjectAccess) MarshalProtoText() string

func (*TrackedWorldStateSnapshot_ObjectAccess) MarshalToSizedBufferVT

func (m *TrackedWorldStateSnapshot_ObjectAccess) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TrackedWorldStateSnapshot_ObjectAccess) MarshalToVT

func (m *TrackedWorldStateSnapshot_ObjectAccess) MarshalToVT(dAtA []byte) (int, error)

func (*TrackedWorldStateSnapshot_ObjectAccess) MarshalVT

func (m *TrackedWorldStateSnapshot_ObjectAccess) MarshalVT() (dAtA []byte, err error)

func (*TrackedWorldStateSnapshot_ObjectAccess) ProtoMessage

func (*TrackedWorldStateSnapshot_ObjectAccess) Reset

func (*TrackedWorldStateSnapshot_ObjectAccess) SizeVT

func (*TrackedWorldStateSnapshot_ObjectAccess) String

func (*TrackedWorldStateSnapshot_ObjectAccess) UnmarshalJSON

func (x *TrackedWorldStateSnapshot_ObjectAccess) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the TrackedWorldStateSnapshot_ObjectAccess from JSON.

func (*TrackedWorldStateSnapshot_ObjectAccess) UnmarshalProtoJSON

UnmarshalProtoJSON unmarshals the TrackedWorldStateSnapshot_ObjectAccess message from JSON.

func (*TrackedWorldStateSnapshot_ObjectAccess) UnmarshalVT

func (m *TrackedWorldStateSnapshot_ObjectAccess) UnmarshalVT(dAtA []byte) error

type Tx

type Tx struct {
	*WorldState
	// contains filtered or unexported fields
}

Tx represents a transaction against the world state. Tx implements the world state transaction interfaces (maps to Tx in hydra).

In the Go implementation (hydra/world/tx.go), Tx provides: - WorldState: full state read/write interface (inherited from WorldState) - tx.Tx: Commit, Discard operations

A Tx maintains state across multiple RPC calls, enabling complex multi-step operations within a single transaction. Always call Discard() when done.

Concurrent calls to WorldState functions should be supported.

func NewTx

func NewTx(client *resource_client.Client, ref resource_client.ResourceRef, readOnly bool) (*Tx, error)

NewTx creates a new Tx resource wrapper.

func (*Tx) Commit

func (tx *Tx) Commit(ctx context.Context) error

Commit commits the transaction. After commit, the transaction should be discarded.

func (*Tx) Discard

func (tx *Tx) Discard(ctx context.Context) error

Discard discards the transaction without committing changes. Always call this when done with the transaction.

type ValidRequest

type ValidRequest struct {
	// contains filtered or unexported fields
}

ValidRequest is the request type for Valid.

func (*ValidRequest) CloneMessageVT

func (m *ValidRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ValidRequest) CloneVT

func (m *ValidRequest) CloneVT() *ValidRequest

func (*ValidRequest) EqualMessageVT

func (this *ValidRequest) EqualMessageVT(thatMsg any) bool

func (*ValidRequest) EqualVT

func (this *ValidRequest) EqualVT(that *ValidRequest) bool

func (*ValidRequest) MarshalJSON

func (x *ValidRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ValidRequest to JSON.

func (*ValidRequest) MarshalProtoJSON

func (x *ValidRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ValidRequest message to JSON.

func (*ValidRequest) MarshalProtoText

func (x *ValidRequest) MarshalProtoText() string

func (*ValidRequest) MarshalToSizedBufferVT

func (m *ValidRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidRequest) MarshalToVT

func (m *ValidRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ValidRequest) MarshalVT

func (m *ValidRequest) MarshalVT() (dAtA []byte, err error)

func (*ValidRequest) ProtoMessage

func (*ValidRequest) ProtoMessage()

func (*ValidRequest) Reset

func (x *ValidRequest) Reset()

func (*ValidRequest) SizeVT

func (m *ValidRequest) SizeVT() (n int)

func (*ValidRequest) String

func (x *ValidRequest) String() string

func (*ValidRequest) UnmarshalJSON

func (x *ValidRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ValidRequest from JSON.

func (*ValidRequest) UnmarshalProtoJSON

func (x *ValidRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ValidRequest message from JSON.

func (*ValidRequest) UnmarshalVT

func (m *ValidRequest) UnmarshalVT(dAtA []byte) error

type ValidResponse

type ValidResponse struct {

	// Valid indicates if the iterator points to a valid entry.
	Valid bool `protobuf:"varint,1,opt,name=valid,proto3" json:"valid,omitempty"`
	// contains filtered or unexported fields
}

ValidResponse is the response type for Valid.

func (*ValidResponse) CloneMessageVT

func (m *ValidResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ValidResponse) CloneVT

func (m *ValidResponse) CloneVT() *ValidResponse

func (*ValidResponse) EqualMessageVT

func (this *ValidResponse) EqualMessageVT(thatMsg any) bool

func (*ValidResponse) EqualVT

func (this *ValidResponse) EqualVT(that *ValidResponse) bool

func (*ValidResponse) GetValid

func (x *ValidResponse) GetValid() bool

func (*ValidResponse) MarshalJSON

func (x *ValidResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ValidResponse to JSON.

func (*ValidResponse) MarshalProtoJSON

func (x *ValidResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ValidResponse message to JSON.

func (*ValidResponse) MarshalProtoText

func (x *ValidResponse) MarshalProtoText() string

func (*ValidResponse) MarshalToSizedBufferVT

func (m *ValidResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidResponse) MarshalToVT

func (m *ValidResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ValidResponse) MarshalVT

func (m *ValidResponse) MarshalVT() (dAtA []byte, err error)

func (*ValidResponse) ProtoMessage

func (*ValidResponse) ProtoMessage()

func (*ValidResponse) Reset

func (x *ValidResponse) Reset()

func (*ValidResponse) SizeVT

func (m *ValidResponse) SizeVT() (n int)

func (*ValidResponse) String

func (x *ValidResponse) String() string

func (*ValidResponse) UnmarshalJSON

func (x *ValidResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ValidResponse from JSON.

func (*ValidResponse) UnmarshalProtoJSON

func (x *ValidResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ValidResponse message from JSON.

func (*ValidResponse) UnmarshalVT

func (m *ValidResponse) UnmarshalVT(dAtA []byte) error

type WaitRevRequest

type WaitRevRequest struct {

	// Rev is the minimum revision number to wait for.
	Rev uint64 `protobuf:"varint,1,opt,name=rev,proto3" json:"rev,omitempty"`
	// IgnoreNotFound waits for the object to exist if it doesn't.
	IgnoreNotFound bool `protobuf:"varint,2,opt,name=ignore_not_found,json=ignoreNotFound,proto3" json:"ignoreNotFound,omitempty"`
	// contains filtered or unexported fields
}

WaitRevRequest is the request type for WaitRev.

func (*WaitRevRequest) CloneMessageVT

func (m *WaitRevRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*WaitRevRequest) CloneVT

func (m *WaitRevRequest) CloneVT() *WaitRevRequest

func (*WaitRevRequest) EqualMessageVT

func (this *WaitRevRequest) EqualMessageVT(thatMsg any) bool

func (*WaitRevRequest) EqualVT

func (this *WaitRevRequest) EqualVT(that *WaitRevRequest) bool

func (*WaitRevRequest) GetIgnoreNotFound

func (x *WaitRevRequest) GetIgnoreNotFound() bool

func (*WaitRevRequest) GetRev

func (x *WaitRevRequest) GetRev() uint64

func (*WaitRevRequest) MarshalJSON

func (x *WaitRevRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the WaitRevRequest to JSON.

func (*WaitRevRequest) MarshalProtoJSON

func (x *WaitRevRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the WaitRevRequest message to JSON.

func (*WaitRevRequest) MarshalProtoText

func (x *WaitRevRequest) MarshalProtoText() string

func (*WaitRevRequest) MarshalToSizedBufferVT

func (m *WaitRevRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WaitRevRequest) MarshalToVT

func (m *WaitRevRequest) MarshalToVT(dAtA []byte) (int, error)

func (*WaitRevRequest) MarshalVT

func (m *WaitRevRequest) MarshalVT() (dAtA []byte, err error)

func (*WaitRevRequest) ProtoMessage

func (*WaitRevRequest) ProtoMessage()

func (*WaitRevRequest) Reset

func (x *WaitRevRequest) Reset()

func (*WaitRevRequest) SizeVT

func (m *WaitRevRequest) SizeVT() (n int)

func (*WaitRevRequest) String

func (x *WaitRevRequest) String() string

func (*WaitRevRequest) UnmarshalJSON

func (x *WaitRevRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the WaitRevRequest from JSON.

func (*WaitRevRequest) UnmarshalProtoJSON

func (x *WaitRevRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the WaitRevRequest message from JSON.

func (*WaitRevRequest) UnmarshalVT

func (m *WaitRevRequest) UnmarshalVT(dAtA []byte) error

type WaitRevResponse

type WaitRevResponse struct {

	// Rev is the revision number when the wait condition was satisfied.
	Rev uint64 `protobuf:"varint,1,opt,name=rev,proto3" json:"rev,omitempty"`
	// contains filtered or unexported fields
}

WaitRevResponse is the response type for WaitRev.

func (*WaitRevResponse) CloneMessageVT

func (m *WaitRevResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*WaitRevResponse) CloneVT

func (m *WaitRevResponse) CloneVT() *WaitRevResponse

func (*WaitRevResponse) EqualMessageVT

func (this *WaitRevResponse) EqualMessageVT(thatMsg any) bool

func (*WaitRevResponse) EqualVT

func (this *WaitRevResponse) EqualVT(that *WaitRevResponse) bool

func (*WaitRevResponse) GetRev

func (x *WaitRevResponse) GetRev() uint64

func (*WaitRevResponse) MarshalJSON

func (x *WaitRevResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the WaitRevResponse to JSON.

func (*WaitRevResponse) MarshalProtoJSON

func (x *WaitRevResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the WaitRevResponse message to JSON.

func (*WaitRevResponse) MarshalProtoText

func (x *WaitRevResponse) MarshalProtoText() string

func (*WaitRevResponse) MarshalToSizedBufferVT

func (m *WaitRevResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WaitRevResponse) MarshalToVT

func (m *WaitRevResponse) MarshalToVT(dAtA []byte) (int, error)

func (*WaitRevResponse) MarshalVT

func (m *WaitRevResponse) MarshalVT() (dAtA []byte, err error)

func (*WaitRevResponse) ProtoMessage

func (*WaitRevResponse) ProtoMessage()

func (*WaitRevResponse) Reset

func (x *WaitRevResponse) Reset()

func (*WaitRevResponse) SizeVT

func (m *WaitRevResponse) SizeVT() (n int)

func (*WaitRevResponse) String

func (x *WaitRevResponse) String() string

func (*WaitRevResponse) UnmarshalJSON

func (x *WaitRevResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the WaitRevResponse from JSON.

func (*WaitRevResponse) UnmarshalProtoJSON

func (x *WaitRevResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the WaitRevResponse message from JSON.

func (*WaitRevResponse) UnmarshalVT

func (m *WaitRevResponse) UnmarshalVT(dAtA []byte) error

type WaitSeqnoRequest

type WaitSeqnoRequest struct {

	// Seqno is the minimum sequence number to wait for.
	Seqno uint64 `protobuf:"varint,1,opt,name=seqno,proto3" json:"seqno,omitempty"`
	// contains filtered or unexported fields
}

WaitSeqnoRequest is the request type for WaitSeqno.

func (*WaitSeqnoRequest) CloneMessageVT

func (m *WaitSeqnoRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*WaitSeqnoRequest) CloneVT

func (m *WaitSeqnoRequest) CloneVT() *WaitSeqnoRequest

func (*WaitSeqnoRequest) EqualMessageVT

func (this *WaitSeqnoRequest) EqualMessageVT(thatMsg any) bool

func (*WaitSeqnoRequest) EqualVT

func (this *WaitSeqnoRequest) EqualVT(that *WaitSeqnoRequest) bool

func (*WaitSeqnoRequest) GetSeqno

func (x *WaitSeqnoRequest) GetSeqno() uint64

func (*WaitSeqnoRequest) MarshalJSON

func (x *WaitSeqnoRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the WaitSeqnoRequest to JSON.

func (*WaitSeqnoRequest) MarshalProtoJSON

func (x *WaitSeqnoRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the WaitSeqnoRequest message to JSON.

func (*WaitSeqnoRequest) MarshalProtoText

func (x *WaitSeqnoRequest) MarshalProtoText() string

func (*WaitSeqnoRequest) MarshalToSizedBufferVT

func (m *WaitSeqnoRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WaitSeqnoRequest) MarshalToVT

func (m *WaitSeqnoRequest) MarshalToVT(dAtA []byte) (int, error)

func (*WaitSeqnoRequest) MarshalVT

func (m *WaitSeqnoRequest) MarshalVT() (dAtA []byte, err error)

func (*WaitSeqnoRequest) ProtoMessage

func (*WaitSeqnoRequest) ProtoMessage()

func (*WaitSeqnoRequest) Reset

func (x *WaitSeqnoRequest) Reset()

func (*WaitSeqnoRequest) SizeVT

func (m *WaitSeqnoRequest) SizeVT() (n int)

func (*WaitSeqnoRequest) String

func (x *WaitSeqnoRequest) String() string

func (*WaitSeqnoRequest) UnmarshalJSON

func (x *WaitSeqnoRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the WaitSeqnoRequest from JSON.

func (*WaitSeqnoRequest) UnmarshalProtoJSON

func (x *WaitSeqnoRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the WaitSeqnoRequest message from JSON.

func (*WaitSeqnoRequest) UnmarshalVT

func (m *WaitSeqnoRequest) UnmarshalVT(dAtA []byte) error

type WaitSeqnoResponse

type WaitSeqnoResponse struct {

	// Seqno is the sequence number when the wait condition was satisfied.
	Seqno uint64 `protobuf:"varint,1,opt,name=seqno,proto3" json:"seqno,omitempty"`
	// contains filtered or unexported fields
}

WaitSeqnoResponse is the response type for WaitSeqno.

func (*WaitSeqnoResponse) CloneMessageVT

func (m *WaitSeqnoResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*WaitSeqnoResponse) CloneVT

func (m *WaitSeqnoResponse) CloneVT() *WaitSeqnoResponse

func (*WaitSeqnoResponse) EqualMessageVT

func (this *WaitSeqnoResponse) EqualMessageVT(thatMsg any) bool

func (*WaitSeqnoResponse) EqualVT

func (this *WaitSeqnoResponse) EqualVT(that *WaitSeqnoResponse) bool

func (*WaitSeqnoResponse) GetSeqno

func (x *WaitSeqnoResponse) GetSeqno() uint64

func (*WaitSeqnoResponse) MarshalJSON

func (x *WaitSeqnoResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the WaitSeqnoResponse to JSON.

func (*WaitSeqnoResponse) MarshalProtoJSON

func (x *WaitSeqnoResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the WaitSeqnoResponse message to JSON.

func (*WaitSeqnoResponse) MarshalProtoText

func (x *WaitSeqnoResponse) MarshalProtoText() string

func (*WaitSeqnoResponse) MarshalToSizedBufferVT

func (m *WaitSeqnoResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WaitSeqnoResponse) MarshalToVT

func (m *WaitSeqnoResponse) MarshalToVT(dAtA []byte) (int, error)

func (*WaitSeqnoResponse) MarshalVT

func (m *WaitSeqnoResponse) MarshalVT() (dAtA []byte, err error)

func (*WaitSeqnoResponse) ProtoMessage

func (*WaitSeqnoResponse) ProtoMessage()

func (*WaitSeqnoResponse) Reset

func (x *WaitSeqnoResponse) Reset()

func (*WaitSeqnoResponse) SizeVT

func (m *WaitSeqnoResponse) SizeVT() (n int)

func (*WaitSeqnoResponse) String

func (x *WaitSeqnoResponse) String() string

func (*WaitSeqnoResponse) UnmarshalJSON

func (x *WaitSeqnoResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the WaitSeqnoResponse from JSON.

func (*WaitSeqnoResponse) UnmarshalProtoJSON

func (x *WaitSeqnoResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the WaitSeqnoResponse message from JSON.

func (*WaitSeqnoResponse) UnmarshalVT

func (m *WaitSeqnoResponse) UnmarshalVT(dAtA []byte) error

type WatchWorldRootSnapshotsRequest added in v0.51.7

type WatchWorldRootSnapshotsRequest struct {
	// contains filtered or unexported fields
}

WatchWorldRootSnapshotsRequest is the request type for WatchWorldRootSnapshots.

func (*WatchWorldRootSnapshotsRequest) CloneMessageVT added in v0.51.7

func (*WatchWorldRootSnapshotsRequest) CloneVT added in v0.51.7

func (*WatchWorldRootSnapshotsRequest) EqualMessageVT added in v0.51.7

func (this *WatchWorldRootSnapshotsRequest) EqualMessageVT(thatMsg any) bool

func (*WatchWorldRootSnapshotsRequest) EqualVT added in v0.51.7

func (*WatchWorldRootSnapshotsRequest) MarshalJSON added in v0.51.7

func (x *WatchWorldRootSnapshotsRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the WatchWorldRootSnapshotsRequest to JSON.

func (*WatchWorldRootSnapshotsRequest) MarshalProtoJSON added in v0.51.7

func (x *WatchWorldRootSnapshotsRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the WatchWorldRootSnapshotsRequest message to JSON.

func (*WatchWorldRootSnapshotsRequest) MarshalProtoText added in v0.51.7

func (x *WatchWorldRootSnapshotsRequest) MarshalProtoText() string

func (*WatchWorldRootSnapshotsRequest) MarshalToSizedBufferVT added in v0.51.7

func (m *WatchWorldRootSnapshotsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WatchWorldRootSnapshotsRequest) MarshalToVT added in v0.51.7

func (m *WatchWorldRootSnapshotsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*WatchWorldRootSnapshotsRequest) MarshalVT added in v0.51.7

func (m *WatchWorldRootSnapshotsRequest) MarshalVT() (dAtA []byte, err error)

func (*WatchWorldRootSnapshotsRequest) ProtoMessage added in v0.51.7

func (*WatchWorldRootSnapshotsRequest) ProtoMessage()

func (*WatchWorldRootSnapshotsRequest) Reset added in v0.51.7

func (x *WatchWorldRootSnapshotsRequest) Reset()

func (*WatchWorldRootSnapshotsRequest) SizeVT added in v0.51.7

func (m *WatchWorldRootSnapshotsRequest) SizeVT() (n int)

func (*WatchWorldRootSnapshotsRequest) String added in v0.51.7

func (*WatchWorldRootSnapshotsRequest) UnmarshalJSON added in v0.51.7

func (x *WatchWorldRootSnapshotsRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the WatchWorldRootSnapshotsRequest from JSON.

func (*WatchWorldRootSnapshotsRequest) UnmarshalProtoJSON added in v0.51.7

func (x *WatchWorldRootSnapshotsRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the WatchWorldRootSnapshotsRequest message from JSON.

func (*WatchWorldRootSnapshotsRequest) UnmarshalVT added in v0.51.7

func (m *WatchWorldRootSnapshotsRequest) UnmarshalVT(dAtA []byte) error

type WatchWorldStateRequest

type WatchWorldStateRequest struct {
	// contains filtered or unexported fields
}

WatchWorldStateRequest is the request type for WatchWorldState.

func (*WatchWorldStateRequest) CloneMessageVT

func (*WatchWorldStateRequest) CloneVT

func (*WatchWorldStateRequest) EqualMessageVT

func (this *WatchWorldStateRequest) EqualMessageVT(thatMsg any) bool

func (*WatchWorldStateRequest) EqualVT

func (this *WatchWorldStateRequest) EqualVT(that *WatchWorldStateRequest) bool

func (*WatchWorldStateRequest) MarshalJSON

func (x *WatchWorldStateRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the WatchWorldStateRequest to JSON.

func (*WatchWorldStateRequest) MarshalProtoJSON

func (x *WatchWorldStateRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the WatchWorldStateRequest message to JSON.

func (*WatchWorldStateRequest) MarshalProtoText

func (x *WatchWorldStateRequest) MarshalProtoText() string

func (*WatchWorldStateRequest) MarshalToSizedBufferVT

func (m *WatchWorldStateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WatchWorldStateRequest) MarshalToVT

func (m *WatchWorldStateRequest) MarshalToVT(dAtA []byte) (int, error)

func (*WatchWorldStateRequest) MarshalVT

func (m *WatchWorldStateRequest) MarshalVT() (dAtA []byte, err error)

func (*WatchWorldStateRequest) ProtoMessage

func (*WatchWorldStateRequest) ProtoMessage()

func (*WatchWorldStateRequest) Reset

func (x *WatchWorldStateRequest) Reset()

func (*WatchWorldStateRequest) SizeVT

func (m *WatchWorldStateRequest) SizeVT() (n int)

func (*WatchWorldStateRequest) String

func (x *WatchWorldStateRequest) String() string

func (*WatchWorldStateRequest) UnmarshalJSON

func (x *WatchWorldStateRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the WatchWorldStateRequest from JSON.

func (*WatchWorldStateRequest) UnmarshalProtoJSON

func (x *WatchWorldStateRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the WatchWorldStateRequest message from JSON.

func (*WatchWorldStateRequest) UnmarshalVT

func (m *WatchWorldStateRequest) UnmarshalVT(dAtA []byte) error

type WatchWorldStateResponse

type WatchWorldStateResponse struct {

	// ResourceId is the ID of the tracked WorldState resource.
	// This changes each time tracked resources are modified.
	ResourceId uint32 `protobuf:"varint,1,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// contains filtered or unexported fields
}

WatchWorldStateResponse is the response type for WatchWorldState.

func (*WatchWorldStateResponse) CloneMessageVT

func (*WatchWorldStateResponse) CloneVT

func (*WatchWorldStateResponse) EqualMessageVT

func (this *WatchWorldStateResponse) EqualMessageVT(thatMsg any) bool

func (*WatchWorldStateResponse) EqualVT

func (*WatchWorldStateResponse) GetResourceId

func (x *WatchWorldStateResponse) GetResourceId() uint32

func (*WatchWorldStateResponse) MarshalJSON

func (x *WatchWorldStateResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the WatchWorldStateResponse to JSON.

func (*WatchWorldStateResponse) MarshalProtoJSON

func (x *WatchWorldStateResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the WatchWorldStateResponse message to JSON.

func (*WatchWorldStateResponse) MarshalProtoText

func (x *WatchWorldStateResponse) MarshalProtoText() string

func (*WatchWorldStateResponse) MarshalToSizedBufferVT

func (m *WatchWorldStateResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WatchWorldStateResponse) MarshalToVT

func (m *WatchWorldStateResponse) MarshalToVT(dAtA []byte) (int, error)

func (*WatchWorldStateResponse) MarshalVT

func (m *WatchWorldStateResponse) MarshalVT() (dAtA []byte, err error)

func (*WatchWorldStateResponse) ProtoMessage

func (*WatchWorldStateResponse) ProtoMessage()

func (*WatchWorldStateResponse) Reset

func (x *WatchWorldStateResponse) Reset()

func (*WatchWorldStateResponse) SizeVT

func (m *WatchWorldStateResponse) SizeVT() (n int)

func (*WatchWorldStateResponse) String

func (x *WatchWorldStateResponse) String() string

func (*WatchWorldStateResponse) UnmarshalJSON

func (x *WatchWorldStateResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the WatchWorldStateResponse from JSON.

func (*WatchWorldStateResponse) UnmarshalProtoJSON

func (x *WatchWorldStateResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the WatchWorldStateResponse message from JSON.

func (*WatchWorldStateResponse) UnmarshalVT

func (m *WatchWorldStateResponse) UnmarshalVT(dAtA []byte) error

type WorldRootSnapshot added in v0.51.7

type WorldRootSnapshot struct {

	// RootRef is the committed World root reference.
	RootRef *bucket.ObjectRef `protobuf:"bytes,1,opt,name=root_ref,json=rootRef,proto3" json:"rootRef,omitempty"`
	// Seqno is the world sequence number observed with RootRef.
	Seqno uint64 `protobuf:"varint,2,opt,name=seqno,proto3" json:"seqno,omitempty"`
	// EngineInfo is the Engine metadata associated with RootRef.
	EngineInfo *EngineInfo `protobuf:"bytes,3,opt,name=engine_info,json=engineInfo,proto3" json:"engineInfo,omitempty"`
	// StorageVolumeId is the local storage volume hint, when visible to the Engine.
	StorageVolumeId string `protobuf:"bytes,4,opt,name=storage_volume_id,json=storageVolumeId,proto3" json:"storageVolumeId,omitempty"`
	// contains filtered or unexported fields
}

WorldRootSnapshot identifies one committed Engine root.

func (*WorldRootSnapshot) CloneMessageVT added in v0.51.7

func (m *WorldRootSnapshot) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*WorldRootSnapshot) CloneVT added in v0.51.7

func (m *WorldRootSnapshot) CloneVT() *WorldRootSnapshot

func (*WorldRootSnapshot) EqualMessageVT added in v0.51.7

func (this *WorldRootSnapshot) EqualMessageVT(thatMsg any) bool

func (*WorldRootSnapshot) EqualVT added in v0.51.7

func (this *WorldRootSnapshot) EqualVT(that *WorldRootSnapshot) bool

func (*WorldRootSnapshot) GetEngineInfo added in v0.51.7

func (x *WorldRootSnapshot) GetEngineInfo() *EngineInfo

func (*WorldRootSnapshot) GetRootRef added in v0.51.7

func (x *WorldRootSnapshot) GetRootRef() *bucket.ObjectRef

func (*WorldRootSnapshot) GetSeqno added in v0.51.7

func (x *WorldRootSnapshot) GetSeqno() uint64

func (*WorldRootSnapshot) GetStorageVolumeId added in v0.51.7

func (x *WorldRootSnapshot) GetStorageVolumeId() string

func (*WorldRootSnapshot) MarshalJSON added in v0.51.7

func (x *WorldRootSnapshot) MarshalJSON() ([]byte, error)

MarshalJSON marshals the WorldRootSnapshot to JSON.

func (*WorldRootSnapshot) MarshalProtoJSON added in v0.51.7

func (x *WorldRootSnapshot) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the WorldRootSnapshot message to JSON.

func (*WorldRootSnapshot) MarshalProtoText added in v0.51.7

func (x *WorldRootSnapshot) MarshalProtoText() string

func (*WorldRootSnapshot) MarshalToSizedBufferVT added in v0.51.7

func (m *WorldRootSnapshot) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WorldRootSnapshot) MarshalToVT added in v0.51.7

func (m *WorldRootSnapshot) MarshalToVT(dAtA []byte) (int, error)

func (*WorldRootSnapshot) MarshalVT added in v0.51.7

func (m *WorldRootSnapshot) MarshalVT() (dAtA []byte, err error)

func (*WorldRootSnapshot) ProtoMessage added in v0.51.7

func (*WorldRootSnapshot) ProtoMessage()

func (*WorldRootSnapshot) Reset added in v0.51.7

func (x *WorldRootSnapshot) Reset()

func (*WorldRootSnapshot) SizeVT added in v0.51.7

func (m *WorldRootSnapshot) SizeVT() (n int)

func (*WorldRootSnapshot) String added in v0.51.7

func (x *WorldRootSnapshot) String() string

func (*WorldRootSnapshot) UnmarshalJSON added in v0.51.7

func (x *WorldRootSnapshot) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the WorldRootSnapshot from JSON.

func (*WorldRootSnapshot) UnmarshalProtoJSON added in v0.51.7

func (x *WorldRootSnapshot) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the WorldRootSnapshot message from JSON.

func (*WorldRootSnapshot) UnmarshalVT added in v0.51.7

func (m *WorldRootSnapshot) UnmarshalVT(dAtA []byte) error

type WorldState

type WorldState struct {
	// contains filtered or unexported fields
}

WorldState represents the full state read/write interface to the world. WorldState implements all world state operations.

In the Go implementation (hydra/world/world-state.go), WorldState provides: - GetReadOnly() bool - WorldStorage: BuildStorageCursor, AccessWorldState - WorldStateObject: CreateObject, GetObject, IterateObjects, RenameObject, DeleteObject - WorldStateGraph: SetGraphQuad, DeleteGraphQuad, LookupGraphQuads, DeleteGraphObject - WorldStateOp: ApplyWorldOp - WorldWaitSeqno: GetSeqno, WaitSeqno

This Go SDK implementation wraps WorldStateResourceService.

func NewWorldState

func NewWorldState(client *resource_client.Client, ref resource_client.ResourceRef, readOnly bool) (*WorldState, error)

NewWorldState creates a new WorldState resource wrapper.

func (*WorldState) AccessWorldState

func (ws *WorldState) AccessWorldState(ctx context.Context, ref *bucket.ObjectRef) (uint32, error)

AccessWorldState builds a bucket lookup cursor with an optional ref. If the ref is empty, returns a cursor pointing to the root world state. Returns the resource ID of the created cursor.

func (*WorldState) ApplyWorldOp

func (ws *WorldState) ApplyWorldOp(ctx context.Context, opTypeID string, opData []byte, opSender string) (uint64, bool, error)

ApplyWorldOp applies a batch operation at the world level. The handling of the operation is operation-type specific. Returns (seqno, sysErr, err). If nil is returned for the error, implies success. If sysErr is set, the error is treated as a transient system error.

func (*WorldState) BuildStorageCursor

func (ws *WorldState) BuildStorageCursor(ctx context.Context) (uint32, error)

BuildStorageCursor builds a cursor to the world storage with an empty ref. The cursor should be released independently of the Tx. Returns the resource ID of the created cursor.

func (*WorldState) CreateObject

func (ws *WorldState) CreateObject(ctx context.Context, key string, rootRef *bucket.ObjectRef) (world.ObjectState, error)

CreateObject creates a new object in the world with the specified key and initial data. Returns ErrObjectExists if the object already exists. Appends a OBJECT_SET change to the changelog. Returns an ObjectState resource for the created object.

func (*WorldState) DeleteGraphObject

func (ws *WorldState) DeleteGraphObject(ctx context.Context, objectKey string) error

DeleteGraphObject removes all graph quads that reference the specified object key. Note: objectKey should be the object key, NOT the object key <iri> format.

func (*WorldState) DeleteGraphQuad

func (ws *WorldState) DeleteGraphQuad(ctx context.Context, q world.GraphQuad) error

DeleteGraphQuad removes a specific quad from the graph store. Note: if quad did not exist, returns nil.

func (*WorldState) DeleteObject

func (ws *WorldState) DeleteObject(ctx context.Context, key string) (bool, error)

DeleteObject removes an object and all associated graph quads from the world. Calls DeleteGraphObject internally. Returns (deleted, error). deleted=false if not found.

func (*WorldState) GetObject

func (ws *WorldState) GetObject(ctx context.Context, key string) (world.ObjectState, bool, error)

GetObject retrieves an object from the world by its key. Returns (object, found, error).

func (*WorldState) GetObjectMetadataBatch added in v0.51.6

func (ws *WorldState) GetObjectMetadataBatch(ctx context.Context, keys []string) ([]*world_types.ObjectMetadata, error)

GetObjectMetadataBatch returns graph metadata for object keys.

func (*WorldState) GetObjectRootRefsBatch added in v0.51.7

func (ws *WorldState) GetObjectRootRefsBatch(ctx context.Context, keys []string) ([]*world.ObjectRootRef, error)

GetObjectRootRefsBatch returns root references for object keys.

func (*WorldState) GetReadOnly

func (ws *WorldState) GetReadOnly() bool

GetReadOnly returns if the transaction is read-only. Returns stored metadata without RPC call.

func (*WorldState) GetResourceRef

func (ws *WorldState) GetResourceRef() resource_client.ResourceRef

GetResourceRef returns the resource reference.

func (*WorldState) GetSeqno

func (ws *WorldState) GetSeqno(ctx context.Context) (uint64, error)

GetSeqno returns the current sequence number of the world state. This is also the sequence number of the most recent change. Initializes at 0 for initial world state.

func (*WorldState) IterateObjects

func (ws *WorldState) IterateObjects(ctx context.Context, prefix string, reversed bool) (uint32, error)

IterateObjects returns an iterator with the given object key prefix. The prefix is NOT clipped from the output keys. Keys are returned in sorted order. Returns the resource ID of the created iterator.

func (*WorldState) ListGraphEdgeBuckets added in v0.51.7

func (ws *WorldState) ListGraphEdgeBuckets(ctx context.Context, query *world.GraphEdgeBucketQuery) ([]*world.GraphEdgeBucket, error)

ListGraphEdgeBuckets lists grouped inbound/outbound graph edge buckets.

func (*WorldState) ListObjectsWithType

func (ws *WorldState) ListObjectsWithType(ctx context.Context, typeID string) ([]string, error)

ListObjectsWithType lists object keys with the given type identifier.

func (*WorldState) LookupGraphQuads

func (ws *WorldState) LookupGraphQuads(ctx context.Context, filter world.GraphQuad, limit uint32) ([]world.GraphQuad, error)

LookupGraphQuads searches for graph quads matching the specified filter criteria. If the filter fields are empty, matches any for that field. If not found, returns empty list. If limit is set, stops after finding that number of matching quads.

func (*WorldState) LookupGraphQuadsBatch added in v0.51.6

func (ws *WorldState) LookupGraphQuadsBatch(ctx context.Context, filters []world.GraphQuad, limitPerFilter uint32) ([][]world.GraphQuad, error)

LookupGraphQuadsBatch searches for graph quads using bounded indexed filters.

func (*WorldState) QueryGraphPath added in v0.51.6

func (ws *WorldState) QueryGraphPath(ctx context.Context, query *world.GraphPathQuery) (*world.GraphPathQueryResult, error)

QueryGraphPath executes a bounded server-side graph path query.

func (*WorldState) Release

func (ws *WorldState) Release()

Release releases the resource reference.

func (*WorldState) RenameObject

func (ws *WorldState) RenameObject(ctx context.Context, oldKey, newKey string, descendants bool) (world.ObjectState, error)

RenameObject renames an object key and associated graph quads.

func (*WorldState) SetGraphQuad

func (ws *WorldState) SetGraphQuad(ctx context.Context, q world.GraphQuad) error

SetGraphQuad adds or updates a quad in the graph store. Subject: must be an existing object IRI: <object-key> Predicate: a predicate string, e.g. IRI: <ref> Object: an existing object IRI: <object-key> If already exists, returns nil.

func (*WorldState) WaitSeqno

func (ws *WorldState) WaitSeqno(ctx context.Context, seqno uint64) (uint64, error)

WaitSeqno waits for the world state sequence number to reach or exceed the specified value. Returns the seqno when the condition is reached. If seqno == 0, this might return immediately unconditionally.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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