udp

package

v0.0.0-...-b28dce8 Latest Latest Go to latest Published: Aug 11, 2017 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/linuxerwang/cloudprober

Links

Open Source Insights

Documentation ¶

Overview ¶

Package udp is a generated protocol buffer package.

It is generated from these files:

github.com/google/cloudprober/probes/udp/config.proto

It has these top-level messages:

ProbeConf

Package udp implements a UDP prober. It sends UDP queries to a list of targets and reports statistics on queries sent, queries received, and latency experienced.

Queries to each target are sent in parallel.

Index ¶

Constants
func Ping(addr string, timeout time.Duration) (success bool, latency time.Duration, err error)
type Probe
- func (p *Probe) Init(name string, tgts targets.Targets, interval, timeout time.Duration, ...) error
- func (p *Probe) Start(ctx context.Context, dataChan chan *metrics.EventMetrics)
type ProbeConf

Constants ¶

View Source

const Default_ProbeConf_Port int32 = 31122

View Source

const Default_ProbeConf_StatsExportIntervalMsec int32 = 10000

Variables ¶

This section is empty.

Functions ¶

func Ping ¶

func Ping(addr string, timeout time.Duration) (success bool, latency time.Duration, err error)

Ping sends a UDP "ping" to addr. Probe succeeds if the same data is returned within timeout. TODO: Hide this once b/32340835 is fixed, that is, once nobody using it anymore.

Types ¶

type Probe ¶

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

Probe holds aggregate information about all probe runs, per-target.

func (*Probe) Init ¶

func (p *Probe) Init(name string, tgts targets.Targets, interval, timeout time.Duration, l *logger.Logger, v interface{}) error

Init initializes the probe with the given params.

func (*Probe) Start ¶

func (p *Probe) Start(ctx context.Context, dataChan chan *metrics.EventMetrics)

Start starts and runs the probe indefinitely.

type ProbeConf ¶

type ProbeConf struct {
	// Export stats after these many milliseconds
	StatsExportIntervalMsec *int32 `` /* 138-byte string literal not displayed */
	// Port to send UDP Ping to (UDP Echo).  Should be same as
	// ProberConfig.udp_echo_server_port.
	// TODO: Can we just read this from ProberConfig?
	Port             *int32 `protobuf:"varint,3,opt,name=port,def=31122" json:"port,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ProbeConf) Descriptor ¶

func (*ProbeConf) Descriptor() ([]byte, []int)

func (*ProbeConf) GetPort ¶

func (m *ProbeConf) GetPort() int32

func (*ProbeConf) GetStatsExportIntervalMsec ¶

func (m *ProbeConf) GetStatsExportIntervalMsec() int32

func (*ProbeConf) ProtoMessage ¶

func (*ProbeConf) ProtoMessage()

func (*ProbeConf) Reset ¶

func (m *ProbeConf) Reset()

func (*ProbeConf) String ¶

func (m *ProbeConf) String() string

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
cmd Udp_bin implements a stand-alone udp prober binary using the cloudprober/probes/udp package.	Udp_bin implements a stand-alone udp prober binary using the cloudprober/probes/udp package.

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