beans

README

go-beanstalk-client

• 中文
• English

Purpose

• Learn to learn the relevant grammar knowledge of GoLand and help you understand the basic grammar and understand the characteristics of the language.
• Using the beanstalk queue (Beanstalk is a simple, fast work queue. https://beanstalkd.github.io/) and using Go's coroutine goroutine feature, you can create a factory for each Tube pipeline, the factory has a number of custom quantities Workers and workers receive tasks.

install-linux

cd example

./install.sh

execute file

• beanstalkf
• beanstalkf-daemon background

Command

• start
• status
• stop

Documentation

Overview

Package beans implements a queue of beanstalk framework

Index

• func GetSeparator(x int, y int) string
• func GetSliceByMapString(m map[string]string) []string
• func ListTubeInfo(t *beanstalk.Tube)
• func ListTubesInfo()
• func Monitor(originTubeNum int)
• func Run()
• func ShowStatus(status *map[string]string)
• func Start()
• func Status()
• func TestPut(tubeName *string)
• func TubeFactoryStart(tubeName string)
• type TubeFactory
  • func NewTubeFactory(name string, num int, conn *beanstalk.Conn) *TubeFactory
  • func (tf *TubeFactory) Run()
• type Worker
  • func NewWorker(name string, f func(name string, conn *beanstalk.Conn) error) *Worker
  • func (w *Worker) Execute(tf *TubeFactory)
  • func (w *Worker) ReserveJob()

Functions

func GetSeparator

func GetSeparator(x int, y int) string

GetSeparator get the separator

func GetSliceByMapString

func GetSliceByMapString(m map[string]string) []string

GetSliceByMapString 将无序的map转换为slice

func ListTubeInfo

func ListTubeInfo(t *beanstalk.Tube)

ListTubeInfo view one tube status

func ListTubesInfo

func ListTubesInfo()

ListTubesInfo view all tubes status

func Monitor

func Monitor(originTubeNum int)

Monitor 厂长监控

func Run

func Run()

Run start to run command

func ShowStatus

func ShowStatus(status *map[string]string)

ShowStatus 将状态信息的格式转化为易阅读的格式

func Start

func Start()

Start start to work

func Status

func Status()

Status view the tube status

func TestPut

func TestPut(tubeName *string)

TestPut tube Put Job

func TubeFactoryStart

func TubeFactoryStart(tubeName string)

TubeFactoryStart 管道工厂启动

Types

type TubeFactory

type TubeFactory struct {
	// contains filtered or unexported fields
}

TubeFactory Tube工厂

func NewTubeFactory

func NewTubeFactory(name string, num int, conn *beanstalk.Conn) *TubeFactory

NewTubeFactory 创建Tube工厂

func (*TubeFactory) Run

func (tf *TubeFactory) Run()

Run 工厂启动

type Worker

type Worker struct {
	// contains filtered or unexported fields
}

Worker 工人

func NewWorker

func NewWorker(name string, f func(name string, conn *beanstalk.Conn) error) *Worker

NewWorker 分配工人

func (*Worker) Execute

func (w *Worker) Execute(tf *TubeFactory)

Execute 工人开始操作

func (*Worker) ReserveJob

func (w *Worker) ReserveJob()

ReserveJob 获取任务Job