mirror of
https://github.com/go-micro/go-micro.git
synced 2024-11-24 08:02:32 +02:00
strip use of cmd
This commit is contained in:
parent
056e7e3c32
commit
44b17b7e4b
@ -11,7 +11,6 @@ import (
|
|||||||
|
|
||||||
"github.com/micro/go-micro/broker"
|
"github.com/micro/go-micro/broker"
|
||||||
"github.com/micro/go-micro/client"
|
"github.com/micro/go-micro/client"
|
||||||
"github.com/micro/go-micro/cmd"
|
|
||||||
"github.com/micro/go-micro/codec"
|
"github.com/micro/go-micro/codec"
|
||||||
"github.com/micro/go-micro/errors"
|
"github.com/micro/go-micro/errors"
|
||||||
"github.com/micro/go-micro/metadata"
|
"github.com/micro/go-micro/metadata"
|
||||||
@ -34,8 +33,6 @@ type grpcClient struct {
|
|||||||
func init() {
|
func init() {
|
||||||
encoding.RegisterCodec(jsonCodec{})
|
encoding.RegisterCodec(jsonCodec{})
|
||||||
encoding.RegisterCodec(bytesCodec{})
|
encoding.RegisterCodec(bytesCodec{})
|
||||||
|
|
||||||
cmd.DefaultClients["grpc"] = NewClient
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// secure returns the dial option for whether its a secure or insecure connection
|
// secure returns the dial option for whether its a secure or insecure connection
|
||||||
|
@ -14,7 +14,6 @@ import (
|
|||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/micro/go-micro/broker"
|
"github.com/micro/go-micro/broker"
|
||||||
"github.com/micro/go-micro/cmd"
|
|
||||||
"github.com/micro/go-micro/codec"
|
"github.com/micro/go-micro/codec"
|
||||||
"github.com/micro/go-micro/errors"
|
"github.com/micro/go-micro/errors"
|
||||||
meta "github.com/micro/go-micro/metadata"
|
meta "github.com/micro/go-micro/metadata"
|
||||||
@ -59,8 +58,6 @@ type grpcServer struct {
|
|||||||
func init() {
|
func init() {
|
||||||
encoding.RegisterCodec(jsonCodec{})
|
encoding.RegisterCodec(jsonCodec{})
|
||||||
encoding.RegisterCodec(bytesCodec{})
|
encoding.RegisterCodec(bytesCodec{})
|
||||||
|
|
||||||
cmd.DefaultServers["grpc"] = NewServer
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func newGRPCServer(opts ...server.Option) server.Server {
|
func newGRPCServer(opts ...server.Option) server.Server {
|
||||||
|
@ -5,7 +5,6 @@ import (
|
|||||||
"crypto/tls"
|
"crypto/tls"
|
||||||
"encoding/gob"
|
"encoding/gob"
|
||||||
|
|
||||||
"github.com/micro/go-micro/cmd"
|
|
||||||
"github.com/lucas-clemente/quic-go"
|
"github.com/lucas-clemente/quic-go"
|
||||||
"github.com/micro/go-micro/transport"
|
"github.com/micro/go-micro/transport"
|
||||||
utls "github.com/micro/util/go/lib/tls"
|
utls "github.com/micro/util/go/lib/tls"
|
||||||
@ -34,10 +33,6 @@ type quicListener struct {
|
|||||||
opts transport.ListenOptions
|
opts transport.ListenOptions
|
||||||
}
|
}
|
||||||
|
|
||||||
func init() {
|
|
||||||
cmd.DefaultTransports["quic"] = NewTransport
|
|
||||||
}
|
|
||||||
|
|
||||||
func (q *quicClient) Close() error {
|
func (q *quicClient) Close() error {
|
||||||
return q.quicSocket.st.Close()
|
return q.quicSocket.st.Close()
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user