redis

README

To compile protocol buffer definitions, you need to have installed the standard C++ implementation of protocol buffers and the Go compiler plugin, protoc-gen-go. See here for installation instructions.

Run the following command within this directory: protoc --go_out=build/gen *.proto

Documentation

Index

• func NewClient() (redis.Conn, error)
• func Record(logger *zap.Logger, triggerName string, recorderName string, reqUID string, ...)
• func RecordsFilterByFunction(logger *zap.Logger, queriedFunctionName string, recorders *fv1.RecorderList, ...) ([]byte, error)
• func RecordsFilterByTime(logger *zap.Logger, from string, to string) ([]byte, error)
• func RecordsFilterByTrigger(logger *zap.Logger, queriedTriggerName string, recorders *fv1.RecorderList, ...) ([]byte, error)
• func RecordsListAll(logger *zap.Logger) ([]byte, error)
• func ReplayByReqUID(logger *zap.Logger, routerUrl string, queriedID string) ([]byte, error)
• func ReplayRequest(routerUrl string, request *redisCache.Request) ([]string, error)

Functions

func NewClient

func NewClient() (redis.Conn, error)

func Record

func Record(logger *zap.Logger, triggerName string, recorderName string, reqUID string, request *http.Request, originalUrl url.URL, payload string, response *http.Response, namespace string, timestamp int64)

func RecordsFilterByFunction

func RecordsFilterByFunction(logger *zap.Logger, queriedFunctionName string, recorders *fv1.RecorderList, triggers *fv1.HTTPTriggerList) ([]byte, error)

func RecordsFilterByTime

func RecordsFilterByTime(logger *zap.Logger, from string, to string) ([]byte, error)

Input: `from` (hours ago, between 0 [today] and 5) and `to` (same units) Note: Fractional values don't seem to work -- document that for the user

func RecordsFilterByTrigger

func RecordsFilterByTrigger(logger *zap.Logger, queriedTriggerName string, recorders *fv1.RecorderList, triggers *fv1.HTTPTriggerList) ([]byte, error)

func RecordsListAll

func RecordsListAll(logger *zap.Logger) ([]byte, error)

func ReplayByReqUID

func ReplayByReqUID(logger *zap.Logger, routerUrl string, queriedID string) ([]byte, error)

func ReplayRequest

func ReplayRequest(routerUrl string, request *redisCache.Request) ([]string, error)