protocol

package

v0.9.12 Latest Latest Go to latest Published: Mar 3, 2016 License: Apache-2.0 Imports: 5 Imported by: 10

Details

This section is empty.

This section is empty.

func CompositeCloser(closers ...io.Closer) io.Closer

CompositeCloser creates a new io.Closer whos Close() method calls close of each of the closers

func ForwarderDims(name string, typ string) map[string]string

ForwarderDims are the common stat dimensions we expect on forwarder protocols

func ListenerDims(name string, typ string) map[string]string

ListenerDims are the common stat dimensions we expect on listener protocols

type CompositeListener struct {
	sfxclient.Collector
	io.Closer
}

CompositeListener is a helper struct that expects users to inject their own versions of each type

type DatapointForwarder interface {
	sfxclient.Collector
	io.Closer
	dpsink.DSink
}

DatapointForwarder can send datapoints and not events

type Forwarder interface {
	dpsink.Sink
	sfxclient.Collector
	io.Closer
}

Forwarder is the basic interface endpoints must support for the proxy to forward to them

type Listener interface {
	sfxclient.Collector
	io.Closer
}

Listener is the basic interface anything that listens for new metrics must implement

type OkCloser func()

OkCloser allows any function to become a io.Closer that returns nil and calls itself on close

func (o OkCloser) Close() error

Close calls the wrapped function and returns nil

type UneventfulForwarder struct {
	DatapointForwarder
}

UneventfulForwarder converts a datapoint only forwarder into a datapoint/event forwarder

func (u *UneventfulForwarder) AddEvents(ctx context.Context, events []*event.Event) error

AddEvents does nothing and returns nil