buffer

Documentation

Overview

Package buffer provides a thread-safe buffer implementation for a ring buffer.

Index

• type Ring
  • func NewRing(size int) *Ring
  • func (r *Ring) Enqueue(item interface{}) error

Types

type Ring

type Ring struct {
	queue.Circular
}

Ring is a ring buffer implementation wrapping queue.Circular.

func NewRing

func NewRing(size int) *Ring

NewRing returns a ring buffer initalized with 'size' slots.

func (*Ring) Enqueue

func (r *Ring) Enqueue(item interface{}) error

Enqueue enques an item, If the buffer is full, the oldest item will be evicted.