goCommsSSH

package module
v0.0.0-...-9a14e10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 15, 2022 License: GPL-3.0 Imports: 26 Imported by: 0

README

goCommsSSH

Documentation

Overview

Package internal generated by go-bindata.// sources: DefaultCert DefaultCert.pub

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Asset

func Asset(name string) ([]byte, error)

Asset loads and returns the asset for the given name. It returns an error if the asset could not be found or could not be loaded.

func AssetDir

func AssetDir(name string) ([]string, error)

AssetDir returns the file names below a certain directory embedded in the file by go-bindata. For example if you run go-bindata on data/... and data contains the following hierarchy:

data/
  foo.txt
  img/
    a.png
    b.png

then AssetDir("data") would return []string{"foo.txt", "img"} AssetDir("data/img") would return []string{"a.png", "b.png"} AssetDir("foo.txt") and AssetDir("notexist") would return an error AssetDir("") will return []string{"data"}.

func AssetInfo

func AssetInfo(name string) (os.FileInfo, error)

AssetInfo loads and returns the asset info for the given name. It returns an error if the asset could not be found or could not be loaded.

func AssetNames

func AssetNames() []string

AssetNames returns the names of the assets.

func CreateStackState

func CreateStackState(
	connectionType model.ConnectionType,
	ConnectionManager IConnectionManager.IService,
	UniqueSessionNumber interfaces.IUniqueReferenceService) *common2.StackState

func Inbound

func Inbound(connectionType model.ConnectionType, ConnectionCancelFunc model.ConnectionCancelFunc, logger *zap.Logger, opts ...rxgo.Option) common2.BoundResult

func MustAsset

func MustAsset(name string) []byte

MustAsset is like Asset but panics when Asset would return an error. It simplifies safe initialization of global variables.

func Outbound

func Outbound(connectionType model.ConnectionType, ConnectionCancelFunc model.ConnectionCancelFunc, logger *zap.Logger, opts ...rxgo.Option) common2.BoundResult

func ProvideSshCommunicationStack

func ProvideSshCommunicationStack() fx.Option

func RestoreAsset

func RestoreAsset(dir, name string) error

RestoreAsset restores an asset under the given directory

func RestoreAssets

func RestoreAssets(dir, name string) error

RestoreAssets restores an asset under the given directory recursively

func WrongStackDataError

func WrongStackDataError(connectionType model.ConnectionType, stackData interface{}) error

Types

type InboundStackHandler

type InboundStackHandler struct {
	// contains filtered or unexported fields
}

func NewInboundStackHandler

func NewInboundStackHandler(stackData *StackData) (*InboundStackHandler, error)

func (*InboundStackHandler) Close

func (self *InboundStackHandler) Close() error

func (*InboundStackHandler) Complete

func (self *InboundStackHandler) Complete()

func (*InboundStackHandler) GetAdditionalBytesIncoming

func (self *InboundStackHandler) GetAdditionalBytesIncoming() int

func (*InboundStackHandler) GetAdditionalBytesSend

func (self *InboundStackHandler) GetAdditionalBytesSend() int

func (*InboundStackHandler) NextReadWriterSize

func (self *InboundStackHandler) NextReadWriterSize(
	size goprotoextra.ReadWriterSize,
	_ func(rws goprotoextra.ReadWriterSize) error,
	_ func(size int) error) error

func (*InboundStackHandler) OnComplete

func (self *InboundStackHandler) OnComplete()

func (*InboundStackHandler) OnError

func (self *InboundStackHandler) OnError(err error)

func (*InboundStackHandler) ReadMessage

func (self *InboundStackHandler) ReadMessage(_ interface{}) error

func (*InboundStackHandler) SendData

func (self *InboundStackHandler) SendData(data interface{})

func (*InboundStackHandler) SendError

func (self *InboundStackHandler) SendError(err error)

func (*InboundStackHandler) SendRws

func (self *InboundStackHandler) SendRws(rws goprotoextra.ReadWriterSize)

type ListenAcceptorForTesting

type ListenAcceptorForTesting struct {
	// contains filtered or unexported fields
}

func NewListenAcceptor

func NewListenAcceptor(listener net.Listener) (*ListenAcceptorForTesting, error)

func (*ListenAcceptorForTesting) Accept

func (self *ListenAcceptorForTesting) Accept() (net.Conn, error)

func (*ListenAcceptorForTesting) AcceptWithContext

func (self *ListenAcceptorForTesting) AcceptWithContext() (net.Conn, context.CancelFunc, error)

func (*ListenAcceptorForTesting) Addr

func (self *ListenAcceptorForTesting) Addr() net.Addr

type OutboundStackHandler

type OutboundStackHandler struct {
	// contains filtered or unexported fields
}

func NewOutboundStackHandler

func NewOutboundStackHandler(stackData *StackData) (*OutboundStackHandler, error)

func (*OutboundStackHandler) Close

func (self *OutboundStackHandler) Close() error

func (*OutboundStackHandler) GetAdditionalBytesIncoming

func (self *OutboundStackHandler) GetAdditionalBytesIncoming() int

func (*OutboundStackHandler) GetAdditionalBytesSend

func (self *OutboundStackHandler) GetAdditionalBytesSend() int

func (*OutboundStackHandler) NextReadWriterSize

func (self *OutboundStackHandler) NextReadWriterSize(
	size goprotoextra.ReadWriterSize,
	_ func(rws goprotoextra.ReadWriterSize) error,
	_ func(size int) error) error

func (*OutboundStackHandler) OnComplete

func (self *OutboundStackHandler) OnComplete()

func (*OutboundStackHandler) OnError

func (self *OutboundStackHandler) OnError(err error)

func (*OutboundStackHandler) ReadMessage

func (self *OutboundStackHandler) ReadMessage(_ interface{}) error

func (*OutboundStackHandler) SendRws

type StackData

type StackData struct {
	// contains filtered or unexported fields
}

func NewStackData

func NewStackData(
	connectionType model.ConnectionType,
	conn net.Conn,
	ctx context.Context,
	cancelFunc context.CancelFunc,
	logger *zap.Logger,
	ConnectionManager IConnectionManager.IService,
	uniqueSessionNumber interfaces.IUniqueReferenceService,
	connectionReactor goCommsSshListener.ISshConnectionReactor) *StackData

func (*StackData) Close

func (self *StackData) Close() error

func (*StackData) Start

func (*StackData) Stop

func (self *StackData) Stop() error

Jump to

Keyboard shortcuts

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