1
0
mirror of https://github.com/go-micro/go-micro.git synced 2025-07-12 22:41:07 +02:00

Tunnel no longer embeds transport

This commit is contained in:
Milos Gajdos
2019-08-05 19:41:48 +01:00
parent 34381213e7
commit 6b5dcbf814
2 changed files with 90 additions and 1 deletions

67
tunnel/default.go Normal file
View File

@ -0,0 +1,67 @@
package tunnel
import (
"sync"
"github.com/micro/go-micro/transport"
)
type tun struct {
options Options
sync.RWMutex
connected bool
closed chan bool
}
func newTunnel(opts ...Option) Tunnel {
// initialize default options
options := DefaultOptions()
for _, o := range opts {
o(&options)
}
t := &tun{
options: options,
closed: make(chan bool),
}
return t
}
func (t *tun) Id() string {
return t.options.Id
}
func (t *tun) Address() string {
return t.options.Address
}
func (t *tun) Transport() transport.Transport {
return t.options.Transport
}
func (t *tun) Options() transport.Options {
return transport.Options{}
}
func (t *tun) Connect() error {
return nil
}
func (t *tun) Close() error {
return nil
}
func (t *tun) Status() Status {
select {
case <-t.closed:
return Closed
default:
return Connected
}
}
func (t *tun) String() string {
return "micro"
}