Documentation
¶
Index ¶
- Variables
- func CreateSvsNode(node *schema.Node) schema.NodeImpl
- type MissingData
- type SvsNode
- func (n *SvsNode) CastTo(ptr any) any
- func (n *SvsNode) GetDataName(mNode schema.MatchedNode, name []byte, seq uint64) enc.Name
- func (n *SvsNode) MissingDataChannel() chan MissingData
- func (n *SvsNode) MySequence() uint64
- func (n *SvsNode) NewData(mNode schema.MatchedNode, content enc.Wire) enc.Wire
- func (n *SvsNode) NodeImplTrait() schema.NodeImpl
- func (n *SvsNode) String() string
- type SyncState
Constants ¶
This section is empty.
Variables ¶
var SvsNodeDesc *schema.NodeImplDesc
Functions ¶
Types ¶
type SvsNode ¶
type SvsNode struct {
schema.BaseNodeImpl
OnMissingData *schema.EventTarget
SyncInterval time.Duration
SuppressionInterval time.Duration
BaseMatching enc.Matching
ChannelSize uint64
SelfName enc.Name
// contains filtered or unexported fields
}
SvsNode implements the StateVectorSync but works for only one instance. Similar is RegisterPolicy. A better implementation is needed if there is a need that multiple producers under the same name pattern that runs on the same application instance. It would also be more natural if we make 1-1 mapping between MatchedNodes and SVS instances, instead of the Node and the SVS instance, which is against the philosophy of matching. Also, this sample always starts from sequence number 0.
func (*SvsNode) CastTo ¶
(AI GENERATED DESCRIPTION): Returns the node as either a *SvsNode or its embedded *schema.BaseNodeImpl, or nil if the requested type is not supported.
func (*SvsNode) GetDataName ¶
(AI GENERATED DESCRIPTION): Generates a full data packet name by extending the matched node’s name with a given generic component followed by a sequence‑number component.
func (*SvsNode) MissingDataChannel ¶
func (n *SvsNode) MissingDataChannel() chan MissingData
(AI GENERATED DESCRIPTION): Provides direct access to the node’s `MissingData` channel, which emits notifications of missing data (use this channel rather than the OnMissingData callback).
func (*SvsNode) MySequence ¶
(AI GENERATED DESCRIPTION): Returns the node’s current sequence number.
func (*SvsNode) NewData ¶
(AI GENERATED DESCRIPTION): Creates a new Data packet with an incremented sequence number, updates the node’s local state vector, and broadcasts the state vector, returning the encoded packet (or empty if the provide operation fails).
func (*SvsNode) NodeImplTrait ¶
(AI GENERATED DESCRIPTION): Returns the SvsNode instance as a schema.NodeImpl.
Source Files