Documentation ¶
Index ¶
- type Segment
- func (s *Segment) Close() (err error)
- func (s *Segment) ReadEntry(e *entry.Entry) (common.ErrCode, int, error)
- func (s *Segment) Reading(source io.ReadSeekCloser) (n int, err error)
- func (s *Segment) SeekToRead(offset int64) error
- func (s *Segment) WriteBatch(b entry.Batch) (common.ErrCode, error)
- func (s *Segment) WriteEntry(e entry.Entry) (common.ErrCode, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Segment ¶
type Segment struct {
// contains filtered or unexported fields
}
Segment represents a portion (segment) of a persistent queue.
func NewReadOnlySegment ¶
func NewReadOnlySegment(source io.ReadSeekCloser) (*Segment, int, error)
NewReadOnlySegment creates new Segment for readonly.
func NewSegment ¶
func NewSegment(w io.WriteCloser, entryFormat common.EntryFormat, maxEntries uint32) (*Segment, error)
NewSegment from path.
func (*Segment) Reading ¶
func (s *Segment) Reading(source io.ReadSeekCloser) (n int, err error)
Reading from source.
func (*Segment) SeekToRead ¶ added in v0.1.4
SeekToRead - offset from beginning of Segment.
func (*Segment) WriteBatch ¶ added in v0.2.0
WriteBatch to segment.
Click to show internal directories.
Click to hide internal directories.