streams

README

streams Package

Documentation

Index

• Variables
• type RESTStream
  • func NewRESTStream(url *url.URL, entity, sampler, streamname string) (stream RESTStream, err error)
  • func (s RESTStream) Write(data []byte) (n int, err error)
• type Stream
  • func Open(url *url.URL, entity, sampler string, stream string, options ...xmlrpc.Options) (s *Stream, err error)
  • func (s Stream) Write(data []byte) (n int, err error)
  • func (s Stream) WriteString(data string) (n int, err error)

Variables

var ErrServerError = errors.New("error from server (HTTP Status > 299)")

ErrServerError makes it a little easier for the caller to check the underlying HTTP response

Types

type RESTStream

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

func NewRESTStream

func NewRESTStream(url *url.URL, entity, sampler, streamname string) (stream RESTStream, err error)

func (RESTStream) Write

func (s RESTStream) Write(data []byte) (n int, err error)

type Stream

type Stream struct {
	io.Writer
	io.StringWriter
	xmlrpc.Sampler
	// contains filtered or unexported fields
}

func Open

func Open(url *url.URL, entity, sampler string, stream string, options ...xmlrpc.Options) (s *Stream, err error)

Open a stream for writing. `stream` is an optional stream name and additional arguments are ignored. If no stream name is supplied then the sampler name is used for the stream name.

func (Stream) Write

func (s Stream) Write(data []byte) (n int, err error)

Write data bytes to stream. Whitespace is trimmed.

func (Stream) WriteString

func (s Stream) WriteString(data string) (n int, err error)

Write string to stream. Whitespace is trimmed.