stream

Documentation

Index

• Constants
• Variables
• func Merge(destination string, streams []string) error
• func Serialize(data []byte, indexes map[string]string, tails map[string]int64) ([]byte, error)
• type Event
  • func NewEvent(data []byte, offsets map[string]int64) *Event
  • func (e *Event) Indexes() map[string]string
  • func (e *Event) Next(name, value string) int64
• type Scanner
• type Stream
  • func New(path string) (Stream, error)
  • func Open(path string) (Stream, error)
• type Streamer

Constants

const (
	MAGIC_HEADER = "ESDBstream"
	MAGIC_FOOTER = "closedESDBstream"
)

Variables

var CORRUPTED_EVENT = errors.New("corrupted event")

var CORRUPTED_HEADER = errors.New("Incorrect stream file header.")

var FOOTER_LENGTH = int64(len(MAGIC_FOOTER))

var HEADER_LENGTH = int64(len(MAGIC_HEADER))

var WRITING_TO_CLOSED_STREAM = errors.New("stream has been closed")

Functions

func Merge

func Merge(destination string, streams []string) error

func Serialize

func Serialize(data []byte, indexes map[string]string, tails map[string]int64) ([]byte, error)

Types

type Event

type Event struct {
	Data []byte
	// contains filtered or unexported fields
}

func NewEvent

func NewEvent(data []byte, offsets map[string]int64) *Event

func (*Event) Indexes

func (e *Event) Indexes() map[string]string

func (*Event) Next

func (e *Event) Next(name, value string) int64

type Scanner

type Scanner func(*Event) bool

type Stream

type Stream interface {
	Write(data []byte, indexes map[string]string) (int, error)
	First(name, value string) (int64, error)
	ScanIndex(name, value string, offset int64, scanner Scanner) error
	Iterate(offset int64, scanner Scanner) (int64, error)
	Offset() int64
	Closed() bool
	Close() error
	// contains filtered or unexported methods
}

func New

func New(path string) (Stream, error)

Creates a new open stream at the given path. If the file already exists, an error will be returned.

func Open

func Open(path string) (Stream, error)

type Streamer

type Streamer interface {
	io.WriterAt
	io.ReaderAt
}