MCPcopy Create free account

hub / github.com/EverythingMe/go-disque / types & classes

Types & classes17 in github.com/EverythingMe/go-disque

↓ 7 callersFuncTypeDialFunc
DialFunc is a redis dialer function that should be supplied to the pool
disque/pool.go:40
StructAddRequest
AddRequest describes how you want a job to be enqueued
disque/disque.go:32
StructChan
Chan represents a cross machine "channel" over disque
disqchan/disqchan.go:21
InterfaceClient
Client is the interface that describes a disque client
disque/disque.go:58
StructClient
Client is used to enqueue tasks
tasque/client.go:12
StructCrawlHandler
disqrawl/crawler.go:21
StructFuncTaskHandler
FuncTaskHandler wraps a func as a complete handler
tasque/tasque.go:80
StructHelloResponse
HelloResponse is returned from the Hello command and tells us the state of the cluster
disque/disque.go:52
StructJob
Job describes a job that is about to be enqueued or is received from the client for proecessing
disque/disque.go:16
StructNode
Node describes a node in the cluster, received from Hello
disque/pool.go:28
StructPool
Pool is a client pool that keeps track of the available servers in the cluster, and retrieves clients to random nodes in the cluster. Pooled connectio
disque/pool.go:45
StructRedisClient
RedisClient implements a redigo based client
disque/disque.go:90
StructTask
A task represents the name and parameters of a task we want to execute on a worker. You can use it to pass parameters to the job executor
tasque/tasque.go:18
InterfaceTaskHandler
TaskHandler is the interface that handlers must provide
tasque/tasque.go:74
StructWorker
A worker the runner for a worker process that runs goroutines as worker threads. You register TaskHandlers to handle tasks in the worker
tasque/worker.go:15
Structmessage
disqchan/disqchan.go:109
TypeAliasnodeList
NodeList is a list of nodes with search
disque/pool.go:15