messages

Jan 4, 2023

Changes in this version

+ const DefaultMessageFetchingBackoff

+ const DefaultMessagesPrintingFrequency

+ const DefaultStreamExhaustionGracePeriod

+ func FormatMessage(msg IMessage) (s string, err error)

+ func NewMockNotificationFeedPage(ctx context.Context, hasNext, hasFuture bool) (f *client.NotificationFeed, err error)

+ func NewMockNotificationFeedPaginator(ctx context.Context) (pagination.IPaginatorAndPageFetcher, error)

+ func NewMockNotificationFeedStreamPaginator(ctx context.Context) (pagination.IStreamPaginatorAndPageFetcher, error)

+ type IMessage interface

+ GetCtimeOk func() (*time.Time, bool)

+ GetMessageOk func() (*string, bool)

+ GetSeverityOk func() (*string, bool)

+ GetSourceOk func() (*string, bool)

+ type IMessageLogger interface

+ LogEmptyMessageError func()

+ LogMarshallingError func(rawMessage *any)

+ LogMessage func(msg IMessage)

+ LogMessagesCollection func(ctx context.Context, messagePaginator pagination.IGenericPaginator) error

+ func NewBasicAsynchronousMessageLogger(ctx context.Context, rawLogger logging.ILogger) (IMessageLogger, error)

+ func NewBasicSynchronousMessageLogger(ctx context.Context, rawLogger logging.ILogger) (IMessageLogger, error)

+ func NewPeriodicAsynchronousMessageLogger(ctx context.Context, rawLogger logging.ILogger, printPeriod time.Duration) (IMessageLogger, error)

+ func NewPeriodicSynchronousMessageLogger(ctx context.Context, rawLogger logging.ILogger, printPeriod time.Duration) (IMessageLogger, error)

+ type Logger struct

+ func (l *Logger) Check() error

+ func (l *Logger) Close() error

+ func (l *Logger) Log(output ...interface{})

+ func (l *Logger) LogEmptyMessageError()

+ func (l *Logger) LogError(err ...interface{})

+ func (l *Logger) LogMarshallingError(rawMessage *any)

+ func (l *Logger) LogMessage(msg IMessage)

+ func (l *Logger) LogMessagesCollection(ctx context.Context, messagePaginator pagination.IGenericPaginator) error

+ func (l *Logger) SetLogSource(source string) error

+ func (l *Logger) SetLoggerSource(source string) error

+ func (l *Logger) SetSource(source string) error

+ type MessageLoggerFactory struct

+ func NewMessageLoggerFactory(logger logging.ILogger, asynchronous bool, printingPeriod time.Duration) *MessageLoggerFactory

+ func (f *MessageLoggerFactory) Create(ctx context.Context) (IMessageLogger, error)

+ type PaginatorFactory struct

+ func NewMockMessagePaginatorFactory() *PaginatorFactory

+ func NewPaginatorFactory(runOutTimeOut, backoff time.Duration, ...) *PaginatorFactory

+ func (f *PaginatorFactory) Create(ctx context.Context) (paginator pagination.IStreamPaginatorAndPageFetcher, err error)

+ func (f *PaginatorFactory) UpdatBackOffPeriod(backoff time.Duration) *PaginatorFactory

+ func (f *PaginatorFactory) UpdateRunOutTimeout(runOutTimeOut time.Duration) *PaginatorFactory