koala

package module
v2.4.4+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 20, 2018 License: Apache-2.0 Imports: 1 Imported by: 0

README

koala

人生如戏,全凭演技

Parameters

  • KOALA_INBOUND_ADDR: ip:port, the address inbound server will bind to
  • KOALA_SUT_ADDR: ip:port, the address inbound will call
  • KOALA_OUTBOUND_ADDR: ip:port, the address all outgoing traffic will be redirected to
  • KOALA_LOG_FILE: STDOUT/STDERR/filepath, if using filepath, the log will rotate every hour
  • KOALA_LOG_LEVEL: TRACE/DEBUG/INFO/ERROR/FATAL
  • KOALA_INBOUND_READ_TIMEOUT: a duration string, set the timeout of inbound read response from sut
  • KOALA_OUTBOUND_BYPASS_PORT: port, the port of outbound will bypass, eg replay a session with xdebug and pass xdebug remote port
  • KOALA_GC_GLOBAL_STATUS_TIMEOUT: a duration string, set the timeout of gc for koala global status, eg thread, socket
  • KOALA_REPLAYING_MATCH_STRATEGY: set outbound replaying match strategy, default use chunk match strategy, support sim for similarity match
  • KOALA_REPLAYING_MATCH_THRESHOLD: set outbound replaying similarity match threshold

Build tags

  • koala_go: for go application compiled with koala-go
  • koala_replayer: enable replaying mode
  • koala_recorder: enable recording mode

koala_replayer and koala_recorder can be enabled at the same time, to benchmark recording with replaying.

Recording

recording

  • intercept tcp send/recv
  • associate send/recv data to same thread id as "session"
  • request => response => request, so we can know when a "talk" (with request/response pair) is complete
  • use udp 127.127.127.127:127 to inform recorder with helper information.
  • for "system under test" using thread multiplexing (one thread doing more than one thing), map real thread id to virtual thread id by helper information.

Replaying

replaying

replaying builds on same mechanism, but much more complex

  • "system under test" is a process, "replayer inbound server" and "replayer outbound server" lives in same process. They are two tcp servers started by the .so loaded via LD_PRELOAD.
  • session to replay is injected into the process via "replayer inbound server" tcp connection
  • "replayer inbound server" call the "system under test" via tcp connection, store the "session id <=> inbound socket" mapping.
  • "system under test" call external dependencies, which is intercepted to "replayer outbound server", store the "inbound socket <=> outbound socket" mapping
  • "replayer outbound server" use its own socket to lookup the mapping, to find which session to replay

Gateways

koala support two modes by different gateways (https://github.com/v2pro/koala/tree/master/gateway)

gateway

Real World Scenarios

  • Long Connection: reusing connection sequentially is not a issue, just update the mapping
  • Multiplexing: one thread handing multiple business processes at the same time, need "helper information"
  • One Way Communication: request without response, need "helper information" to cut two requests out
  • Greeting: protocol like mysql send greeting before request. use the ip:port or just guess, to decide if greeting is needed.

Documentation

Overview

public api for go application using koala

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ExcludeCurrentGoRoutineFromRecording

func ExcludeCurrentGoRoutineFromRecording()

func GetCurrentGoRoutineId

func GetCurrentGoRoutineId() int64

GetCurrentGoRoutineId get goid from the g

func SetDelegatedFromGoRoutineId

func SetDelegatedFromGoRoutineId(goid int64)

SetDelegatedFromGoRoutineId should be used when this goroutine is doing work for another goroutine, for example multiplex protocol, the request is generated in one goroutine, but sent out from another one. Tracking the work delegation chain is required to record or replay session.

Types

This section is empty.

Directories

Path Synopsis
cmd
gateway
gw4libc
+build !koala_recorder
+build !koala_recorder
test

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL