sapm

Documentation

Index

• Variables
• type Client
  • func (c *Client) Connect(server string) error
  • func (c *Client) Export(batch core.ExportRequest)
  • func (c *Client) Shutdown()
• type Server
  • func (sr *Server) HTTPHandlerFunc(rw http.ResponseWriter, req *http.Request)
  • func (sr *Server) Listen(endpoint string, onReceive func(batch core.ExportRequest, spanCount int)) error
  • func (sr *Server) Shutdown() error
  • func (sr *Server) Stop()

Variables

var (
	// ErrAlreadyStarted indicates an error on starting an already-started
	// receiver/processor/exporter.
	ErrAlreadyStarted = errors.New("already started")

	// ErrAlreadyStopped indicates an error on stoping an already-stopped
	// receiver/processor/exporter.
	ErrAlreadyStopped = errors.New("already stopped")

	// ErrNilNextConsumer indicates an error on nil next consumer.
	ErrNilNextConsumer = errors.New("nil nextConsumer")
)

Types

type Client

type Client struct {
	Concurrency int
	// contains filtered or unexported fields
}

func (*Client) Connect

func (c *Client) Connect(server string) error

func (*Client) Export

func (c *Client) Export(batch core.ExportRequest)

func (*Client) Shutdown

func (c *Client) Shutdown()

type Server

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

func (*Server) HTTPHandlerFunc

func (sr *Server) HTTPHandlerFunc(rw http.ResponseWriter, req *http.Request)

HTTPHandlerFunction returns an http.HandlerFunc that handles SAPM requests

func (*Server) Listen

func (sr *Server) Listen(endpoint string, onReceive func(batch core.ExportRequest, spanCount int)) error

func (*Server) Shutdown

func (sr *Server) Shutdown() error

StopTraceRetention stops the the sapmReceiver's server

func (*Server) Stop

func (sr *Server) Stop()