Documentation ¶
Index ¶
Constants ¶
View Source
const ( // MessageNoAction means messages have no relation MessageNoAction = iota // MessageInvalidates means message invalidates the other message MessageInvalidates // MessageInvalidated means message is invalidated by the other message MessageInvalidated )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type InvalidationResult ¶
type InvalidationResult int
InvalidationResult determines how a message affects another message when it is put into gossip message store
type MessageAcceptor ¶
type MessageAcceptor func(interface{}) bool
MessageAcceptor is a predicate that is used to determine in which messages the subscriber that created the instance of the MessageAcceptor is interested in.
type MessageReplacingPolicy ¶
type MessageReplacingPolicy func(this interface{}, that interface{}) InvalidationResult
MessageReplacingPolicy Returns: MESSAGE_INVALIDATES if this message invalidates that MESSAGE_INVALIDATED if this message is invalidated by that MESSAGE_NO_ACTION otherwise
Click to show internal directories.
Click to hide internal directories.