Documentation ¶
Index ¶
- Variables
- func SetDialRequestChannel(c chan *DialRequest) ofn.OFN
- func WithDoTeleportFunc(f DoTeleportFunc) ofn.OFN
- func WithLogger(logger logrus.FieldLogger) ofn.OFN
- func WithName(name string) ofn.OFN
- func WithNewDial(f NewDial) ofn.OFN
- func WithOnCloseHandler(h OnCloseHandler) ofn.OFN
- func WithOnDoTeleportFunc(f OnDoTeleportFunc) ofn.OFN
- func WithOnErrorHandler(h OnErrorHandler) ofn.OFN
- func WithSink(addr net.Addr) ofn.OFN
- func WithSource(addr net.Addr) ofn.OFN
- func WithTransport(t transport.Transport) ofn.OFN
- type DialRequest
- type DoTeleportFunc
- type NewDial
- type NewTeleportationSinkOption
- type NewTeleportationSourceOption
- type OnCloseHandler
- type OnDoTeleportFunc
- type OnErrorHandler
- type Portal
- type Teleportation
- type TeleportationSink
- func (ts *TeleportationSink) Close() error
- func (ts *TeleportationSink) DataChannels() []transport.DataChannel
- func (ts *TeleportationSink) Name() string
- func (ts *TeleportationSink) OnDoTeleport(label string) error
- func (ts *TeleportationSink) Portal() Portal
- func (ts *TeleportationSink) Sink() net.Addr
- func (ts *TeleportationSink) Source() net.Addr
- func (ts *TeleportationSink) Transport() transport.Transport
- type TeleportationSource
- func (ts *TeleportationSource) Close() error
- func (ts *TeleportationSource) DataChannels() []transport.DataChannel
- func (ts *TeleportationSource) Name() string
- func (ts *TeleportationSource) Portal() Portal
- func (ts *TeleportationSource) Sink() net.Addr
- func (ts *TeleportationSource) Source() net.Addr
- func (ts *TeleportationSource) Transport() transport.Transport
Constants ¶
This section is empty.
Variables ¶
View Source
var ( PortalStr = []string{ PortalSource: "source", PortalSink: "sink", } )
Functions ¶
func SetDialRequestChannel ¶
func SetDialRequestChannel(c chan *DialRequest) ofn.OFN
func WithDoTeleportFunc ¶
func WithDoTeleportFunc(f DoTeleportFunc) ofn.OFN
func WithLogger ¶
func WithLogger(logger logrus.FieldLogger) ofn.OFN
func WithNewDial ¶
func WithOnCloseHandler ¶
func WithOnCloseHandler(h OnCloseHandler) ofn.OFN
func WithOnDoTeleportFunc ¶
func WithOnDoTeleportFunc(f OnDoTeleportFunc) ofn.OFN
func WithOnErrorHandler ¶
func WithOnErrorHandler(h OnErrorHandler) ofn.OFN
Types ¶
type DialRequest ¶
func NewDialRequest ¶
func NewDialRequest(conn net.Conn) *DialRequest
func NewDialRequestWithQuit ¶
func NewDialRequestWithQuit(conn net.Conn, quit chan struct{}) *DialRequest
type DoTeleportFunc ¶
type OnCloseHandler ¶
type OnCloseHandler func()
type OnDoTeleportFunc ¶
type OnDoTeleportFunc func() error
type OnErrorHandler ¶
type OnErrorHandler func(error)
type Teleportation ¶
type TeleportationSink ¶
type TeleportationSink struct {
// contains filtered or unexported fields
}
func NewTeleportationSink ¶
func NewTeleportationSink(opts ...NewTeleportationSinkOption) (*TeleportationSink, error)
func (*TeleportationSink) Close ¶
func (ts *TeleportationSink) Close() error
func (*TeleportationSink) DataChannels ¶
func (ts *TeleportationSink) DataChannels() []transport.DataChannel
func (*TeleportationSink) Name ¶
func (ts *TeleportationSink) Name() string
func (*TeleportationSink) OnDoTeleport ¶
func (ts *TeleportationSink) OnDoTeleport(label string) error
func (*TeleportationSink) Portal ¶
func (ts *TeleportationSink) Portal() Portal
func (*TeleportationSink) Sink ¶
func (ts *TeleportationSink) Sink() net.Addr
func (*TeleportationSink) Source ¶
func (ts *TeleportationSink) Source() net.Addr
func (*TeleportationSink) Transport ¶
func (ts *TeleportationSink) Transport() transport.Transport
type TeleportationSource ¶
type TeleportationSource struct {
// contains filtered or unexported fields
}
func NewTeleportationSource ¶
func NewTeleportationSource(opts ...NewTeleportationSourceOption) (*TeleportationSource, error)
func (*TeleportationSource) Close ¶
func (ts *TeleportationSource) Close() error
func (*TeleportationSource) DataChannels ¶
func (ts *TeleportationSource) DataChannels() []transport.DataChannel
func (*TeleportationSource) Name ¶
func (ts *TeleportationSource) Name() string
func (*TeleportationSource) Portal ¶
func (ts *TeleportationSource) Portal() Portal
func (*TeleportationSource) Sink ¶
func (ts *TeleportationSource) Sink() net.Addr
func (*TeleportationSource) Source ¶
func (ts *TeleportationSource) Source() net.Addr
func (*TeleportationSource) Transport ¶
func (ts *TeleportationSource) Transport() transport.Transport
Click to show internal directories.
Click to hide internal directories.