striping

Documentation

Index

• Constants
• type Header
  • func NewHeader(byteCount, offsetCount uint64, flags ...uint8) *Header
  • func (header *Header) AddFlag(flags ...uint8)
  • func (header *Header) ContainsFlag(flag uint8) bool
  • func (header *Header) GetEODCount() int
• type Item
  • func (item *Item) Less(b queue.Sortable) bool
• type Segment
  • func NewSegment(data []byte, offset int, flags ...uint8) *Segment
  • func NewSegmentWithHeader(header *Header, data []byte) *Segment
  • func (a *Segment) Less(b queue.Sortable) bool
• type SegmentQueue
  • func NewSegmentQueue(workers int) *SegmentQueue
  • func (q *SegmentQueue) Len() int
  • func (q *SegmentQueue) Peek() *Segment
  • func (q *SegmentQueue) Pop() *Segment
  • func (q *SegmentQueue) Push(segment *Segment)
  • func (q *SegmentQueue) PushChannel() (chan<- *Segment, <-chan *Segment)

Constants

const (
	// BlockFlagEndOfDataCount uint8 = 64
	// BlockFlagSuspectErrors  uint8 = 32
	BlockFlagEndOfData uint8 = 8
)

Extended Block Header Flags

Types

type Header

type Header struct {
	Descriptor  uint8
	ByteCount   uint64
	OffsetCount uint64
}

The header is sent over the data channels and indicates information about the following data (if any) See https://www.ogf.org/documents/GWD-R/GFD-R.020.pdf section "Extended Block Mode"

func NewHeader

func NewHeader(byteCount, offsetCount uint64, flags ...uint8) *Header

func (*Header) AddFlag

func (header *Header) AddFlag(flags ...uint8)

func (*Header) ContainsFlag

func (header *Header) ContainsFlag(flag uint8) bool

func (*Header) GetEODCount

func (header *Header) GetEODCount() int

type Item

type Item struct {
	Segment
}

func (*Item) Less

func (item *Item) Less(b queue.Sortable) bool

type Segment

type Segment struct {
	*Header
	Data []byte
}

func NewSegment

func NewSegment(data []byte, offset int, flags ...uint8) *Segment

func NewSegmentWithHeader

func NewSegmentWithHeader(header *Header, data []byte) *Segment

func (*Segment) Less

func (a *Segment) Less(b queue.Sortable) bool

type SegmentQueue

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

func NewSegmentQueue

func NewSegmentQueue(workers int) *SegmentQueue

func (*SegmentQueue) Len

func (q *SegmentQueue) Len() int

func (*SegmentQueue) Peek

func (q *SegmentQueue) Peek() *Segment

func (*SegmentQueue) Pop

func (q *SegmentQueue) Pop() *Segment

func (*SegmentQueue) Push

func (q *SegmentQueue) Push(segment *Segment)

func (*SegmentQueue) PushChannel

func (q *SegmentQueue) PushChannel() (chan<- *Segment, <-chan *Segment)