monitor

Dec 24, 2020

Changes in this version

+ var ErrIterationFinished = errors.New("attempting to Scan after iteration has ended")

+ var ErrNextNotCalled = errors.New("attempting to Scan before a successful call to Next or NextContext")

+ func IsLogName(ctx context.Context, c Connection, name string) (bool, error)

+ func LogNamesWithMatches(ctx context.Context, c Connection, cond NameMatches) ([]string, error)

+ func LogNamesWithRegexp(ctx context.Context, c Connection, expr string) ([]string, error)

+ func LogNamesWithSubstring(ctx context.Context, c Connection, match string) ([]string, error)

+ func ParseTime(s string, roundUp bool, loc *time.Location) (bool, time.Time)

+ func Scan(dst *Entry, src Entry)

+ type BufferedIterator interface

+ Buffered func() bool

+ func NewBufferedIterator(itr Iterator, bufSize int) BufferedIterator

+ type Connection interface

+ LogNames func(ctx context.Context) ([]string, error)

+ Stream func(ctx context.Context, name string, start *Time, finish *Time) (Iterator, error)

+ type Entry struct

+ Msg logger.Message

+ T time.Time

+ func (e Entry) String() string

+ type FilterFunc func(Entry) bool

+ func And(f ...FilterFunc) FilterFunc

+ func Or(f ...FilterFunc) FilterFunc

+ type Iterator interface

+ Close func() error

+ Err func() error

+ Next func() bool

+ NextContext func(ctx context.Context) (bool, error)

+ Scan func(dest *Entry) error

+ func EmptyIterator() Iterator

+ func FilterIterator(itr Iterator, filter FilterFunc) Iterator

+ func SliceIterator(S []Entry) Iterator

+ func StreamWithFilter(ctx context.Context, c Connection, name string, start *Time, finish *Time, ...) (Iterator, error)

+ func StreamWithIdentifierRegexp(ctx context.Context, c Connection, name string, start *Time, finish *Time, ...) (Iterator, error)

+ func StreamWithIdentifierSubstring(ctx context.Context, c Connection, name string, start *Time, finish *Time, ...) (Iterator, error)

+ func StreamWithMatches(ctx context.Context, c Connection, name string, start *Time, finish *Time, ...) (Iterator, error)

+ func StreamWithMessageRegexp(ctx context.Context, c Connection, name string, start *Time, finish *Time, ...) (Iterator, error)

+ func StreamWithMessageSubstring(ctx context.Context, c Connection, name string, start *Time, finish *Time, ...) (Iterator, error)

+ type Matches struct

+ IdentifierNotRegexp string

+ IdentifierNotSubstring string

+ IdentifierRegexp string

+ IdentifierSubstring string

+ MessageNotRegexp string

+ MessageNotSubstring string

+ MessageRegexp string

+ MessageSubstring string

+ func (c Matches) String() string

+ type NameMatches struct

+ NotRegexp string

+ NotSubstring string

+ Regexp string

+ Substring string

+ func (c NameMatches) String() string

+ type Time struct

+ func NewOffset(n int64) *Time

+ func NewTime(t time.Time) *Time

+ func ParseEndTime(s string, loc *time.Location) (bool, *Time)

+ func ParseStartTime(s string, loc *time.Location) (bool, *Time)

+ func (t *Time) After(s *Time) bool

+ func (t *Time) Before(s *Time) bool

+ func (t *Time) Equal(s *Time) bool

+ func (t *Time) GobDecode(b []byte) error

+ func (t *Time) GobEncode() ([]byte, error)

+ func (t *Time) IsAssigned() bool

+ func (t *Time) IsOffset() (bool, int64)

+ func (t *Time) IsTime() (bool, time.Time)

+ func (t *Time) IsUnassigned() bool

+ func (t *Time) MarshalJSON() ([]byte, error)

+ func (t *Time) String() string

+ func (t *Time) UnmarshalJSON(b []byte) error