server

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

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
}

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
}