logharbour

Jun 8, 2024

Changes in this version

+ const DEFAULT_LOCALE

+ const ESLogsMapping

+ type IPLocation struct

+ City string

+ Country string

+ IPAddress string

+ Latitude float64

+ Longitude float64

+ func ListUnusualIPs(queryToken string, client *elasticsearch.TypedClient, geoLiteDb *geoip2.Reader, ...) ([]IPLocation, error)

type Logger

+ func (l *Logger) LogActivityf(data ActivityInfo, format string, args ...any)

+ func (l *Logger) LogDataChangef(data ChangeInfo, format string, args ...any)

+ func (l *Logger) LogDebugf(data any, format string, args ...any)

+ func (l *Logger) Logf(format string, args ...any)

type LoggerContext

+ func (lc *LoggerContext) IsDebugModeSet() bool

May 2, 2024

Changes in this version

type ElasticsearchClient

+ func (ec *ElasticsearchClient) CreateIndex(indexName, mapping string) error

+ func (ec *ElasticsearchClient) IndexExists(indexName string) (bool, error)

May 1, 2024

Changes in this version

+ const ACTIVITY

+ const DEBUG

+ const DIALTIMEOUT

+ var Index = "logharbour"

+ var LOGHARBOUR_GETLOGS_MAXREC = 5

+ var Priority = []string

+ func GetApps(querytoken string, client *elasticsearch.TypedClient) (apps []string, err error)

+ func GetLocalIPAddress() (string, error)

+ func GetSet(queryToken string, client *elasticsearch.TypedClient, setAttr string, ...) (map[string]int64, error)

+ func GetUnusualIP(queryToken string, client *elasticsearch.TypedClient, unusualPercent float64, ...) ([]string, error)

+ type GetLogsParam struct

+ App *string

+ Class *string

+ Field *string

+ FromTS *time.Time

+ Instance *string

+ Module *string

+ NDays *int

+ Operation *string

+ Priority *LogPriority

+ RemoteIP *string

+ SearchAfterDocID *string

+ SearchAfterTS *string

+ ToTS *time.Time

+ Type *LogType

+ Who *string

+ type GetSetParam struct

+ App *string

+ Class *string

+ Fromts *time.Time

+ Instance *string

+ Ndays *int

+ Op *string

+ Pri *LogPriority

+ RemoteIP *string

+ Tots *time.Time

+ Type *LogType

+ Who *string

+ type GetUnusualIPParam struct

+ App *string

+ Class *string

+ NDays *int

+ Operation *string

+ Who *string

+ type LogData struct

+ ActivityData string

+ ChangeData *ChangeInfo

+ DebugData *DebugInfo

type LogEntry

+ Id string

+ func GetChanges(querytoken string, client *elasticsearch.TypedClient, logParam GetLogsParam) ([]LogEntry, int, error)

+ func GetLogs(querytoken string, client *elasticsearch.TypedClient, logParam GetLogsParam) ([]LogEntry, int, error)

Feb 22, 2024

Changes in this version

type ChangeDetail

+ NewVal any

+ OldVal any

type ChangeInfo

+ Op string

+ type Consumer interface

+ Start func(batchSize int) (<-chan error, error)

+ Stop func() error

+ func NewConsumer(brokers []string, topic string, handler MessageHandler) (Consumer, error)

+ type ElasticsearchClient struct

+ func NewElasticsearchClient(cfg elasticsearch.Config) (*ElasticsearchClient, error)

+ func (ec *ElasticsearchClient) Write(index string, documentID string, body string) error

+ type ElasticsearchWriter interface

+ Write func(index string, documentID string, body string) error

type LogEntry

+ App string

+ Class string

+ InstanceId string

+ Msg string

+ Pri LogPriority

type Logger

+ func (l *Logger) WithClass(whatClass string) *Logger

+ func (l *Logger) WithInstanceId(whatInstanceId string) *Logger

type LoggerContext

+ func (lc *LoggerContext) ChangeMinLogPriority(minLogPriority LogPriority)

+ func (lc *LoggerContext) IsDebugMode() bool

+ func (lc *LoggerContext) SetDebugMode(enable bool)

+ type MessageHandler func(messages []*sarama.ConsumerMessage) error

Jan 15, 2024

Changes in this version

+ type ChangeDetail struct

+ Field string

+ NewValue any

+ OldValue any

+ func NewChangeDetail(field string, oldValue, newValue any) ChangeDetail

type ChangeInfo

+ func NewChangeInfo(entity, operation string) *ChangeInfo

+ func (ci *ChangeInfo) AddChange(field string, oldValue, newValue any) *ChangeInfo

type DebugInfo

+ Data map[string]any

+ type KafkaConfig struct

+ Brokers []string

+ ClientID *string

+ CompressionLevel *int

+ DialTimeout *time.Duration

+ MaxOpenRequests *int

+ ReadTimeout *time.Duration

+ RequiredAcks *sarama.RequiredAcks

+ Retries *int

+ ReturnErrors *bool

+ ReturnSuccesses *bool

+ Timeout *time.Duration

+ Topic string

+ WriteTimeout *time.Duration

+ type KafkaWriter interface

+ Close func() error

+ Write func(p []byte) (n int, err error)

+ func NewKafkaWriter(kafkaConfig KafkaConfig, opts ...KafkaWriterOption) (KafkaWriter, error)

+ type KafkaWriterOption func(*kafkaWriter)

+ func WithPoolSize(size int) KafkaWriterOption

Dec 9, 2023

Changes in this version

type Logger

+ func (l *Logger) ChangeMinLogPriority(minLogPriority LogPriority)

+ type LoggerContext struct

+ func NewLoggerContext(minLogPriority LogPriority) *LoggerContext

Dec 6, 2023

Changes in this version

type LogEntry

+ Error string

type Logger

+ func (l *Logger) Error(err error) *Logger

Dec 6, 2023

Changes in this version

type Logger

+ func (l *Logger) Crit() *Logger

+ func (l *Logger) Debug0() *Logger

+ func (l *Logger) Debug1() *Logger

+ func (l *Logger) Debug2() *Logger

+ func (l *Logger) Err() *Logger

+ func (l *Logger) Info() *Logger

+ func (l *Logger) Sec() *Logger

+ func (l *Logger) Warn() *Logger

Nov 30, 2023

Changes in this version

type LogPriority

+ func (lp *LogPriority) UnmarshalJSON(data []byte) error

+ func (lp LogPriority) String() string

type LogType

+ const Unknown

+ func (lt *LogType) UnmarshalJSON(data []byte) error

+ func (lt LogType) String() string

type Logger

+ func (l *Logger) Log(message string) error

Nov 20, 2023

Changes in this version

+ const DefaultPriority

+ const LogPriorityCrit

+ const LogPriorityDebug0

+ const LogPriorityDebug1

+ const LogPriorityDebug2

+ const LogPriorityErr

+ const LogPriorityInfo

+ const LogPrioritySec

+ const LogPriorityUnknown

+ const LogPriorityWarn

+ const LogTypeActivity

+ const LogTypeChange

+ const LogTypeDebug

+ const LogTypeUnknown

+ func GetDebugInfo(skip int) (fileName string, lineNumber int, functionName string, stackTrace string)

+ type ActivityInfo any

+ type ChangeInfo struct

+ Changes map[string]any

+ Entity string

+ Operation string

+ type DebugInfo struct

+ FileName string

+ FunctionName string

+ LineNumber int

+ Pid int

+ Runtime string

+ StackTrace string

+ Variables map[string]any

+ type FallbackWriter struct

+ func NewFallbackWriter(primary, fallback io.Writer) *FallbackWriter

+ func (fw *FallbackWriter) Write(p []byte) (n int, err error)

+ type LogEntry struct

+ AppName string

+ Data any

+ Message string

+ Module string

+ Op string

+ Priority LogPriority

+ RemoteIP string

+ Status Status

+ System string

+ Type LogType

+ WhatClass string

+ WhatInstanceId string

+ When time.Time

+ Who string

+ type LogPriority int

+ const Crit

+ const Debug0

+ const Debug1

+ const Debug2

+ const Err

+ const Info

+ const Sec

+ const Warn

+ func (lp LogPriority) MarshalJSON() ([]byte, error)

+ type LogType int

+ const Activity

+ const Change

+ const Debug

+ func (lt LogType) MarshalJSON() ([]byte, error)

+ type Logger struct

+ func NewLogger(appName string, writer io.Writer) *Logger

+ func NewLoggerWithFallback(appName string, fallbackWriter *FallbackWriter) *Logger

+ func (l *Logger) ChangePriority(newPriority LogPriority)

+ func (l *Logger) LogActivity(message string, data ActivityInfo) error

+ func (l *Logger) LogDataChange(message string, data ChangeInfo) error

+ func (l *Logger) LogDebug(message string, data DebugInfo) error

+ func (l *Logger) WithModule(module string) *Logger

+ func (l *Logger) WithOp(op string) *Logger

+ func (l *Logger) WithPriority(priority LogPriority) *Logger

+ func (l *Logger) WithRemoteIP(remoteIP string) *Logger

+ func (l *Logger) WithStatus(status Status) *Logger

+ func (l *Logger) WithWhatClass(whatClass string) *Logger

+ func (l *Logger) WithWhatInstanceId(whatInstanceId string) *Logger

+ func (l *Logger) WithWho(who string) *Logger

+ type Status int

+ const Failure

+ const Success