go/go-micro
1
0
Fork 0
mirror of https://github.com/go-micro/go-micro.git synced 2025-11-06 08:29:15 +02:00
Code Issues Releases Activity

refactor network

Browse Source
This commit is contained in:
Asim Aslam
2020-12-12 18:59:40 +00:00
parent f8f84b42ac
commit 35c59042bf
23 changed files with 635 additions and 2981 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/grpc/options.go
View File

@@ -5,7 +5,6 @@ import (
"crypto/tls"
"net"
"github.com/micro/go-micro/v2/auth"
"github.com/micro/go-micro/v2/broker"
"github.com/micro/go-micro/v2/codec"
"github.com/micro/go-micro/v2/registry"
@@ -67,7 +66,6 @@ func MaxMsgSize(s int) server.Option {
func newOptions(opt ...server.Option) server.Options {
opts := server.Options{
Auth: auth.DefaultAuth,
Codecs: make(map[string]codec.NewCodec),
Metadata: map[string]string{},
Broker: broker.DefaultBroker,

13
server/options.go
View File

@@ -6,7 +6,6 @@ import (
"sync"
"time"
"github.com/micro/go-micro/v2/auth"
"github.com/micro/go-micro/v2/broker"
"github.com/micro/go-micro/v2/codec"
"github.com/micro/go-micro/v2/debug/trace"
@@ -19,7 +18,6 @@ type Options struct {
Broker broker.Broker
Registry registry.Registry
Tracer trace.Tracer
Auth auth.Auth
Transport transport.Transport
Metadata map[string]string
Name string
@@ -60,10 +58,6 @@ func newOptions(opt ...Option) Options {
o(&opts)
}
if opts.Auth == nil {
opts.Auth = auth.DefaultAuth
}
if opts.Broker == nil {
opts.Broker = broker.DefaultBroker
}
@@ -171,13 +165,6 @@ func Tracer(t trace.Tracer) Option {
}
}
// Auth mechanism for role based access control
func Auth(a auth.Auth) Option {
return func(o *Options) {
o.Auth = a
}
}
// Transport mechanism for communication e.g http, rabbitmq, etc
func Transport(t transport.Transport) Option {
return func(o *Options) {