pkg.gl

Categorygithub.com/infinilabs/frameworkmodulesqueuedisk_queue

package

1.1.0

Repository: https://github.com/infinilabs/framework.git

Documentation: pkg.go.dev

# Functions

GetDataPath

No description provided by the author

GetFileName

No description provided by the author

GetLastCompressFileNum

No description provided by the author

GetLastS3UploadFileNum

No description provided by the author

NewDiskQueueByConfig

NewDiskQueue instantiates a new instance of DiskBasedQueue, retrieving metadata from the filesystem and starting the read ahead goroutine.

Notify

No description provided by the author

RegisterEventListener

No description provided by the author

RemoveFile

No description provided by the author

SmartGetFileName

if local file not found, try to download from s3.

# Constants

ConsumerOffsetBucket

No description provided by the author

ReadComplete

No description provided by the author

WriteComplete

No description provided by the author

# Structs

CompressConfig

No description provided by the author

Consumer

NOTE: Consumer is not thread-safe.

Context

No description provided by the author

DiskBasedQueue

providing a filesystem backed FIFO queue.

DiskCompress

No description provided by the author

DiskQueue

No description provided by the author

DiskQueueConfig

No description provided by the author

Event

No description provided by the author

Message

No description provided by the author

Producer

No description provided by the author

RetentionConfig

No description provided by the author

WriteResponse

No description provided by the author

# Type aliases

EventHandler

No description provided by the author

EventType

No description provided by the author