more comments

This commit is contained in:
Asim 2015-11-26 00:23:36 +00:00
parent bb360d5f2c
commit 24b8cd3d97

View File

@ -83,60 +83,70 @@ func (o options) Metadata() map[string]string {
return o.metadata return o.metadata
} }
// Server name
func Name(n string) Option { func Name(n string) Option {
return func(o *options) { return func(o *options) {
o.name = n o.name = n
} }
} }
// Unique server id
func Id(id string) Option { func Id(id string) Option {
return func(o *options) { return func(o *options) {
o.id = id o.id = id
} }
} }
// Version of the service
func Version(v string) Option { func Version(v string) Option {
return func(o *options) { return func(o *options) {
o.version = v o.version = v
} }
} }
// Address to bind to - host:port
func Address(a string) Option { func Address(a string) Option {
return func(o *options) { return func(o *options) {
o.address = a o.address = a
} }
} }
// The address to advertise for discovery - host:port
func Advertise(a string) Option { func Advertise(a string) Option {
return func(o *options) { return func(o *options) {
o.advertise = a o.advertise = a
} }
} }
// Broker to use for pub/sub
func Broker(b broker.Broker) Option { func Broker(b broker.Broker) Option {
return func(o *options) { return func(o *options) {
o.broker = b o.broker = b
} }
} }
// Codec to use to encode/decode requests for a given content type
func Codec(contentType string, cf CodecFunc) Option { func Codec(contentType string, cf CodecFunc) Option {
return func(o *options) { return func(o *options) {
o.codecs[contentType] = cf o.codecs[contentType] = cf
} }
} }
// Registry used for discovery
func Registry(r registry.Registry) Option { func Registry(r registry.Registry) Option {
return func(o *options) { return func(o *options) {
o.registry = r o.registry = r
} }
} }
// Transport mechanism for communication e.g http, rabbitmq, etc
func Transport(t transport.Transport) Option { func Transport(t transport.Transport) Option {
return func(o *options) { return func(o *options) {
o.transport = t o.transport = t
} }
} }
// Metadata associated with the server
func Metadata(md map[string]string) Option { func Metadata(md map[string]string) Option {
return func(o *options) { return func(o *options) {
o.metadata = md o.metadata = md