tangle

package

Go to main page

Versions in this module

v0

v0.2.4

Sep 3, 2020

v0.2.3

Aug 11, 2020

Changes in this version

type Approver

+ func (approver *Approver) ApproverMessageID() message.ID

+ func (approver *Approver) ReferencedMessageID() message.ID

type MissingMessage

+ func (missingMessage *MissingMessage) MessageID() message.ID

v0.2.2

Jul 27, 2020

Changes in this version

type MessageMetadata

+ func (messageMetadata *MessageMetadata) ReceivedTime() time.Time

type Tangle

+ func (tangle *Tangle) DBStats() (solidCount int, messageCount int, avgSolidificationTime float64, ...)

+ func (tangle *Tangle) DeleteMissingMessage(messageID message.Id)

+ func (tangle *Tangle) MissingMessages() (ids []message.Id)

+ func (tangle *Tangle) RetrieveAllTips() (tips []message.Id)

+ func (tangle *Tangle) SolidifierWorkerPoolStatus() (name string, load int)

+ func (tangle *Tangle) StoreMessageWorkerPoolStatus() (name string, load int)

v0.2.1

Jul 1, 2020

v0.2.0

Jun 30, 2020

Changes in this version

+ const MaxMissingTimeBeforeCleanup

+ const MissingCheckInterval

+ const PrefixApprovers

+ const PrefixMessage

+ const PrefixMessageMetadata

+ const PrefixMissingMessage

+ func ApproverFromStorageKey(key []byte, optionalTargetObject ...*Approver) (result objectstorage.StorableObject, consumedBytes int, err error)

+ func MessageMetadataFromStorageKey(key []byte) (result objectstorage.StorableObject, consumedBytes int, err error)

+ func MissingMessageFromStorageKey(key []byte, optionalTargetObject ...*MissingMessage) (result objectstorage.StorableObject, consumedBytes int, err error)

+ type Approver struct

+ func ApproverFromBytes(bytes []byte, optionalTargetObject ...*Approver) (result *Approver, err error, consumedBytes int)

+ func NewApprover(referencedMessageId message.Id, approverMessageId message.Id) *Approver

+ func ParseApprover(marshalUtil *marshalutil.MarshalUtil, optionalTargetObject ...*Approver) (result *Approver, err error)

+ func (approver *Approver) ApproverMessageId() message.Id

+ func (approver *Approver) Bytes() []byte

+ func (approver *Approver) ObjectStorageKey() []byte

+ func (approver *Approver) ObjectStorageValue() (result []byte)

+ func (approver *Approver) ReferencedMessageId() message.Id

+ func (approver *Approver) String() string

+ func (approver *Approver) UnmarshalObjectStorageValue(data []byte) (consumedBytes int, err error)

+ func (approver *Approver) Update(other objectstorage.StorableObject)

+ type CachedApprover struct

+ func (cachedApprover *CachedApprover) Consume(consumer func(approver *Approver)) (consumed bool)

+ func (cachedApprover *CachedApprover) Unwrap() *Approver

+ type CachedApprovers []*CachedApprover

+ func (cachedApprovers CachedApprovers) Consume(consumer func(approver *Approver)) (consumed bool)

+ type CachedMessageMetadata struct

+ func (cachedMessageMetadata *CachedMessageMetadata) Retain() *CachedMessageMetadata

+ func (cachedMessageMetadata *CachedMessageMetadata) Unwrap() *MessageMetadata

+ type Events struct

+ MessageAttached *events.Event

+ MessageMissing *events.Event

+ MessageRemoved *events.Event

+ MessageSolid *events.Event

+ MessageUnsolidifiable *events.Event

+ MissingMessageReceived *events.Event

+ type MessageMetadata struct

+ func MessageMetadataFromBytes(bytes []byte) (result *MessageMetadata, err error, consumedBytes int)

+ func NewMessageMetadata(messageId message.Id) *MessageMetadata

+ func ParseMessageMetadata(marshalUtil *marshalutil.MarshalUtil) (result *MessageMetadata, err error)

+ func (messageMetadata *MessageMetadata) IsSolid() (result bool)

+ func (messageMetadata *MessageMetadata) ObjectStorageKey() []byte

+ func (messageMetadata *MessageMetadata) ObjectStorageValue() []byte

+ func (messageMetadata *MessageMetadata) SetSolid(solid bool) (modified bool)

+ func (messageMetadata *MessageMetadata) SolidificationTime() time.Time

+ func (messageMetadata *MessageMetadata) UnmarshalObjectStorageValue(data []byte) (consumedBytes int, err error)

+ func (messageMetadata *MessageMetadata) Update(other objectstorage.StorableObject)

+ type MissingMessage struct

+ func NewMissingMessage(messageId message.Id) *MissingMessage

+ func (missingMessage *MissingMessage) MessageId() message.Id

+ func (missingMessage *MissingMessage) MissingSince() time.Time

+ func (missingMessage *MissingMessage) ObjectStorageKey() []byte

+ func (missingMessage *MissingMessage) ObjectStorageValue() (result []byte)

+ func (missingMessage *MissingMessage) UnmarshalObjectStorageValue(data []byte) (consumedBytes int, err error)

+ func (missingMessage *MissingMessage) Update(other objectstorage.StorableObject)

+ type Tangle struct

+ Events Events

+ func New(store kvstore.KVStore) (result *Tangle)

+ func (tangle *Tangle) Approvers(messageId message.Id) CachedApprovers

+ func (tangle *Tangle) AttachMessage(msg *message.Message)

+ func (tangle *Tangle) DeleteMessage(messageId message.Id)

+ func (tangle *Tangle) Message(messageId message.Id) *message.CachedMessage

+ func (tangle *Tangle) MessageMetadata(messageId message.Id) *CachedMessageMetadata

+ func (tangle *Tangle) MonitorMissingMessages(shutdownSignal <-chan struct{})

+ func (tangle *Tangle) Prune() error

+ func (tangle *Tangle) Shutdown() *Tangle

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL