client

Documentation

Index

• Constants
• func Plugin() *node.Plugin
• type Connector
  • func NewConnector(network string, address string) *Connector
  • func (c *Connector) Close() (err error)
  • func (c *Connector) Start()
  • func (c *Connector) Stop()
  • func (c *Connector) Write(b []byte) (int, error)
• type EventDispatchers

Constants

const (
	// PluginName is the name of  the analysis client plugin.
	PluginName = "Analysis-Client"
	// CfgServerAddress defines the config flag of the analysis server address.
	CfgServerAddress = "analysis.client.serverAddress"
)

Functions

func Plugin

func Plugin() *node.Plugin

Plugin gets the plugin instance

Types

type Connector

type Connector struct {
	// contains filtered or unexported fields
}

A Connector is a redialing Writer on the underlying connection.

func NewConnector

func NewConnector(network string, address string) *Connector

NewConnector creates a new Connector.

func (*Connector) Close

func (c *Connector) Close() (err error)

Close closes the current connection. If the Connector is not closed, a new redial will be triggered.

func (*Connector) Start

func (c *Connector) Start()

Start starts the Connector.

func (*Connector) Stop

func (c *Connector) Stop()

Stop stops the Connector.

func (*Connector) Write

func (c *Connector) Write(b []byte) (int, error)

Write writes data to the underlying connection. It returns an error if currently no connection has been established.

type EventDispatchers

type EventDispatchers struct {
	// Heartbeat defines the Heartbeat function.
	Heartbeat func(heartbeat *packet.Heartbeat)
}

EventDispatchers holds the Heartbeat function.