jvm

Documentation

Index

• Constants
• func Attach(port string, javaHome string, pid string) (*spec.Response, string)
• func CheckFlagValues(processName, processId string) (string, *spec.Response)
• func CheckPortFromSandboxToken(username string) (port string, err error)
• func Detach(port string) *spec.Response
• func Prepare(processName, processId string) (response *spec.Response, port string)
• func Revoke(record *data.PreparationRecord, processName, processId string) *spec.Response
• type Executor
  • func NewExecutor() *Executor
  • func (e *Executor) Exec(uid string, ctx context.Context, model *spec.ExpModel) *spec.Response
  • func (e *Executor) Name() string
  • func (e *Executor) QueryStatus(uid string) *spec.Response
  • func (e *Executor) SetChannel(channel spec.Channel)

Constants

const DefaultNamespace = "default"

const DefaultUri = "sandbox/default/module/http/chaosblade"

Functions

func Attach

func Attach(port string, javaHome string, pid string) (*spec.Response, string)

func CheckFlagValues

func CheckFlagValues(processName, processId string) (string, *spec.Response)

checkFlagValues query pre-record from sqlite by process name or process id 1. The process and pid are not empty, then the process is used to find the process. If the process id and the found process are not found, the error is returned. 2. Process is empty, pid is not empty, then determine if the pid process exists 3. Process is not empty, pid is empty, then it is judged whether the process exists, there is no error, and the process id is assigned to pid. 4. Process and pid are both empty, then an error is returned.

func CheckPortFromSandboxToken

func CheckPortFromSandboxToken(username string) (port string, err error)

CheckPortFromSandboxToken will read last line and curl the port for testing connectivity

func Detach

func Detach(port string) *spec.Response

func Prepare

func Prepare(processName, processId string) (response *spec.Response, port string)

func Revoke

func Revoke(record *data.PreparationRecord, processName, processId string) *spec.Response

Revoke 卸载 Java agent

Types

type Executor

type Executor struct {
	Uri string
	// contains filtered or unexported fields
}

Executor for jvm experiment

func NewExecutor

func NewExecutor() *Executor

func (*Executor) Exec

func (e *Executor) Exec(uid string, ctx context.Context, model *spec.ExpModel) *spec.Response

func (*Executor) Name

func (e *Executor) Name() string

func (*Executor) QueryStatus

func (e *Executor) QueryStatus(uid string) *spec.Response

func (*Executor) SetChannel

func (e *Executor) SetChannel(channel spec.Channel)