queue

package
v0.0.0-...-38575d5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 9, 2024 License: AGPL-3.0 Imports: 12 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type API

type API struct {
	api.Handler
}

func (*API) DeleteConsumersByQuery

func (module *API) DeleteConsumersByQuery(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*API) DeleteQueue

func (module *API) DeleteQueue(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*API) DeleteQueuesByQuery

func (module *API) DeleteQueuesByQuery(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*API) QueueDeleteConsumerByID

func (module *API) QueueDeleteConsumerByID(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*API) QueueExplore

func (module *API) QueueExplore(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*API) QueueGetConsumerOffset

func (module *API) QueueGetConsumerOffset(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*API) QueueResetConsumerOffset

func (module *API) QueueResetConsumerOffset(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*API) QueueStatsAction

func (module *API) QueueStatsAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*API) SingleQueueStatsAction

func (module *API) SingleQueueStatsAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

type DeleteConsumersByQueryRequest

type DeleteConsumersByQueryRequest struct {
	Selector *queue1.QueueSelector `json:"selector"`
}

type DeleteQueuesByQueryRequest

type DeleteQueuesByQueryRequest struct {
	Selector *queue1.QueueSelector `json:"selector"`
}

type Module

type Module struct {
}

func (*Module) Name

func (this *Module) Name() string

func (*Module) Setup

func (this *Module) Setup()

func (*Module) Start

func (this *Module) Start() error

func (*Module) Stop

func (this *Module) Stop() error

Directories

Path Synopsis
Package queue implements a double-ended queue (aka "deque") data structure on top of a slice.
Package queue implements a double-ended queue (aka "deque") data structure on top of a slice.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL