Versions in this module Expand all Collapse all v0 v0.2.0 Jan 3, 2026 v0.0.3 Dec 24, 2025 Changes in this version + const MsgTypeMigrationRequest + type Addr string + type CacheUpdateOperation struct + Addr string + Data []byte + NewState string + func (op *CacheUpdateOperation) Execute(nodeID int) error + type Event struct + Cycle uint64 + Details string + EventType string + MessageID *dataflow.MessageID + NodeID int + PacketSeq *int + type LocalNodeAccessor struct + func NewLocalNodeAccessor(n node.Node) *LocalNodeAccessor + func (a *LocalNodeAccessor) GetCache() cache.Cache + func (a *LocalNodeAccessor) GetDecoder() decoder.Decoder + func (a *LocalNodeAccessor) GetDirectory() directory.Directory + func (a *LocalNodeAccessor) GetNode() node.Node + func (a *LocalNodeAccessor) NodeID() int + type MigrationPayload struct + ResumeCh chan interface{} + TxnID string + YieldCh chan *YieldCommand + type MigrationResult struct + Message *message.Message + NodeAccessor NodeAccessor + type NodeAccessor interface + GetCache func() cache.Cache + GetDecoder func() decoder.Decoder + GetDirectory func() directory.Directory + GetNode func() node.Node + NodeID func() int + type Operation interface + Execute func(nodeID int) error + type Protocol string + const ProtocolAXI + const ProtocolCHI + const ProtocolCXL + type Transaction struct + CompletedCycle uint64 + CreatedCycle uint64 + Events []Event + ID dataflow.TransactionID + InitiatorNodeID int + Messages []*message.Message + Protocol Protocol + State TransactionState + Type int + type TransactionState string + const TransactionStateCompleted + const TransactionStateFailed + const TransactionStateInProgress + const TransactionStatePending + type TxnContext struct + func NewTxnContext(nodeID int, txnID dataflow.TransactionID, yieldCh chan *YieldCommand, ...) *TxnContext + func (tc *TxnContext) Complete(result interface{}) error + func (tc *TxnContext) GetCache() cache.Cache + func (tc *TxnContext) GetDecoder() decoder.Decoder + func (tc *TxnContext) GetDirectory() directory.Directory + func (tc *TxnContext) GetNode() node.Node + func (tc *TxnContext) MigrateTo(targetNodeID int) (*TxnContext, error) + func (tc *TxnContext) NodeID() int + func (tc *TxnContext) Send(msg *message.Message) error + func (tc *TxnContext) SendAndWait(msg *message.Message) error + func (tc *TxnContext) TxnID() dataflow.TransactionID + func (tc *TxnContext) Yield(cmd *YieldCommand) (interface{}, error) + type TxnManager struct + func NewTxnManager(n node.Node) *TxnManager + func (tm *TxnManager) ActiveCount() int + func (tm *TxnManager) GetTransaction(txnID dataflow.TransactionID) *Transaction + func (tm *TxnManager) Start(ctx context.Context, txnFunc func(*TxnContext)) dataflow.TransactionID + func (tm *TxnManager) Tick(cycle uint64, incoming []*message.Message) ([]*message.Message, error) + type WaitForMessage struct + Addr string + SourceID *int + TargetID *int + Type int + type YieldCommand struct + MigrateToNodeID int + Operations []Operation + SendQueue []*message.Message + Timeout time.Duration + Type YieldType + WaitFor *WaitForMessage + type YieldType string + const YieldTypeComplete + const YieldTypeMigrateTo + const YieldTypeSendAndWait + const YieldTypeSendOnly + const YieldTypeWaitForMessage + const YieldTypeWaitForTimeout
Go to main page