recorder

Documentation

Index

• Constants
• func FileRecorder(filename string, opts ...FileRecorderOption) recorder.Recorder
• func HTTPRecorder(url string, opts ...HTTPRecorderOption) recorder.Recorder
• func RedisListRecorder(addr string, opts ...RedisRecorderOption) recorder.Recorder
• func RedisSetRecorder(addr string, opts ...RedisRecorderOption) recorder.Recorder
• func RedisSortedSetRecorder(addr string, opts ...RedisRecorderOption) recorder.Recorder
• func TCPRecorder(addr string, opts ...TCPRecorderOption) recorder.Recorder
• type DNSRecorderObject
• type FileRecorderOption
  • func SepRecorderOption(sep string) FileRecorderOption
• type HTTPRecorderObject
• type HTTPRecorderOption
  • func HeaderHTTPRecorderOption(header http.Header) HTTPRecorderOption
  • func TimeoutHTTPRecorderOption(timeout time.Duration) HTTPRecorderOption
• type HTTPRequestRecorderObject
• type HTTPResponseRecorderObject
• type HandlerRecorderObject
  • func (p *HandlerRecorderObject) Record(ctx context.Context, r recorder.Recorder) error
• type RedisRecorderOption
  • func DBRedisRecorderOption(db int) RedisRecorderOption
  • func KeyRedisRecorderOption(key string) RedisRecorderOption
  • func PasswordRedisRecorderOption(password string) RedisRecorderOption
• type TCPRecorderOption
  • func LogTCPRecorderOption(log logger.Logger) TCPRecorderOption
  • func TimeoutTCPRecorderOption(timeout time.Duration) TCPRecorderOption

Constants

const (
	RecorderServiceHandler       = "recorder.service.handler"
	RecorderServiceHandlerSerial = "recorder.service.handler.serial"
	RecorderServiceHandlerTunnel = "recorder.service.handler.tunnel"
)

Functions

func FileRecorder

func FileRecorder(filename string, opts ...FileRecorderOption) recorder.Recorder

FileRecorder records data to file.

func HTTPRecorder

func HTTPRecorder(url string, opts ...HTTPRecorderOption) recorder.Recorder

HTTPRecorder records data to HTTP service.

func RedisListRecorder

func RedisListRecorder(addr string, opts ...RedisRecorderOption) recorder.Recorder

RedisListRecorder records data to a redis list.

func RedisSetRecorder

func RedisSetRecorder(addr string, opts ...RedisRecorderOption) recorder.Recorder

RedisSetRecorder records data to a redis set.

func RedisSortedSetRecorder

func RedisSortedSetRecorder(addr string, opts ...RedisRecorderOption) recorder.Recorder

RedisSortedSetRecorder records data to a redis sorted set.

func TCPRecorder

func TCPRecorder(addr string, opts ...TCPRecorderOption) recorder.Recorder

TCPRecorder records data to TCP service.

Types

type DNSRecorderObject

type DNSRecorderObject struct {
	ID       int    `json:"id"`
	Name     string `json:"name"`
	Class    string `json:"class"`
	Type     string `json:"type"`
	Question string `json:"question"`
	Answer   string `json:"answer"`
	Cached   bool   `json:"cached"`
}

type FileRecorderOption

type FileRecorderOption func(opts *fileRecorderOptions)

func SepRecorderOption

func SepRecorderOption(sep string) FileRecorderOption

type HTTPRecorderObject

type HTTPRecorderObject struct {
	Host       string                     `json:"host"`
	Method     string                     `json:"method"`
	Proto      string                     `json:"proto"`
	Scheme     string                     `json:"scheme"`
	URI        string                     `json:"uri"`
	StatusCode int                        `json:"statusCode"`
	Request    HTTPRequestRecorderObject  `json:"request"`
	Response   HTTPResponseRecorderObject `json:"response"`
}

type HTTPRecorderOption

type HTTPRecorderOption func(opts *httpRecorderOptions)

func HeaderHTTPRecorderOption

func HeaderHTTPRecorderOption(header http.Header) HTTPRecorderOption

func TimeoutHTTPRecorderOption

func TimeoutHTTPRecorderOption(timeout time.Duration) HTTPRecorderOption

type HTTPRequestRecorderObject

type HTTPRequestRecorderObject struct {
	ContentLength int64       `json:"contentLength"`
	Header        http.Header `json:"header"`
}

type HTTPResponseRecorderObject

type HTTPResponseRecorderObject struct {
	ContentLength int64       `json:"contentLength"`
	Header        http.Header `json:"header"`
}

type HandlerRecorderObject

type HandlerRecorderObject struct {
	Node       string              `json:"node,omitempty"`
	Service    string              `json:"service"`
	Network    string              `json:"network"`
	RemoteAddr string              `json:"remote"`
	LocalAddr  string              `json:"local"`
	Host       string              `json:"host"`
	ClientIP   string              `json:"clientIP"`
	ClientID   string              `json:"clientID,omitempty"`
	HTTP       *HTTPRecorderObject `json:"http,omitempty"`
	DNS        *DNSRecorderObject  `json:"dns,omitempty"`
	Err        string              `json:"err,omitempty"`
	Duration   time.Duration       `json:"duration"`
	Time       time.Time           `json:"time"`
	SID        string              `json:"sid"`
}

func (*HandlerRecorderObject) Record

func (p *HandlerRecorderObject) Record(ctx context.Context, r recorder.Recorder) error

type RedisRecorderOption

type RedisRecorderOption func(opts *redisRecorderOptions)

func DBRedisRecorderOption

func DBRedisRecorderOption(db int) RedisRecorderOption

func KeyRedisRecorderOption

func KeyRedisRecorderOption(key string) RedisRecorderOption

func PasswordRedisRecorderOption

func PasswordRedisRecorderOption(password string) RedisRecorderOption

type TCPRecorderOption

type TCPRecorderOption func(opts *tcpRecorderOptions)

func LogTCPRecorderOption

func LogTCPRecorderOption(log logger.Logger) TCPRecorderOption

func TimeoutTCPRecorderOption

func TimeoutTCPRecorderOption(timeout time.Duration) TCPRecorderOption