tunnel

package

v0.0.0-...-6d4f3c0 Latest Latest Go to latest Published: Nov 21, 2022 License: MIT Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ecomgems/linkage

Links

Open Source Insights

Documentation ¶

Overview ¶

Package tunnel opens a tunnel using provided server and tunnel configuration and keeps it until something will break it or close it. As soon as the tunnel closed, it returns a signal to executing the routine using the channel flag.

Index ¶

func GetFullKeyPath(keyPath string) string
func NewSshConfig(serverConfig config.Server) (*ssh.ClientConfig, error)
type State
type Stats
- func NewStats(state State, updateStatsCallback func(stats *Stats)) *Stats
type Tunnel
- func NewTunnel(appRuntime runtime.ApplicationRuntime, serverConfig config.Server, ...) *Tunnel

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetFullKeyPath ¶

func GetFullKeyPath(keyPath string) string

func NewSshConfig ¶

func NewSshConfig(serverConfig config.Server) (*ssh.ClientConfig, error)

Types ¶

type State ¶

type State int

const (
	Starting State = iota
	Started
	Stopped
)

type Stats ¶

type Stats struct {
	*sync.Mutex
	State State

	TxCount             int64
	RxCount             int64
	TxSpeed             int64
	RxSpeed             int64
	ConnQty             int64
	UpdateStatsCallback func(stats *Stats)
	// contains filtered or unexported fields
}

func NewStats ¶

func NewStats(state State, updateStatsCallback func(stats *Stats)) *Stats

func (*Stats) AddConnQty ¶

func (s *Stats) AddConnQty()

func (*Stats) AddRxCount ¶

func (s *Stats) AddRxCount(count int64)

func (*Stats) AddTxCount ¶

func (s *Stats) AddTxCount(count int64)

func (*Stats) InitSpeedCalculation ¶

func (s *Stats) InitSpeedCalculation()

func (*Stats) SetConnQty ¶

func (s *Stats) SetConnQty(qty int64)

func (*Stats) SubConnQty ¶

func (s *Stats) SubConnQty()

func (*Stats) UpdateState ¶

func (s *Stats) UpdateState(state State)

type Tunnel ¶

type Tunnel struct {
	*sync.Mutex

	ServerConfig config.Server
	TunnelConfig config.Tunnel
	LoggerCh     chan string
	StatsCh      chan *Stats
	// contains filtered or unexported fields
}

func NewTunnel ¶

func NewTunnel(appRuntime runtime.ApplicationRuntime, serverConfig config.Server, tunnelConfig config.Tunnel) *Tunnel

func (*Tunnel) GetTunnelId ¶

func (t *Tunnel) GetTunnelId() string

func (*Tunnel) Init ¶

func (t *Tunnel) Init(runtime runtime.ApplicationRuntime)

func (*Tunnel) Start ¶

func (t *Tunnel) Start() error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL