service

type Binder interface {
	Start(ws *websocket.Conn, store *SessionStore) error
}

type BinderAcceptMessage struct {
	Event       string `json:"event"`
	SessionID   string `json:"session_id"`
	PeerAddress string `json:"peer_address"`
}

type Service interface {
	GetBinder(key string, port int) (Binder, error)
}

type Session interface {
	// PeerAddr returns the network address of a connected peer. This must be
	// invariant throughout the entire lifetime of a session.
	PeerAddr() net.Addr

	// Start starts a tunneling session through given websocket channel.
	Start(ws *websocket.Conn) error

	// Close closes client connection. This cancels tunneling session.
	Close() error
}

type SessionStore struct {
	sync.Mutex
	// contains filtered or unexported fields
}