unistack-org/micro
4
0
Fork 3
Code Issues 15 Pull Requests 2 Actions Packages Projects Releases 246 Wiki Activity

Comments for options

Browse Source
This commit is contained in:
Asim 2015-11-26 12:51:53 +00:00
parent 54b0be8d7e
commit 8ab77fc3d7
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
client/options.go
View File

@ -14,30 +14,35 @@ type options struct {
transport transport.Transport transport transport.Transport
} }
// Broker to be used 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 be used 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
} }
} }
// Default content type of the client
func ContentType(ct string) Option { func ContentType(ct string) Option {
return func(o *options) { return func(o *options) {
o.contentType = ct o.contentType = ct
} }
} }
// Registry to find nodes for a given service
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 to use 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