tcpexecutor

Documentation

Index

• Constants
• type TCPExecutor
  • func NewTCPExecutor(ctx context.Context) (*TCPExecutor, error)
  • func (e *TCPExecutor) CheckConfig(ctx context.Context, args []v1alpha1.MeasureArgs, judgement v1alpha1.Judgement) error
  • func (e *TCPExecutor) InitialData(ctx context.Context, args []v1alpha1.MeasureArgs) (string, error)
  • func (e *TCPExecutor) Measure(ctx context.Context, args []v1alpha1.MeasureArgs, judgement v1alpha1.Judgement, ...) error

Constants

const (
	IPArgsKey      = "ip"
	PortArgsKey    = "port"
	TimeoutArgsKey = "timeout"
)

Types

type TCPExecutor

type TCPExecutor struct {
}

func NewTCPExecutor

func NewTCPExecutor(ctx context.Context) (*TCPExecutor, error)

func (*TCPExecutor) CheckConfig

func (e *TCPExecutor) CheckConfig(ctx context.Context, args []v1alpha1.MeasureArgs, judgement v1alpha1.Judgement) error

func (*TCPExecutor) InitialData

func (e *TCPExecutor) InitialData(ctx context.Context, args []v1alpha1.MeasureArgs) (string, error)

func (*TCPExecutor) Measure

func (e *TCPExecutor) Measure(ctx context.Context, args []v1alpha1.MeasureArgs, judgement v1alpha1.Judgement, initialData string) error