file

Documentation

Index

• Constants
• Variables
• type Config
• type Queue
  • func NewQueue(file *os.File, pattern Safe) (*Queue, error)
  • func NewQueueByModel(model ballistic.DataModel, config ...Config) (*Queue, error)
  • func (f *Queue) Eject(limit int) (models []interface{}, err error)
  • func (f *Queue) Len() int
  • func (f *Queue) Push(model encoding.BinaryMarshaler) error
• type Safe

Constants

const (
	CRC32HashOffset int64 = 0
	CRC32HashSize   int64 = 4
	SkipAheadOffset       = CRC32HashOffset + CRC32HashSize
	SkipAheadSize   int64 = 8
	DataOffset            = SkipAheadOffset + SkipAheadSize
	HeadSize              = CRC32HashSize + SkipAheadSize
	MetaElementSize       = 2
)

Variables

var ConfigDefault = Config{
	Workspace:  "/tmp",
	MaxHistory: 3,
}

ConfigDefault is the default config

var (
	ErrInvalidFile = fmt.Errorf("file invalid")
)

Types

type Config

type Config struct {
	Workspace  string
	MaxHistory int
}

Config defines the config for file queue.

type Queue

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

func NewQueue

func NewQueue(file *os.File, pattern Safe) (*Queue, error)

func NewQueueByModel

func NewQueueByModel(model ballistic.DataModel, config ...Config) (*Queue, error)

func (*Queue) Eject

func (f *Queue) Eject(limit int) (models []interface{}, err error)

func (*Queue) Len

func (f *Queue) Len() int

func (*Queue) Push

func (f *Queue) Push(model encoding.BinaryMarshaler) error

type Safe

type Safe interface {
	encoding.BinaryMarshaler
	encoding.BinaryUnmarshaler
}