tunnel

type DialOption func(*DialOptions)

type DialOptions struct {
	// specify a multicast connection
	Multicast bool
	// the dial timeout
	Timeout time.Duration
}

type Link interface {
	// The id of the link
	Id() string
	// honours transport socket
	transport.Socket
}

type Listener interface {
	Accept() (Session, error)
	Channel() string
	Close() error
}

type Option func(*Options)

type Options struct {
	// Id is tunnel id
	Id string
	// Address is tunnel address
	Address string
	// Nodes are remote nodes
	Nodes []string
	// The shared auth token
	Token string
	// Transport listens to incoming connections
	Transport transport.Transport
}

type Session interface {
	// The unique session id
	Id() string
	// The channel name
	Channel() string
	// a transport socket
	transport.Socket
}

type Tunnel interface {
	Init(opts ...Option) error
	// Address the tunnel is listening on
	Address() string
	// Connect connects the tunnel
	Connect() error
	// Close closes the tunnel
	Close() error
	// Connect to a channel
	Dial(channel string, opts ...DialOption) (Session, error)
	// Accept connections on a channel
	Listen(channel string) (Listener, error)
	// All the links the tunnel is connected to
	Links() []Link
	// Name of the tunnel implementation
	String() string
}