README
¶
Golang HA Stack
Share a thread-safe FIFO Stack across multiple hosts. HA Stack use Redis as backend and helps you to push and pop elements in your stack.
Open or connect to a Stack
Each stack have a logical name, a is accessible through redis.
stack, err := hastack.Connect("mystack", "localhost:6379", "", 3, 100)
Push
stack, _ := hastack.Connect("mystack", "localhost:6379", "", 3, 100)
var data myData{
...,
}
s.Push(data)
Pop
stack, _ := hastack.Connect("mystack", "localhost:6379", "", 3, 100)
var data myData{}
err := s.Pop(&data) //can be nil is there is no data in the stack
Blocking Pop
stack, _ = hastack.Connect("mystack", "localhost:6379", "", 3, 100)
var data myData{}
err := s.BPop(&data) //This will block the thread until data can be poped
Documentation
¶
Overview ¶
Package hastack aims to share a thread-safe FIFO Stack across multiple hosts. HA Stack use Redis as backend and helps you to push and pop elements in your stack. See https://github.com/fsamin/go-hastack for sample usages.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Stack ¶
type Stack struct {
// contains filtered or unexported fields
}
Stack serves as a collection of elements, with two principal operations: push, which adds an element to the collection, and pop, which removes the most recently added element that was not yet removed. Hastack uses Redis ad backend and ensures thread-safe access to enable high availability capacities Import this as dependencies to manage a thread-safe FIFO Stack across multiple hosts
func (*Stack) InboxLength ¶
InboxLength returns size of pending message
func (*Stack) OutboxLength ¶
OutboxLength returns size of computed message
Source Files