diskqueue

package module

v0.0.0-...-167aa3e Latest Latest Go to latest Published: Dec 20, 2018 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const (
	TIMETOFLUSH = 1e9
	MAXSIZE     = 100000000

	HEADERSZ = 22
	DELRECSZ = 43
)

This section is empty.

func CopyFile(dst, src string) (int64, error)

UTILS (copyfile)

type Data struct {
	Offset  uint32
	Payload []byte
}

Data Struct Contém os registros do Push

type DataChannelResponse struct {
	Response []byte
	Err      error
}

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

func New(dbdir string) (dq *DiskQueue, err error)

func (dq *DiskQueue) Close() (err error)

Disk Storage Close

func (dq *DiskQueue) MaxSize(m uint64)

func (dq *DiskQueue) Pop() ([]byte, error)

func (dq *DiskQueue) PopReadOnly(nroRec uint64) (data [][]byte, nroRecDone uint64)

POP READ ONLY ========================================================

func (dq *DiskQueue) Push(s []byte) error

func (dq *DiskQueue) ReadDelRecord() (offset int64, err error)

Read last del record

func (dq *DiskQueue) ReadHeader() (rec *Record, err error)

func (dq *DiskQueue) ReadPayload(rec *Record) (err error)

func (dq *DiskQueue) SetCleanerTime(d time.Duration)

func (dq *DiskQueue) WriteDelRecord(off int64, crcpush uint32) error

type RecData struct {
	Data []byte
}

type Record struct {
	Len     int32
	Crc     uint32
	Payload []byte
}

Timestamp into payload In-memory control active segments

type RecordPop struct {
	Crc     uint32 //10 + space
	Offset  int64  //20 + space
	CrcPush uint32 //10 + \n
}

uint32 + int64 (4+8) = 12 bytes offset crc + offset last pop record