Documentation ¶
Index ¶
Constants ¶
View Source
const DataFilePrefix = "tcpmon-dataf-"
View Source
const HeaderSize = 6
View Source
const SealFileSuffix = ".zst"
View Source
const Version = uint16(0xadde)
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Config ¶
func (*Config) WithMaxEntriesPerFile ¶
WithMaxEntriesPerFile set the max entries count per file
func (*Config) WithMaxSize ¶
WithMaxSize set the max size for storage, in bytes
type DataFileReader ¶
type DataFileReader struct {
// contains filtered or unexported fields
}
func NewDataFileReader ¶
func NewDataFileReader(filePath string, fs afero.Fs) (*DataFileReader, error)
func (*DataFileReader) Close ¶
func (r *DataFileReader) Close()
func (*DataFileReader) Read ¶
func (r *DataFileReader) Read() ([]byte, error)
func (*DataFileReader) ReadHeader ¶
func (r *DataFileReader) ReadHeader() (uint32, error)
type DataStore ¶
type DataStore struct {
// contains filtered or unexported fields
}
func NewDataStore ¶
func (*DataStore) GetLatestFileNo ¶
type MetricContext ¶
type MetricContext struct {
Value []byte
}
type Reader ¶
type Reader struct {
// contains filtered or unexported fields
}
func NewDataStoreReader ¶
func NewDataStoreReader(config *ReaderConfig) (*Reader, error)
type ReaderConfig ¶
type ReaderConfig struct {
// contains filtered or unexported fields
}
func NewReaderConfig ¶
func NewReaderConfig(baseDir string) *ReaderConfig
func (*ReaderConfig) WithFs ¶
func (c *ReaderConfig) WithFs(fs afero.Fs) *ReaderConfig
func (*ReaderConfig) WithPrefix ¶
func (c *ReaderConfig) WithPrefix(s string) *ReaderConfig
func (*ReaderConfig) WithSuffix ¶
func (c *ReaderConfig) WithSuffix(s string) *ReaderConfig
Click to show internal directories.
Click to hide internal directories.