plugin

Documentation

Index

• func GetUniqueID(ctx ssh.ChallengeContext) string
• type ChainPlugins
  • func (cp *ChainPlugins) Append(p *GrpcPlugin) error
  • func (cp *ChainPlugins) CreateChallengeContext(conn ssh.ConnMetadata) (ssh.ChallengeContext, error)
  • func (cp *ChainPlugins) InstallPiperConfig(config *GrpcPluginConfig) error
  • func (cp *ChainPlugins) NextAuthMethods(conn ssh.ConnMetadata, challengeCtx ssh.ChallengeContext) ([]string, error)
• type CmdPlugin
  • func DialCmd(cmd *exec.Cmd) (*CmdPlugin, error)
• type GrpcPlugin
  • func DialGrpc(conn *grpc.ClientConn) (*GrpcPlugin, error)
  • func (g *GrpcPlugin) BannerCallback(conn ssh.ConnMetadata, challengeCtx ssh.ChallengeContext) string
  • func (g *GrpcPlugin) CreateChallengeContext(conn ssh.ConnMetadata) (ssh.ChallengeContext, error)
  • func (g *GrpcPlugin) CreatePiperConfig() (*GrpcPluginConfig, error)
  • func (g *GrpcPlugin) InstallPiperConfig(config *GrpcPluginConfig) error
  • func (g *GrpcPlugin) KeyboardInteractiveCallback(conn ssh.ConnMetadata, client ssh.KeyboardInteractiveChallenge, ...) (*ssh.Upstream, error)
  • func (g *GrpcPlugin) NewConnection(meta *connMeta) error
  • func (g *GrpcPlugin) NextAuthMethodsRemote(conn ssh.ConnMetadata, challengeCtx ssh.ChallengeContext) ([]string, error)
  • func (g *GrpcPlugin) NoClientAuthCallback(conn ssh.ConnMetadata, challengeCtx ssh.ChallengeContext) (*ssh.Upstream, error)
  • func (g *GrpcPlugin) PasswordCallback(conn ssh.ConnMetadata, password []byte, challengeCtx ssh.ChallengeContext) (*ssh.Upstream, error)
  • func (g *GrpcPlugin) PipeCreateErrorCallback(conn net.Conn, err error)
  • func (g *GrpcPlugin) PipeErrorCallback(conn ssh.ConnMetadata, challengeCtx ssh.ChallengeContext, pipeerr error)
  • func (g *GrpcPlugin) PipeStartCallback(conn ssh.ConnMetadata, challengeCtx ssh.ChallengeContext)
  • func (g *GrpcPlugin) PublicKeyCallback(conn ssh.ConnMetadata, key ssh.PublicKey, challengeCtx ssh.ChallengeContext) (*ssh.Upstream, error)
  • func (g *GrpcPlugin) RecvLogs(writer io.Writer) error
  • func (g *GrpcPlugin) UpstreamAuthFailureCallbackLocal(onn ssh.ConnMetadata, method string, err error, ...)
  • func (g *GrpcPlugin) UpstreamAuthFailureCallbackRemote(conn ssh.ConnMetadata, method string, err error, ...)
• type GrpcPluginConfig

Functions

func GetUniqueID

func GetUniqueID(ctx ssh.ChallengeContext) string

Types

type ChainPlugins

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

func (*ChainPlugins) Append

func (cp *ChainPlugins) Append(p *GrpcPlugin) error

func (*ChainPlugins) CreateChallengeContext

func (cp *ChainPlugins) CreateChallengeContext(conn ssh.ConnMetadata) (ssh.ChallengeContext, error)

func (*ChainPlugins) InstallPiperConfig

func (cp *ChainPlugins) InstallPiperConfig(config *GrpcPluginConfig) error

func (*ChainPlugins) NextAuthMethods

func (cp *ChainPlugins) NextAuthMethods(conn ssh.ConnMetadata, challengeCtx ssh.ChallengeContext) ([]string, error)

type CmdPlugin

type CmdPlugin struct {
	GrpcPlugin
	Quit <-chan error
}

func DialCmd

func DialCmd(cmd *exec.Cmd) (*CmdPlugin, error)

type GrpcPlugin

type GrpcPlugin struct {
	Name         string
	OnNextPlugin func(conn ssh.ChallengeContext, upstream *libplugin.UpstreamNextPluginAuth) error
	// contains filtered or unexported fields
}

func DialGrpc

func DialGrpc(conn *grpc.ClientConn) (*GrpcPlugin, error)

func (*GrpcPlugin) BannerCallback

func (g *GrpcPlugin) BannerCallback(conn ssh.ConnMetadata, challengeCtx ssh.ChallengeContext) string

func (*GrpcPlugin) CreateChallengeContext

func (g *GrpcPlugin) CreateChallengeContext(conn ssh.ConnMetadata) (ssh.ChallengeContext, error)

func (*GrpcPlugin) CreatePiperConfig

func (g *GrpcPlugin) CreatePiperConfig() (*GrpcPluginConfig, error)

func (*GrpcPlugin) InstallPiperConfig

func (g *GrpcPlugin) InstallPiperConfig(config *GrpcPluginConfig) error

func (*GrpcPlugin) KeyboardInteractiveCallback

func (g *GrpcPlugin) KeyboardInteractiveCallback(conn ssh.ConnMetadata, client ssh.KeyboardInteractiveChallenge, challengeCtx ssh.ChallengeContext) (*ssh.Upstream, error)

func (*GrpcPlugin) NewConnection

func (g *GrpcPlugin) NewConnection(meta *connMeta) error

func (*GrpcPlugin) NextAuthMethodsRemote

func (g *GrpcPlugin) NextAuthMethodsRemote(conn ssh.ConnMetadata, challengeCtx ssh.ChallengeContext) ([]string, error)

func (*GrpcPlugin) NoClientAuthCallback

func (g *GrpcPlugin) NoClientAuthCallback(conn ssh.ConnMetadata, challengeCtx ssh.ChallengeContext) (*ssh.Upstream, error)

func (*GrpcPlugin) PasswordCallback

func (g *GrpcPlugin) PasswordCallback(conn ssh.ConnMetadata, password []byte, challengeCtx ssh.ChallengeContext) (*ssh.Upstream, error)

func (*GrpcPlugin) PipeCreateErrorCallback

func (g *GrpcPlugin) PipeCreateErrorCallback(conn net.Conn, err error)

func (*GrpcPlugin) PipeErrorCallback

func (g *GrpcPlugin) PipeErrorCallback(conn ssh.ConnMetadata, challengeCtx ssh.ChallengeContext, pipeerr error)

func (*GrpcPlugin) PipeStartCallback

func (g *GrpcPlugin) PipeStartCallback(conn ssh.ConnMetadata, challengeCtx ssh.ChallengeContext)

func (*GrpcPlugin) PublicKeyCallback

func (g *GrpcPlugin) PublicKeyCallback(conn ssh.ConnMetadata, key ssh.PublicKey, challengeCtx ssh.ChallengeContext) (*ssh.Upstream, error)

func (*GrpcPlugin) RecvLogs

func (g *GrpcPlugin) RecvLogs(writer io.Writer) error

func (*GrpcPlugin) UpstreamAuthFailureCallbackLocal

func (g *GrpcPlugin) UpstreamAuthFailureCallbackLocal(onn ssh.ConnMetadata, method string, err error, challengeCtx ssh.ChallengeContext)

func (*GrpcPlugin) UpstreamAuthFailureCallbackRemote

func (g *GrpcPlugin) UpstreamAuthFailureCallbackRemote(conn ssh.ConnMetadata, method string, err error, challengeCtx ssh.ChallengeContext)

type GrpcPluginConfig

type GrpcPluginConfig struct {
	ssh.PiperConfig

	PipeCreateErrorCallback func(conn net.Conn, err error)
	PipeStartCallback       func(conn ssh.ConnMetadata, challengeCtx ssh.ChallengeContext)
	PipeErrorCallback       func(conn ssh.ConnMetadata, challengeCtx ssh.ChallengeContext, err error)
}