none

package
v1.3.0 Latest Latest
Warning

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

Go to latest
Published: Nov 12, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Name     = "none-queue"
	ShowName = "None Queue"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Queue

type Queue struct {
	config.CommonFields
}

func (*Queue) Ack

func (q *Queue) Ack(_ *event.Offset)

func (*Queue) Close

func (q *Queue) Close() error

func (*Queue) DefaultConfig

func (q *Queue) DefaultConfig() string

func (*Queue) Dequeue

func (q *Queue) Dequeue() (*api.SequenceEvent, error)

func (*Queue) Description

func (q *Queue) Description() string

func (*Queue) Enqueue

func (q *Queue) Enqueue(e *v1.SniffData) error

func (*Queue) Initialize

func (q *Queue) Initialize() error

func (*Queue) IsFull added in v0.4.0

func (q *Queue) IsFull() bool

func (*Queue) Name

func (q *Queue) Name() string

func (*Queue) ShowName added in v0.4.0

func (q *Queue) ShowName() string

func (*Queue) TotalSize added in v0.4.0

func (q *Queue) TotalSize() int64

func (*Queue) UsedCount added in v0.4.0

func (q *Queue) UsedCount() int64

Jump to

Keyboard shortcuts

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