archive

Documentation

Overview

Package archive contains tools for transition between TAR files and SampleReader

Copyright (c) 2020, NVIDIA CORPORATION. All rights reserved.

Package archive contains tools for transition between TAR files and SampleReader

Copyright (c) 2020, NVIDIA CORPORATION. All rights reserved.

Package archive contains tools for transition between TAR files and SampleReader

Copyright (c) 2020, NVIDIA CORPORATION. All rights reserved.

Package archive contains tools for transition between TAR files and SampleReader

Copyright (c) 2020, NVIDIA CORPORATION. All rights reserved.

Index

• func NewTarGzReader(reader io.Reader) (core.SampleReader, error)
• func NewTarReader(reader io.Reader) (core.SampleReader, error)
• type Record
  • func NewRecord(name string) *Record
  • func (r *Record) SameMembers(record *Record) bool
  • func (r *Record) SetMember(name string, value []byte)
• type RecordsDefaultManager
  • func NewRecordsManager() *RecordsDefaultManager
  • func (m *RecordsDefaultManager) DeleteRecord(name string)
  • func (m *RecordsDefaultManager) GetRecord(name string) *Record
  • func (m *RecordsDefaultManager) GetRecords() map[string]*Record
  • func (m *RecordsDefaultManager) Len() int
  • func (m *RecordsDefaultManager) StoreRecord(name string, r *Record)
  • func (m *RecordsDefaultManager) UpdateRecord(name, member string, value []byte)
• type RecordsManager
• type TarGreedyReader
  • func (t *TarGreedyReader) Read() (*core.Sample, error)
• type TarSeekReader
  • func (t *TarSeekReader) Read() (sample *core.Sample, err error)

Functions

func NewTarGzReader

func NewTarGzReader(reader io.Reader) (core.SampleReader, error)

func NewTarReader

func NewTarReader(reader io.Reader) (core.SampleReader, error)

Types

type Record

type Record struct {
	Name    string
	Members map[string][]byte
}

func NewRecord

func NewRecord(name string) *Record

func (*Record) SameMembers

func (r *Record) SameMembers(record *Record) bool

func (*Record) SetMember

func (r *Record) SetMember(name string, value []byte)

type RecordsDefaultManager

type RecordsDefaultManager struct {
	Records map[string]*Record
}

func NewRecordsManager

func NewRecordsManager() *RecordsDefaultManager

func (*RecordsDefaultManager) DeleteRecord

func (m *RecordsDefaultManager) DeleteRecord(name string)

func (*RecordsDefaultManager) GetRecord

func (m *RecordsDefaultManager) GetRecord(name string) *Record

func (*RecordsDefaultManager) GetRecords

func (m *RecordsDefaultManager) GetRecords() map[string]*Record

func (*RecordsDefaultManager) Len

func (m *RecordsDefaultManager) Len() int

func (*RecordsDefaultManager) StoreRecord

func (m *RecordsDefaultManager) StoreRecord(name string, r *Record)

func (*RecordsDefaultManager) UpdateRecord

func (m *RecordsDefaultManager) UpdateRecord(name, member string, value []byte)

type RecordsManager

type RecordsManager interface {
	StoreRecord(name string, record *Record)
	UpdateRecord(name string, member string, value []byte)
	GetRecord(name string) *Record
	GetRecords() map[string]*Record
	DeleteRecord(name string)
	Len() int
}

type TarGreedyReader

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

func (*TarGreedyReader) Read

func (t *TarGreedyReader) Read() (*core.Sample, error)

type TarSeekReader

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

func (*TarSeekReader) Read

func (t *TarSeekReader) Read() (sample *core.Sample, err error)