disk

Documentation

Index

• type Entry
• type SwitchBuffer
  • func NewSwitchBuffer(handler func(items *list.List) error) *SwitchBuffer
  • func (s *SwitchBuffer) Destroy()
  • func (s *SwitchBuffer) Push(item interface{}) chan error
  • func (s *SwitchBuffer) Schedule()

Types

type Entry

type Entry struct {
	Source  interface{}
	ErrChan chan error
}

type SwitchBuffer

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

func NewSwitchBuffer

func NewSwitchBuffer(handler func(items *list.List) error) *SwitchBuffer

NewSwitchBuffer create a new SwitchBuffer.

func (*SwitchBuffer) Destroy

func (s *SwitchBuffer) Destroy()

Cache gets current writable buffer.

func (*SwitchBuffer) Push

func (s *SwitchBuffer) Push(item interface{}) chan error

Cache gets current writable buffer.

func (*SwitchBuffer) Schedule

func (s *SwitchBuffer) Schedule()

must run in a personal goroutine.