memqueue

package
v6.1.2+incompatible Latest Latest
Warning

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

Go to latest
Published: Jan 9, 2018 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Package memqueue provides an in-memory queue.Queue implementation for use with the publisher pipeline. The queue implementation is registered as queue type "mem".

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Broker

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

func NewBroker

func NewBroker(
	settings Settings,
) *Broker

NewBroker creates a new broker based in-memory queue holding up to sz number of events. If waitOnClose is set to true, the broker will block on Close, until all internal workers handling incoming messages and ACKs have been shut down.

func (*Broker) BufferConfig

func (b *Broker) BufferConfig() queue.BufferConfig

func (*Broker) Close

func (b *Broker) Close() error

func (*Broker) Consumer

func (b *Broker) Consumer() queue.Consumer

func (*Broker) Producer

func (b *Broker) Producer(cfg queue.ProducerConfig) queue.Producer

type Settings

type Settings struct {
	Eventer        queue.Eventer
	Events         int
	FlushMinEvents int
	FlushTimeout   time.Duration
	WaitOnClose    bool
}

Jump to

Keyboard shortcuts

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