Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Serve ¶
func Serve( aggregator aggregator.Aggregator, doneCh chan struct{}, opts Options, ) error
Serve starts serving RPC traffic.
Types ¶
type Options ¶ added in v0.15.6
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 ¶ added in v0.15.6
func NewOptions(iOpts instrument.Options) Options
NewOptions creates a new aggregator server options.
Source Files
Click to show internal directories.
Click to hide internal directories.