raft

Oct 15, 2024

Changes in this version

type FSMResponse

+ Group string

Oct 9, 2024

Changes in this version

type Node

+ func (n *Node) Nack(QueueName string, id uint64) error

Oct 2, 2024

Changes in this version

type Node

+ func (n *Node) GetQueueInfo(queueName string) (*queue.QueueInfo, error)

+ func (n *Node) GetQueues() []*queue.QueueInfo

+ func (node *Node) PrometheusRegistry() prometheus.Registerer

Sep 29, 2024

Changes in this version

+ type AckPayload struct

+ ID uint64

+ QueueName string

type Command

+ Payload interface{}

+ func (c *Command) UnmarshalJSON(data []byte) error

+ func (c Command) MarshalJSON() ([]byte, error)

+ type CreateQueuePayload struct

+ QueueName string

+ QueueType string

+ type DeleteQueuePayload struct

+ QueueName string

+ type DequeuePayload struct

+ Ack bool

+ QueueName string

+ type EnqueuePayload struct

+ Content string

+ Group string

+ ID uint64

+ Priority int64

+ QueueName string

type FSMSnapshot

+ NodeID string

+ type NackPayload struct

+ ID uint64

+ QueueName string

type Node

+ func (node *Node) GenerateID() uint64

+ func (node *Node) InitIDGenerator() error

+ type UpdatePriorityPayload struct

+ ID uint64

+ Priority int64

+ QueueName string

Sep 5, 2024

Changes in this version

+ type Command struct

+ Ack bool

+ Content string

+ Group string

+ ID uint64

+ Op string

+ Priority int64

+ QueueName string

+ QueueType string

+ type FSM struct

+ NodeID string

+ func (f *FSM) Apply(raftLog *raft.Log) interface{}

+ func (f *FSM) Restore(rc io.ReadCloser) error

+ func (f *FSM) Snapshot() (raft.FSMSnapshot, error)

+ type FSMResponse struct

+ Content string

+ ID uint64

+ Priority int64

+ QueueName string

+ type FSMSnapshot struct

+ func (f *FSMSnapshot) Persist(sink raft.SnapshotSink) error

+ func (f *FSMSnapshot) Release()

+ type Node struct

+ QueueManager *queue.QueueManager

+ Raft *raft.Raft

+ func NewNode(db *badger.DB, raftDir string, id, address, raftPort string, peers []string) *Node

+ func (n *Node) Ack(QueueName string, id uint64) error

+ func (n *Node) CreateQueue(queueType, queueName string) error

+ func (n *Node) DeleteQueue(queueName string) error

+ func (n *Node) Dequeue(QueueName string, ack bool) (*queue.Message, error)

+ func (n *Node) Enqueue(queueName string, group string, priority int64, content string) (*queue.Message, error)

+ func (n *Node) GetByID(id uint64) (*queue.Message, error)

+ func (n *Node) IsLeader() bool

+ func (n *Node) Join(nodeID, addr string) error

+ func (n *Node) Leader() string

+ func (n *Node) UpdatePriority(queueName string, id uint64, priority int64) error

+ func (node *Node) Initialize()

+ func (node *Node) ListenToLeaderChanges()

+ func (node *Node) SetLeaderChangeFunc(leaderChangeFn func(bool))