sobject_sync

package
v0.57.5 Latest Latest
Warning

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

 Go to latest Published: Sep 9, 2026 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const SyncProtocolID = protocol.ID("alpha/so-sync/2")

SyncProtocolID is the protocol ID used for SO sync solicitation.

Variables

View Source 
var ErrAccessDenied = errors.New("shared object synchronization access denied")

ErrAccessDenied means a participant no longer has readable object access.

Functions

This section is empty.

Types

type SOSync 

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

SOSync synchronizes one shared object over the session transport's child bus.

func NewSOSync 

func NewSOSync(
	le *logrus.Entry,
	b bus.Bus,
	soID string,
	localObjectPeerID peer.ID,
	localObjectKey crypto.PrivKey,
	soHost *sobject.SOHost,
	peerAdmission func(peer.ID, bool),
	accessValidators ...SnapshotAccessValidator,
) *SOSync

NewSOSync constructs a new SOSync.

localObjectPeerID is the local storage identity checked against inbound state. The transport peer routes the sync stream but need not be a Space participant. localObjectKey must belong to localObjectPeerID and remains available for the SOSync lifetime. Authentication rejects a mismatched key. peerAdmission, when non-nil, observes explicit responses from peers permitted by local authority. Calls may be concurrent and must return promptly. A remote denial describes that source's response, not a local membership change.

func (*SOSync) Execute 

func (s *SOSync) Execute(ctx context.Context) error

Execute runs the SO sync, emitting a SolicitProtocol directive and handling matched streams until ctx is canceled.

func (*SOSync) SetPeerRecoveryObserver 

func (s *SOSync) SetPeerRecoveryObserver(observer func(peer.ID, bool))

SetPeerRecoveryObserver configures source-recovery observation before Execute starts. The observer must return promptly; calls can come from concurrent peer streams.

type SOSyncAck 

type SOSyncAck struct {

	// AckedSeqno is the acknowledged sequence number.
	AckedSeqno uint64 `protobuf:"varint,1,opt,name=acked_seqno,json=ackedSeqno,proto3" json:"ackedSeqno,omitempty"`
	// Revision releases the sender's pinned advertisement after receipt or decline.
	Revision uint64 `protobuf:"varint,2,opt,name=revision,proto3" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

SOSyncAck acknowledges receipt up to a sequence number.

func (*SOSyncAck) CloneMessageVT 

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

func (*SOSyncAck) CloneVT 

func (m *SOSyncAck) CloneVT() *SOSyncAck

func (*SOSyncAck) EqualMessageVT 

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

func (*SOSyncAck) EqualVT 

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

func (*SOSyncAck) GetAckedSeqno 

func (x *SOSyncAck) GetAckedSeqno() uint64

func (*SOSyncAck) GetRevision 

func (x *SOSyncAck) GetRevision() uint64

func (*SOSyncAck) MarshalJSON 

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

MarshalJSON marshals the SOSyncAck to JSON.

func (*SOSyncAck) MarshalProtoJSON 

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

MarshalProtoJSON marshals the SOSyncAck message to JSON.

func (*SOSyncAck) MarshalProtoText 

func (x *SOSyncAck) MarshalProtoText() string

func (*SOSyncAck) MarshalToSizedBufferVT 

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

func (*SOSyncAck) MarshalToVT 

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

func (*SOSyncAck) MarshalVT 

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

func (*SOSyncAck) ProtoMessage 

func (*SOSyncAck) ProtoMessage()

func (*SOSyncAck) Reset 

func (x *SOSyncAck) Reset()

func (*SOSyncAck) SizeVT 

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

func (*SOSyncAck) String 

func (x *SOSyncAck) String() string

func (*SOSyncAck) UnmarshalJSON 

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

UnmarshalJSON unmarshals the SOSyncAck from JSON.

func (*SOSyncAck) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the SOSyncAck message from JSON.

func (*SOSyncAck) UnmarshalVT 

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

type SOSyncAuthTranscript 

type SOSyncAuthTranscript struct {

	// SharedObjectId binds the proof to one object.
	SharedObjectId string `protobuf:"bytes,1,opt,name=shared_object_id,json=sharedObjectId,proto3" json:"sharedObjectId,omitempty"`
	// SenderTransport is the authenticated transport identity producing the proof.
	SenderTransport []byte `protobuf:"bytes,2,opt,name=sender_transport,json=senderTransport,proto3" json:"senderTransport,omitempty"`
	// ReceiverTransport is the authenticated transport identity receiving the proof.
	ReceiverTransport []byte `protobuf:"bytes,3,opt,name=receiver_transport,json=receiverTransport,proto3" json:"receiverTransport,omitempty"`
	// SenderNonce is the challenge produced by the signing endpoint.
	SenderNonce []byte `protobuf:"bytes,4,opt,name=sender_nonce,json=senderNonce,proto3" json:"senderNonce,omitempty"`
	// ReceiverNonce is the challenge produced by the verifying endpoint.
	ReceiverNonce []byte `protobuf:"bytes,5,opt,name=receiver_nonce,json=receiverNonce,proto3" json:"receiverNonce,omitempty"`
	// contains filtered or unexported fields
}

SOSyncAuthTranscript is the canonical signed binding for one direction.

func (*SOSyncAuthTranscript) CloneMessageVT 

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

func (*SOSyncAuthTranscript) CloneVT 

func (m *SOSyncAuthTranscript) CloneVT() *SOSyncAuthTranscript

func (*SOSyncAuthTranscript) EqualMessageVT 

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

func (*SOSyncAuthTranscript) EqualVT 

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

func (*SOSyncAuthTranscript) GetReceiverNonce 

func (x *SOSyncAuthTranscript) GetReceiverNonce() []byte

func (*SOSyncAuthTranscript) GetReceiverTransport 

func (x *SOSyncAuthTranscript) GetReceiverTransport() []byte

func (*SOSyncAuthTranscript) GetSenderNonce 

func (x *SOSyncAuthTranscript) GetSenderNonce() []byte

func (*SOSyncAuthTranscript) GetSenderTransport 

func (x *SOSyncAuthTranscript) GetSenderTransport() []byte

func (*SOSyncAuthTranscript) GetSharedObjectId 

func (x *SOSyncAuthTranscript) GetSharedObjectId() string

func (*SOSyncAuthTranscript) MarshalJSON 

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

MarshalJSON marshals the SOSyncAuthTranscript to JSON.

func (*SOSyncAuthTranscript) MarshalProtoJSON 

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

MarshalProtoJSON marshals the SOSyncAuthTranscript message to JSON.

func (*SOSyncAuthTranscript) MarshalProtoText 

func (x *SOSyncAuthTranscript) MarshalProtoText() string

func (*SOSyncAuthTranscript) MarshalToSizedBufferVT 

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

func (*SOSyncAuthTranscript) MarshalToVT 

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

func (*SOSyncAuthTranscript) MarshalVT 

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

func (*SOSyncAuthTranscript) ProtoMessage 

func (*SOSyncAuthTranscript) ProtoMessage()

func (*SOSyncAuthTranscript) Reset 

func (x *SOSyncAuthTranscript) Reset()

func (*SOSyncAuthTranscript) SizeVT 

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

func (*SOSyncAuthTranscript) String 

func (x *SOSyncAuthTranscript) String() string

func (*SOSyncAuthTranscript) UnmarshalJSON 

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

UnmarshalJSON unmarshals the SOSyncAuthTranscript from JSON.

func (*SOSyncAuthTranscript) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the SOSyncAuthTranscript message from JSON.

func (*SOSyncAuthTranscript) UnmarshalVT 

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

type SOSyncAuthorization 

type SOSyncAuthorization struct {

	// Accepted permits this authenticated participant to proceed to data exchange.
	Accepted bool `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	// contains filtered or unexported fields
}

SOSyncAuthorization reports the receiver's current admission decision.

func (*SOSyncAuthorization) CloneMessageVT 

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

func (*SOSyncAuthorization) CloneVT 

func (m *SOSyncAuthorization) CloneVT() *SOSyncAuthorization

func (*SOSyncAuthorization) EqualMessageVT 

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

func (*SOSyncAuthorization) EqualVT 

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

func (*SOSyncAuthorization) GetAccepted 

func (x *SOSyncAuthorization) GetAccepted() bool

func (*SOSyncAuthorization) MarshalJSON 

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

MarshalJSON marshals the SOSyncAuthorization to JSON.

func (*SOSyncAuthorization) MarshalProtoJSON 

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

MarshalProtoJSON marshals the SOSyncAuthorization message to JSON.

func (*SOSyncAuthorization) MarshalProtoText 

func (x *SOSyncAuthorization) MarshalProtoText() string

func (*SOSyncAuthorization) MarshalToSizedBufferVT 

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

func (*SOSyncAuthorization) MarshalToVT 

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

func (*SOSyncAuthorization) MarshalVT 

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

func (*SOSyncAuthorization) ProtoMessage 

func (*SOSyncAuthorization) ProtoMessage()

func (*SOSyncAuthorization) Reset 

func (x *SOSyncAuthorization) Reset()

func (*SOSyncAuthorization) SizeVT 

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

func (*SOSyncAuthorization) String 

func (x *SOSyncAuthorization) String() string

func (*SOSyncAuthorization) UnmarshalJSON 

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

UnmarshalJSON unmarshals the SOSyncAuthorization from JSON.

func (*SOSyncAuthorization) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the SOSyncAuthorization message from JSON.

func (*SOSyncAuthorization) UnmarshalVT 

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

type SOSyncChallenge 

type SOSyncChallenge struct {

	// Nonce is exactly 32 random bytes, newly generated for this stream.
	Nonce []byte `protobuf:"bytes,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// contains filtered or unexported fields
}

SOSyncChallenge provides fresh entropy for one stream authentication.

func (*SOSyncChallenge) CloneMessageVT 

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

func (*SOSyncChallenge) CloneVT 

func (m *SOSyncChallenge) CloneVT() *SOSyncChallenge

func (*SOSyncChallenge) EqualMessageVT 

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

func (*SOSyncChallenge) EqualVT 

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

func (*SOSyncChallenge) GetNonce 

func (x *SOSyncChallenge) GetNonce() []byte

func (*SOSyncChallenge) MarshalJSON 

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

MarshalJSON marshals the SOSyncChallenge to JSON.

func (*SOSyncChallenge) MarshalProtoJSON 

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

MarshalProtoJSON marshals the SOSyncChallenge message to JSON.

func (*SOSyncChallenge) MarshalProtoText 

func (x *SOSyncChallenge) MarshalProtoText() string

func (*SOSyncChallenge) MarshalToSizedBufferVT 

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

func (*SOSyncChallenge) MarshalToVT 

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

func (*SOSyncChallenge) MarshalVT 

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

func (*SOSyncChallenge) ProtoMessage 

func (*SOSyncChallenge) ProtoMessage()

func (*SOSyncChallenge) Reset 

func (x *SOSyncChallenge) Reset()

func (*SOSyncChallenge) SizeVT 

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

func (*SOSyncChallenge) String 

func (x *SOSyncChallenge) String() string

func (*SOSyncChallenge) UnmarshalJSON 

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

UnmarshalJSON unmarshals the SOSyncChallenge from JSON.

func (*SOSyncChallenge) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the SOSyncChallenge message from JSON.

func (*SOSyncChallenge) UnmarshalVT 

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

type SOSyncHead 

type SOSyncHead struct {

	// Revision increases for each advertised state on this stream.
	Revision uint64 `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"`
	// ConfigHash identifies the advertised configuration head.
	ConfigHash []byte `protobuf:"bytes,2,opt,name=config_hash,json=configHash,proto3" json:"configHash,omitempty"`
	// ConfigSeqno is the configuration-chain sequence at ConfigHash.
	ConfigSeqno uint64 `protobuf:"varint,3,opt,name=config_seqno,json=configSeqno,proto3" json:"configSeqno,omitempty"`
	// RootSeqno is the advertised signed root sequence.
	RootSeqno uint64 `protobuf:"varint,4,opt,name=root_seqno,json=rootSeqno,proto3" json:"rootSeqno,omitempty"`
	// StateHash is SHA-256 of the serialized transferable snapshot; it grants no authority.
	StateHash []byte `protobuf:"bytes,5,opt,name=state_hash,json=stateHash,proto3" json:"stateHash,omitempty"`
	// contains filtered or unexported fields
}

SOSyncHead remains pinned until its revision is acknowledged.

func (*SOSyncHead) CloneMessageVT 

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

func (*SOSyncHead) CloneVT 

func (m *SOSyncHead) CloneVT() *SOSyncHead

func (*SOSyncHead) EqualMessageVT 

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

func (*SOSyncHead) EqualVT 

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

func (*SOSyncHead) GetConfigHash 

func (x *SOSyncHead) GetConfigHash() []byte

func (*SOSyncHead) GetConfigSeqno 

func (x *SOSyncHead) GetConfigSeqno() uint64

func (*SOSyncHead) GetRevision 

func (x *SOSyncHead) GetRevision() uint64

func (*SOSyncHead) GetRootSeqno 

func (x *SOSyncHead) GetRootSeqno() uint64

func (*SOSyncHead) GetStateHash 

func (x *SOSyncHead) GetStateHash() []byte

func (*SOSyncHead) MarshalJSON 

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

MarshalJSON marshals the SOSyncHead to JSON.

func (*SOSyncHead) MarshalProtoJSON 

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

MarshalProtoJSON marshals the SOSyncHead message to JSON.

func (*SOSyncHead) MarshalProtoText 

func (x *SOSyncHead) MarshalProtoText() string

func (*SOSyncHead) MarshalToSizedBufferVT 

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

func (*SOSyncHead) MarshalToVT 

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

func (*SOSyncHead) MarshalVT 

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

func (*SOSyncHead) ProtoMessage 

func (*SOSyncHead) ProtoMessage()

func (*SOSyncHead) Reset 

func (x *SOSyncHead) Reset()

func (*SOSyncHead) SizeVT 

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

func (*SOSyncHead) String 

func (x *SOSyncHead) String() string

func (*SOSyncHead) UnmarshalJSON 

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

UnmarshalJSON unmarshals the SOSyncHead from JSON.

func (*SOSyncHead) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the SOSyncHead message from JSON.

func (*SOSyncHead) UnmarshalVT 

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

type SOSyncHistoryPage 

type SOSyncHistoryPage struct {

	// Revision identifies the pinned target advertisement.
	Revision uint64 `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"`
	// Cursor is the hash immediately before this page's first entry.
	Cursor []byte `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// Changes are contiguous, oldest-first signed transitions.
	Changes []*sobject.SOConfigChange `protobuf:"bytes,3,rep,name=changes,proto3" json:"changes,omitempty"`
	// contains filtered or unexported fields
}

SOSyncHistoryPage advances the request's cursor without adopting any state.

func (*SOSyncHistoryPage) CloneMessageVT 

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

func (*SOSyncHistoryPage) CloneVT 

func (m *SOSyncHistoryPage) CloneVT() *SOSyncHistoryPage

func (*SOSyncHistoryPage) EqualMessageVT 

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

func (*SOSyncHistoryPage) EqualVT 

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

func (*SOSyncHistoryPage) GetChanges 

func (x *SOSyncHistoryPage) GetChanges() []*sobject.SOConfigChange

func (*SOSyncHistoryPage) GetCursor 

func (x *SOSyncHistoryPage) GetCursor() []byte

func (*SOSyncHistoryPage) GetRevision 

func (x *SOSyncHistoryPage) GetRevision() uint64

func (*SOSyncHistoryPage) MarshalJSON 

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

MarshalJSON marshals the SOSyncHistoryPage to JSON.

func (*SOSyncHistoryPage) MarshalProtoJSON 

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

MarshalProtoJSON marshals the SOSyncHistoryPage message to JSON.

func (*SOSyncHistoryPage) MarshalProtoText 

func (x *SOSyncHistoryPage) MarshalProtoText() string

func (*SOSyncHistoryPage) MarshalToSizedBufferVT 

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

func (*SOSyncHistoryPage) MarshalToVT 

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

func (*SOSyncHistoryPage) MarshalVT 

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

func (*SOSyncHistoryPage) ProtoMessage 

func (*SOSyncHistoryPage) ProtoMessage()

func (*SOSyncHistoryPage) Reset 

func (x *SOSyncHistoryPage) Reset()

func (*SOSyncHistoryPage) SizeVT 

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

func (*SOSyncHistoryPage) String 

func (x *SOSyncHistoryPage) String() string

func (*SOSyncHistoryPage) UnmarshalJSON 

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

UnmarshalJSON unmarshals the SOSyncHistoryPage from JSON.

func (*SOSyncHistoryPage) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the SOSyncHistoryPage message from JSON.

func (*SOSyncHistoryPage) UnmarshalVT 

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

type SOSyncHistoryRequest 

type SOSyncHistoryRequest struct {

	// Revision identifies the peer's pinned advertisement.
	Revision uint64 `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"`
	// BaseHash identifies the receiver's exact trusted checkpoint.
	BaseHash []byte `protobuf:"bytes,2,opt,name=base_hash,json=baseHash,proto3" json:"baseHash,omitempty"`
	// contains filtered or unexported fields
}

SOSyncHistoryRequest requests one complete candidate rooted in held trust.

func (*SOSyncHistoryRequest) CloneMessageVT 

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

func (*SOSyncHistoryRequest) CloneVT 

func (m *SOSyncHistoryRequest) CloneVT() *SOSyncHistoryRequest

func (*SOSyncHistoryRequest) EqualMessageVT 

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

func (*SOSyncHistoryRequest) EqualVT 

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

func (*SOSyncHistoryRequest) GetBaseHash 

func (x *SOSyncHistoryRequest) GetBaseHash() []byte

func (*SOSyncHistoryRequest) GetRevision 

func (x *SOSyncHistoryRequest) GetRevision() uint64

func (*SOSyncHistoryRequest) MarshalJSON 

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

MarshalJSON marshals the SOSyncHistoryRequest to JSON.

func (*SOSyncHistoryRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the SOSyncHistoryRequest message to JSON.

func (*SOSyncHistoryRequest) MarshalProtoText 

func (x *SOSyncHistoryRequest) MarshalProtoText() string

func (*SOSyncHistoryRequest) MarshalToSizedBufferVT 

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

func (*SOSyncHistoryRequest) MarshalToVT 

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

func (*SOSyncHistoryRequest) MarshalVT 

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

func (*SOSyncHistoryRequest) ProtoMessage 

func (*SOSyncHistoryRequest) ProtoMessage()

func (*SOSyncHistoryRequest) Reset 

func (x *SOSyncHistoryRequest) Reset()

func (*SOSyncHistoryRequest) SizeVT 

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

func (*SOSyncHistoryRequest) String 

func (x *SOSyncHistoryRequest) String() string

func (*SOSyncHistoryRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the SOSyncHistoryRequest from JSON.

func (*SOSyncHistoryRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the SOSyncHistoryRequest message from JSON.

func (*SOSyncHistoryRequest) UnmarshalVT 

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

type SOSyncMessage 

type SOSyncMessage struct {

	// Body is the message body.
	//
	// Types that are assignable to Body:
	//	*SOSyncMessage_Snapshot
	//	*SOSyncMessage_Op
	//	*SOSyncMessage_Ack
	//	*SOSyncMessage_Challenge
	//	*SOSyncMessage_Proof
	//	*SOSyncMessage_Authorization
	//	*SOSyncMessage_Head
	//	*SOSyncMessage_HistoryRequest
	//	*SOSyncMessage_HistoryPage
	//	*SOSyncMessage_RecoveryRequired
	Body isSOSyncMessage_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

SOSyncMessage is the bidirectional message on the solicit stream.

func (*SOSyncMessage) CloneMessageVT 

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

func (*SOSyncMessage) CloneVT 

func (m *SOSyncMessage) CloneVT() *SOSyncMessage

func (*SOSyncMessage) EqualMessageVT 

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

func (*SOSyncMessage) EqualVT 

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

func (*SOSyncMessage) GetAck 

func (x *SOSyncMessage) GetAck() *SOSyncAck

func (*SOSyncMessage) GetAuthorization 

func (x *SOSyncMessage) GetAuthorization() *SOSyncAuthorization

func (*SOSyncMessage) GetBody 

func (m *SOSyncMessage) GetBody() isSOSyncMessage_Body

func (*SOSyncMessage) GetChallenge 

func (x *SOSyncMessage) GetChallenge() *SOSyncChallenge

func (*SOSyncMessage) GetHead 

func (x *SOSyncMessage) GetHead() *SOSyncHead

func (*SOSyncMessage) GetHistoryPage 

func (x *SOSyncMessage) GetHistoryPage() *SOSyncHistoryPage

func (*SOSyncMessage) GetHistoryRequest 

func (x *SOSyncMessage) GetHistoryRequest() *SOSyncHistoryRequest

func (*SOSyncMessage) GetOp 

func (x *SOSyncMessage) GetOp() *SOSyncOp

func (*SOSyncMessage) GetProof 

func (x *SOSyncMessage) GetProof() *peer.Signature

func (*SOSyncMessage) GetRecoveryRequired 

func (x *SOSyncMessage) GetRecoveryRequired() *SOSyncRecoveryRequired

func (*SOSyncMessage) GetSnapshot 

func (x *SOSyncMessage) GetSnapshot() *SOSyncSnapshot

func (*SOSyncMessage) MarshalJSON 

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

MarshalJSON marshals the SOSyncMessage to JSON.

func (*SOSyncMessage) MarshalProtoJSON 

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

MarshalProtoJSON marshals the SOSyncMessage message to JSON.

func (*SOSyncMessage) MarshalProtoText 

func (x *SOSyncMessage) MarshalProtoText() string

func (*SOSyncMessage) MarshalToSizedBufferVT 

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

func (*SOSyncMessage) MarshalToVT 

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

func (*SOSyncMessage) MarshalVT 

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

func (*SOSyncMessage) ProtoMessage 

func (*SOSyncMessage) ProtoMessage()

func (*SOSyncMessage) Reset 

func (x *SOSyncMessage) Reset()

func (*SOSyncMessage) SizeVT 

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

func (*SOSyncMessage) String 

func (x *SOSyncMessage) String() string

func (*SOSyncMessage) UnmarshalJSON 

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

UnmarshalJSON unmarshals the SOSyncMessage from JSON.

func (*SOSyncMessage) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the SOSyncMessage message from JSON.

func (*SOSyncMessage) UnmarshalVT 

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

type SOSyncMessage_Ack 

type SOSyncMessage_Ack struct {
	// Ack acknowledges receipt up to a sequence number.
	Ack *SOSyncAck `protobuf:"bytes,3,opt,name=ack,proto3,oneof"`
}

func (*SOSyncMessage_Ack) CloneOneofVT 

func (m *SOSyncMessage_Ack) CloneOneofVT() isSOSyncMessage_Body

func (*SOSyncMessage_Ack) CloneVT 

func (m *SOSyncMessage_Ack) CloneVT() *SOSyncMessage_Ack

func (*SOSyncMessage_Ack) EqualVT 

func (this *SOSyncMessage_Ack) EqualVT(thatIface isSOSyncMessage_Body) bool

func (*SOSyncMessage_Ack) MarshalToSizedBufferVT 

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

func (*SOSyncMessage_Ack) MarshalToVT 

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

func (*SOSyncMessage_Ack) SizeVT 

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

type SOSyncMessage_Authorization 

type SOSyncMessage_Authorization struct {
	// Authorization reports acceptance without revealing configuration data.
	Authorization *SOSyncAuthorization `protobuf:"bytes,6,opt,name=authorization,proto3,oneof"`
}

func (*SOSyncMessage_Authorization) CloneOneofVT 

func (m *SOSyncMessage_Authorization) CloneOneofVT() isSOSyncMessage_Body

func (*SOSyncMessage_Authorization) CloneVT 

func (m *SOSyncMessage_Authorization) CloneVT() *SOSyncMessage_Authorization

func (*SOSyncMessage_Authorization) EqualVT 

func (this *SOSyncMessage_Authorization) EqualVT(thatIface isSOSyncMessage_Body) bool

func (*SOSyncMessage_Authorization) MarshalToSizedBufferVT 

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

func (*SOSyncMessage_Authorization) MarshalToVT 

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

func (*SOSyncMessage_Authorization) SizeVT 

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

type SOSyncMessage_Challenge 

type SOSyncMessage_Challenge struct {
	// Challenge begins authentication without disclosing object state.
	Challenge *SOSyncChallenge `protobuf:"bytes,4,opt,name=challenge,proto3,oneof"`
}

func (*SOSyncMessage_Challenge) CloneOneofVT 

func (m *SOSyncMessage_Challenge) CloneOneofVT() isSOSyncMessage_Body

func (*SOSyncMessage_Challenge) CloneVT 

func (m *SOSyncMessage_Challenge) CloneVT() *SOSyncMessage_Challenge

func (*SOSyncMessage_Challenge) EqualVT 

func (this *SOSyncMessage_Challenge) EqualVT(thatIface isSOSyncMessage_Body) bool

func (*SOSyncMessage_Challenge) MarshalToSizedBufferVT 

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

func (*SOSyncMessage_Challenge) MarshalToVT 

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

func (*SOSyncMessage_Challenge) SizeVT 

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

type SOSyncMessage_Head 

type SOSyncMessage_Head struct {
	// Head advertises a pinned state after authentication.
	Head *SOSyncHead `protobuf:"bytes,7,opt,name=head,proto3,oneof"`
}

func (*SOSyncMessage_Head) CloneOneofVT 

func (m *SOSyncMessage_Head) CloneOneofVT() isSOSyncMessage_Body

func (*SOSyncMessage_Head) CloneVT 

func (m *SOSyncMessage_Head) CloneVT() *SOSyncMessage_Head

func (*SOSyncMessage_Head) EqualVT 

func (this *SOSyncMessage_Head) EqualVT(thatIface isSOSyncMessage_Body) bool

func (*SOSyncMessage_Head) MarshalToSizedBufferVT 

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

func (*SOSyncMessage_Head) MarshalToVT 

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

func (*SOSyncMessage_Head) SizeVT 

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

type SOSyncMessage_HistoryPage 

type SOSyncMessage_HistoryPage struct {
	// HistoryPage carries one bounded contiguous suffix page.
	HistoryPage *SOSyncHistoryPage `protobuf:"bytes,9,opt,name=history_page,json=historyPage,proto3,oneof"`
}

func (*SOSyncMessage_HistoryPage) CloneOneofVT 

func (m *SOSyncMessage_HistoryPage) CloneOneofVT() isSOSyncMessage_Body

func (*SOSyncMessage_HistoryPage) CloneVT 

func (m *SOSyncMessage_HistoryPage) CloneVT() *SOSyncMessage_HistoryPage

func (*SOSyncMessage_HistoryPage) EqualVT 

func (this *SOSyncMessage_HistoryPage) EqualVT(thatIface isSOSyncMessage_Body) bool

func (*SOSyncMessage_HistoryPage) MarshalToSizedBufferVT 

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

func (*SOSyncMessage_HistoryPage) MarshalToVT 

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

func (*SOSyncMessage_HistoryPage) SizeVT 

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

type SOSyncMessage_HistoryRequest 

type SOSyncMessage_HistoryRequest struct {
	// HistoryRequest asks for a suffix from the receiver's held checkpoint.
	HistoryRequest *SOSyncHistoryRequest `protobuf:"bytes,8,opt,name=history_request,json=historyRequest,proto3,oneof"`
}

func (*SOSyncMessage_HistoryRequest) CloneOneofVT 

func (m *SOSyncMessage_HistoryRequest) CloneOneofVT() isSOSyncMessage_Body

func (*SOSyncMessage_HistoryRequest) CloneVT 

func (m *SOSyncMessage_HistoryRequest) CloneVT() *SOSyncMessage_HistoryRequest

func (*SOSyncMessage_HistoryRequest) EqualVT 

func (this *SOSyncMessage_HistoryRequest) EqualVT(thatIface isSOSyncMessage_Body) bool

func (*SOSyncMessage_HistoryRequest) MarshalToSizedBufferVT 

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

func (*SOSyncMessage_HistoryRequest) MarshalToVT 

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

func (*SOSyncMessage_HistoryRequest) SizeVT 

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

type SOSyncMessage_Op 

type SOSyncMessage_Op struct {
	// Op carries a signed operation for the peer to apply.
	Op *SOSyncOp `protobuf:"bytes,2,opt,name=op,proto3,oneof"`
}

func (*SOSyncMessage_Op) CloneOneofVT 

func (m *SOSyncMessage_Op) CloneOneofVT() isSOSyncMessage_Body

func (*SOSyncMessage_Op) CloneVT 

func (m *SOSyncMessage_Op) CloneVT() *SOSyncMessage_Op

func (*SOSyncMessage_Op) EqualVT 

func (this *SOSyncMessage_Op) EqualVT(thatIface isSOSyncMessage_Body) bool

func (*SOSyncMessage_Op) MarshalToSizedBufferVT 

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

func (*SOSyncMessage_Op) MarshalToVT 

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

func (*SOSyncMessage_Op) SizeVT 

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

type SOSyncMessage_Proof 

type SOSyncMessage_Proof struct {
	// Proof binds the participant signing key to this transport exchange.
	Proof *peer.Signature `protobuf:"bytes,5,opt,name=proof,proto3,oneof"`
}

func (*SOSyncMessage_Proof) CloneOneofVT 

func (m *SOSyncMessage_Proof) CloneOneofVT() isSOSyncMessage_Body

func (*SOSyncMessage_Proof) CloneVT 

func (m *SOSyncMessage_Proof) CloneVT() *SOSyncMessage_Proof

func (*SOSyncMessage_Proof) EqualVT 

func (this *SOSyncMessage_Proof) EqualVT(thatIface isSOSyncMessage_Body) bool

func (*SOSyncMessage_Proof) MarshalToSizedBufferVT 

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

func (*SOSyncMessage_Proof) MarshalToVT 

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

func (*SOSyncMessage_Proof) SizeVT 

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

type SOSyncMessage_RecoveryRequired 

type SOSyncMessage_RecoveryRequired struct {
	// RecoveryRequired reports that trusted recovery must replace this exchange.
	RecoveryRequired *SOSyncRecoveryRequired `protobuf:"bytes,10,opt,name=recovery_required,json=recoveryRequired,proto3,oneof"`
}

func (*SOSyncMessage_RecoveryRequired) CloneOneofVT 

func (m *SOSyncMessage_RecoveryRequired) CloneOneofVT() isSOSyncMessage_Body

func (*SOSyncMessage_RecoveryRequired) CloneVT 

func (m *SOSyncMessage_RecoveryRequired) CloneVT() *SOSyncMessage_RecoveryRequired

func (*SOSyncMessage_RecoveryRequired) EqualVT 

func (this *SOSyncMessage_RecoveryRequired) EqualVT(thatIface isSOSyncMessage_Body) bool

func (*SOSyncMessage_RecoveryRequired) MarshalToSizedBufferVT 

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

func (*SOSyncMessage_RecoveryRequired) MarshalToVT 

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

func (*SOSyncMessage_RecoveryRequired) SizeVT 

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

type SOSyncMessage_Snapshot 

type SOSyncMessage_Snapshot struct {
	// Snapshot is a full SOState snapshot exchanged after mutual authentication.
	Snapshot *SOSyncSnapshot `protobuf:"bytes,1,opt,name=snapshot,proto3,oneof"`
}

func (*SOSyncMessage_Snapshot) CloneOneofVT 

func (m *SOSyncMessage_Snapshot) CloneOneofVT() isSOSyncMessage_Body

func (*SOSyncMessage_Snapshot) CloneVT 

func (m *SOSyncMessage_Snapshot) CloneVT() *SOSyncMessage_Snapshot

func (*SOSyncMessage_Snapshot) EqualVT 

func (this *SOSyncMessage_Snapshot) EqualVT(thatIface isSOSyncMessage_Body) bool

func (*SOSyncMessage_Snapshot) MarshalToSizedBufferVT 

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

func (*SOSyncMessage_Snapshot) MarshalToVT 

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

func (*SOSyncMessage_Snapshot) SizeVT 

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

type SOSyncOp 

type SOSyncOp struct {

	// Operation is the SOOperation proto bytes (MarshalVT).
	Operation []byte `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// Nonce is the sender's nonce counter.
	Nonce uint64 `protobuf:"varint,2,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// PeerId is the sender's peer ID (raw multihash bytes).
	PeerId []byte `protobuf:"bytes,3,opt,name=peer_id,json=peerId,proto3" json:"peerId,omitempty"`
	// contains filtered or unexported fields
}

SOSyncOp carries a signed operation for the peer to apply.

func (*SOSyncOp) CloneMessageVT 

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

func (*SOSyncOp) CloneVT 

func (m *SOSyncOp) CloneVT() *SOSyncOp

func (*SOSyncOp) EqualMessageVT 

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

func (*SOSyncOp) EqualVT 

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

func (*SOSyncOp) GetNonce 

func (x *SOSyncOp) GetNonce() uint64

func (*SOSyncOp) GetOperation 

func (x *SOSyncOp) GetOperation() []byte

func (*SOSyncOp) GetPeerId 

func (x *SOSyncOp) GetPeerId() []byte

func (*SOSyncOp) MarshalJSON 

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

MarshalJSON marshals the SOSyncOp to JSON.

func (*SOSyncOp) MarshalProtoJSON 

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

MarshalProtoJSON marshals the SOSyncOp message to JSON.

func (*SOSyncOp) MarshalProtoText 

func (x *SOSyncOp) MarshalProtoText() string

func (*SOSyncOp) MarshalToSizedBufferVT 

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

func (*SOSyncOp) MarshalToVT 

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

func (*SOSyncOp) MarshalVT 

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

func (*SOSyncOp) ProtoMessage 

func (*SOSyncOp) ProtoMessage()

func (*SOSyncOp) Reset 

func (x *SOSyncOp) Reset()

func (*SOSyncOp) SizeVT 

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

func (*SOSyncOp) String 

func (x *SOSyncOp) String() string

func (*SOSyncOp) UnmarshalJSON 

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

UnmarshalJSON unmarshals the SOSyncOp from JSON.

func (*SOSyncOp) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the SOSyncOp message from JSON.

func (*SOSyncOp) UnmarshalVT 

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

type SOSyncRecoveryRequired 

type SOSyncRecoveryRequired struct {

	// Revision identifies the advertisement whose history could not be supplied.
	Revision uint64 `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

SOSyncRecoveryRequired ends catch-up without changing receiver-held state.

func (*SOSyncRecoveryRequired) CloneMessageVT 

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

func (*SOSyncRecoveryRequired) CloneVT 

func (m *SOSyncRecoveryRequired) CloneVT() *SOSyncRecoveryRequired

func (*SOSyncRecoveryRequired) EqualMessageVT 

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

func (*SOSyncRecoveryRequired) EqualVT 

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

func (*SOSyncRecoveryRequired) GetRevision 

func (x *SOSyncRecoveryRequired) GetRevision() uint64

func (*SOSyncRecoveryRequired) MarshalJSON 

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

MarshalJSON marshals the SOSyncRecoveryRequired to JSON.

func (*SOSyncRecoveryRequired) MarshalProtoJSON 

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

MarshalProtoJSON marshals the SOSyncRecoveryRequired message to JSON.

func (*SOSyncRecoveryRequired) MarshalProtoText 

func (x *SOSyncRecoveryRequired) MarshalProtoText() string

func (*SOSyncRecoveryRequired) MarshalToSizedBufferVT 

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

func (*SOSyncRecoveryRequired) MarshalToVT 

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

func (*SOSyncRecoveryRequired) MarshalVT 

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

func (*SOSyncRecoveryRequired) ProtoMessage 

func (*SOSyncRecoveryRequired) ProtoMessage()

func (*SOSyncRecoveryRequired) Reset 

func (x *SOSyncRecoveryRequired) Reset()

func (*SOSyncRecoveryRequired) SizeVT 

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

func (*SOSyncRecoveryRequired) String 

func (x *SOSyncRecoveryRequired) String() string

func (*SOSyncRecoveryRequired) UnmarshalJSON 

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

UnmarshalJSON unmarshals the SOSyncRecoveryRequired from JSON.

func (*SOSyncRecoveryRequired) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the SOSyncRecoveryRequired message from JSON.

func (*SOSyncRecoveryRequired) UnmarshalVT 

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

type SOSyncSnapshot 

type SOSyncSnapshot struct {

	// SoState is the full SOState proto bytes (MarshalVT).
	SoState []byte `protobuf:"bytes,1,opt,name=so_state,json=soState,proto3" json:"soState,omitempty"`
	// RootSeqno is the inner_seqno from SORoot.
	RootSeqno uint64 `protobuf:"varint,2,opt,name=root_seqno,json=rootSeqno,proto3" json:"rootSeqno,omitempty"`
	// Revision binds this snapshot to the requested, pinned advertisement.
	Revision uint64 `protobuf:"varint,3,opt,name=revision,proto3" json:"revision,omitempty"`
	// BaseHash is the trusted checkpoint named by the request.
	BaseHash []byte `protobuf:"bytes,4,opt,name=base_hash,json=baseHash,proto3" json:"baseHash,omitempty"`
	// contains filtered or unexported fields
}

SOSyncSnapshot is a full SOState snapshot exchanged after mutual authentication.

func (*SOSyncSnapshot) CloneMessageVT 

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

func (*SOSyncSnapshot) CloneVT 

func (m *SOSyncSnapshot) CloneVT() *SOSyncSnapshot

func (*SOSyncSnapshot) EqualMessageVT 

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

func (*SOSyncSnapshot) EqualVT 

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

func (*SOSyncSnapshot) GetBaseHash 

func (x *SOSyncSnapshot) GetBaseHash() []byte

func (*SOSyncSnapshot) GetRevision 

func (x *SOSyncSnapshot) GetRevision() uint64

func (*SOSyncSnapshot) GetRootSeqno 

func (x *SOSyncSnapshot) GetRootSeqno() uint64

func (*SOSyncSnapshot) GetSoState 

func (x *SOSyncSnapshot) GetSoState() []byte

func (*SOSyncSnapshot) MarshalJSON 

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

MarshalJSON marshals the SOSyncSnapshot to JSON.

func (*SOSyncSnapshot) MarshalProtoJSON 

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

MarshalProtoJSON marshals the SOSyncSnapshot message to JSON.

func (*SOSyncSnapshot) MarshalProtoText 

func (x *SOSyncSnapshot) MarshalProtoText() string

func (*SOSyncSnapshot) MarshalToSizedBufferVT 

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

func (*SOSyncSnapshot) MarshalToVT 

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

func (*SOSyncSnapshot) MarshalVT 

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

func (*SOSyncSnapshot) ProtoMessage 

func (*SOSyncSnapshot) ProtoMessage()

func (*SOSyncSnapshot) Reset 

func (x *SOSyncSnapshot) Reset()

func (*SOSyncSnapshot) SizeVT 

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

func (*SOSyncSnapshot) String 

func (x *SOSyncSnapshot) String() string

func (*SOSyncSnapshot) UnmarshalJSON 

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

UnmarshalJSON unmarshals the SOSyncSnapshot from JSON.

func (*SOSyncSnapshot) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the SOSyncSnapshot message from JSON.

func (*SOSyncSnapshot) UnmarshalVT 

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

type SnapshotAccessValidator added in v0.57.2 

type SnapshotAccessValidator func(context.Context, *sobject.SOState) error

SnapshotAccessValidator verifies that the local object identity can decode an inbound snapshot before it replaces durable state.

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.