Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type AckTable ¶
type AckTable struct {
// contains filtered or unexported fields
}
func NewAckTracker ¶
func NewAckTracker() *AckTable
func (*AckTable) GetNumAcks ¶
type MessageHeap ¶
func (MessageHeap) IsEmpty ¶
func (queue MessageHeap) IsEmpty() bool
func (MessageHeap) Len ¶
func (queue MessageHeap) Len() int
func (MessageHeap) Less ¶
func (queue MessageHeap) Less(i, j int) bool
func (MessageHeap) Peek ¶
func (queue MessageHeap) Peek() *pb.MessageVC
func (*MessageHeap) Pop ¶
func (queue *MessageHeap) Pop() interface{}
func (*MessageHeap) Push ¶
func (queue *MessageHeap) Push(x interface{})
func (MessageHeap) Swap ¶
func (queue MessageHeap) Swap(i, j int)
type MessageTable ¶
type MessageTable struct {
// contains filtered or unexported fields
}
func NewMessageTable ¶
func NewMessageTable(groupsize int) *MessageTable
func (*MessageTable) IsReady ¶
func (table *MessageTable) IsReady(messageID string) (bool, error)
IsReady:
La funzione IsReady si occupa di stabilire se un messaggio è pronto per essere rilasciato all utente oppure no. Controlla che il messaggio input abbia ricevuto tutti gli ack e che non ci siano messaggi in arrivo con clock minore del suo.
func (*MessageTable) Remove ¶
func (table *MessageTable) Remove(messageID string) error
type MessageVCFIFO ¶
type MessageVCFIFO struct {
// contains filtered or unexported fields
}
func NewMessageVCFifo ¶
func NewMessageVCFifo() *MessageVCFIFO
func (*MessageVCFIFO) Len ¶
func (queue *MessageVCFIFO) Len() int
func (*MessageVCFIFO) Pop ¶
func (queue *MessageVCFIFO) Pop() *api.MessageVC
func (*MessageVCFIFO) Push ¶
func (queue *MessageVCFIFO) Push(message *api.MessageVC)
type MessageVCRecvQueue ¶
type MessageVCRecvQueue struct {
// contains filtered or unexported fields
}
func NewMessageVCRecvQueue ¶
func NewMessageVCRecvQueue(groups []string, verbose bool) *MessageVCRecvQueue
func (*MessageVCRecvQueue) IsEmpty ¶
func (queue *MessageVCRecvQueue) IsEmpty() bool
func (*MessageVCRecvQueue) Len ¶
func (queue *MessageVCRecvQueue) Len() int
func (*MessageVCRecvQueue) Pop ¶
func (queue *MessageVCRecvQueue) Pop() *pb.MessageVC
type TableEntry ¶
type TableEntry struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.