lineup, a tiny queue server lineup is a very simple queue server. all it does is serve a binary-safe priority queue with a simple protocol inspired by redis and memcached. it's designed to be as small, simple, and hackable as possible. why? most of the reasons i made this are personal. - i wanted to - i learned a lot there are some pragmatic reasons too! - minimalist codebase - i don't agree with how other queue servers are implemented (except maybe resque) - i didn't make the other ones i kept lineup as simple as possible, because it needed to be that way. stuff like job timeouts, multiple queues, etc. can all be managed by client code. if your job takes too long, just stop processing and requeue it. want multiple queues? run multiple instances of lineupd. that's not to say that lineupd is complete, not to any degree. usage run lineupd and it will listen on :9876, and create a logfile lineupd.log and pidfile lineupd.pid. if you want to explicitly set any options, there are --port, --logfile, and --pidfile command line options. there is also the --timeout option, which sets the number of seconds to wait to disconnect an idle client. bugs - the --daemonize option doesn't work yet. most of the code is there, but i can't find a plain old fork() call in the go stdlib. help here would be great. credits (c) 2009 justin poliey http://justinpoliey.com inspired by: redis http://code.google.com/p/redis memcached http://memcached.org beanstalkd http://kr.github.com/beanstalkd suckless http://suckless.org
A minimalistic message queue server, in Go
Owner
Justin Poliey
Similar Resources
Phalanx is a cloud-native full-text search and indexing server written in Go built on top of Bluge that provides endpoints through gRPC and traditional RESTful API.
Phalanx Phalanx is a cloud-native full-text search and indexing server written in Go built on top of Bluge that provides endpoints through gRPC and tr
A server for TurboRepo Remote Cache to store cache artefacts in Google Cloud Storage or Amazon S3
Tapico Turborepo Remote Cache This is an implementation of Vercel's Turborepo Remote Cache API endpoints used by the turborepo CLI command. This solut
Temporal Server docker-compose files
Temporal Server docker-compose files This repository provides docker-compose fil
Transcoder - This package implements a transcoding server
muxable/transcoder This package implements a transcoding server. It accepts WebR
Embedded javascript server-side renderer for Golang
v8ssr Embedded javascript server-side renderer for Golang. Useful for static server-side rendering. This does not attempt to polyfill node or browser
Forklift: an API application developed with go that enables virtual server migration from vcenter virtualization environment to openstack environment
What is the Forklift? Forklift is an API application developed with go that enables virtual server migration from vcenter virtualization environment t
Machinery is an asynchronous task queue/job queue based on distributed message passing.
Machinery Machinery is an asynchronous task queue/job queue based on distributed message passing. V2 Experiment First Steps Configuration Lock Broker
Machinery is an asynchronous task queue/job queue based on distributed message passing.
Machinery Machinery is an asynchronous task queue/job queue based on distributed message passing. V2 Experiment First Steps Configuration Lock Broker
A Multi Consumer per Message Queue with persistence and Queue Stages.
CrimsonQ A Multi Consumer per Message Queue with persistence and Queue Stages. Under Active Development Crimson Queue allows you to have multiple cons
Priority queue with message-group based partitioning and equal attention guarantee for each message group based on Redis
redis-ordered-queue-go Priority queue with message-group based partitioning and equal attention guarantee for each message group based on Redis What i
Prometheus Common Data Exporter can parse JSON, XML, yaml or other format data from various sources (such as HTTP response message, local file, TCP response message and UDP response message) into Prometheus metric data.
Prometheus Common Data Exporter Prometheus Common Data Exporter 用于将多种来源(如http响应报文、本地文件、TCP响应报文、UDP响应报文)的Json、xml、yaml或其它格式的数据,解析为Prometheus metric数据。
Unlimited job queue for go, using a pool of concurrent workers processing the job queue entries
kyoo: A Go library providing an unlimited job queue and concurrent worker pools About kyoo is the phonetic transcription of the word queue. It provide
painless task queue manager for shell commands with an intuitive cli interface (execute shell commands in distributed cloud-native queue manager).
EXEQ DOCS STILL IN PROGRESS. Execute shell commands in queues via cli or http interface. Features Simple intuitive tiny cli app. Modular queue backend
A single binary, simple, message queue.
MiniQueue A stupid simple, single binary message queue using HTTP/2. Most messaging workloads don't require enormous amounts of data, endless features
Sandglass is a distributed, horizontally scalable, persistent, time sorted message queue.
Sandglass is a distributed, horizontally scalable, persistent, time ordered message queue. It was developed to support asynchronous tasks and message
A lightweight, distributed and reliable message queue based on Redis
nmq A lightweight, distributed and reliable message queue based on Redis Get Started Download go get github.com/inuggets/nmq Usage import "github.com
KubeMQ is a Kubernetes native message queue broker
KubeMQ Community is the open-source version of KubeMQ, the Kubernetes native message broker. More about KubeMQ
Simple docker container to publish a fixed message to a specified queue. Created to be used with k8s CRON scheduling.
RabbitMQ Publish CRON Simple docker container to publish a fixed message to a specified rabbitmq exchange. Created to be used as part of a Kubernetes
Read metrics from a Message Queue in Json format and expose them in a Prometheus compatible format
mq2prom Read metrics from a Message Queue in Json format and expose them in a Prometheus compatible format. Currently only works for MQTT compatible M
Related tags
Some helper types for go1: priority queue, slice wrapper.
go-villa Package villa contains some helper types for Go: priority queue, slice wrapper, binary-search, merge-sort. GoDoc Link: http://godoc.org/githu
Enforce git message commit consistency
Gommit Gommit analyze commits messages to ensure they follow defined pattern. Summary Setup Usage Practical Usage Third Part Libraries Setup Download
RTS: request to struct. Generates Go structs from JSON server responses.
RTS: Request to Struct Generate Go structs definitions from JSON server responses. RTS defines type names using the specified lines in the route file
ephemeral metric aggregation server
hemera hemera is a zero-dependency statsd implementation written in Go. The project takes advantage of modular packages and interfaces to make connect
OTS: Open Terraforming Server
OTS: Open Terraforming Server A prototype open source alternative to terraform enterprise
server for dozenplans
DozenPlans Server 学习养成计划主要是针对考研学生用户的任务管理系统, 用户可以添加 学习 任务, 每个任务都有自己的主题、 完成时间和优先级, 根据设定的完成时间和优先级对 用户进行不同频率的提醒, 直到其完成该任务, 任务可以设定提醒频率和时间期限, 避免导致任务越堆积越多, 除
thermal print server for esc pos printers
thprint thprint is an extremely simple printing server for thermal printers connected to raspberry pis. This printing server exposes a print endpoint
Count Dracula is a fast metrics server that counts entries while automatically expiring old ones
In-Memory Expirable Key Counter This is a fast metrics server, ideal for tracking throttling. Put values to the server, and then count them. Values ex
Module to ease interaction with Pact's development server & ScalableBFT
go-pact Module to ease interaction with Pact's development server & ScalableBFT Install go install github.com/jfamousket/go-pact@latest Functions H
Example ReSTFul Server in Golang - SBU-Snapp-School
students.go Introduction ReSTful API to create, update, retrieve and delete students from a datastore. Requests needs validation, package needs tests,