Documentation
¶
Overview ¶
Package serverstore implements storing logic for fakeintake server Stores raw payloads and try parsing known payloads dumping them to json
Index ¶
- func IsRouteHandled(route string) bool
- type Store
- func (s *Store) AppendPayload(route string, data []byte, encoding string, collectTime time.Time) error
- func (s *Store) CleanUpPayloadsOlderThan(time time.Time)
- func (s *Store) Flush()
- func (s *Store) GetJSONPayloads(route string) (payloads []api.ParsedPayload)
- func (s *Store) GetRawPayloads(route string) (payloads []api.Payload)
- func (s *Store) GetRouteStats() map[string]int
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsRouteHandled ¶
IsRouteHandled checks if a route is handled by the Datadog parsed store
Types ¶
type Store ¶
type Store struct {
NbPayloads *prometheus.GaugeVec
// contains filtered or unexported fields
}
Store implements a thread-safe storage for raw and json dumped payloads
func (*Store) AppendPayload ¶
func (s *Store) AppendPayload(route string, data []byte, encoding string, collectTime time.Time) error
AppendPayload adds a payload to the store and tries parsing and adding a dumped json to the parsed store
func (*Store) CleanUpPayloadsOlderThan ¶
CleanUpPayloadsOlderThan removes payloads older than time
func (*Store) GetJSONPayloads ¶
func (s *Store) GetJSONPayloads(route string) (payloads []api.ParsedPayload)
GetJSONPayloads returns payloads collected and parsed to json for route `route`
func (*Store) GetRawPayloads ¶
GetRawPayloads returns payloads collected for route `route`
func (*Store) GetRouteStats ¶
GetRouteStats returns stats on collectedraw payloads by route
Source Files
Click to show internal directories.
Click to hide internal directories.