internal

package
v1.4.1 Latest Latest
Warning

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

 Go to latest Published: Jan 16, 2025 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MessageTypeInternal messaging.MessageType = 0xFFFF_0000 + iota

	// MessageTypeNetworkUpdate is an update to a network account that has been
	// pushed from the DN via an anchor.
	MessageTypeNetworkUpdate

	// MessageTypeMessageIsReady indicates that a message is ready to be
	// processed.
	MessageTypeMessageIsReady

	// MessageTypePseudoSynthetic wraps produced messages between accounts in
	// the same domain that would otherwise be synthetic.
	MessageTypePseudoSynthetic

	// MessageTypeExpiredTransaction expires a pending transaction.
	MessageTypeExpiredTransaction

	// MessageTypeNetworkMaintenanceOp executes a network maintenance operation.
	MessageTypeNetworkMaintenanceOp
)

Variables

This section is empty.

Functions

func NewDatabaseObserver 

func NewDatabaseObserver() database.Observer

Types

type ExpiredTransaction added in v1.2.0 

type ExpiredTransaction struct {
	TxID *url.TxID
	// contains filtered or unexported fields
}

ExpiredTransaction expires a pending transaction.

func (*ExpiredTransaction) CopyAsInterface added in v1.2.0 

func (m *ExpiredTransaction) CopyAsInterface() any

func (*ExpiredTransaction) Hash added in v1.2.0 

func (m *ExpiredTransaction) Hash() [32]byte

func (*ExpiredTransaction) ID added in v1.2.0 

func (m *ExpiredTransaction) ID() *url.TxID

func (ExpiredTransaction) MarshalBinary added in v1.2.0 

func (ExpiredTransaction) MarshalBinary() (data []byte, err error)

MarshalBinary returns an error.

func (*ExpiredTransaction) Type added in v1.2.0 

func (m *ExpiredTransaction) Type() messaging.MessageType

func (ExpiredTransaction) UnmarshalBinary added in v1.2.0 

func (ExpiredTransaction) UnmarshalBinary(data []byte) error

UnmarshalBinary returns an error.

func (ExpiredTransaction) UnmarshalBinaryFrom added in v1.2.0 

func (ExpiredTransaction) UnmarshalBinaryFrom(io.Reader) error

UnmarshalBinaryFrom returns an error.

func (ExpiredTransaction) UnmarshalFieldsFrom added in v1.2.0 

func (ExpiredTransaction) UnmarshalFieldsFrom(*encoding.Reader) error

UnmarshalFieldsFrom returns an error.

type MessageIsReady 

type MessageIsReady struct {
	TxID *url.TxID
	// contains filtered or unexported fields
}

MessageIsReady indicates that the transaction is ready to be executed.

func (*MessageIsReady) CopyAsInterface 

func (m *MessageIsReady) CopyAsInterface() any

func (MessageIsReady) Hash 

func (MessageIsReady) Hash() [32]byte

Hash panics.

func (*MessageIsReady) ID 

func (m *MessageIsReady) ID() *url.TxID

func (MessageIsReady) MarshalBinary 

func (MessageIsReady) MarshalBinary() (data []byte, err error)

MarshalBinary returns an error.

func (*MessageIsReady) Type 

func (m *MessageIsReady) Type() messaging.MessageType

func (MessageIsReady) UnmarshalBinary 

func (MessageIsReady) UnmarshalBinary(data []byte) error

UnmarshalBinary returns an error.

func (MessageIsReady) UnmarshalBinaryFrom 

func (MessageIsReady) UnmarshalBinaryFrom(io.Reader) error

UnmarshalBinaryFrom returns an error.

func (MessageIsReady) UnmarshalFieldsFrom 

func (MessageIsReady) UnmarshalFieldsFrom(*encoding.Reader) error

UnmarshalFieldsFrom returns an error.

type NetworkMaintenanceOp added in v1.3.0 

type NetworkMaintenanceOp struct {
	Cause     *url.TxID
	Operation protocol.NetworkMaintenanceOperation
	// contains filtered or unexported fields
}

NetworkMaintenanceOp expires a network maintenance operation.

func (*NetworkMaintenanceOp) CopyAsInterface added in v1.3.0 

func (m *NetworkMaintenanceOp) CopyAsInterface() any

func (*NetworkMaintenanceOp) Hash added in v1.3.0 

func (m *NetworkMaintenanceOp) Hash() [32]byte

func (*NetworkMaintenanceOp) ID added in v1.3.0 

func (m *NetworkMaintenanceOp) ID() *url.TxID

func (NetworkMaintenanceOp) MarshalBinary added in v1.3.0 

func (NetworkMaintenanceOp) MarshalBinary() (data []byte, err error)

MarshalBinary returns an error.

func (*NetworkMaintenanceOp) Type added in v1.3.0 

func (m *NetworkMaintenanceOp) Type() messaging.MessageType

func (NetworkMaintenanceOp) UnmarshalBinary added in v1.3.0 

func (NetworkMaintenanceOp) UnmarshalBinary(data []byte) error

UnmarshalBinary returns an error.

func (NetworkMaintenanceOp) UnmarshalBinaryFrom added in v1.3.0 

func (NetworkMaintenanceOp) UnmarshalBinaryFrom(io.Reader) error

UnmarshalBinaryFrom returns an error.

func (NetworkMaintenanceOp) UnmarshalFieldsFrom added in v1.3.0 

func (NetworkMaintenanceOp) UnmarshalFieldsFrom(*encoding.Reader) error

UnmarshalFieldsFrom returns an error.

type NetworkUpdate 

type NetworkUpdate struct {
	Cause   [32]byte
	Account *url.URL
	Body    protocol.TransactionBody
	// contains filtered or unexported fields
}

NetworkUpdate is an update to a network account that has been pushed from the DN via an anchor.

func (*NetworkUpdate) CopyAsInterface 

func (m *NetworkUpdate) CopyAsInterface() any

func (NetworkUpdate) Hash 

func (NetworkUpdate) Hash() [32]byte

Hash panics.

func (*NetworkUpdate) ID 

func (m *NetworkUpdate) ID() *url.TxID

func (NetworkUpdate) MarshalBinary 

func (NetworkUpdate) MarshalBinary() (data []byte, err error)

MarshalBinary returns an error.

func (*NetworkUpdate) Type 

func (m *NetworkUpdate) Type() messaging.MessageType

func (NetworkUpdate) UnmarshalBinary 

func (NetworkUpdate) UnmarshalBinary(data []byte) error

UnmarshalBinary returns an error.

func (NetworkUpdate) UnmarshalBinaryFrom 

func (NetworkUpdate) UnmarshalBinaryFrom(io.Reader) error

UnmarshalBinaryFrom returns an error.

func (NetworkUpdate) UnmarshalFieldsFrom 

func (NetworkUpdate) UnmarshalFieldsFrom(*encoding.Reader) error

UnmarshalFieldsFrom returns an error.

type PseudoSynthetic 

type PseudoSynthetic struct {
	Message messaging.Message
	// contains filtered or unexported fields
}

PseudoSynthetic wraps produced messages between accounts in the same domain that would otherwise be synthetic.

func (*PseudoSynthetic) CopyAsInterface 

func (m *PseudoSynthetic) CopyAsInterface() any

func (PseudoSynthetic) Hash 

func (PseudoSynthetic) Hash() [32]byte

Hash panics.

func (*PseudoSynthetic) ID 

func (m *PseudoSynthetic) ID() *url.TxID

func (PseudoSynthetic) MarshalBinary 

func (PseudoSynthetic) MarshalBinary() (data []byte, err error)

MarshalBinary returns an error.

func (*PseudoSynthetic) Type 

func (m *PseudoSynthetic) Type() messaging.MessageType

func (PseudoSynthetic) UnmarshalBinary 

func (PseudoSynthetic) UnmarshalBinary(data []byte) error

UnmarshalBinary returns an error.

func (PseudoSynthetic) UnmarshalBinaryFrom 

func (PseudoSynthetic) UnmarshalBinaryFrom(io.Reader) error

UnmarshalBinaryFrom returns an error.

func (PseudoSynthetic) UnmarshalFieldsFrom 

func (PseudoSynthetic) UnmarshalFieldsFrom(*encoding.Reader) error

UnmarshalFieldsFrom returns an error.

func (*PseudoSynthetic) Unwrap 

func (m *PseudoSynthetic) Unwrap() messaging.Message

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.