goCommsSSH

README

goCommsSSH

Documentation

Overview

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

Index

• func Asset(name string) ([]byte, error)
• func AssetDir(name string) ([]string, error)
• func AssetInfo(name string) (os.FileInfo, error)
• func AssetNames() []string
• func CreateStackState(connectionType model.ConnectionType, ...) *common2.StackState
• func Inbound(connectionType model.ConnectionType, ...) common2.BoundResult
• func MustAsset(name string) []byte
• func Outbound(connectionType model.ConnectionType, ...) common2.BoundResult
• func ProvideSshCommunicationStack() fx.Option
• func RestoreAsset(dir, name string) error
• func RestoreAssets(dir, name string) error
• func WrongStackDataError(connectionType model.ConnectionType, stackData interface{}) error
• type InboundStackHandler
  • func NewInboundStackHandler(stackData *StackData) (*InboundStackHandler, error)
  • func (self *InboundStackHandler) Close() error
  • func (self *InboundStackHandler) Complete()
  • func (self *InboundStackHandler) GetAdditionalBytesIncoming() int
  • func (self *InboundStackHandler) GetAdditionalBytesSend() int
  • func (self *InboundStackHandler) NextReadWriterSize(size goprotoextra.ReadWriterSize, ...) error
  • func (self *InboundStackHandler) OnComplete()
  • func (self *InboundStackHandler) OnError(err error)
  • func (self *InboundStackHandler) ReadMessage(_ interface{}) error
  • func (self *InboundStackHandler) SendData(data interface{})
  • func (self *InboundStackHandler) SendError(err error)
  • func (self *InboundStackHandler) SendRws(rws goprotoextra.ReadWriterSize)
• type ListenAcceptorForTesting
  • func NewListenAcceptor(listener net.Listener) (*ListenAcceptorForTesting, error)
  • func (self *ListenAcceptorForTesting) Accept() (net.Conn, error)
  • func (self *ListenAcceptorForTesting) AcceptWithContext() (net.Conn, context.CancelFunc, error)
  • func (self *ListenAcceptorForTesting) Addr() net.Addr
• type OutboundStackHandler
  • func NewOutboundStackHandler(stackData *StackData) (*OutboundStackHandler, error)
  • func (self *OutboundStackHandler) Close() error
  • func (self *OutboundStackHandler) GetAdditionalBytesIncoming() int
  • func (self *OutboundStackHandler) GetAdditionalBytesSend() int
  • func (self *OutboundStackHandler) NextReadWriterSize(size goprotoextra.ReadWriterSize, ...) error
  • func (self *OutboundStackHandler) OnComplete()
  • func (self *OutboundStackHandler) OnError(err error)
  • func (self *OutboundStackHandler) ReadMessage(_ interface{}) error
  • func (self *OutboundStackHandler) SendRws(rws goprotoextra.ReadWriterSize) error
• type StackData
  • func NewStackData(connectionType model.ConnectionType, conn net.Conn, ctx context.Context, ...) *StackData
  • func (self *StackData) Close() error
  • func (self *StackData) Start(Ctx context.Context) (common.IInputStreamForStack, error)
  • func (self *StackData) Stop() error

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

func (self *OutboundStackHandler) SendRws(rws goprotoextra.ReadWriterSize) error

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 (self *StackData) Start(Ctx context.Context) (common.IInputStreamForStack, error)

func (*StackData) Stop

func (self *StackData) Stop() error