ringbuffer

Documentation

Index

• type RingBuffer
  • func New[T any](name string, size uint64) *RingBuffer[T]
  • func (r *RingBuffer[T]) Close()
  • func (r *RingBuffer[T]) Name() string
  • func (r *RingBuffer[T]) Receive() (T, error)
  • func (r *RingBuffer[T]) Send(value T) error

Types

type RingBuffer

type RingBuffer[T any] struct {
	// contains filtered or unexported fields
}

func New

func New[T any](name string, size uint64) *RingBuffer[T]

func (*RingBuffer[T]) Close

func (r *RingBuffer[T]) Close()

func (*RingBuffer[T]) Name

func (r *RingBuffer[T]) Name() string

func (*RingBuffer[T]) Receive

func (r *RingBuffer[T]) Receive() (T, error)

func (*RingBuffer[T]) Send

func (r *RingBuffer[T]) Send(value T) error