rawtcp

package
v0.14.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 25, 2019 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewHandler

func NewHandler(aggregator aggregator.Aggregator, opts Options) xserver.Handler

NewHandler creates a new raw TCP handler.

func NewServer

func NewServer(address string, aggregator aggregator.Aggregator, opts Options) xserver.Server

NewServer creates a new raw TCP server.

Types

type Options

type Options interface {
	// SetClockOptions sets the clock options.
	SetClockOptions(value clock.Options) Options

	// ClockOptions returns the clock options.
	ClockOptions() clock.Options

	// SetInstrumentOptions sets the instrument options.
	SetInstrumentOptions(value instrument.Options) Options

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

	// SetServerOptions sets the server options.
	SetServerOptions(value server.Options) Options

	// ServerOptiosn returns the server options.
	ServerOptions() server.Options

	// SetMsgpackUnaggregatedIteratorOptions sets the msgpack unaggregated iterator options.
	SetMsgpackUnaggregatedIteratorOptions(value msgpack.UnaggregatedIteratorOptions) Options

	// MsgpackUnaggregatedIteratorOptions returns the msgpack unaggregated iterator options.
	MsgpackUnaggregatedIteratorOptions() msgpack.UnaggregatedIteratorOptions

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

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

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

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

	// SetErrorLogLimitPerSecond sets the error log limit per second.
	SetErrorLogLimitPerSecond(value int64) Options

	// ErrorLogLimitPerSecond returns the error log limit per second.
	ErrorLogLimitPerSecond() int64
}

Options provide a set of server options.

func NewOptions

func NewOptions() Options

NewOptions creates a new set of server options.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL