queue

package

v0.0.0-...-36d655e Latest Latest Go to latest Published: Oct 24, 2023 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Daz-3ux/dMQ

Documentation ¶

Index ¶

Constants
func NewLine(name string, recycle time.Duration) *line
func NewTopic(name string) *topic
type DazQueue
- func NewDazQueue(storage store.Storage) (*DazQueue, error)
type DazQueueStore
type MessageQueue

Constants ¶

View Source

const (
	StorageKeyWord   string = "DazQueueKey"
	ErrTopicNotExist string = "topic not exist"
	ErrLineNotExist  string = "line not exist"
	ErrTopicExist    string = "topic already exist"
	ErrLineExist     string = "line already exist"
	ErrKey           string = "key illegal"
	ErrNone          string = "no message"
)

Variables ¶

This section is empty.

Functions ¶

func NewLine ¶

func NewLine(name string, recycle time.Duration) *line

func NewTopic ¶

func NewTopic(name string) *topic

Types ¶

type DazQueue ¶

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

func NewDazQueue ¶

func NewDazQueue(storage store.Storage) (*DazQueue, error)

func (*DazQueue) Close ¶

func (d *DazQueue) Close()

func (*DazQueue) Create ¶

func (d *DazQueue) Create(name string) error

func (*DazQueue) CreateTopic ¶

func (d *DazQueue) CreateTopic(name string) error

func (*DazQueue) Pop ¶

func (d *DazQueue) Pop(name string) ([]byte, error)

func (*DazQueue) Push ¶

func (d *DazQueue) Push(name string, data []byte) error

type DazQueueStore ¶

type DazQueueStore struct {
	Topics []string
}

type MessageQueue ¶

type MessageQueue interface {
	Create(name string) error
	Push(name string, data []byte) error
	Pop(name string) ([]byte, error)
	Close()
}

Source Files ¶

View all Source files

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