buffer

Documentation

Index

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

Types

type Digest

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

type DigestBuffer

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

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 (a *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 (a *DigestBuffer) SameDigests(b *DigestBuffer) bool

SameDigests returns true if given digest are same

type Message

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

func NewMessage

func NewMessage(m, callbackType string) Message

type MessageBuffer

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

func NewMessageBuffer

func NewMessageBuffer() *MessageBuffer

NewMessageBuffer creates new MessageBuffer

func (*MessageBuffer) AddMessage

func (msgBuffer *MessageBuffer) AddMessage(msg Message)

AddMessage adds message in message buffer

func (*MessageBuffer) DigestBuffer

func (msgBuffer *MessageBuffer) DigestBuffer() *DigestBuffer

Digest returns a slice with ID of messages from given buffer

func (*MessageBuffer) IncrementGossipCount

func (msgBuffer *MessageBuffer) IncrementGossipCount()

IncrementGossipCount increments gossip count for each message from message buffer

func (*MessageBuffer) SameMessages

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

func (*MessageBuffer) UnwrapMessageBuffer

func (msgBuffer *MessageBuffer) UnwrapMessageBuffer() []string

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