disk

package
v0.0.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 30, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL