serverstore

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 NewStore() *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) []api.ParsedPayload
  • func (s *Store) GetRawPayloads(route string) []api.Payload
  • func (s *Store) GetRouteStats() map[string]int

Functions

func IsRouteHandled

func IsRouteHandled(route string) bool

IsRouteHandled checks if a route is handled by the Datadog parsed store

Types

type Store

type Store struct {
	// contains filtered or unexported fields
}

Store implements a thread-safe storage for raw and json dumped payloads

func NewStore

func NewStore() *Store

NewStore initialise a new payloads store

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

func (s *Store) CleanUpPayloadsOlderThan(time time.Time)

CleanUpPayloadsOlderThan removes payloads older than time

func (*Store) Flush

func (s *Store) Flush()

Flush cleans up any stored payload

func (*Store) GetJSONPayloads

func (s *Store) GetJSONPayloads(route string) []api.ParsedPayload

GetJSONPayloads returns payloads collected and parsed to json for route `route`

func (*Store) GetRawPayloads

func (s *Store) GetRawPayloads(route string) []api.Payload

GetRawPayloads returns payloads collected for route `route`

func (*Store) GetRouteStats

func (s *Store) GetRouteStats() map[string]int

GetRouteStats returns stats on collectedraw payloads by route