Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

proio

package module

Go to main page

Versions in this module

v0

v0.7.0

Apr 23, 2019

Changes in this version

type Event

+ func (evt *Event) AddSerializedEntry(tag string, wireData []byte, pbType string, descriptor []byte) (id uint64, err error)

v0.6.2

Apr 10, 2019

v0.6.1

Apr 9, 2019

v0.6.0

Mar 26, 2019

v0.5.0

Feb 19, 2019

Changes in this version

type Event

+ func CopyEvent(event *Event) *Event

type Reader

+ func (rdr *Reader) DeferUntilClose(thisFunc func())

type Writer

+ func (wrt *Writer) DeferUntilClose(thisFunc func() error)

v0.4.3

Jan 15, 2019

v0.4.2

Jan 10, 2019

v0.4.1

Nov 19, 2018

v0.4.0

Oct 24, 2018

Changes in this version

type Reader

+ Metadata map[string][]byte

type Writer

+ BucketDumpThres int

+ CompLevel int

v0.3.2

Oct 11, 2018

v0.3.1

Oct 5, 2018

v0.3.0

Sep 25, 2018

Changes in this version

+ func StoredFileDescriptorProtos() []protobuf.Message

type Event

+ func (evt *Event) FlushCache()

type Reader

+ BucketHeader *proto.BucketHeader

v0.2.1

Aug 29, 2018

v0.2.0

Aug 28, 2018

Changes in this version

type Compression

+ const LZMA

v0.1.1

Aug 27, 2018

v0.1.0

Aug 23, 2018

Changes in this version

+ type Compression int

+ const GZIP

+ const LZ4

+ const UNCOMPRESSED

+ type Event struct

+ Err error

+ Metadata map[string][]byte

+ func NewEvent() *Event

+ func (evt *Event) AddEntries(tag string, entries ...protobuf.Message) []uint64

+ func (evt *Event) AddEntry(tag string, entry protobuf.Message) uint64

+ func (evt *Event) AllEntries() []uint64

+ func (evt *Event) DeleteTag(tag string)

+ func (evt *Event) EntryTags(id uint64) []string

+ func (evt *Event) GetEntry(id uint64) protobuf.Message

+ func (evt *Event) RemoveEntry(id uint64)

+ func (evt *Event) String() string

+ func (evt *Event) TagEntry(id uint64, tags ...string)

+ func (evt *Event) TaggedEntries(tag string) []uint64

+ func (evt *Event) Tags() []string

+ func (evt *Event) UntagEntry(id uint64, tag string)

+ type Reader struct

+ Err chan error

+ EvtScanBufSize int

+ func NewReader(streamReader io.Reader) *Reader

+ func Open(filename string) (*Reader, error)

+ func (rdr *Reader) Close()

+ func (rdr *Reader) Next() (*Event, error)

+ func (rdr *Reader) NextHeader() (*proto.BucketHeader, error)

+ func (rdr *Reader) ScanEvents() <-chan *Event

+ func (rdr *Reader) SeekToStart() error

+ func (rdr *Reader) Skip(nEvents int) (nSkipped int, err error)

+ func (rdr *Reader) StopScan()

+ type Writer struct

+ func Create(filename string) (*Writer, error)

+ func NewWriter(streamWriter io.Writer) *Writer

+ func (wrt *Writer) Close() error

+ func (wrt *Writer) Flush() error

+ func (wrt *Writer) Push(event *Event) error

+ func (wrt *Writer) PushMetadata(name string, data []byte) error

+ func (wrt *Writer) SetCompression(comp Compression) error