util

Jan 3, 2024

Changes in this version

type CEPUMParams

+ Xattr_params *XattrParams

type CPPUMParams

+ Xattr_params *XattrParams

+ type XattrParams struct

+ SetXattr bool

+ XattrName string

+ Xattrvalue string

Jan 3, 2024

Changes in this version

+ func GetPasteFileName_Common(prefix string, file_contents []byte, timestamp int64) string

type LSRFD_Params

+ Entry_should_be_deleted_fn func(int64) bool

Jan 3, 2024

Changes in this version

type ConcurrentExpiringPersistentURLMap

+ func (manager *ConcurrentExpiringPersistentURLMap) NumPastes() int

type ConcurrentPersistentPermanentURLMap

+ func (manager *ConcurrentPersistentPermanentURLMap) NumPastes() int

+ type GenericConcurrentPersistentMap interface

+ GetEntry func(short_url string) (MapItem, error)

+ NumItems func() int

+ NumPastes func() int

+ PutEntry func(requested_length int, long_url string, expiry_time int64, ...) (string, error)

Jan 3, 2024

Changes in this version

type ConcurrentExpiringMap

+ func (cem *ConcurrentExpiringMap) NumPastes() int

type ConcurrentMap

+ NumPastes func() int

type ConcurrentPermanentMap

+ func (cpm *ConcurrentPermanentMap) NumPastes() int

type ExpiringMapItem

+ func NewTestExpiringMapItem(value string, valuetype MapItemValueType, timestamp int64) *ExpiringMapItem

+ type MapWithPastesCount interface

+ DeleteKey func(key string)

+ GetKey func(key string) (T, error)

+ InsertNew func(key string, value T) error

+ NumItems func() int

+ NumPastes func() int

+ func NewMapWithPastesCount[T MapItem](size int64) MapWithPastesCount[T]

+ type MapWithPastesCount_impl struct

+ func (mwpc *MapWithPastesCount_impl[T]) DeleteKey(key string)

+ func (mwpc *MapWithPastesCount_impl[T]) GetKey(key string) (T, error)

+ func (mwpc *MapWithPastesCount_impl[T]) InsertNew(key string, value T) error

+ func (mwpc *MapWithPastesCount_impl[T]) NumItems() int

+ func (mwpc *MapWithPastesCount_impl[T]) NumPastes() int

Jan 3, 2024

Changes in this version

type CEPUMParams

+ Paste_bucket_directory_path_absolute string

+ Paste_bucket_interval int64

+ Paste_extra_keeparound_seconds_disk int64

type CPPUMParams

+ Bucket_directory_path_absolute string

+ type PasteStorage interface

+ InsertFile func([]byte, int64) string

+ type PermanentBucketStorage struct

+ func NewPermanentBucketStorage(bucket_directory_path_absolute string) *PermanentBucketStorage

+ func (pbs *PermanentBucketStorage) InsertFile(file_contents []byte, _ int64) string

Jan 3, 2024

Changes in this version

type MapItemType

+ IsTemporary bool

+ ValueType MapItemValueType

Jan 3, 2024

Changes in this version

+ var IsAlnum = [256]byte

+ func Crypto_Rand_Alnum_String(length int) string

+ func Crypto_Rand_Base64String(length int) string

+ type ExpiringBucketStorage struct

+ func NewExpiringBucketStorage(bucket_interval int64, bucket_directory_path_absolute string, ...) *ExpiringBucketStorage

+ func (ebs *ExpiringBucketStorage) DeleteExpiredBuckets()

+ func (ebs *ExpiringBucketStorage) InsertFile(file_contents []byte, expiry_time int64) string

+ type MapItemType struct

+ type MapItemValueType interface

+ ToString func() string

+ type PASTE_TYPE_t struct

+ var TYPE_MAP_ITEM_PASTE PASTE_TYPE_t = PASTE_TYPE_t{}

+ func (PASTE_TYPE_t) ToString() string

+ type URL_TYPE_t struct

+ var TYPE_MAP_ITEM_URL URL_TYPE_t = URL_TYPE_t{}

+ func (URL_TYPE_t) ToString() string

Dec 16, 2023

Changes in this version

type ConcurrentExpiringPersistentURLMap

+ func (manager *ConcurrentExpiringPersistentURLMap) NumItems() int

type ConcurrentPersistentPermanentURLMap

+ func (manager *ConcurrentPersistentPermanentURLMap) NumItems() int

Dec 14, 2023

Changes in this version

type ExpiringMapItem

+ func (emi *ExpiringMapItem) GetType() string

type MapItem

+ GetType func() string

type PermanentMapItem

+ func (pmi *PermanentMapItem) GetType() string

Dec 14, 2023

Changes in this version

type ExpiringMapItem

+ func (emi *ExpiringMapItem) GetExpiryTime() int64

type MapItem

+ GetExpiryTime func() int64

type PermanentMapItem

+ func (emi *PermanentMapItem) GetExpiryTime() int64

Dec 14, 2023

Changes in this version

+ func Compute_String_Checksum(str string) string

+ func Convert_str_to_uint64(input_str string) uint64

+ func Convert_uint64_to_str(bigendian_uint64 uint64, length int) string

+ func IsSameType(a, b interface{}) bool

+ func LBSES_Get_bucket_filename(timestamp int64) string

+ func LBSES_Parse_bucket_filename_to_timestamp(filename string) (int64, error)

+ func LSPS_Parse_log_filename_to_number(filename string) (int64, error)

+ func LoadStoredRecordsFromDisk(params *LSRFD_Params) (ConcurrentMap, *MapSizeFileManager)

+ func PutEntry_Common(requested_length int, long_url string, timestamp int64, ...) (string, error)

+ func RunFuncEveryXSeconds(fn fn_type, run_interval_seconds int)

+ func Validate_Timestamp_Common(timestamp_unix int64) error

+ func Write_Entry_To_File(key string, value string, timestamp int64, file_handle *os.File) error

+ type CEMNonExistentKeyError struct

+ func (e CEMNonExistentKeyError) Error() string

+ type CEPUMParams struct

+ B53m *Base53IDManager

+ Bucket_directory_path_absolute string

+ Bucket_interval int64

+ Expiry_check_interval_seconds_disk int

+ Expiry_check_interval_seconds_ram int

+ Extra_keeparound_seconds_disk int64

+ Extra_keeparound_seconds_ram int64

+ Generate_strings_up_to int

+ Size_file_path_absolute string

+ Size_file_rounded_multiple int64

+ type CPMNonExistentKeyError struct

+ func (e CPMNonExistentKeyError) Error() string

+ type CPPUMParams struct

+ B53m *Base53IDManager

+ Generate_strings_up_to int

+ Log_directory_path_absolute string

+ Log_file_max_size_bytes int64

+ Size_file_path_absolute string

+ Size_file_rounded_multiple int64

type ConcurrentExpiringMap

+ func (*ConcurrentExpiringMap) BeginConstruction(stored_map_length int64, expiry_callback ExpiryCallback) ConcurrentMap

+ func (cem *ConcurrentExpiringMap) ContinueConstruction(key_str string, value_str string, expiry_time int64)

+ func (cem *ConcurrentExpiringMap) FinishConstruction()

+ type ConcurrentExpiringPersistentURLMap struct

+ func CreateConcurrentExpiringPersistentURLMapFromDisk(cepum_params *CEPUMParams) *ConcurrentExpiringPersistentURLMap

+ func (manager *ConcurrentExpiringPersistentURLMap) GetEntry(short_url string) (MapItem, error)

+ func (manager *ConcurrentExpiringPersistentURLMap) PrintInternalState()

+ func (manager *ConcurrentExpiringPersistentURLMap) PutEntry(requested_length int, long_url string, expiry_time int64) (string, error)

+ func (manager *ConcurrentExpiringPersistentURLMap) RemoveAllExpiredURLsFromDisk()

+ func (manager *ConcurrentExpiringPersistentURLMap) RemoveAllExpiredURLsFromRAM()

+ type ConcurrentMap interface

+ BeginConstruction func(int64, ExpiryCallback) ConcurrentMap

+ ContinueConstruction func(string, string, int64)

+ FinishConstruction func()

+ Get_Entry func(string) (MapItem, error)

+ NumItems func() int

type ConcurrentPermanentMap

+ func (*ConcurrentPermanentMap) BeginConstruction(stored_map_length int64, expiry_callback ExpiryCallback) ConcurrentMap

+ func (cpm *ConcurrentPermanentMap) ContinueConstruction(key_str string, value_str string, expiry_time int64)

+ func (cpm *ConcurrentPermanentMap) FinishConstruction()

+ func (cpm *ConcurrentPermanentMap) Put_New_Entry(key string, value string, _ int64) error

+ type ConcurrentPersistentPermanentURLMap struct

+ func CreateConcurrentPersistentPermanentURLMapFromDisk(cppum_params *CPPUMParams) *ConcurrentPersistentPermanentURLMap

+ func (manager *ConcurrentPersistentPermanentURLMap) GetEntry(short_url string) (MapItem, error)

+ func (manager *ConcurrentPersistentPermanentURLMap) PrintInternalState()

+ func (manager *ConcurrentPersistentPermanentURLMap) PutEntry(requested_length int, long_url string) (string, error)

type ExpiringMapItem

+ func (emi *ExpiringMapItem) GetValue() string

+ func (emi *ExpiringMapItem) MapItemToString() string

+ type LSRFD_Params struct

+ B53m *Base53IDManager

+ Entry_should_be_ignored_fn func(int64) bool

+ Expiry_callback ExpiryCallback

+ Generate_strings_up_to int

+ Log_directory_path_absolute string

+ Lss LogStructuredStorage

+ Nil_ptr ConcurrentMap

+ Size_file_path_absolute string

+ Size_file_rounded_multiple int64

+ Slice_storage map[int]*RandomBag64

+ type LogBucketStructuredExpiringStorage struct

+ func NewLogBucketStructuredExpiringStorage(bucket_interval int64, bucket_directory_path_absolute string) *LogBucketStructuredExpiringStorage

+ func (*LogBucketStructuredExpiringStorage) ValidateLogFilename(filename string) error

+ func (lbses *LogBucketStructuredExpiringStorage) AppendNewEntry(key string, value string, expiry_time int64) error

+ func (lbses *LogBucketStructuredExpiringStorage) DeleteExpiredLogFiles(extra_keeparound_seconds_disk int64)

+ type LogStorage interface

+ AppendNewEntry func(string, string, int64) error

+ type LogStructuredPermanentStorage struct

+ func NewLogStructuredPermanentStorage(log_file_max_size int64, log_directory_path_absolute string) *LogStructuredPermanentStorage

+ func (*LogStructuredPermanentStorage) ValidateLogFilename(filename string) error

+ func (lsps *LogStructuredPermanentStorage) AppendNewEntry(key string, value string, generation_time_unix int64) error

+ type LogStructuredStorage interface

+ ValidateLogFilename func(filename string) error

+ type MapItem interface

+ GetValue func() string

+ MapItemToString func() string

+ func GetEntryCommon(cm ConcurrentMap, short_url string) (MapItem, error)

+ type MapItem2 struct

+ type MapSizeFileManager struct

+ func NewMapSizeFileManager(size_file_path_absolute string, size_multiple int64) *MapSizeFileManager

+ func (msfm *MapSizeFileManager) UpdateMapSizeRounded(actual_size int64)

type NonExistentKeyError

+ NonExistentKeyError func() string

+ type People []MapItem2

+ func (p People) Len() int

+ func (p People) Less(i, j int) bool

+ func (p People) Swap(i, j int)

+ type PermanentMapItem struct

+ func (pmi *PermanentMapItem) GetValue() string

+ func (pmi *PermanentMapItem) MapItemToString() string

+ type ShouldBase53IDBePlacedIntoSliceFn func(string) bool

+ type URLMap interface

+ NumItems func() int

+ Put_New_Entry func(string, string, int64) error

Dec 9, 2023

Changes in this version

type Base53IDManager

+ func (b53m *Base53IDManager) Convert_str_to_uint64(input_str string) uint64

Dec 9, 2023

Changes in this version

type ConcurrentExpiringMap

+ func (cem *ConcurrentExpiringMap) GetAllItems() map[interface{}]ExpiringMapItem

Dec 8, 2023

Changes in this version

+ func Crypto_RandString(length int) string

Dec 8, 2023

Changes in this version

+ const BASE53_ALPHABET_SIZE

+ const XATTR_1F604_FILESERVER_CAN_BE_SERVED

+ func Assert_error_equals(t *testing.T, err error, expected string, skip_level int)

+ func Assert_no_error(t *testing.T, err error, skip_level int)

+ func Assert_result_equals_bool(t *testing.T, actual bool, err error, expected bool, skip_level int)

+ func Assert_result_equals_bytes(t *testing.T, actual []byte, err error, expected string, skip_level int)

+ func Assert_result_equals_interface(t *testing.T, actual interface{}, err error, expected interface{}, ...)

+ func Assert_result_equals_string_slice(t *testing.T, actual []string, err error, expected []string, skip_level int)

+ func Assert_result_equals_time(t *testing.T, actual time.Time, err error, expected time.Time, line_number int)

+ func BuildStruct[T any]() *T

+ func CheckTCPPort(port int) net.Listener

+ func Check_err(err error)

+ func Check_no_other_instances_running(socket_addr string)

+ func Copy_Slice_Into_150_Arr(slice []byte, arr [150]byte)

+ func Crypto_Randint(max int) (int, error)

+ func Crypto_Random_Choice[T any](arr *[]T) (T, error)

+ func Divmod(numerator, denominator int) (int, int)

+ func Get_file_size(f *os.File) int64

+ func Getxattr(path string, name string, data []byte) (int, error)

+ func Int64_to_string(num int64) string

+ func Power_Naive(a, b int) int

+ func Power_Slow(a, b, m int) int

+ func PrintMemUsage()

+ func ReplaceString(str string, replacement rune, index int) string

+ func Retryfunc(taskname string, dotask retrylib_task, expected_duration time.Duration, ...)

+ func Retryproc(procname string, expected_duration time.Duration, max_wait time.Duration)

+ func ReverseString(s string) string

+ func SetLogFile(filename string) *os.File

+ func Setxattr(path string, name string, data []byte, flags int) error

+ func String_to_int64(s string) (int64, error)

+ func Use(vals ...interface{})

+ type BandwidthMonitor struct

+ func (bm *BandwidthMonitor) GetTotalAllBytes() int64

+ func (bm *BandwidthMonitor) GetTotalTXBytes() int64

+ func (bm *BandwidthMonitor) RunThread(time_interval_secs int)

+ type Base53ErrorChecksumMismatch struct

+ func (e Base53ErrorChecksumMismatch) Error() string

+ type Base53ErrorIllegalCharacter struct

+ func (e Base53ErrorIllegalCharacter) Error() string

+ type Base53ErrorIllegalPair struct

+ func (e Base53ErrorIllegalPair) Error() string

+ type Base53ErrorStrWithoutCsumTooLong struct

+ func (e Base53ErrorStrWithoutCsumTooLong) Error() string

+ type Base53ErrorStrWithoutCsumTooShort struct

+ func (e Base53ErrorStrWithoutCsumTooShort) Error() string

+ type Base53ID interface

+ GetCombinedString func() string

+ GetCsum func() byte

+ GetStrWithoutCsum func() string

+ Length func() int

+ type Base53IDManager struct

+ func NewBase53IDManager() *Base53IDManager

+ func (b53m *Base53IDManager) B53_generate_all_Base53IDs(n int) ([]Base53ID, error)

+ func (b53m *Base53IDManager) B53_generate_all_Base53IDs_int64(n int) ([]uint64, error)

+ func (b53m *Base53IDManager) B53_generate_all_Base53IDs_int64_optimized(n int) ([]uint64, error)

+ func (b53m *Base53IDManager) B53_generate_all_Base53IDs_int64_test(n int) ([]uint64, error)

+ func (b53m *Base53IDManager) B53_generate_next_Base53ID(old_id Base53ID) (Base53ID, error)

+ func (b53m *Base53IDManager) B53_generate_random_Base53ID(n int) (Base53ID, error)

+ func (b53m *Base53IDManager) Convert_uint64_to_Base53ID(bigendian_uint64 uint64, length int) (*_base53ID_impl, error)

+ func (b53m *Base53IDManager) Convert_uint64_to_byte_array(bigendian_uint64 uint64) []byte

+ func (b53m *Base53IDManager) Convert_uint64_to_str(bigendian_uint64 uint64, length int) string

+ func (b53m *Base53IDManager) NewBase53ID(str_without_csum string, csum byte, remap bool) (*_base53ID_impl, error)

+ type CEMItem struct

+ Expiry_time_unix int64

+ Key interface{}

+ Value interface{}

+ type CPMItem struct

+ Key interface{}

+ Value interface{}

+ type ConcurrentExpiringMap struct

+ func NewConcurrentExpiringMapFromSlice(expiry_callback ExpiryCallback, kv_pairs []CEMItem) *ConcurrentExpiringMap

+ func NewEmptyConcurrentExpiringMap(expiry_callback ExpiryCallback) *ConcurrentExpiringMap

+ func (cem *ConcurrentExpiringMap) Get_Entry(key interface{}) (interface{}, error)

+ func (cem *ConcurrentExpiringMap) NumItems() int

+ func (cem *ConcurrentExpiringMap) Put_New_Entry(key interface{}, value interface{}, expiry_time int64) error

+ func (cem *ConcurrentExpiringMap) Remove_All_Expired(extra_keeparound_seconds int64)

+ type ConcurrentPermanentMap struct

+ func NewConcurrentPermanentMapFromSlice(kv_pairs []CPMItem) *ConcurrentPermanentMap

+ func NewEmptyConcurrentPermanentMap() *ConcurrentPermanentMap

+ func (cpm *ConcurrentPermanentMap) Get_Entry(key interface{}) (interface{}, bool)

+ func (cpm *ConcurrentPermanentMap) NumItems() int

+ func (cpm *ConcurrentPermanentMap) Put_Entry(key interface{}, value interface{})

+ type CryptoRandomChoiceEmptySliceError struct

+ func (e CryptoRandomChoiceEmptySliceError) Error() string

+ type ERROR struct

+ S string

+ func Error(s string) ERROR

+ type EXACT_MATCH_HANDLER_t struct

+ var EXACT_MATCH_HANDLER EXACT_MATCH_HANDLER_t = EXACT_MATCH_HANDLER_t{}

+ type ExpiringHeapItem struct

+ func (p ExpiringHeapItem) String() string

+ type ExpiringHeapQueue []*ExpiringHeapItem

+ func (pq *ExpiringHeapQueue) Pop() any

+ func (pq *ExpiringHeapQueue) Push(x any)

+ func (pq ExpiringHeapQueue) Len() int

+ func (pq ExpiringHeapQueue) Less(i, j int) bool

+ func (pq ExpiringHeapQueue) Swap(i, j int)

+ type ExpiringMapItem struct

+ func (p ExpiringMapItem) String() string

+ type ExpiryCallback func(interface{})

+ type FileEntry struct

+ FileInfo fs.FileInfo

+ FilePath string

+ TimeCreated time.Time

+ type HandlerTypeEnum interface

+ type KeyAlreadyExistsError struct

+ func (e KeyAlreadyExistsError) Error() string

+ type KeyExpiredError struct

+ func (e KeyExpiredError) Error() string

+ type LONGEST_PREFIX_HANDLER_t struct

+ var LONGEST_PREFIX_HANDLER LONGEST_PREFIX_HANDLER_t = LONGEST_PREFIX_HANDLER_t{}

+ type LogFileDeleter struct

+ AbsoluteDirectoryPath string

+ CurrentLogFileName string

+ DirectorySizeLimitBytes int64

+ func NewLogFileDeleter(directory_path string, size_limit int64, log_file_name string) *LogFileDeleter

+ func (lfd *LogFileDeleter) Delete_Excess_Files()

+ func (lfd *LogFileDeleter) RunThread(time_interval_secs int)

+ type NewBase53IDParams struct

+ Csum byte

+ Remap bool

+ Str_without_csum string

+ type NonExistentKeyError struct

+ func (e NonExistentKeyError) Error() string

+ type RESULT struct

+ S interface{}

+ func Result(s interface{}) RESULT

+ type RandomBag64 struct

+ func CreateRandomBagFromSlice(items []uint64) *RandomBag64

+ func (rb *RandomBag64) PopRandom() (uint64, error)

+ func (rb *RandomBag64) Push(item uint64)

+ func (rb *RandomBag64) Size() int

+ type RandomBagEmptyError struct

+ func (e RandomBagEmptyError) Error() string

+ type SafeTLSAutoCertManager struct

+ func NewSafeAutoCertManager(tls_email_address string, domain_name_without_www string, ssl_cache_dir string, ...) *SafeTLSAutoCertManager

+ func (m *SafeTLSAutoCertManager) GetSecureTLSConfig() *tls.Config

+ type ValidationResult struct

+ Message string

+ Success bool