memory

Documentation

Index

• Constants
• 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 *protocol.Event) error
  • func (q *Queue) Initialize() error
  • func (q *Queue) Name() string

Constants

const (
	Name = "memory-queue"
)

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 *protocol.Event) error

func (*Queue) Initialize

func (q *Queue) Initialize() error

func (*Queue) Name

func (q *Queue) Name() string