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.
Click to show internal directories.
Click to hide internal directories.