relay

package

v0.0.0-...-bd03ed3 Latest Latest Go to latest Published: May 7, 2016 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Package relay implements fan-out to remote relays.

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	DropRepeats     bool
	Host            string
	MaxConnsPerHost *int
	OnQueueFull     string
}

func (c *Config) Validate() error

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

Pool represents a pool of relay connections.

func NewPool(configs map[string]*Config, series tsdb.Series) *Pool

NewPool creates a pool of relays connections.

func (p *Pool) Broadcast()

Broadcast broadcasts received data points to all relays.

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

func NewRelay(name string, config *Config) (*Relay, error)

NewRelay returns a new relay.

func (r *Relay) Submit(point *tsdb.Point)

Submit submits the given point to the relay. It does not block in network calls to the relay host. Not safe for concurrent use.