utils

package
v1.4.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 30, 2025 License: GPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const MAX_SENDERS_AT_SAME_TIME = 10
View Source 
const SLEEP_OF_LOOP_IN_MS = 10

Variables

This section is empty.

Functions

func FileExists 

func FileExists(fileName string) bool

func MaxBool 

func MaxBool(x, y bool) bool

func MaxNum 

func MaxNum[T int64 | float64](x, y T) T

func MaxStr 

func MaxStr(x, y string) string

func MinBool 

func MinBool(x, y bool) bool

func MinNum 

func MinNum[T int64 | float64](x, y T) T

func MinStr 

func MinStr(x, y string) string

func ReadFileAsBinary 

func ReadFileAsBinary(path string) []byte

func ReadFileAsString 

func ReadFileAsString(path string) string

func RunCommandInDir 

func RunCommandInDir(dir string, command string, params ...string) (string, error)

func RunCommandInDirNoOutput 

func RunCommandInDirNoOutput(dir string, command string, params ...string) error

func WriteFileAsBinary 

func WriteFileAsBinary(fileName string, data []byte)

func WriteFileAsString 

func WriteFileAsString(fileName string, data string)

Types

type BasicLogger 

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

func (*BasicLogger) Clone 

func (bl *BasicLogger) Clone() LoggerIFace

func (*BasicLogger) Debug 

func (bl *BasicLogger) Debug(pattern string, args ...interface{})

func (*BasicLogger) Error 

func (bl *BasicLogger) Error(pattern string, args ...interface{})

func (*BasicLogger) Fatal 

func (bl *BasicLogger) Fatal(pattern string, args ...interface{})

func (*BasicLogger) GetConfig 

func (bl *BasicLogger) GetConfig() LoggerConfig

func (*BasicLogger) GetLogger 

func (bl *BasicLogger) GetLogger() *log.Logger

func (*BasicLogger) GetType 

func (bl *BasicLogger) GetType() string

func (*BasicLogger) Info 

func (bl *BasicLogger) Info(pattern string, args ...interface{})

func (*BasicLogger) SetConfig 

func (bl *BasicLogger) SetConfig(config LoggerConfig)

func (*BasicLogger) SetLogger 

func (bl *BasicLogger) SetLogger(logger *log.Logger)

func (*BasicLogger) Warning 

func (bl *BasicLogger) Warning(pattern string, args ...interface{})

type IdleCounter 

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

func NewIdleCounter 

func NewIdleCounter(timeout time.Duration) *IdleCounter

func (*IdleCounter) GetChan 

func (ic *IdleCounter) GetChan() <-chan time.Time

func (*IdleCounter) Kill added in v1.1.8 

func (ic *IdleCounter) Kill()

func (*IdleCounter) Reset 

func (ic *IdleCounter) Reset()

func (*IdleCounter) Set 

func (ic *IdleCounter) Set(timeout time.Duration)

func (*IdleCounter) Stop 

func (ic *IdleCounter) Stop()

type LockedCounter 

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

func (*LockedCounter) Dec 

func (lc *LockedCounter) Dec()

func (*LockedCounter) GetValue 

func (lc *LockedCounter) GetValue() int

func (*LockedCounter) Inc 

func (lc *LockedCounter) Inc()

func (*LockedCounter) SetStartValue 

func (lc *LockedCounter) SetStartValue(value int)

type LockedValue 

type LockedValue[T interface{}] struct {
	// contains filtered or unexported fields
}

func (*LockedValue[T]) GetValue 

func (lv *LockedValue[T]) GetValue() T

func (*LockedValue[T]) Set 

func (lv *LockedValue[T]) Set(newValue T)

type LogLevel 

type LogLevel int
const (
	DebugLevel LogLevel = iota
	InfoLevel
	WarningLevel
	ErrorLevel
	FatalLevel
)

type LoggerConfig 

type LoggerConfig struct {
	Level            LogLevel
	FileToLog        string
	StreamBufferSize int
	StreamLogLines   int
}

type LoggerIFace 

type LoggerIFace interface {
	GetType() string
	SetConfig(LoggerConfig)
	GetConfig() LoggerConfig
	SetLogger(*log.Logger)
	GetLogger() *log.Logger
	Clone() LoggerIFace
	Debug(string, ...interface{})
	Info(string, ...interface{})
	Warning(string, ...interface{})
	Error(string, ...interface{})
	Fatal(string, ...interface{})
}

func NewBasicLogger 

func NewBasicLogger(config LoggerConfig, prefix string) LoggerIFace

func NewStreamLogger 

func NewStreamLogger(logBuffer *StreamLogBuffer, config LoggerConfig, prefix string) LoggerIFace

type Queue 

type Queue[T interface{}] struct {
	// contains filtered or unexported fields
}

func (*Queue[T]) Close 

func (q *Queue[T]) Close()

func (*Queue[T]) GetChan 

func (q *Queue[T]) GetChan() <-chan T

It returns a receive only channel so it cannot be used for send

func (*Queue[T]) GetStates 

func (q *Queue[T]) GetStates() (bool, bool)

func (*Queue[T]) Open 

func (q *Queue[T]) Open(name string, size int, waitTimeInMS int, sleepTimeInMS int, logger LoggerIFace)

func (*Queue[T]) Release 

func (q *Queue[T]) Release()

Have to also nil that channel to be not selected for drain after that it cannot be drained

func (*Queue[T]) Send 

func (q *Queue[T]) Send(data T)

func (*Queue[T]) Wait 

func (q *Queue[T]) Wait(tsToMatch time.Time, timeout time.Duration) (data T, gotData bool)

type Signal 

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

func (*Signal) Close 

func (s *Signal) Close()

func (*Signal) GetChan 

func (s *Signal) GetChan() <-chan struct{}

It returns a receive only channel so it cannot be used for send

func (*Signal) GetStates 

func (s *Signal) GetStates() (bool, bool)

func (*Signal) Open 

func (s *Signal) Open(name string, logger LoggerIFace)

func (*Signal) Release 

func (s *Signal) Release()

func (*Signal) Send 

func (s *Signal) Send()

type StreamLogBuffer 

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

func (*StreamLogBuffer) Dump 

func (slb *StreamLogBuffer) Dump() []byte

func (*StreamLogBuffer) EnableStreaming 

func (slb *StreamLogBuffer) EnableStreaming(value bool)

func (*StreamLogBuffer) Flush 

func (slb *StreamLogBuffer) Flush() []byte

func (*StreamLogBuffer) Init 

func (sbl *StreamLogBuffer) Init()

func (*StreamLogBuffer) IsStreamingEnabled 

func (slb *StreamLogBuffer) IsStreamingEnabled() bool

func (*StreamLogBuffer) Run 

func (slb *StreamLogBuffer) Run()

func (*StreamLogBuffer) SetUrl 

func (slb *StreamLogBuffer) SetUrl(url string)

func (*StreamLogBuffer) Stop 

func (slb *StreamLogBuffer) Stop()

func (*StreamLogBuffer) Write 

func (slb *StreamLogBuffer) Write(data []byte) (int, error)

type StreamLogger 

type StreamLogger struct {
	BasicLogger
	// contains filtered or unexported fields
}

func (*StreamLogger) Clone 

func (sl *StreamLogger) Clone() LoggerIFace

func (*StreamLogger) EnableStreaming 

func (sl *StreamLogger) EnableStreaming(val bool)

func (*StreamLogger) GetBuffer 

func (sl *StreamLogger) GetBuffer() *StreamLogBuffer

func (*StreamLogger) GetType 

func (sl *StreamLogger) GetType() string

func (*StreamLogger) IsStreamingEnabled 

func (sl *StreamLogger) IsStreamingEnabled() bool

func (*StreamLogger) SetBuffer 

func (sl *StreamLogger) SetBuffer(buffer *StreamLogBuffer)

func (*StreamLogger) SetUrl 

func (sl *StreamLogger) SetUrl(url string)

func (*StreamLogger) Start 

func (sl *StreamLogger) Start()

func (*StreamLogger) Stop 

func (sl *StreamLogger) Stop()

type WithTimestampIFace added in v1.1.3 

type WithTimestampIFace interface {
	GetTimestamp() time.Time
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.