Help us shape the future of Go! Take the 2026 Go Developer Survey

sobject_world_engine

package
v0.57.21 Latest Latest
Warning

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

 Go to latest Published: Oct 2, 2026 License: Apache-2.0 Imports: 48 Imported by: 0

Documentation

Index

Constants

View Source 
const ConfigID = ControllerID

ConfigID is the string used to identify this config object.

View Source 
const ControllerID = "sobject/world/engine"

ControllerID identifies the block graph engine controller.

View Source 
const LocalProofKeyPrefix = "world-publication-v3/"

LocalProofKeyPrefix prefixes the completion proofs RetainWorld keeps in the caller's local state store when the block store cannot hold them itself.

Variables

View Source 
var (
	SpaceWorldFinalizationStatus_name = map[int32]string{
		0: "SPACE_WORLD_FINALIZATION_STATUS_UNKNOWN",
		1: "SPACE_WORLD_FINALIZATION_STATUS_ACCEPTED",
		2: "SPACE_WORLD_FINALIZATION_STATUS_REJECTED",
		3: "SPACE_WORLD_FINALIZATION_STATUS_STALE_BASE",
		4: "SPACE_WORLD_FINALIZATION_STATUS_MISSING_BLOCK",
		5: "SPACE_WORLD_FINALIZATION_STATUS_LOST_AUTHORITY",
	}
	SpaceWorldFinalizationStatus_value = map[string]int32{
		"SPACE_WORLD_FINALIZATION_STATUS_UNKNOWN":        0,
		"SPACE_WORLD_FINALIZATION_STATUS_ACCEPTED":       1,
		"SPACE_WORLD_FINALIZATION_STATUS_REJECTED":       2,
		"SPACE_WORLD_FINALIZATION_STATUS_STALE_BASE":     3,
		"SPACE_WORLD_FINALIZATION_STATUS_MISSING_BLOCK":  4,
		"SPACE_WORLD_FINALIZATION_STATUS_LOST_AUTHORITY": 5,
	}
)

Enum value maps for SpaceWorldFinalizationStatus.

View Source 
var Version = controller.MustParseVersion("0.0.1")

Version is the controller version.

Functions

func NewSOWorldOpBlock 

func NewSOWorldOpBlock() block.Block

NewSOWorldOpBlock constructs a new SOWorldOp block.

func OpenReadCheckpoint 

func OpenReadCheckpoint(
	ctx context.Context,
	le *logrus.Entry,
	b bus.Bus,
	so sobject.SharedObject,
	snapshot sobject.SharedObjectStateSnapshot,
) (world.Engine, func(), error)

OpenReadCheckpoint serves one retained World without starting a live body controller. Release closes the cursor after all readers have released their transactions.

func RetainWorld 

func RetainWorld(ctx context.Context, so sobject.SharedObject, head *bucket.ObjectRef, local kvtx.Store, visited func(*block.BlockRef, []byte)) error

RetainWorld copies a complete World graph into its SharedObject's block store. It follows the refs the store reports for each block, so it needs no block types. Completion proofs skip immutable subtrees only after their ownership writes are durable. The caller owns the proof store and serializes calls for it. visited observes newly traversed blocks; cached complete subtrees are omitted.

Types

type AdvanceStorageGenerationOp 

type AdvanceStorageGenerationOp struct {

	// StorageGeneration is the storage generation the operation advances from.
	StorageGeneration uint64 `protobuf:"varint,1,opt,name=storage_generation,json=storageGeneration,proto3" json:"storageGeneration,omitempty"`
	// contains filtered or unexported fields
}

AdvanceStorageGenerationOp advances the storage generation of the World. Only the validator submits it, after listing the storage bucket and before dropping unreachable blocks from the listed packs.

func (*AdvanceStorageGenerationOp) CloneMessageVT 

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

func (*AdvanceStorageGenerationOp) CloneVT 

func (m *AdvanceStorageGenerationOp) CloneVT() *AdvanceStorageGenerationOp

func (*AdvanceStorageGenerationOp) EqualMessageVT 

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

func (*AdvanceStorageGenerationOp) EqualVT 

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

func (*AdvanceStorageGenerationOp) GetStorageGeneration 

func (x *AdvanceStorageGenerationOp) GetStorageGeneration() uint64

func (*AdvanceStorageGenerationOp) MarshalJSON 

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

MarshalJSON marshals the AdvanceStorageGenerationOp to JSON.

func (*AdvanceStorageGenerationOp) MarshalProtoJSON 

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

MarshalProtoJSON marshals the AdvanceStorageGenerationOp message to JSON.

func (*AdvanceStorageGenerationOp) MarshalProtoText 

func (x *AdvanceStorageGenerationOp) MarshalProtoText() string

func (*AdvanceStorageGenerationOp) MarshalToSizedBufferVT 

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

func (*AdvanceStorageGenerationOp) MarshalToVT 

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

func (*AdvanceStorageGenerationOp) MarshalVT 

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

func (*AdvanceStorageGenerationOp) ProtoMessage 

func (*AdvanceStorageGenerationOp) ProtoMessage()

func (*AdvanceStorageGenerationOp) Reset 

func (x *AdvanceStorageGenerationOp) Reset()

func (*AdvanceStorageGenerationOp) SizeVT 

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

func (*AdvanceStorageGenerationOp) String 

func (x *AdvanceStorageGenerationOp) String() string

func (*AdvanceStorageGenerationOp) UnmarshalJSON 

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

UnmarshalJSON unmarshals the AdvanceStorageGenerationOp from JSON.

func (*AdvanceStorageGenerationOp) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the AdvanceStorageGenerationOp message from JSON.

func (*AdvanceStorageGenerationOp) UnmarshalVT 

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

type ApplyTxOp 

type ApplyTxOp struct {

	// tx is the tx or tx batch to apply
	Tx *tx.Tx `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"`
	// StorageGeneration is the storage generation the transaction was built on.
	StorageGeneration uint64 `protobuf:"varint,2,opt,name=storage_generation,json=storageGeneration,proto3" json:"storageGeneration,omitempty"`
	// contains filtered or unexported fields
}

ApplyTxOp is the operation to apply a world transaction.

func (*ApplyTxOp) CloneMessageVT 

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

func (*ApplyTxOp) CloneVT 

func (m *ApplyTxOp) CloneVT() *ApplyTxOp

func (*ApplyTxOp) EqualMessageVT 

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

func (*ApplyTxOp) EqualVT 

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

func (*ApplyTxOp) GetStorageGeneration 

func (x *ApplyTxOp) GetStorageGeneration() uint64

func (*ApplyTxOp) GetTx 

func (x *ApplyTxOp) GetTx() *tx.Tx

func (*ApplyTxOp) MarshalJSON 

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

MarshalJSON marshals the ApplyTxOp to JSON.

func (*ApplyTxOp) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ApplyTxOp message to JSON.

func (*ApplyTxOp) MarshalProtoText 

func (x *ApplyTxOp) MarshalProtoText() string

func (*ApplyTxOp) MarshalToSizedBufferVT 

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

func (*ApplyTxOp) MarshalToVT 

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

func (*ApplyTxOp) MarshalVT 

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

func (*ApplyTxOp) ProtoMessage 

func (*ApplyTxOp) ProtoMessage()

func (*ApplyTxOp) Reset 

func (x *ApplyTxOp) Reset()

func (*ApplyTxOp) SizeVT 

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

func (*ApplyTxOp) String 

func (x *ApplyTxOp) String() string

func (*ApplyTxOp) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ApplyTxOp from JSON.

func (*ApplyTxOp) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ApplyTxOp message from JSON.

func (*ApplyTxOp) UnmarshalVT 

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

type Config 

type Config struct {

	// EngineId is the identifier used to look up the world on the bus.
	// Used to match & resolve WorldEngine directives.
	// If empty, LookupWorldEngine will not be processed.
	EngineId string `protobuf:"bytes,1,opt,name=engine_id,json=engineId,proto3" json:"engineId,omitempty"`
	// Ref is the shared object ref.
	Ref *sobject.SharedObjectRef `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"`
	// InitWorldOp overrides the contents of the InitWorldOp when initializing the world.
	// Only used if the shared object is empty.
	InitWorldOp *InitWorldOp `protobuf:"bytes,3,opt,name=init_world_op,json=initWorldOp,proto3" json:"initWorldOp,omitempty"`
	// DisableLookup disables looking up anything on the bus via directives.
	// Implies both DisableApplyWorldOp and DisableApplyObjectOp.
	DisableLookup bool `protobuf:"varint,4,opt,name=disable_lookup,json=disableLookup,proto3" json:"disableLookup,omitempty"`
	// DisableApplyWorldOp disables calling the ApplyWorldOp directive.
	DisableApplyWorldOp bool `protobuf:"varint,5,opt,name=disable_apply_world_op,json=disableApplyWorldOp,proto3" json:"disableApplyWorldOp,omitempty"`
	// DisableApplyObjectOp disables calling the ApplyObjectOp directive.
	DisableApplyObjectOp bool `protobuf:"varint,6,opt,name=disable_apply_object_op,json=disableApplyObjectOp,proto3" json:"disableApplyObjectOp,omitempty"`
	// Verbose logs all operation results as debug messages.
	Verbose bool `protobuf:"varint,7,opt,name=verbose,proto3" json:"verbose,omitempty"`
	// ProcessOpsBackoff is the backoff for processing ops as a validator.
	// Defaults to reasonable defaults if unset.
	ProcessOpsBackoff *backoff.Backoff `protobuf:"bytes,8,opt,name=process_ops_backoff,json=processOpsBackoff,proto3" json:"processOpsBackoff,omitempty"`
	// contains filtered or unexported fields
}

Config configures a World Graph engine bound to a block graph and controlled by a Shared Object. Uses MountSharedObject to mount and access the shared object and block store. Stores the HEAD reference in the Shared Object.

func NewConfig 

func NewConfig(engineID string, ref *sobject.SharedObjectRef) *Config

NewConfig constructs a new block world engine config.

func (*Config) CloneMessageVT 

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

func (*Config) CloneVT 

func (m *Config) CloneVT() *Config

func (*Config) EqualMessageVT 

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

func (*Config) EqualVT 

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

func (*Config) EqualsConfig 

func (c *Config) EqualsConfig(other config.Config) bool

EqualsConfig checks if the config is equal to another.

func (*Config) GetConfigID 

func (c *Config) GetConfigID() string

GetConfigID returns the unique string for this configuration type. This string is stored with the encoded config.

func (*Config) GetDisableApplyObjectOp 

func (x *Config) GetDisableApplyObjectOp() bool

func (*Config) GetDisableApplyWorldOp 

func (x *Config) GetDisableApplyWorldOp() bool

func (*Config) GetDisableLookup 

func (x *Config) GetDisableLookup() bool

func (*Config) GetEngineId 

func (x *Config) GetEngineId() string

func (*Config) GetInitWorldOp 

func (x *Config) GetInitWorldOp() *InitWorldOp

func (*Config) GetProcessOpsBackoff 

func (x *Config) GetProcessOpsBackoff() *backoff.Backoff

func (*Config) GetRef 

func (x *Config) GetRef() *sobject.SharedObjectRef

func (*Config) GetVerbose 

func (x *Config) GetVerbose() bool

func (*Config) MarshalJSON 

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

MarshalJSON marshals the Config to JSON.

func (*Config) MarshalProtoJSON 

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

MarshalProtoJSON marshals the Config message to JSON.

func (*Config) MarshalProtoText 

func (x *Config) MarshalProtoText() string

func (*Config) MarshalToSizedBufferVT 

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

func (*Config) MarshalToVT 

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

func (*Config) MarshalVT 

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

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) Reset 

func (x *Config) Reset()

func (*Config) SizeVT 

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

func (*Config) String 

func (x *Config) String() string

func (*Config) UnmarshalJSON 

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

UnmarshalJSON unmarshals the Config from JSON.

func (*Config) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the Config message from JSON.

func (*Config) UnmarshalVT 

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

func (*Config) Validate 

func (c *Config) Validate() error

Validate validates the configuration. This is a cursory validation to see if the values "look correct."

type Controller 

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

Controller drives a World Graph engine bound to a block graph and controlled by a Shared Object. Uses MountSharedObject to mount and access the shared object and block store. Stores the HEAD reference in the Shared Object.

func NewController 

func NewController(
	le *logrus.Entry,
	bus bus.Bus,
	conf *Config,
	sfs *block_transform.StepFactorySet,
) (*Controller, error)

NewController constructs a new World Engine controller.

func StartEngineWithConfig 

func StartEngineWithConfig(
	ctx context.Context,
	b bus.Bus,
	conf *Config,
	rel func(),
) (*Controller, directive.Instance, directive.Reference, error)

StartEngineWithConfig starts the sobject world engine with a config and waits for the controller to run. A failed execution is transient, such as a predecessor engine still holding the write lease or World blocks still in transit, so the wait continues through the loader's retries until ctx ends. rel is called when the controller stops running. Release the reference to stop the controller.

func (*Controller) Close 

func (c *Controller) Close() error

Close releases any resources used by the controller. Error indicates any issue encountered releasing.

func (*Controller) Execute 

func (c *Controller) Execute(ctx context.Context) error

Execute executes the engine controller. Returning nil ends execution. Returning an error triggers a retry with backoff.

func (*Controller) GetControllerInfo 

func (c *Controller) GetControllerInfo() *controller.Info

GetControllerInfo returns information about the controller.

func (*Controller) GetWorldEngine 

func (c *Controller) GetWorldEngine(ctx context.Context) (Engine, error)

GetWorldEngine waits for the engine to be built. Returns the Engine managed by the controller.

func (*Controller) HandleDirective 

func (c *Controller) HandleDirective(ctx context.Context, di directive.Instance) ([]directive.Resolver, error)

HandleDirective asks if the handler can resolve the directive.

func (*Controller) SetStaticLookupOp added in v0.52.0 

func (c *Controller) SetStaticLookupOp(lookupOp world.LookupOp)

SetStaticLookupOp sets an in-process world operation lookup chain for this engine. It is composed before the bus lookup, so domain-owned built-ins do not depend on an outer controller lifecycle.

func (*Controller) WaitWorldEngineReplaced 

func (c *Controller) WaitWorldEngineReplaced(ctx context.Context, eng Engine) error

WaitWorldEngineReplaced waits until eng is no longer the published engine. The controller replaces its engine when read access is lost and regained.

type Engine 

type Engine = world.Engine

Engine is the world engine type.

type Factory 

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

Factory constructs a world engine controller

func NewFactory 

func NewFactory(bus bus.Bus) *Factory

NewFactory builds a world block engine factory.

func (*Factory) Construct 

func (t *Factory) Construct(
	ctx context.Context,
	conf config.Config,
	opts controller.ConstructOpts,
) (controller.Controller, error)

Construct constructs the associated controller given configuration.

func (*Factory) ConstructConfig 

func (t *Factory) ConstructConfig() config.Config

ConstructConfig constructs an instance of the controller configuration.

func (*Factory) GetConfigID 

func (t *Factory) GetConfigID() string

GetConfigID returns the configuration ID for the controller.

func (*Factory) GetControllerID 

func (t *Factory) GetControllerID() string

GetControllerID returns the unique ID for the controller.

func (*Factory) GetVersion 

func (t *Factory) GetVersion() controller.Version

GetVersion returns the version of this controller.

type InitWorldOp 

type InitWorldOp struct {

	// LastChangeDisable indicates the changelog is disabled for this world.
	// If set, last_change will be empty, except for the seqno field.
	// NOTE: the seqno field will not be empty on LastChange.
	LastChangeDisable bool `protobuf:"varint,1,opt,name=last_change_disable,json=lastChangeDisable,proto3" json:"lastChangeDisable,omitempty"`
	// TransformConf is the transform configuration to use for the world.
	// If unset, a default transform config with a random key will be generated.
	TransformConf *transform.Config `protobuf:"bytes,2,opt,name=transform_conf,json=transformConf,proto3" json:"transformConf,omitempty"`
	// contains filtered or unexported fields
}

InitWorldOp is the operation to initialize the inner state.

func (*InitWorldOp) CloneMessageVT 

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

func (*InitWorldOp) CloneVT 

func (m *InitWorldOp) CloneVT() *InitWorldOp

func (*InitWorldOp) EqualMessageVT 

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

func (*InitWorldOp) EqualVT 

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

func (*InitWorldOp) GetLastChangeDisable 

func (x *InitWorldOp) GetLastChangeDisable() bool

func (*InitWorldOp) GetTransformConf 

func (x *InitWorldOp) GetTransformConf() *transform.Config

func (*InitWorldOp) MarshalJSON 

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

MarshalJSON marshals the InitWorldOp to JSON.

func (*InitWorldOp) MarshalProtoJSON 

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

MarshalProtoJSON marshals the InitWorldOp message to JSON.

func (*InitWorldOp) MarshalProtoText 

func (x *InitWorldOp) MarshalProtoText() string

func (*InitWorldOp) MarshalToSizedBufferVT 

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

func (*InitWorldOp) MarshalToVT 

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

func (*InitWorldOp) MarshalVT 

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

func (*InitWorldOp) ProtoMessage 

func (*InitWorldOp) ProtoMessage()

func (*InitWorldOp) Reset 

func (x *InitWorldOp) Reset()

func (*InitWorldOp) SizeVT 

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

func (*InitWorldOp) String 

func (x *InitWorldOp) String() string

func (*InitWorldOp) UnmarshalJSON 

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

UnmarshalJSON unmarshals the InitWorldOp from JSON.

func (*InitWorldOp) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the InitWorldOp message from JSON.

func (*InitWorldOp) UnmarshalVT 

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

func (*InitWorldOp) Validate 

func (i *InitWorldOp) Validate() error

Validate validates the InitWorldOp configuration.

type InnerState 

type InnerState struct {

	// HeadRef is the most recent reference to the world state.
	// Includes the in-line transform config w/ crypto key.
	// The bucket ID will be overridden when loaded.
	// The bucket ID should be set to empty.
	// The object referenced is a .world.block.World block.
	HeadRef *bucket.ObjectRef `protobuf:"bytes,1,opt,name=head_ref,json=headRef,proto3" json:"headRef,omitempty"`
	// StorageGeneration is the storage generation of the accepted World.
	// The Space authority advances it before reclaiming unreachable blocks from
	// the storage bucket. Transactions built on an older generation are rejected.
	StorageGeneration uint64 `protobuf:"varint,2,opt,name=storage_generation,json=storageGeneration,proto3" json:"storageGeneration,omitempty"`
	// RetainedRoots are past World roots the Space keeps restorable, sorted by
	// name. Storage reclaim treats every block they reach as live.
	RetainedRoots []*RetainedRoot `protobuf:"bytes,3,rep,name=retained_roots,json=retainedRoots,proto3" json:"retainedRoots,omitempty"`
	// contains filtered or unexported fields
}

InnerState contains the inner state object for the SharedObject. Note that the SharedObject inner state thas a very small size limit.

func BuildInitialInnerState added in v0.51.2 

func BuildInitialInnerState(initOp *InitWorldOp) (*InnerState, error)

BuildInitialInnerState builds the initialized empty world state.

func ReadInnerState 

func ReadInnerState(ctx context.Context, snap sobject.SharedObjectStateSnapshot) (*InnerState, error)

ReadInnerState parses the World state from a SharedObject snapshot. The state is empty until the World is initialized.

func (*InnerState) CloneMessageVT 

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

func (*InnerState) CloneVT 

func (m *InnerState) CloneVT() *InnerState

func (*InnerState) EqualMessageVT 

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

func (*InnerState) EqualVT 

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

func (*InnerState) GetHeadRef 

func (x *InnerState) GetHeadRef() *bucket.ObjectRef

func (*InnerState) GetRetainedRoots 

func (x *InnerState) GetRetainedRoots() []*RetainedRoot

func (*InnerState) GetStorageGeneration 

func (x *InnerState) GetStorageGeneration() uint64

func (*InnerState) MarshalJSON 

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

MarshalJSON marshals the InnerState to JSON.

func (*InnerState) MarshalProtoJSON 

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

MarshalProtoJSON marshals the InnerState message to JSON.

func (*InnerState) MarshalProtoText 

func (x *InnerState) MarshalProtoText() string

func (*InnerState) MarshalToSizedBufferVT 

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

func (*InnerState) MarshalToVT 

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

func (*InnerState) MarshalVT 

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

func (*InnerState) ProtoMessage 

func (*InnerState) ProtoMessage()

func (*InnerState) Reset 

func (x *InnerState) Reset()

func (*InnerState) SizeVT 

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

func (*InnerState) String 

func (x *InnerState) String() string

func (*InnerState) UnmarshalJSON 

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

UnmarshalJSON unmarshals the InnerState from JSON.

func (*InnerState) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the InnerState message from JSON.

func (*InnerState) UnmarshalVT 

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

type RetainedRoot 

type RetainedRoot struct {

	// Name identifies the root within the Space.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// RootRef is the World root block. It uses the head's transform config.
	RootRef *block.BlockRef `protobuf:"bytes,2,opt,name=root_ref,json=rootRef,proto3" json:"rootRef,omitempty"`
	// contains filtered or unexported fields
}

RetainedRoot is a past World root kept restorable under a name.

func (*RetainedRoot) CloneMessageVT 

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

func (*RetainedRoot) CloneVT 

func (m *RetainedRoot) CloneVT() *RetainedRoot

func (*RetainedRoot) EqualMessageVT 

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

func (*RetainedRoot) EqualVT 

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

func (*RetainedRoot) GetName 

func (x *RetainedRoot) GetName() string

func (*RetainedRoot) GetRootRef 

func (x *RetainedRoot) GetRootRef() *block.BlockRef

func (*RetainedRoot) MarshalJSON 

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

MarshalJSON marshals the RetainedRoot to JSON.

func (*RetainedRoot) MarshalProtoJSON 

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

MarshalProtoJSON marshals the RetainedRoot message to JSON.

func (*RetainedRoot) MarshalProtoText 

func (x *RetainedRoot) MarshalProtoText() string

func (*RetainedRoot) MarshalToSizedBufferVT 

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

func (*RetainedRoot) MarshalToVT 

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

func (*RetainedRoot) MarshalVT 

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

func (*RetainedRoot) ProtoMessage 

func (*RetainedRoot) ProtoMessage()

func (*RetainedRoot) Reset 

func (x *RetainedRoot) Reset()

func (*RetainedRoot) SizeVT 

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

func (*RetainedRoot) String 

func (x *RetainedRoot) String() string

func (*RetainedRoot) UnmarshalJSON 

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

UnmarshalJSON unmarshals the RetainedRoot from JSON.

func (*RetainedRoot) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the RetainedRoot message from JSON.

func (*RetainedRoot) UnmarshalVT 

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

type RetainedRootSet 

type RetainedRootSet struct {

	// Roots are the retained roots, sorted by name.
	Roots []*RetainedRoot `protobuf:"bytes,1,rep,name=roots,proto3" json:"roots,omitempty"`
	// contains filtered or unexported fields
}

RetainedRootSet is the block the validator keeps as its one local named root for all retained roots. Its outgoing refs are the retained World roots.

func (*RetainedRootSet) CloneMessageVT 

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

func (*RetainedRootSet) CloneVT 

func (m *RetainedRootSet) CloneVT() *RetainedRootSet

func (*RetainedRootSet) EqualMessageVT 

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

func (*RetainedRootSet) EqualVT 

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

func (*RetainedRootSet) GetRoots 

func (x *RetainedRootSet) GetRoots() []*RetainedRoot

func (*RetainedRootSet) MarshalJSON 

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

MarshalJSON marshals the RetainedRootSet to JSON.

func (*RetainedRootSet) MarshalProtoJSON 

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

MarshalProtoJSON marshals the RetainedRootSet message to JSON.

func (*RetainedRootSet) MarshalProtoText 

func (x *RetainedRootSet) MarshalProtoText() string

func (*RetainedRootSet) MarshalToSizedBufferVT 

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

func (*RetainedRootSet) MarshalToVT 

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

func (*RetainedRootSet) MarshalVT 

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

func (*RetainedRootSet) ProtoMessage 

func (*RetainedRootSet) ProtoMessage()

func (*RetainedRootSet) Reset 

func (x *RetainedRootSet) Reset()

func (*RetainedRootSet) SizeVT 

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

func (*RetainedRootSet) String 

func (x *RetainedRootSet) String() string

func (*RetainedRootSet) UnmarshalJSON 

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

UnmarshalJSON unmarshals the RetainedRootSet from JSON.

func (*RetainedRootSet) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the RetainedRootSet message from JSON.

func (*RetainedRootSet) UnmarshalVT 

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

type SOWorldOp 

type SOWorldOp struct {

	// Body is the body of the operation.
	//
	// Types that are assignable to Body:
	//	*SOWorldOp_InitWorld
	//	*SOWorldOp_ApplyTxOp
	//	*SOWorldOp_AdvanceStorageGeneration
	//	*SOWorldOp_SetRetainedRoot
	Body isSOWorldOp_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

SOWorldOp is the outer wrapper for a shared object operation against a world InnerState.

func (*SOWorldOp) CloneMessageVT 

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

func (*SOWorldOp) CloneVT 

func (m *SOWorldOp) CloneVT() *SOWorldOp

func (*SOWorldOp) EqualMessageVT 

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

func (*SOWorldOp) EqualVT 

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

func (*SOWorldOp) GetAdvanceStorageGeneration 

func (x *SOWorldOp) GetAdvanceStorageGeneration() *AdvanceStorageGenerationOp

func (*SOWorldOp) GetApplyTxOp 

func (x *SOWorldOp) GetApplyTxOp() *ApplyTxOp

func (*SOWorldOp) GetBody 

func (m *SOWorldOp) GetBody() isSOWorldOp_Body

func (*SOWorldOp) GetInitWorld 

func (x *SOWorldOp) GetInitWorld() *InitWorldOp

func (*SOWorldOp) GetSetRetainedRoot 

func (x *SOWorldOp) GetSetRetainedRoot() *SetRetainedRootOp

func (*SOWorldOp) MarshalBlock 

func (o *SOWorldOp) MarshalBlock() ([]byte, error)

MarshalBlock marshals the block to binary. This is the initial step of marshaling, before transformations.

func (*SOWorldOp) MarshalJSON 

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

MarshalJSON marshals the SOWorldOp to JSON.

func (*SOWorldOp) MarshalProtoJSON 

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

MarshalProtoJSON marshals the SOWorldOp message to JSON.

func (*SOWorldOp) MarshalProtoText 

func (x *SOWorldOp) MarshalProtoText() string

func (*SOWorldOp) MarshalToSizedBufferVT 

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

func (*SOWorldOp) MarshalToVT 

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

func (*SOWorldOp) MarshalVT 

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

func (*SOWorldOp) ProtoMessage 

func (*SOWorldOp) ProtoMessage()

func (*SOWorldOp) Reset 

func (x *SOWorldOp) Reset()

func (*SOWorldOp) SizeVT 

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

func (*SOWorldOp) String 

func (x *SOWorldOp) String() string

func (*SOWorldOp) UnmarshalBlock 

func (o *SOWorldOp) UnmarshalBlock(data []byte) error

UnmarshalBlock unmarshals the block to the object. This is the final step of decoding, after transformations.

func (*SOWorldOp) UnmarshalJSON 

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

UnmarshalJSON unmarshals the SOWorldOp from JSON.

func (*SOWorldOp) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the SOWorldOp message from JSON.

func (*SOWorldOp) UnmarshalVT 

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

type SOWorldOp_AdvanceStorageGeneration 

type SOWorldOp_AdvanceStorageGeneration struct {
	// AdvanceStorageGeneration advances the storage generation.
	AdvanceStorageGeneration *AdvanceStorageGenerationOp `protobuf:"bytes,3,opt,name=advance_storage_generation,json=advanceStorageGeneration,proto3,oneof"`
}

func (*SOWorldOp_AdvanceStorageGeneration) CloneOneofVT 

func (m *SOWorldOp_AdvanceStorageGeneration) CloneOneofVT() isSOWorldOp_Body

func (*SOWorldOp_AdvanceStorageGeneration) CloneVT 

func (m *SOWorldOp_AdvanceStorageGeneration) CloneVT() *SOWorldOp_AdvanceStorageGeneration

func (*SOWorldOp_AdvanceStorageGeneration) EqualVT 

func (this *SOWorldOp_AdvanceStorageGeneration) EqualVT(thatIface isSOWorldOp_Body) bool

func (*SOWorldOp_AdvanceStorageGeneration) MarshalToSizedBufferVT 

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

func (*SOWorldOp_AdvanceStorageGeneration) MarshalToVT 

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

func (*SOWorldOp_AdvanceStorageGeneration) SizeVT 

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

type SOWorldOp_ApplyTxOp 

type SOWorldOp_ApplyTxOp struct {
	// ApplyTxOp applies a world transaction.
	ApplyTxOp *ApplyTxOp `protobuf:"bytes,2,opt,name=apply_tx_op,json=applyTxOp,proto3,oneof"`
}

func (*SOWorldOp_ApplyTxOp) CloneOneofVT 

func (m *SOWorldOp_ApplyTxOp) CloneOneofVT() isSOWorldOp_Body

func (*SOWorldOp_ApplyTxOp) CloneVT 

func (m *SOWorldOp_ApplyTxOp) CloneVT() *SOWorldOp_ApplyTxOp

func (*SOWorldOp_ApplyTxOp) EqualVT 

func (this *SOWorldOp_ApplyTxOp) EqualVT(thatIface isSOWorldOp_Body) bool

func (*SOWorldOp_ApplyTxOp) MarshalToSizedBufferVT 

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

func (*SOWorldOp_ApplyTxOp) MarshalToVT 

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

func (*SOWorldOp_ApplyTxOp) SizeVT 

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

type SOWorldOp_InitWorld 

type SOWorldOp_InitWorld struct {
	// InitWorld is the init world operation.
	InitWorld *InitWorldOp `protobuf:"bytes,1,opt,name=init_world,json=initWorld,proto3,oneof"`
}

func (*SOWorldOp_InitWorld) CloneOneofVT 

func (m *SOWorldOp_InitWorld) CloneOneofVT() isSOWorldOp_Body

func (*SOWorldOp_InitWorld) CloneVT 

func (m *SOWorldOp_InitWorld) CloneVT() *SOWorldOp_InitWorld

func (*SOWorldOp_InitWorld) EqualVT 

func (this *SOWorldOp_InitWorld) EqualVT(thatIface isSOWorldOp_Body) bool

func (*SOWorldOp_InitWorld) MarshalToSizedBufferVT 

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

func (*SOWorldOp_InitWorld) MarshalToVT 

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

func (*SOWorldOp_InitWorld) SizeVT 

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

type SOWorldOp_SetRetainedRoot 

type SOWorldOp_SetRetainedRoot struct {
	// SetRetainedRoot retains or releases a past World root.
	SetRetainedRoot *SetRetainedRootOp `protobuf:"bytes,4,opt,name=set_retained_root,json=setRetainedRoot,proto3,oneof"`
}

func (*SOWorldOp_SetRetainedRoot) CloneOneofVT 

func (m *SOWorldOp_SetRetainedRoot) CloneOneofVT() isSOWorldOp_Body

func (*SOWorldOp_SetRetainedRoot) CloneVT 

func (m *SOWorldOp_SetRetainedRoot) CloneVT() *SOWorldOp_SetRetainedRoot

func (*SOWorldOp_SetRetainedRoot) EqualVT 

func (this *SOWorldOp_SetRetainedRoot) EqualVT(thatIface isSOWorldOp_Body) bool

func (*SOWorldOp_SetRetainedRoot) MarshalToSizedBufferVT 

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

func (*SOWorldOp_SetRetainedRoot) MarshalToVT 

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

func (*SOWorldOp_SetRetainedRoot) SizeVT 

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

type SetRetainedRootOp 

type SetRetainedRootOp struct {

	// Name identifies the root within the Space.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// RootRef is the World root block to retain, or empty to release.
	RootRef *block.BlockRef `protobuf:"bytes,2,opt,name=root_ref,json=rootRef,proto3" json:"rootRef,omitempty"`
	// StorageGeneration is the generation of the accepted state whose head is
	// root_ref. The validator rejects an older one: a reclaim pass that advanced
	// past it may have judged the root's blocks dead before the validator copied
	// them.
	StorageGeneration uint64 `protobuf:"varint,3,opt,name=storage_generation,json=storageGeneration,proto3" json:"storageGeneration,omitempty"`
	// contains filtered or unexported fields
}

SetRetainedRootOp retains a past World root under a name, replacing a root with the same name, or releases the name when root_ref is empty.

func (*SetRetainedRootOp) CloneMessageVT 

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

func (*SetRetainedRootOp) CloneVT 

func (m *SetRetainedRootOp) CloneVT() *SetRetainedRootOp

func (*SetRetainedRootOp) EqualMessageVT 

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

func (*SetRetainedRootOp) EqualVT 

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

func (*SetRetainedRootOp) GetName 

func (x *SetRetainedRootOp) GetName() string

func (*SetRetainedRootOp) GetRootRef 

func (x *SetRetainedRootOp) GetRootRef() *block.BlockRef

func (*SetRetainedRootOp) GetStorageGeneration 

func (x *SetRetainedRootOp) GetStorageGeneration() uint64

func (*SetRetainedRootOp) MarshalJSON 

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

MarshalJSON marshals the SetRetainedRootOp to JSON.

func (*SetRetainedRootOp) MarshalProtoJSON 

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

MarshalProtoJSON marshals the SetRetainedRootOp message to JSON.

func (*SetRetainedRootOp) MarshalProtoText 

func (x *SetRetainedRootOp) MarshalProtoText() string

func (*SetRetainedRootOp) MarshalToSizedBufferVT 

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

func (*SetRetainedRootOp) MarshalToVT 

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

func (*SetRetainedRootOp) MarshalVT 

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

func (*SetRetainedRootOp) ProtoMessage 

func (*SetRetainedRootOp) ProtoMessage()

func (*SetRetainedRootOp) Reset 

func (x *SetRetainedRootOp) Reset()

func (*SetRetainedRootOp) SizeVT 

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

func (*SetRetainedRootOp) String 

func (x *SetRetainedRootOp) String() string

func (*SetRetainedRootOp) UnmarshalJSON 

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

UnmarshalJSON unmarshals the SetRetainedRootOp from JSON.

func (*SetRetainedRootOp) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the SetRetainedRootOp message from JSON.

func (*SetRetainedRootOp) UnmarshalVT 

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

type SpaceWorldFinalizationDecision added in v0.52.0 

type SpaceWorldFinalizationDecision struct {

	// Status is the accept/reject/fence result.
	Status SpaceWorldFinalizationStatus `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// AcceptedSharedObjectRoot is set only when status is ACCEPTED.
	AcceptedSharedObjectRoot *sobject.SORoot `` /* 134-byte string literal not displayed */
	// AcceptedWorldRoot is set only when status is ACCEPTED.
	AcceptedWorldRoot *bucket.ObjectRef `protobuf:"bytes,3,opt,name=accepted_world_root,json=acceptedWorldRoot,proto3" json:"acceptedWorldRoot,omitempty"`
	// Error explains rejected or retryable decisions.
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// Retryable indicates the follower may refresh and resubmit a new packet.
	Retryable bool `protobuf:"varint,5,opt,name=retryable,proto3" json:"retryable,omitempty"`
	// LocalOperationId echoes the packet local id for follower correlation.
	LocalOperationId string `protobuf:"bytes,6,opt,name=local_operation_id,json=localOperationId,proto3" json:"localOperationId,omitempty"`
	// contains filtered or unexported fields
}

SpaceWorldFinalizationDecision is returned by the leader or Spacewave daemon.

func (*SpaceWorldFinalizationDecision) CloneMessageVT added in v0.52.0 

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

func (*SpaceWorldFinalizationDecision) CloneVT added in v0.52.0 

func (m *SpaceWorldFinalizationDecision) CloneVT() *SpaceWorldFinalizationDecision

func (*SpaceWorldFinalizationDecision) EqualMessageVT added in v0.52.0 

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

func (*SpaceWorldFinalizationDecision) EqualVT added in v0.52.0 

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

func (*SpaceWorldFinalizationDecision) GetAcceptedSharedObjectRoot added in v0.52.0 

func (x *SpaceWorldFinalizationDecision) GetAcceptedSharedObjectRoot() *sobject.SORoot

func (*SpaceWorldFinalizationDecision) GetAcceptedWorldRoot added in v0.52.0 

func (x *SpaceWorldFinalizationDecision) GetAcceptedWorldRoot() *bucket.ObjectRef

func (*SpaceWorldFinalizationDecision) GetError added in v0.52.0 

func (x *SpaceWorldFinalizationDecision) GetError() string

func (*SpaceWorldFinalizationDecision) GetLocalOperationId added in v0.52.0 

func (x *SpaceWorldFinalizationDecision) GetLocalOperationId() string

func (*SpaceWorldFinalizationDecision) GetRetryable added in v0.52.0 

func (x *SpaceWorldFinalizationDecision) GetRetryable() bool

func (*SpaceWorldFinalizationDecision) GetStatus added in v0.52.0 

func (x *SpaceWorldFinalizationDecision) GetStatus() SpaceWorldFinalizationStatus

func (*SpaceWorldFinalizationDecision) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the SpaceWorldFinalizationDecision to JSON.

func (*SpaceWorldFinalizationDecision) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the SpaceWorldFinalizationDecision message to JSON.

func (*SpaceWorldFinalizationDecision) MarshalProtoText added in v0.52.0 

func (x *SpaceWorldFinalizationDecision) MarshalProtoText() string

func (*SpaceWorldFinalizationDecision) MarshalToSizedBufferVT added in v0.52.0 

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

func (*SpaceWorldFinalizationDecision) MarshalToVT added in v0.52.0 

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

func (*SpaceWorldFinalizationDecision) MarshalVT added in v0.52.0 

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

func (*SpaceWorldFinalizationDecision) ProtoMessage added in v0.52.0 

func (*SpaceWorldFinalizationDecision) ProtoMessage()

func (*SpaceWorldFinalizationDecision) Reset added in v0.52.0 

func (x *SpaceWorldFinalizationDecision) Reset()

func (*SpaceWorldFinalizationDecision) SizeVT added in v0.52.0 

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

func (*SpaceWorldFinalizationDecision) String added in v0.52.0 

func (x *SpaceWorldFinalizationDecision) String() string

func (*SpaceWorldFinalizationDecision) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the SpaceWorldFinalizationDecision from JSON.

func (*SpaceWorldFinalizationDecision) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the SpaceWorldFinalizationDecision message from JSON.

func (*SpaceWorldFinalizationDecision) UnmarshalVT added in v0.52.0 

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

func (*SpaceWorldFinalizationDecision) Validate added in v0.52.0 

func (d *SpaceWorldFinalizationDecision) Validate() error

Validate checks accepted decisions carry the roots followers need to refresh.

type SpaceWorldFinalizationPacket added in v0.52.0 

type SpaceWorldFinalizationPacket struct {

	// BaseSharedObjectRoot is the SharedObject root observed before candidate work.
	BaseSharedObjectRoot *sobject.SORoot `protobuf:"bytes,1,opt,name=base_shared_object_root,json=baseSharedObjectRoot,proto3" json:"baseSharedObjectRoot,omitempty"`
	// BaseWorldRoot is the World root observed before candidate work.
	BaseWorldRoot *bucket.ObjectRef `protobuf:"bytes,2,opt,name=base_world_root,json=baseWorldRoot,proto3" json:"baseWorldRoot,omitempty"`
	// CandidateWorldRoot is the follower-produced candidate World root.
	CandidateWorldRoot *bucket.ObjectRef `protobuf:"bytes,3,opt,name=candidate_world_root,json=candidateWorldRoot,proto3" json:"candidateWorldRoot,omitempty"`
	// CandidateContentId identifies the candidate content/op payload being finalized.
	CandidateContentId []byte `protobuf:"bytes,4,opt,name=candidate_content_id,json=candidateContentId,proto3" json:"candidateContentId,omitempty"`
	// AuthorityEpoch identifies the leader/daemon authority epoch observed by the follower.
	AuthorityEpoch uint64 `protobuf:"varint,6,opt,name=authority_epoch,json=authorityEpoch,proto3" json:"authorityEpoch,omitempty"`
	// BlocksAvailable is true when the follower believes candidate blocks are readable by the authority owner.
	BlocksAvailable bool `protobuf:"varint,7,opt,name=blocks_available,json=blocksAvailable,proto3" json:"blocksAvailable,omitempty"`
	// Op is the SharedObject World operation that produced the candidate root.
	Op *SOWorldOp `protobuf:"bytes,8,opt,name=op,proto3" json:"op,omitempty"`
	// FollowerParticipantId identifies the submitting follower.
	FollowerParticipantId string `protobuf:"bytes,9,opt,name=follower_participant_id,json=followerParticipantId,proto3" json:"followerParticipantId,omitempty"`
	// LocalOperationId lets the follower correlate accepted/rejected decisions.
	LocalOperationId string `protobuf:"bytes,10,opt,name=local_operation_id,json=localOperationId,proto3" json:"localOperationId,omitempty"`
	// contains filtered or unexported fields
}

SpaceWorldFinalizationPacket is submitted by a follower after it has produced candidate World content but before any SharedObject root is finalized.

func (*SpaceWorldFinalizationPacket) CloneMessageVT added in v0.52.0 

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

func (*SpaceWorldFinalizationPacket) CloneVT added in v0.52.0 

func (m *SpaceWorldFinalizationPacket) CloneVT() *SpaceWorldFinalizationPacket

func (*SpaceWorldFinalizationPacket) EqualMessageVT added in v0.52.0 

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

func (*SpaceWorldFinalizationPacket) EqualVT added in v0.52.0 

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

func (*SpaceWorldFinalizationPacket) GetAuthorityEpoch added in v0.52.0 

func (x *SpaceWorldFinalizationPacket) GetAuthorityEpoch() uint64

func (*SpaceWorldFinalizationPacket) GetBaseSharedObjectRoot added in v0.52.0 

func (x *SpaceWorldFinalizationPacket) GetBaseSharedObjectRoot() *sobject.SORoot

func (*SpaceWorldFinalizationPacket) GetBaseWorldRoot added in v0.52.0 

func (x *SpaceWorldFinalizationPacket) GetBaseWorldRoot() *bucket.ObjectRef

func (*SpaceWorldFinalizationPacket) GetBlocksAvailable added in v0.52.0 

func (x *SpaceWorldFinalizationPacket) GetBlocksAvailable() bool

func (*SpaceWorldFinalizationPacket) GetCandidateContentId added in v0.52.0 

func (x *SpaceWorldFinalizationPacket) GetCandidateContentId() []byte

func (*SpaceWorldFinalizationPacket) GetCandidateWorldRoot added in v0.52.0 

func (x *SpaceWorldFinalizationPacket) GetCandidateWorldRoot() *bucket.ObjectRef

func (*SpaceWorldFinalizationPacket) GetFollowerParticipantId added in v0.52.0 

func (x *SpaceWorldFinalizationPacket) GetFollowerParticipantId() string

func (*SpaceWorldFinalizationPacket) GetLocalOperationId added in v0.52.0 

func (x *SpaceWorldFinalizationPacket) GetLocalOperationId() string

func (*SpaceWorldFinalizationPacket) GetOp added in v0.52.0 

func (x *SpaceWorldFinalizationPacket) GetOp() *SOWorldOp

func (*SpaceWorldFinalizationPacket) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the SpaceWorldFinalizationPacket to JSON.

func (*SpaceWorldFinalizationPacket) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the SpaceWorldFinalizationPacket message to JSON.

func (*SpaceWorldFinalizationPacket) MarshalProtoText added in v0.52.0 

func (x *SpaceWorldFinalizationPacket) MarshalProtoText() string

func (*SpaceWorldFinalizationPacket) MarshalToSizedBufferVT added in v0.52.0 

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

func (*SpaceWorldFinalizationPacket) MarshalToVT added in v0.52.0 

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

func (*SpaceWorldFinalizationPacket) MarshalVT added in v0.52.0 

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

func (*SpaceWorldFinalizationPacket) ProtoMessage added in v0.52.0 

func (*SpaceWorldFinalizationPacket) ProtoMessage()

func (*SpaceWorldFinalizationPacket) Reset added in v0.52.0 

func (x *SpaceWorldFinalizationPacket) Reset()

func (*SpaceWorldFinalizationPacket) SizeVT added in v0.52.0 

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

func (*SpaceWorldFinalizationPacket) String added in v0.52.0 

func (x *SpaceWorldFinalizationPacket) String() string

func (*SpaceWorldFinalizationPacket) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the SpaceWorldFinalizationPacket from JSON.

func (*SpaceWorldFinalizationPacket) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the SpaceWorldFinalizationPacket message from JSON.

func (*SpaceWorldFinalizationPacket) UnmarshalVT added in v0.52.0 

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

func (*SpaceWorldFinalizationPacket) Validate added in v0.52.0 

func (p *SpaceWorldFinalizationPacket) Validate() error

Validate checks the follower finalization packet has the fields required for authority-side stale-base and candidate-availability decisions.

type SpaceWorldFinalizationStatus added in v0.52.0 

type SpaceWorldFinalizationStatus int32

SpaceWorldFinalizationStatus is the authority owner's decision for a packet. 

const (
	// SPACE_WORLD_FINALIZATION_STATUS_UNKNOWN is invalid.
	SpaceWorldFinalizationStatus_SPACE_WORLD_FINALIZATION_STATUS_UNKNOWN SpaceWorldFinalizationStatus = 0
	// SPACE_WORLD_FINALIZATION_STATUS_ACCEPTED means the SharedObject root was finalized.
	SpaceWorldFinalizationStatus_SPACE_WORLD_FINALIZATION_STATUS_ACCEPTED SpaceWorldFinalizationStatus = 1
	// SPACE_WORLD_FINALIZATION_STATUS_REJECTED means the candidate is not accepted and should be retained follower-side only.
	SpaceWorldFinalizationStatus_SPACE_WORLD_FINALIZATION_STATUS_REJECTED SpaceWorldFinalizationStatus = 2
	// SPACE_WORLD_FINALIZATION_STATUS_STALE_BASE means the candidate was based on stale SharedObject or World state.
	SpaceWorldFinalizationStatus_SPACE_WORLD_FINALIZATION_STATUS_STALE_BASE SpaceWorldFinalizationStatus = 3
	// SPACE_WORLD_FINALIZATION_STATUS_MISSING_BLOCK means the authority owner could not read candidate blocks.
	SpaceWorldFinalizationStatus_SPACE_WORLD_FINALIZATION_STATUS_MISSING_BLOCK SpaceWorldFinalizationStatus = 4
	// SPACE_WORLD_FINALIZATION_STATUS_LOST_AUTHORITY means the contacted owner no longer holds finalization authority.
	SpaceWorldFinalizationStatus_SPACE_WORLD_FINALIZATION_STATUS_LOST_AUTHORITY SpaceWorldFinalizationStatus = 5
)

func (SpaceWorldFinalizationStatus) Enum added in v0.52.0 

func (x SpaceWorldFinalizationStatus) Enum() *SpaceWorldFinalizationStatus

func (SpaceWorldFinalizationStatus) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the SpaceWorldFinalizationStatus to JSON.

func (SpaceWorldFinalizationStatus) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the SpaceWorldFinalizationStatus to JSON.

func (SpaceWorldFinalizationStatus) MarshalProtoText added in v0.52.0 

func (x SpaceWorldFinalizationStatus) MarshalProtoText() string

func (SpaceWorldFinalizationStatus) MarshalText added in v0.52.0 

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

MarshalText marshals the SpaceWorldFinalizationStatus to text.

func (SpaceWorldFinalizationStatus) String added in v0.52.0 

func (x SpaceWorldFinalizationStatus) String() string

func (*SpaceWorldFinalizationStatus) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the SpaceWorldFinalizationStatus from JSON.

func (*SpaceWorldFinalizationStatus) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the SpaceWorldFinalizationStatus from JSON.

func (*SpaceWorldFinalizationStatus) UnmarshalText added in v0.52.0 

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

UnmarshalText unmarshals the SpaceWorldFinalizationStatus from text.

type SpaceWorldRejectedCandidate added in v0.52.0 

type SpaceWorldRejectedCandidate struct {

	// Packet is the candidate submission that was not accepted.
	Packet *SpaceWorldFinalizationPacket `protobuf:"bytes,1,opt,name=packet,proto3" json:"packet,omitempty"`
	// Decision is the non-accepted authority outcome.
	Decision *SpaceWorldFinalizationDecision `protobuf:"bytes,2,opt,name=decision,proto3" json:"decision,omitempty"`
	// RetainedUnixNano records when the follower retained cleanup bookkeeping.
	RetainedUnixNano uint64 `protobuf:"varint,3,opt,name=retained_unix_nano,json=retainedUnixNano,proto3" json:"retainedUnixNano,omitempty"`
	// contains filtered or unexported fields
}

SpaceWorldRejectedCandidate records follower-local retention bookkeeping for a candidate that authority did not accept. The record does not grant any leader-side block deletion authority.

func (*SpaceWorldRejectedCandidate) CloneMessageVT added in v0.52.0 

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

func (*SpaceWorldRejectedCandidate) CloneVT added in v0.52.0 

func (m *SpaceWorldRejectedCandidate) CloneVT() *SpaceWorldRejectedCandidate

func (*SpaceWorldRejectedCandidate) EqualMessageVT added in v0.52.0 

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

func (*SpaceWorldRejectedCandidate) EqualVT added in v0.52.0 

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

func (*SpaceWorldRejectedCandidate) GetDecision added in v0.52.0 

func (x *SpaceWorldRejectedCandidate) GetDecision() *SpaceWorldFinalizationDecision

func (*SpaceWorldRejectedCandidate) GetPacket added in v0.52.0 

func (x *SpaceWorldRejectedCandidate) GetPacket() *SpaceWorldFinalizationPacket

func (*SpaceWorldRejectedCandidate) GetRetainedUnixNano added in v0.52.0 

func (x *SpaceWorldRejectedCandidate) GetRetainedUnixNano() uint64

func (*SpaceWorldRejectedCandidate) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the SpaceWorldRejectedCandidate to JSON.

func (*SpaceWorldRejectedCandidate) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the SpaceWorldRejectedCandidate message to JSON.

func (*SpaceWorldRejectedCandidate) MarshalProtoText added in v0.52.0 

func (x *SpaceWorldRejectedCandidate) MarshalProtoText() string

func (*SpaceWorldRejectedCandidate) MarshalToSizedBufferVT added in v0.52.0 

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

func (*SpaceWorldRejectedCandidate) MarshalToVT added in v0.52.0 

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

func (*SpaceWorldRejectedCandidate) MarshalVT added in v0.52.0 

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

func (*SpaceWorldRejectedCandidate) ProtoMessage added in v0.52.0 

func (*SpaceWorldRejectedCandidate) ProtoMessage()

func (*SpaceWorldRejectedCandidate) Reset added in v0.52.0 

func (x *SpaceWorldRejectedCandidate) Reset()

func (*SpaceWorldRejectedCandidate) SizeVT added in v0.52.0 

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

func (*SpaceWorldRejectedCandidate) String added in v0.52.0 

func (x *SpaceWorldRejectedCandidate) String() string

func (*SpaceWorldRejectedCandidate) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the SpaceWorldRejectedCandidate from JSON.

func (*SpaceWorldRejectedCandidate) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the SpaceWorldRejectedCandidate message from JSON.

func (*SpaceWorldRejectedCandidate) UnmarshalVT added in v0.52.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.