rx

Mar 25, 2020

Changes in this version

+ const RotationSignalEvent

+ var ErrJournalClosed = errors.New("journal closed")

type RxJournal

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

Aug 22, 2019

Changes in this version

type RxJournal

+ func (j *RxJournal) Rotate() error

Jul 12, 2019

Changes in this version

+ var ErrNotInitialize = errors.New("not initialized, call `ReceiveConfiguration` first")

+ type Config struct

+ Enable bool

+ EnableRemoteTransfer bool

+ type RxJournal struct

+ func NewDefaultRxJournal(journalServiceClient *backend.RxGrpcClient) *RxJournal

+ func (j *RxJournal) Close() error

+ func (j *RxJournal) CollectAndTransferExistedLogs()

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

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

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

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

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