buffer

Documentation

Index

• type Digest
• type DigestBuffer
  • func WrapDigestBuffer(digestSlice []string) *DigestBuffer
  • func (digestBuffer *DigestBuffer) ContainsDigest(digest Digest) bool
  • func (digestBuffer *DigestBuffer) GetMissingDigests(b *DigestBuffer) *DigestBuffer
  • func (digestBuffer *DigestBuffer) GetMissingMessageBuffer(msgBuffer *MessageBuffer) *MessageBuffer
  • func (digestBuffer *DigestBuffer) Length() int
  • func (digestBuffer *DigestBuffer) SameDigests(b *DigestBuffer) bool
• type Message
  • func NewMessage(m interface{}, callbackType string) Message
• type MessageBuffer
  • func NewMessageBuffer() *MessageBuffer
  • func (msgBuffer *MessageBuffer) AddMessage(msg Message) error
  • func (msgBuffer *MessageBuffer) DigestBuffer() *DigestBuffer
  • func (msgBuffer *MessageBuffer) IncrementGossipCount()
  • func (msgBuffer *MessageBuffer) Length() int
  • func (msgBuffer *MessageBuffer) SameMessages(b *MessageBuffer) bool
  • func (msgBuffer *MessageBuffer) UnwrapMessageBuffer() []interface{}

Types

type Digest

type Digest struct {
	ID string `json:"digest_id"`
}

Digest is a digest of message

type DigestBuffer

type DigestBuffer struct {
	Digests []Digest `json:"digest_buffer_list"`
}

DigestBuffer is a digest buffer

func WrapDigestBuffer

func WrapDigestBuffer(digestSlice []string) *DigestBuffer

WrapDigestBuffer wraps []string into DigestBuffer

func (*DigestBuffer) ContainsDigest

func (digestBuffer *DigestBuffer) ContainsDigest(digest Digest) bool

ContainsDigest check if digest buffer contains the given digest

func (*DigestBuffer) GetMissingDigests

func (digestBuffer *DigestBuffer) GetMissingDigests(b *DigestBuffer) *DigestBuffer

GetMissingDigests returns the disjunction between the digest buffers digestBufferA - digestBufferB

func (*DigestBuffer) GetMissingMessageBuffer

func (digestBuffer *DigestBuffer) GetMissingMessageBuffer(msgBuffer *MessageBuffer) *MessageBuffer

GetMissingMessageBuffer returns messages buffer from given digest buffer

func (*DigestBuffer) Length

func (digestBuffer *DigestBuffer) Length() int

Length returns the length of digest buffer

func (*DigestBuffer) SameDigests

func (digestBuffer *DigestBuffer) SameDigests(b *DigestBuffer) bool

SameDigests returns true if given digest are same

type Message

type Message struct {
	ID           string      `json:"message_ID"`
	Msg          interface{} `json:"message_msg"`
	CallbackType string      `json:"message_callback_type"`
	GossipCount  int         `json:"message_gossip_count"`
}

Message is a message

func NewMessage

func NewMessage(m interface{}, callbackType string) Message

NewMessage creates new message

type MessageBuffer

type MessageBuffer struct {
	Messages []Message   `json:"message_buffer_list"`
	Mux      *sync.Mutex `json:"message_buffer_mux"`
}

MessageBuffer is the buffer with messages

func NewMessageBuffer

func NewMessageBuffer() *MessageBuffer

NewMessageBuffer creates new MessageBuffer

func (*MessageBuffer) AddMessage

func (msgBuffer *MessageBuffer) AddMessage(msg Message) error

AddMessage adds message in message buffer

func (*MessageBuffer) DigestBuffer

func (msgBuffer *MessageBuffer) DigestBuffer() *DigestBuffer

DigestBuffer returns a DigestBuffer from given buffer

func (*MessageBuffer) IncrementGossipCount

func (msgBuffer *MessageBuffer) IncrementGossipCount()

IncrementGossipCount increments gossip count for each message from message buffer

func (*MessageBuffer) Length

func (msgBuffer *MessageBuffer) Length() int

Length return the length of message buffer

func (*MessageBuffer) SameMessages

func (msgBuffer *MessageBuffer) SameMessages(b *MessageBuffer) bool

SameMessages returns true if given message buffer contains same messages

func (*MessageBuffer) UnwrapMessageBuffer

func (msgBuffer *MessageBuffer) UnwrapMessageBuffer() []interface{}

UnwrapMessageBuffer wraps a message buffer TODO write a test for this function