memory

Documentation

Index

• Constants
• Variables
• type Queue
  • func (q *Queue) Ack(_ *event.Offset)
  • func (q *Queue) Close() error
  • func (q *Queue) DefaultConfig() string
  • func (q *Queue) Dequeue() (*api.SequenceEvent, error)
  • func (q *Queue) Description() string
  • func (q *Queue) Enqueue(e *v1.SniffData) error
  • func (q *Queue) Initialize() error
  • func (q *Queue) IsFull() bool
  • func (q *Queue) Name() string
  • func (q *Queue) ShowName() string
  • func (q *Queue) TotalSize() int64
  • func (q *Queue) UsedCount() int64

Constants

const (
	Name     = "memory-queue"
	ShowName = "Memory Queue"
)

Variables

var DefaultOffset = event.Offset{
	Position: "",
}

Types

type Queue

type Queue struct {
	config.CommonFields
	// config
	EventBufferSize int `mapstructure:"event_buffer_size"` // The maximum buffer event size.
	// contains filtered or unexported fields
}

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

func (q *Queue) IsFull() bool

func (*Queue) Name

func (q *Queue) Name() string

func (*Queue) ShowName

func (q *Queue) ShowName() string

func (*Queue) TotalSize

func (q *Queue) TotalSize() int64

func (*Queue) UsedCount

func (q *Queue) UsedCount() int64