tcp

Documentation

Index

• Variables
• func New(globalConfig define.Config, taskConfig define.TaskConfig) define.Task
• type Gather
  • func (g *Gather) Run(ctx context.Context, e chan<- define.Event)

Variables

var NewConn = func(ctx context.Context, taskConf *configs.TCPTaskConfig, addr string) (net.Conn, error) {
	dialer := net.Dialer{
		Timeout: taskConf.Timeout,
	}

	return dialer.DialContext(ctx, "tcp", addr)
}

NewConn :

Functions

func New

func New(globalConfig define.Config, taskConfig define.TaskConfig) define.Task

Types

type Gather

type Gather struct {
	tasks.BaseTask
	// contains filtered or unexported fields
}

Gather :

func (*Gather) Run

func (g *Gather) Run(ctx context.Context, e chan<- define.Event)