replay

Documentation

Index

• func ReplayInfluxLog(fpath string, interval time.Duration, player Replayer) int
• type Replayer
• type WebSocket
  • func NewWebSocket(url string) *WebSocket
  • func (w *WebSocket) Close() error
  • func (w *WebSocket) Connect() error
  • func (w *WebSocket) Write(messageData []byte) error

Functions

func ReplayInfluxLog

func ReplayInfluxLog(fpath string, interval time.Duration, player Replayer) int

Types

type Replayer

type Replayer func(messageData []byte) error

type WebSocket

type WebSocket struct {
	URL            string            `toml:"url"`
	ConnectTimeout time.Duration     `toml:"connect_timeout"`
	WriteTimeout   time.Duration     `toml:"write_timeout"`
	ReadTimeout    time.Duration     `toml:"read_timeout"`
	Headers        map[string]string `toml:"headers"`
	UseTextFrames  bool              `toml:"use_text_frames"`
	// contains filtered or unexported fields
}

WebSocket can output to WebSocket endpoint. This is a direct copy of the telegraf websocket output plugin

func NewWebSocket

func NewWebSocket(url string) *WebSocket

func (*WebSocket) Close

func (w *WebSocket) Close() error

Close closes the connection. Noop if already closed.

func (*WebSocket) Connect

func (w *WebSocket) Connect() error

Connect to the output endpoint.

func (*WebSocket) Write

func (w *WebSocket) Write(messageData []byte) error

Write writes the given metrics to the destination. Not thread-safe.