rx

package
v1.5.1 Latest Latest
Warning

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

Go to latest
Published: Nov 23, 2020 License: GPL-3.0 Imports: 10 Imported by: 2

Documentation

Index

Constants

View Source
const (
	RotationSignalEvent = "CONFIG:LOG_ROTATE"
)

Variables

View Source
var (
	ErrJournalClosed = errors.New("journal closed")
)

Functions

This section is empty.

Types

type Config

type Config struct {
	log.Config
	Enable               bool `schema:"Включение/отключение журналирования"`
	EnableRemoteTransfer bool `` /* 199-byte string literal not displayed */
}

type RxJournal

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

func NewDefaultRxJournal

func NewDefaultRxJournal(journalServiceClient *backend.RxGrpcClient) *RxJournal

func (*RxJournal) Close

func (j *RxJournal) Close() error

func (*RxJournal) CollectAndTransferExistedLogs

func (j *RxJournal) CollectAndTransferExistedLogs()

func (*RxJournal) Error

func (j *RxJournal) Error(event string, req []byte, res []byte, err error) error

func (*RxJournal) Info

func (j *RxJournal) Info(event string, req []byte, res []byte) error

func (*RxJournal) Log

func (j *RxJournal) Log(level entry.Level, event string, req []byte, res []byte, err error) error

func (*RxJournal) ReceiveConfiguration

func (j *RxJournal) ReceiveConfiguration(loggerConfig Config, moduleName string)

func (*RxJournal) Rotate added in v1.1.2

func (j *RxJournal) Rotate() error

func (*RxJournal) SubscribeToRotationSignal added in v1.5.0

func (j *RxJournal) SubscribeToRotationSignal() (event string, f func(_ []byte))

func (*RxJournal) Warn

func (j *RxJournal) Warn(event string, req []byte, res []byte, err error) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL