server

Documentation

Index

• func NewServer(addr string, opts Options) xserver.Server
• type HandleFn
• type HandlerOptions
  • func NewHandlerOptions() HandlerOptions
• type Options
  • func NewOptions() Options

Functions

func NewServer

func NewServer(addr string, opts Options) xserver.Server

NewServer creates a new server.

Types

type HandleFn

type HandleFn func(unaggregated.MetricUnion, metadata.StagedMetadatas) error

HandleFn handles a metric alongside its staged metadatas.

type HandlerOptions

type HandlerOptions interface {
	// SetInstrumentOptions sets the instrument options.
	SetInstrumentOptions(value instrument.Options) HandlerOptions

	// InstrumentOptions returns the instrument options.
	InstrumentOptions() instrument.Options

	// SetProtobufUnaggregatedIteratorOptions sets the protobuf unaggregated iterator options.
	SetProtobufUnaggregatedIteratorOptions(value protobuf.UnaggregatedOptions) HandlerOptions

	// ProtobufUnaggregatedIteratorOptions returns the protobuf unaggregated iterator options.
	ProtobufUnaggregatedIteratorOptions() protobuf.UnaggregatedOptions

	// SetReadBufferSize sets the read buffer size.
	SetReadBufferSize(value int) HandlerOptions

	// ReadBufferSize returns the read buffer size.
	ReadBufferSize() int

	// SetHandleFn sets the handle fn.
	SetHandleFn(value HandleFn) HandlerOptions

	// HandleFn returns the handle fn.
	HandleFn() HandleFn
}

HandlerOptions provide a set of options for the handler.

func NewHandlerOptions

func NewHandlerOptions() HandlerOptions

NewHandlerOptions create a new set of options for the handler.

type Options

type Options interface {
	// SetHandlerOptions sets the handler options.
	SetHandlerOptions(value HandlerOptions) Options

	// HandlerOptions returns the handler options.
	HandlerOptions() HandlerOptions

	// SetTCPServerOptions sets the TCP server options.
	SetTCPServerOptions(value xserver.Options) Options

	// TCPServerOptions returns the TCP server options.
	TCPServerOptions() xserver.Options
}

Options provide a set of options for the server.

func NewOptions

func NewOptions() Options

NewOptions create a new set of server options.