Documentation
¶
Index ¶
- Constants
- Variables
- func From16To10(str string) int64
- func SecondsToUnixTime(seconds int) time.Time
- type ApplicationType
- type ComplexDataParser
- type ComplexDataType
- type CtxEventReader
- type Event
- type EventCauseType
- type EventManager
- type EventReader
- type EventScopeType
- type EventType
- type Exporter
- type ExporterConfig
- type ExporterStorage
- type InMemoryJournal
- type JournalStorage
- type LgfReader
- type LgpReader
- func (r *LgpReader) Close() error
- func (r *LgpReader) Offset() int64
- func (r *LgpReader) Read(limit int, timeout time.Duration) (items []Event, err error)
- func (r *LgpReader) ReadCtx(ctx context.Context, limit int, timeout time.Duration) (items []Event, err error)
- func (r *LgpReader) Seek(offset int64) (int64, error)
- type LgpReaderOptions
- type LongPoller
- type Manager
- type ManagerOptions
- type Objects
- type Poller
- type RefObject
- type SeverityType
- type TransactionStatusType
Constants ¶
View Source
const ( ObjectTypeNone = 0 ObjectTypeUsers = 1 ObjectTypeComputers = 2 ObjectTypeApplications = 3 ObjectTypeEvents = 4 ObjectTypeMetadata = 5 ObjectTypeServers = 6 ObjectTypeMainPorts = 7 ObjectTypeAddPorts = 8 ObjectTypeSessionDataSeparator = 9 ObjectTypeSessionDataSeparatorValue = 10 ObjectTypeUnknown = 11 )
Variables ¶
View Source
var ErrLgfNotFound = errors.New("lgf not found")
Functions ¶
func From16To10 ¶
func SecondsToUnixTime ¶
Types ¶
type ApplicationType ¶
type ApplicationType string
const ( Application1CV8 ApplicationType = "1CV8" //"1CV8" => "Толстый клиент", Application1CV8C ApplicationType = "1CV8C" //"1CV8C" => "Тонкий клиент", ApplicationWebClient ApplicationType = "WebClient" //"WebClient" => "Веб-клиент", ApplicationDesigner ApplicationType = "Designer" //"Designer" => "Конфигуратор", ApplicationCOMConnection ApplicationType = "COMConnection" //"COMConnection" => "Внешнее соединение (COM, обычное)", ApplicationWSConnection ApplicationType = "WSConnection" //"WSConnection" => "Сессия web-сервиса", ApplicationBackgroundJob ApplicationType = "BackgroundJob" //"BackgroundJob" => "Фоновое задание", ApplicationSystemBackgroundJob ApplicationType = "SystemBackgroundJob" //"SystemBackgroundJob" => "Системное фоновое задание", ApplicationSrvrConsole ApplicationType = "SrvrConsole" //"SrvrConsole" => "Консоль кластера", ApplicationCOMConsole ApplicationType = "COMConsole" //"COMConsole" => "Внешнее соединение (COM, административное)", ApplicationJobScheduler ApplicationType = "JobScheduler" //"JobScheduler" => "Планировщик заданий", ApplicationDebugger ApplicationType = "Debugger" //"Debugger" => "Отладчик", ApplicationRAS ApplicationType = "RAS" //"RAS" => "Сервер администрирования", )
func (ApplicationType) String ¶
func (t ApplicationType) String() string
type ComplexDataParser ¶
type ComplexDataType ¶
type ComplexDataType int
const ( UnknownComplexData ComplexDataType = 0 AuthenticationErrorData ComplexDataType = 1 AuthenticationData ComplexDataType = 6 UpdateUserData ComplexDataType = 30 )
func (ComplexDataType) Parser ¶
func (c ComplexDataType) Parser() ComplexDataParser
type CtxEventReader ¶
type Event ¶
type Event struct {
Date time.Time
TransactionStatus TransactionStatusType
TransactionDate time.Time
TransactionNumber int64
UserUuid string
User string
Computer string
Application ApplicationType
Connection int64
Event EventType
Severity SeverityType
Comment string
MetadataUuid string
Metadata string
Data interface{}
DataPresentation string
Server string
MainPort string
AddPort string
Session int64
Offset int64
Size int64
JournalFile string
JournalUUID string
}
type EventCauseType ¶
type EventCauseType string
const ( EventCauseAccess EventCauseType = "Access" //"_$Access$_.Access" => "Доступ.Доступ", EventCauseAccessDenied EventCauseType = "AccessDenied" //"_$Access$_.AccessDenied" => "Доступ.Отказ в доступе", EventCauseDelete EventCauseType = "Delete" //"_$Data$_.Delete" => "Данные.Удаление", EventCauseDeletePredefinedData EventCauseType = "DeletePredefinedData" //"_$Data$_.DeletePredefinedData" => " Данные.Удаление предопределенных данных", EventCauseDeleteVersions EventCauseType = "DeleteVersions" //"_$Data$_.DeleteVersions" => "Данные.Удаление версий", EventCauseNew EventCauseType = "New" //"_$Data$_.New" => "Данные.Добавление", EventCauseNewPredefinedData EventCauseType = "NewPredefinedData" //"_$Data$_.NewPredefinedData" => "Данные.Добавление предопределенных данных", EventCauseNewVersion EventCauseType = "NewVersion" //"_$Data$_.NewVersion" => "Данные.Добавление версии", EventCausePos EventCauseType = "Pos" //"_$Data$_.Pos" => "Данные.Проведение", EventCausePredefinedDataInitialization EventCauseType = "PredefinedDataInitialization" //"_$Data$_.PredefinedDataInitialization" => "Данные.Инициализация предопределенных данных", EventCausePredefinedDataInitializationDataNotFound EventCauseType = "PredefinedDataInitializationDataNotFound" //"_$Data$_.PredefinedDataInitializationDataNotFound" => "Данные.Инициализация предопределенных данных.Данные не найдены", EventCauseSetPredefinedDataInitialization EventCauseType = "SetPredefinedDataInitialization" //"_$Data$_.SetPredefinedDataInitialization" => "Данные.Установка инициализации предопределенных данных", EventCauseSetStandardODataInterfaceContent EventCauseType = "SetStandardODataInterfaceContent" //"_$Data$_.SetStandardODataInterfaceContent" => "Данные.Изменение состава стандартного интерфейса OData", EventCauseTotalsMaxPeriodUpdate EventCauseType = "TotalsMaxPeriodUpdate" //"_$Data$_.TotalsMaxPeriodUpdate" => "Данные.Изменение максимального периода рассчитанных итогов", EventCauseTotalsMinPeriodUpdate EventCauseType = "TotalsMinPeriodUpdate" //"_$Data$_.TotalsMinPeriodUpdate" => "Данные.Изменение минимального периода рассчитанных итогов", EventCausePost EventCauseType = "Post" //"_$Data$_.Post" => "Данные.Проведение", EventCauseUnpost EventCauseType = "Unpost" //"_$Data$_.Unpost" => "Данные.Отмена проведения", EventCauseUpdate EventCauseType = "Update" //"_$Data$_.Update" => "Данные.Изменение", EventCauseUpdatePredefinedData EventCauseType = "UpdatePredefinedData" //"_$Data$_.UpdatePredefinedData" => "Данные.Изменение предопределенных данных", EventCauseVersionCommentUpdate EventCauseType = "VersionCommentUpdate" //"_$Data$_.VersionCommentUpdate" => "Данные.Изменение комментария версии", EventCauseConfigExtensionUpdate EventCauseType = "ConfigExtensionUpdate" //"_$InfoBase$_.ConfigExtensionUpdate" => "Информационная база.Изменение расширения конфигурации", EventCauseConfigUpdate EventCauseType = "ConfigUpdate" //"_$InfoBase$_.ConfigUpdate" => "Информационная база.Изменение конфигурации", EventCauseDBConfigBackgroundUpdateCancel EventCauseType = "DBConfigBackgroundUpdateCancel" //"_$InfoBase$_.DBConfigBackgroundUpdateCancel" => "Информационная база.Отмена фонового обновления", EventCauseDBConfigBackgroundUpdateFinish EventCauseType = "DBConfigBackgroundUpdateFinish" //"_$InfoBase$_.DBConfigBackgroundUpdateFinish" => "Информационная база.Завершение фонового обновления", EventCauseDBConfigBackgroundUpdateResume EventCauseType = "DBConfigBackgroundUpdateResume" //"_$InfoBase$_.DBConfigBackgroundUpdateResume" => "Информационная база.Продолжение (после приостановки) процесса фонового обновления", EventCauseDBConfigBackgroundUpdateStart EventCauseType = "DBConfigBackgroundUpdateStart" //"_$InfoBase$_.DBConfigBackgroundUpdateStart" => "Информационная база.Запуск фонового обновления", EventCauseDBConfigBackgroundUpdateSuspend EventCauseType = "DBConfigBackgroundUpdateSuspend" //"_$InfoBase$_.DBConfigBackgroundUpdateSuspend" => "Информационная база.Приостановка (пауза) процесса фонового обновления", EventCauseDBConfigExtensionUpdate EventCauseType = "DBConfigExtensionUpdate" //"_$InfoBase$_.DBConfigExtensionUpdate" => "Информационная база.Изменение расширения конфигурации", EventCauseDBConfigExtensionUpdateError EventCauseType = "DBConfigExtensionUpdateError" //"_$InfoBase$_.DBConfigExtensionUpdateError" => "Информационная база.Ошибка изменения расширения конфигурации", EventCauseDBConfigUpdate EventCauseType = "DBConfigUpdate" //"_$InfoBase$_.DBConfigUpdate" => "Информационная база.Изменение конфигурации базы данных", EventCauseDBConfigUpdateStart EventCauseType = "DBConfigUpdateStart" //"_$InfoBase$_.DBConfigUpdateStart" => "Информационная база.Запуск обновления конфигурации базы данных", EventCauseDumpError EventCauseType = "DumpError" //"_$InfoBase$_.DumpError" => "Информационная база.Ошибка выгрузки в файл", EventCauseDumpFinish EventCauseType = "DumpFinish" //"_$InfoBase$_.DumpFinish" => "Информационная база.Окончание выгрузки в файл", EventCauseDumpStart EventCauseType = "DumpStart" //"_$InfoBase$_.DumpStart" => "Информационная база.Начало выгрузки в файл", EventCauseEraseData EventCauseType = "EraseData" //"_$InfoBase$_.EraseData" => " Информационная база.Удаление данных информационной баз", EventCauseEventLogReduce EventCauseType = "EventLogReduce" //"_$InfoBase$_.EventLogReduce" => "Информационная база.Сокращение журнала регистрации", EventCauseEventLogReduceError EventCauseType = "EventLogReduceError" //"_$InfoBase$_.EventLogReduceError" => "Информационная база.Ошибка сокращения журнала регистрации", EventCauseEventLogSettingsUpdate EventCauseType = "EventLogSettingsUpdate" //"_$InfoBase$_.EventLogSettingsUpdate" => "Информационная база.Изменение параметров журнала регистрации", EventCauseEventLogSettingsUpdateError EventCauseType = "EventLogSettingsUpdateError" //"_$InfoBase$_.EventLogSettingsUpdateError" => "Информационная база.Ошибка при изменение настроек журнала регистрации", EventCauseInfoBaseAdmParamsUpdate EventCauseType = "InfoBaseAdmParamsUpdate" //"_$InfoBase$_.InfoBaseAdmParamsUpdate" => "Информационная база.Изменение параметров информационной базы", EventCauseInfoBaseAdmParamsUpdateError EventCauseType = "InfoBaseAdmParamsUpdateError" //"_$InfoBase$_.InfoBaseAdmParamsUpdateError" => "Информационная база.Ошибка изменения параметров информационной базы", EventCauseIntegrationServiceActiveUpdate EventCauseType = "IntegrationServiceActiveUpdate" //"_$InfoBase$_.IntegrationServiceActiveUpdate" => "Информационная база.Изменение активности сервиса интеграции", EventCauseIntegrationServiceSettingsUpdate EventCauseType = "IntegrationServiceSettingsUpdate" //"_$InfoBase$_.IntegrationServiceSettingsUpdate" => "Информационная база.Изменение настроек сервиса интеграции", EventCauseMasterNodeUpdate EventCauseType = "MasterNodeUpdate" //"_$InfoBase$_.MasterNodeUpdate" => "Информационная база.Изменение главного узла", EventCausePredefinedDataUpdate EventCauseType = "PredefinedDataUpdate" //"_$InfoBase$_.PredefinedDataUpdate" => "Информационная база.Обновление предопределенных данных", EventCauseRegionalSettingsUpdate EventCauseType = "RegionalSettingsUpdate" //"_$InfoBase$_.RegionalSettingsUpdate" => "Информационная база.Изменение региональных установок", EventCauseRestoreError EventCauseType = "RestoreError" //"_$InfoBase$_.RestoreError" => "Информационная база.Ошибка загрузки из файла", EventCauseRestoreFinish EventCauseType = "RestoreFinish" //"_$InfoBase$_.RestoreFinish" => "Информационная база.Окончание загрузки из файла", EventCauseRestoreStart EventCauseType = "RestoreStart" //"_$InfoBase$_.RestoreStart" => "Информационная база.Начало загрузки из файла", EventCauseSecondFactorAuthTemplateDelete EventCauseType = "SecondFactorAuthTemplateDelete" //"_$InfoBase$_.SecondFactorAuthTemplateDelete" => "Информационная база.Удаление шаблона вторго фактора аутентификации", EventCauseSecondFactorAuthTemplateNew EventCauseType = "SecondFactorAuthTemplateNew" //"_$InfoBase$_.SecondFactorAuthTemplateNew" => "Информационная база.Добавление шаблона вторго фактора аутентификации", EventCauseSecondFactorAuthTemplateUpdate EventCauseType = "SecondFactorAuthTemplateUpdate" //"_$InfoBase$_.SecondFactorAuthTemplateUpdate" => "Информационная база.Изменение шаблона вторго фактора аутентификации", EventCauseSetPredefinedDataUpdate EventCauseType = "SetPredefinedDataUpdate" //"_$InfoBase$_.SetPredefinedDataUpdate" => "Информационная база.Установить обновление предопределенных данных", EventCauseTARImportant EventCauseType = "TARImportant" //"_$InfoBase$_.TARImportant" => "Тестирование и исправление.Ошибка", EventCauseTARInfo EventCauseType = "TARInfo" //"_$InfoBase$_.TARInfo" => "Тестирование и исправление.Сообщение", EventCauseTARMess EventCauseType = "TARMess" //"_$InfoBase$_.TARMess" => "Тестирование и исправление.Предупреждение", EventCauseCancel EventCauseType = "Cancel" //"_$Job$_.Cancel" => "Фоновое задание.Отмена", EventCauseFail EventCauseType = "Fail" //"_$Job$_.Fail" => "Фоновое задание.Ошибка выполнения", EventCauseStart EventCauseType = "Start" //"_$Job$_.Start" => "Фоновое задание.Запуск", EventCauseSucceed EventCauseType = "Succeed" //"_$Job$_.Succeed" => "Фоновое задание.Успешное завершение", EventCauseTerminate EventCauseType = "Terminate" //"_$Job$_.Terminate" => "Фоновое задание.Принудительное завершение", EventCauseNegativeAssertion EventCauseType = "NegativeAssertion" //"_$OpenIDProvider$_.NegativeAssertion" => "Провайдер OpenID.Отклонено", EventCausePositiveAssertion EventCauseType = "PositiveAssertion" //"_$OpenIDProvider$_.PositiveAssertion" => "Провайдер OpenID.Подтверждено", EventCauseAuthentication EventCauseType = "Authentication" //"_$Session$_.Authentication" => "Сеанс.Аутентификация", EventCauseAuthenticationError EventCauseType = "AuthenticationError" //"_$Session$_.AuthenticationError" => "Сеанс.Ошибка аутентификации", EventCauseAuthenticationFirstFactor EventCauseType = "AuthenticationFirstFactor" //"_$Session$_.AuthenticationFirstFactor" => "Сеанс.Аутентификация первый фактор", EventCauseConfigExtensionApplyError EventCauseType = "ConfigExtensionApplyError" //"_$Session$_.ConfigExtensionApplyError" => "Сеанс.Ошибка применения расширения конфигурации", EventCauseFinish EventCauseType = "Finish" //"_$Session$_.Finish" => "Сеанс.Завершение", EventCauseBegin EventCauseType = "Begin" //"_$Session$_.Start" => "Сеанс.Начало", "_$Transaction$_.Begin" => "Транзакция.Начало", EventCauseCommit EventCauseType = "Commit" //"_$Transaction$_.Commit" => "Транзакция.Фиксация", EventCauseRollback EventCauseType = "Rollback" //"_$Transaction$_.Rollback" => "Транзакция.Отмена", EventCauseAuthenticationLock EventCauseType = "AuthenticationLock" //"_$User$_.AuthenticationLock" => "Пользователи.Блокировка аутентификации", EventCauseAuthenticationUnlock EventCauseType = "AuthenticationUnlock" //"_$User$_.AuthenticationUnlock" => "Пользователи.Разблокировка аутентификации", EventCauseAuthenticationUnlockError EventCauseType = "AuthenticationUnlockError" //"_$User$_.AuthenticationUnlockError " => "Пользователи.Ошибка разблокировки аутентификации", EventCauseDeleteError EventCauseType = "DeleteError" //"_$User$_.DeleteError" => "Пользователи.Ошибка удаления", EventCauseUpdateError EventCauseType = "UpdateError" //"_$User$_.UpdateError" => "Пользователи. Ошибка изменения", EventCauseNewError EventCauseType = "NewError" //"_$User$_.NewError" => "Пользователи.Ошибка добавления", )
func (EventCauseType) String ¶
func (t EventCauseType) String() string
type EventManager ¶
type EventManager struct {
Events chan Event
Poller Poller
// contains filtered or unexported fields
}
func (*EventManager) Poll ¶
func (m *EventManager) Poll(dest chan Event, stop chan struct{})
func (*EventManager) Start ¶
func (m *EventManager) Start()
func (*EventManager) Stop ¶
func (m *EventManager) Stop()
type EventReader ¶
type EventScopeType ¶
type EventScopeType string
const ( EventScopeUndefined EventScopeType = "_$Undefined$_" // => Неопределено EventScopeAccess EventScopeType = "_$Access$_" // => Доступ EventScopeData EventScopeType = "_$Data$_" // => Данные EventScopeInfobase EventScopeType = "_$InfoBase$_" // => Информационная база EventScopeJob EventScopeType = "_$Job$_" // => Фоновое задание EventScopeOpenIDProvider EventScopeType = "_$OpenIDProvider$_" // => Провайдер OpenID EventScopePerformError EventScopeType = "_$PerformError$_" // => Ошибка выполнения EventScopeSession EventScopeType = "_$Session$_" // => Сеанс EventScopeTransaction EventScopeType = "_$Transaction$_" // => Транзакция EventScopeUser EventScopeType = "_$User$_" // => Пользователи )
func (EventScopeType) String ¶
func (t EventScopeType) String() string
type EventType ¶
type EventType string
func (EventType) Cause ¶
func (t EventType) Cause() EventCauseType
func (EventType) Scope ¶
func (t EventType) Scope() EventScopeType
type Exporter ¶
type Exporter struct {
File string // Файл логов
TZ *time.Location // Временная зона для времени логово
Timeout time.Duration // timeout чтения
Events chan Event
Poller Poller
// contains filtered or unexported fields
}
func NewExporter ¶
func NewExporter(eventReader EventReader, storage []ExporterStorage, config ...ExporterConfig) *Exporter
type ExporterConfig ¶
type ExporterStorage ¶
type ExporterStorage interface {
Push(event Event)
}
type InMemoryJournal ¶
type InMemoryJournal struct {
// contains filtered or unexported fields
}
func NewInMemoryJournal ¶
func NewInMemoryJournal() *InMemoryJournal
func (InMemoryJournal) GetOffset ¶
func (i InMemoryJournal) GetOffset(file string) int64
func (InMemoryJournal) SetOffset ¶
func (i InMemoryJournal) SetOffset(file string, off int64)
type JournalStorage ¶
type LgfReader ¶
type LgfReader struct {
// contains filtered or unexported fields
}
func NewLgfReader ¶
func (*LgfReader) ObjectValue ¶
type LgpReader ¶
func NewLgpReader ¶
func NewLgpReader(path string, opts ...LgpReaderOptions) (*LgpReader, error)
NewLgpReader создает новый читатель журнала регистрации 1С
type LgpReaderOptions ¶
type LongPoller ¶
type LongPoller struct {
Limit int
Timeout time.Duration
// AllowedSeverity contains the event types
// Possible values:
// SeverityInfo => "Информация"
// SeverityError => "Ошибка"
// SeverityWarn => "Предупреждение"
// SeverityNote => "Примечание"
//
AllowedSeverity []SeverityType
LastErr error
}
func (*LongPoller) Poll ¶
func (p *LongPoller) Poll(r EventReader, dest chan Event, stop chan struct{})
Poll does long polling.
type Manager ¶
type Manager struct {
Folder []string // Каталог жерналов регистрации
LiveMode bool // Auto use live mode
BulkSize int
Timeout time.Duration
Ticker time.Duration
TZ *time.Location
// contains filtered or unexported fields
}
Manager основной объект выполнения чтения и экспорта журналов регистрации
func NewManager ¶
func NewManager(ctx context.Context, opt ManagerOptions) *Manager
type ManagerOptions ¶
type ManagerOptions struct {
Timeout time.Duration
Folder []string
PoolSize int
IdleCheckFrequency time.Duration
JournalStorage JournalStorage
Exporters []ExporterStorage
BulkSize int
}
type Poller ¶
type Poller interface {
Poll(r EventReader, dest chan Event, stop chan struct{})
}
type SeverityType ¶
type SeverityType string
const ( SeverityInfo SeverityType = "I" //"I" => "Информация", SeverityError SeverityType = "E" //"E" => "Ошибка", SeverityWarn SeverityType = "W" //"W" => "Предупреждение", SeverityNote SeverityType = "N" //"N" => "Примечание", )
func (SeverityType) String ¶
func (t SeverityType) String() string
type TransactionStatusType ¶
type TransactionStatusType string
const ( TransactionStatusCommitted TransactionStatusType = "U" // "U" => "Зафиксирована", TransactionStatusCanceled TransactionStatusType = "C" //"C" => "Отменена", TransactionStatusNotCompleted TransactionStatusType = "R" //"R" => "Не завершена", TransactionStatusNoTransaction TransactionStatusType = "N" //"N" => "Нет транзакции", )
func (TransactionStatusType) String ¶
func (t TransactionStatusType) String() string
Source Files
¶
Click to show internal directories.
Click to hide internal directories.