serve

Documentation

Index

• func Serve(aggregator aggregator.Aggregator, doneCh chan struct{}, opts Options) error
• type Options
  • func NewOptions(iOpts instrument.Options) Options

Functions

func Serve

func Serve(
	aggregator aggregator.Aggregator,
	doneCh chan struct{},
	opts Options,
) error

Serve starts serving RPC traffic.

Types

type Options

type Options interface {
	// SetM3MsgAddr sets the M3 message address.
	SetM3MsgAddr(value string) Options

	// M3MsgAddr returns the M3 message address.
	M3MsgAddr() string

	// SetM3MsgServerOpts sets the M3MsgServerOpts.
	SetM3MsgServerOpts(value m3msgserver.Options) Options

	// M3MsgServerOpts returns the M3MsgServerOpts.
	M3MsgServerOpts() m3msgserver.Options

	// SetRawTCPAddr sets the RawTCP address.
	SetRawTCPAddr(value string) Options

	// RawTCPAddr returns the RawTCP address.
	RawTCPAddr() string

	// SetRawTCPServerOpts sets the RawTCPServerOpts.
	SetRawTCPServerOpts(value rawtcpserver.Options) Options

	// RawTCPServerOpts returns the RawTCPServerOpts.
	RawTCPServerOpts() rawtcpserver.Options

	// SetHTTPAddr sets the HTTP address.
	SetHTTPAddr(value string) Options

	// HTTPAddr returns the HTTP address.
	HTTPAddr() string

	// SetHTTPServerOpts sets the HTTPServerOpts.
	SetHTTPServerOpts(value httpserver.Options) Options

	// HTTPServerOpts returns the HTTPServerOpts.
	HTTPServerOpts() httpserver.Options

	// SetInstrumentOpts sets the InstrumentOpts.
	SetInstrumentOpts(value instrument.Options) Options

	// InstrumentOpts returns the InstrumentOpts.
	InstrumentOpts() instrument.Options

	// SetRWOptions sets RW options.
	SetRWOptions(value xio.Options) Options

	// RWOptions returns the RW options.
	RWOptions() xio.Options
}

Options are aggregator options.

func NewOptions

func NewOptions(iOpts instrument.Options) Options

NewOptions creates a new aggregator server options.