Versions in this module Expand all Collapse all v1 v1.0.0 Apr 16, 2024 Changes in this version + const ConnectionRetries + const FollowPollTime + const TimeFormat + func Dedup(messageChan chan LogMessage) chan LogMessage + func FlattenAttributes(m, into map[string]interface{}, prefix string) + func MatchesQuery(m LogMessage, q Query) bool + func MustJsonDecode(jsonString string, dst interface{}) + func MustJsonEncode(obj interface{}) string + func Project(m map[string]interface{}, fields []string) map[string]interface + func ReQueryFollow(ctx context.Context, queryMessagesFunc func() ([]LogMessage, error)) <-chan LogMessage + type Client interface + ImplementsAdvancedFilters func() bool + Query func(ctx context.Context, query Query) <-chan LogMessage + type EqualityFilter struct + FieldName string + Operator string + Value string + func (f EqualityFilter) Matches(m LogMessage) bool + type ExistenceFilter struct + Exists bool + FieldName string + func (f ExistenceFilter) Matches(m LogMessage) bool + type LogMessage struct + Attributes map[string]interface{} + ID string + MessageKey string + Timestamp time.Time + func FlattenLogMessage(message LogMessage) LogMessage + func NewLogMessage() LogMessage + func (lm LogMessage) ContentHash() string + func (lm LogMessage) Map() map[string]interface{} + func (lm LogMessage) Message() (string, bool) + func (lm LogMessage) UniqueID() string + type MembershipFilter struct + FieldName string + InvalidValues []string + ValidValues []string + func (f MembershipFilter) Matches(m LogMessage) bool + type Query struct + After *time.Time + Before *time.Time + EqualityFilters []EqualityFilter + ExistenceFilters []ExistenceFilter + Follow bool + MaxResults int + MembershipFilters []MembershipFilter + QueryString string + SelectFields []string + Unique bool + type QuerySelectors struct + After string + Before string + Exists []string + Last string + MessageKey string + NotExists []string + NotOneOf []string + OneOf []string + QueryString []string + Select []string + Unique bool + Where []string
Go to main page