util

Documentation

Index

• type ChannelBuffer
  • func NewChannelBuffer(capacity int) *ChannelBuffer
  • func (cb *ChannelBuffer) Add(item interface{})
  • func (cb *ChannelBuffer) Close() []interface{}
  • func (cb *ChannelBuffer) Get() []interface{}
  • func (cb *ChannelBuffer) PeriodicFunc(period time.Duration, f func([]interface{}))
  • func (cb *ChannelBuffer) StopFunc()

Types

type ChannelBuffer

type ChannelBuffer struct {
	// contains filtered or unexported fields
}

func NewChannelBuffer

func NewChannelBuffer(capacity int) *ChannelBuffer

func (*ChannelBuffer) Add

func (cb *ChannelBuffer) Add(item interface{})

ATTENTION: nil must not be passed as an argument to Add().

func (*ChannelBuffer) Close

func (cb *ChannelBuffer) Close() []interface{}

ATTENTION: Add() or Get() must not be called after or concurrently with Close().

func (*ChannelBuffer) Get

func (cb *ChannelBuffer) Get() []interface{}

func (*ChannelBuffer) PeriodicFunc

func (cb *ChannelBuffer) PeriodicFunc(period time.Duration, f func([]interface{}))

func (*ChannelBuffer) StopFunc

func (cb *ChannelBuffer) StopFunc()