queue

package

v0.0.0-...-678c32f Latest Latest Go to latest Published: Apr 11, 2020 License: Apache-2.0, MIT Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Cosin/framework

Links

Open Source Insights

Documentation ¶

Rendered for

Index ¶

type BackendQueue
- func NewDiskQueue(name string, dataPath string, maxBytesPerFile int64, minMsgSize int32, ...) BackendQueue

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BackendQueue ¶

type BackendQueue interface {
	Put([]byte) error
	ReadChan() chan []byte // this is expected to be an *unbuffered* channel
	Close() error
	Delete() error
	Depth() int64
	Empty() error
}

BackendQueue represents the behavior for the secondary message storage system

func NewDiskQueue ¶

func NewDiskQueue(name string, dataPath string, maxBytesPerFile int64,
	minMsgSize int32, maxMsgSize int32,
	syncEvery int64, syncTimeout time.Duration, readBufferSize int) BackendQueue

NewDiskQueue instantiates a new instance of diskQueue, retrieving metadata from the filesystem and starting the read ahead goroutine

Source Files ¶

View all Source files

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