Documentation ¶
Index ¶
- Constants
- func CopyFile(dst, src string) (int64, error)
- type Data
- type DataChannelResponse
- type DiskQueue
- func (dq *DiskQueue) Close() (err error)
- func (dq *DiskQueue) MaxSize(m uint64)
- func (dq *DiskQueue) Pop() ([]byte, error)
- func (dq *DiskQueue) PopReadOnly(nroRec uint64) (data [][]byte, nroRecDone uint64)
- func (dq *DiskQueue) Push(s []byte) error
- func (dq *DiskQueue) ReadDelRecord() (offset int64, err error)
- 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
- type Record
- type RecordPop
Constants ¶
View Source
const ( TIMETOFLUSH = 1e9 MAXSIZE = 100000000 HEADERSZ = 22 DELRECSZ = 43 )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type DataChannelResponse ¶
type DiskQueue ¶
type DiskQueue struct {
// contains filtered or unexported fields
}
func (*DiskQueue) PopReadOnly ¶
POP READ ONLY ========================================================
func (*DiskQueue) ReadDelRecord ¶
Read last del record
func (*DiskQueue) ReadHeader ¶
func (*DiskQueue) ReadPayload ¶
func (*DiskQueue) SetCleanerTime ¶
Click to show internal directories.
Click to hide internal directories.