updates #207
| @@ -5,6 +5,7 @@ import ( | |||||||
| 	"crypto/tls" | 	"crypto/tls" | ||||||
| 	"time" | 	"time" | ||||||
|  |  | ||||||
|  | 	"go.unistack.org/micro/v3/codec" | ||||||
| 	"go.unistack.org/micro/v3/logger" | 	"go.unistack.org/micro/v3/logger" | ||||||
| 	"go.unistack.org/micro/v3/meter" | 	"go.unistack.org/micro/v3/meter" | ||||||
| 	"go.unistack.org/micro/v3/tracer" | 	"go.unistack.org/micro/v3/tracer" | ||||||
| @@ -26,6 +27,8 @@ type Options struct { | |||||||
| 	Name string | 	Name string | ||||||
| 	// Addrs specifies register addrs | 	// Addrs specifies register addrs | ||||||
| 	Addrs []string | 	Addrs []string | ||||||
|  | 	// Codec used to marshal/unmarshal data in register | ||||||
|  | 	Codec codec.Codec | ||||||
| 	// Timeout specifies timeout | 	// Timeout specifies timeout | ||||||
| 	Timeout time.Duration | 	Timeout time.Duration | ||||||
| } | } | ||||||
| @@ -37,6 +40,7 @@ func NewOptions(opts ...Option) Options { | |||||||
| 		Meter:   meter.DefaultMeter, | 		Meter:   meter.DefaultMeter, | ||||||
| 		Tracer:  tracer.DefaultTracer, | 		Tracer:  tracer.DefaultTracer, | ||||||
| 		Context: context.Background(), | 		Context: context.Background(), | ||||||
|  | 		Codec:   codec.NewCodec(), | ||||||
| 	} | 	} | ||||||
| 	for _, o := range opts { | 	for _, o := range opts { | ||||||
| 		o(&options) | 		o(&options) | ||||||
| @@ -310,3 +314,11 @@ func Name(n string) Option { | |||||||
| 		o.Name = n | 		o.Name = n | ||||||
| 	} | 	} | ||||||
| } | } | ||||||
|  |  | ||||||
|  | type codecKey struct{} | ||||||
|  |  | ||||||
|  | func Codec(c codec.Codec) Option { | ||||||
|  | 	return func(o *Options) { | ||||||
|  | 		o.Codec = c | ||||||
|  | 	} | ||||||
|  | } | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user