libplugin

package

Go to main page

Versions in this module

v1

v1.5.3

Feb 10, 2026

v1.5.2

Jan 29, 2026

Changes in this version

+ const SshPiperPlugin_Banner_FullMethodName

+ const SshPiperPlugin_KeyboardInteractiveAuth_FullMethodName

+ const SshPiperPlugin_ListCallbacks_FullMethodName

+ const SshPiperPlugin_Logs_FullMethodName

+ const SshPiperPlugin_NewConnection_FullMethodName

+ const SshPiperPlugin_NextAuthMethods_FullMethodName

+ const SshPiperPlugin_NoneAuth_FullMethodName

+ const SshPiperPlugin_PasswordAuth_FullMethodName

+ const SshPiperPlugin_PipeCreateErrorNotice_FullMethodName

+ const SshPiperPlugin_PipeErrorNotice_FullMethodName

+ const SshPiperPlugin_PipeStartNotice_FullMethodName

+ const SshPiperPlugin_PublicKeyAuth_FullMethodName

+ const SshPiperPlugin_UpstreamAuthFailureNotice_FullMethodName

+ const SshPiperPlugin_VerifyHostKey_FullMethodName

v1.5.1

Nov 24, 2025

v1.5.0

Jun 30, 2025

Changes in this version

type Upstream

+ Uri string

+ func (x *Upstream) GetOrGenerateUri() string

+ func (x *Upstream) GetUri() string

v1.4.8

May 7, 2025

v1.4.7

Mar 15, 2025

v1.4.6

Feb 17, 2025

v1.4.5

Dec 22, 2024

v1.4.4

Nov 10, 2024

v1.4.3

Oct 28, 2024

Changes in this version

type ConnMeta

+ Metadata map[string]string

+ func (c *ConnMeta) GetMeta(key string) string

+ func (x *ConnMeta) GetMetadata() map[string]string

type ConnMetadata

+ GetMeta func(key string) string

+ type SkelPipe interface

+ From func() []SkelPipeFrom

+ type SkelPipeFrom interface

+ MatchConn func(conn ConnMetadata) (SkelPipeTo, error)

+ type SkelPipeFromPassword interface

+ TestPassword func(conn ConnMetadata, password []byte) (bool, error)

+ type SkelPipeFromPublicKey interface

+ AuthorizedKeys func(conn ConnMetadata) ([]byte, error)

+ TrustedUserCAKeys func(conn ConnMetadata) ([]byte, error)

+ type SkelPipeTo interface

+ Host func(conn ConnMetadata) string

+ IgnoreHostKey func(conn ConnMetadata) bool

+ KnownHosts func(conn ConnMetadata) ([]byte, error)

+ User func(conn ConnMetadata) string

+ type SkelPipeToPassword interface

+ OverridePassword func(conn ConnMetadata) ([]byte, error)

+ type SkelPipeToPrivateKey interface

+ PrivateKey func(conn ConnMetadata) ([]byte, []byte, error)

+ type SkelPlugin struct

+ func NewSkelPlugin(listPipe func(ConnMetadata) ([]SkelPipe, error)) *SkelPlugin

+ func (p *SkelPlugin) CreateConfig() *SshPiperPluginConfig

+ func (p *SkelPlugin) PasswordCallback(conn ConnMetadata, password []byte) (*Upstream, error)

+ func (p *SkelPlugin) PublicKeyCallback(conn ConnMetadata, publicKey []byte) (*Upstream, error)

+ func (p *SkelPlugin) SupportedMethods(conn ConnMetadata) ([]string, error)

+ func (p *SkelPlugin) VerifyHostKeyCallback(conn ConnMetadata, hostname, netaddr string, key []byte) error

type Upstream

+ func (x *Upstream) GetRetryCurrentPlugin() *UpstreamRetryCurrentPluginAuth

+ type UpstreamRetryCurrentPluginAuth struct

+ Meta map[string]string

+ func (*UpstreamRetryCurrentPluginAuth) Descriptor() ([]byte, []int)

+ func (*UpstreamRetryCurrentPluginAuth) ProtoMessage()

+ func (x *UpstreamRetryCurrentPluginAuth) GetMeta() map[string]string

+ func (x *UpstreamRetryCurrentPluginAuth) ProtoReflect() protoreflect.Message

+ func (x *UpstreamRetryCurrentPluginAuth) Reset()

+ func (x *UpstreamRetryCurrentPluginAuth) String() string

+ type Upstream_RetryCurrentPlugin struct

+ RetryCurrentPlugin *UpstreamRetryCurrentPluginAuth

+ func CreateRetryCurrentPluginAuth(meta map[string]string) *Upstream_RetryCurrentPlugin

v1.4.2

Oct 23, 2024

v1.4.1

Oct 18, 2024

v1.3.2

Oct 18, 2024

v1.3.1

May 30, 2024

v1.3.0

May 9, 2024

Changes in this version

type PluginTemplate

+ LogFormatter logrus.Formatter

v1.2.8

Mar 3, 2024 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

v1.2.7

Feb 15, 2024 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

Changes in this version

type SshPiperPluginConfig

+ GrpcRemoteSignerFactory grpcsigner.SignerFactory

v1.2.6

Jan 30, 2024 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

v1.2.5

Jan 1, 2024 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

Changes in this version

+ type PipeCreateErrorNoticeRequest struct

+ Error string

+ FromAddr string

+ func (*PipeCreateErrorNoticeRequest) Descriptor() ([]byte, []int)

+ func (*PipeCreateErrorNoticeRequest) ProtoMessage()

+ func (x *PipeCreateErrorNoticeRequest) GetError() string

+ func (x *PipeCreateErrorNoticeRequest) GetFromAddr() string

+ func (x *PipeCreateErrorNoticeRequest) ProtoReflect() protoreflect.Message

+ func (x *PipeCreateErrorNoticeRequest) Reset()

+ func (x *PipeCreateErrorNoticeRequest) String() string

+ type PipeCreateErrorNoticeResponse struct

+ func (*PipeCreateErrorNoticeResponse) Descriptor() ([]byte, []int)

+ func (*PipeCreateErrorNoticeResponse) ProtoMessage()

+ func (x *PipeCreateErrorNoticeResponse) ProtoReflect() protoreflect.Message

+ func (x *PipeCreateErrorNoticeResponse) Reset()

+ func (x *PipeCreateErrorNoticeResponse) String() string

type SshPiperPluginClient

+ PipeCreateErrorNotice func(ctx context.Context, in *PipeCreateErrorNoticeRequest, opts ...grpc.CallOption) (*PipeCreateErrorNoticeResponse, error)

type SshPiperPluginConfig

+ PipeCreateErrorCallback func(remoteAddr string, err error)

type SshPiperPluginServer

+ PipeCreateErrorNotice func(context.Context, *PipeCreateErrorNoticeRequest) (*PipeCreateErrorNoticeResponse, error)

type UnimplementedSshPiperPluginServer

+ func (UnimplementedSshPiperPluginServer) PipeCreateErrorNotice(context.Context, *PipeCreateErrorNoticeRequest) (*PipeCreateErrorNoticeResponse, error)

v1.2.4

Dec 12, 2023 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

v1.2.3

Aug 27, 2023 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

Changes in this version

type UpstreamPrivateKeyAuth

+ CaPublicKey []byte

+ func (x *UpstreamPrivateKeyAuth) GetCaPublicKey() []byte

v1.2.2

Aug 15, 2023 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

v1.2.1

Aug 13, 2023 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

v1.2.0

Aug 11, 2023 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

v1.1.22

Aug 2, 2023 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

v1.1.4

Jul 13, 2023 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

v1.0.105

May 23, 2023 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

v1.0.101

Apr 4, 2023 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

v1.0.96

Mar 11, 2023 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

Changes in this version

+ type PipeErrorNoticeRequest struct

+ Error string

+ Meta *ConnMeta

+ func (*PipeErrorNoticeRequest) Descriptor() ([]byte, []int)

+ func (*PipeErrorNoticeRequest) ProtoMessage()

+ func (x *PipeErrorNoticeRequest) GetError() string

+ func (x *PipeErrorNoticeRequest) GetMeta() *ConnMeta

+ func (x *PipeErrorNoticeRequest) ProtoReflect() protoreflect.Message

+ func (x *PipeErrorNoticeRequest) Reset()

+ func (x *PipeErrorNoticeRequest) String() string

+ type PipeErrorNoticeResponse struct

+ func (*PipeErrorNoticeResponse) Descriptor() ([]byte, []int)

+ func (*PipeErrorNoticeResponse) ProtoMessage()

+ func (x *PipeErrorNoticeResponse) ProtoReflect() protoreflect.Message

+ func (x *PipeErrorNoticeResponse) Reset()

+ func (x *PipeErrorNoticeResponse) String() string

+ type PipeStartNoticeRequest struct

+ Meta *ConnMeta

+ func (*PipeStartNoticeRequest) Descriptor() ([]byte, []int)

+ func (*PipeStartNoticeRequest) ProtoMessage()

+ func (x *PipeStartNoticeRequest) GetMeta() *ConnMeta

+ func (x *PipeStartNoticeRequest) ProtoReflect() protoreflect.Message

+ func (x *PipeStartNoticeRequest) Reset()

+ func (x *PipeStartNoticeRequest) String() string

+ type PipeStartNoticeResponse struct

+ func (*PipeStartNoticeResponse) Descriptor() ([]byte, []int)

+ func (*PipeStartNoticeResponse) ProtoMessage()

+ func (x *PipeStartNoticeResponse) ProtoReflect() protoreflect.Message

+ func (x *PipeStartNoticeResponse) Reset()

+ func (x *PipeStartNoticeResponse) String() string

type SshPiperPluginClient

+ PipeErrorNotice func(ctx context.Context, in *PipeErrorNoticeRequest, opts ...grpc.CallOption) (*PipeErrorNoticeResponse, error)

+ PipeStartNotice func(ctx context.Context, in *PipeStartNoticeRequest, opts ...grpc.CallOption) (*PipeStartNoticeResponse, error)

type SshPiperPluginConfig

+ PipeErrorCallback func(conn ConnMetadata, err error)

+ PipeStartCallback func(conn ConnMetadata)

type SshPiperPluginServer

+ PipeErrorNotice func(context.Context, *PipeErrorNoticeRequest) (*PipeErrorNoticeResponse, error)

+ PipeStartNotice func(context.Context, *PipeStartNoticeRequest) (*PipeStartNoticeResponse, error)

type UnimplementedSshPiperPluginServer

+ func (UnimplementedSshPiperPluginServer) PipeErrorNotice(context.Context, *PipeErrorNoticeRequest) (*PipeErrorNoticeResponse, error)

+ func (UnimplementedSshPiperPluginServer) PipeStartNotice(context.Context, *PipeStartNoticeRequest) (*PipeStartNoticeResponse, error)

+ type VerifyHostKeyResponse struct

+ Verified bool

+ func (*VerifyHostKeyResponse) Descriptor() ([]byte, []int)

+ func (*VerifyHostKeyResponse) ProtoMessage()

+ func (x *VerifyHostKeyResponse) GetVerified() bool

+ func (x *VerifyHostKeyResponse) ProtoReflect() protoreflect.Message

+ func (x *VerifyHostKeyResponse) Reset()

+ func (x *VerifyHostKeyResponse) String() string

v1.0.94

Mar 1, 2023 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

Changes in this version

+ func VerifyHostKeyFromKnownHosts(knownhostsData io.Reader, hostname, netaddr string, key []byte) error

v1.0.83

Jan 7, 2023 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

v1.0.80

Jan 7, 2023 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

v1.0.78

Jan 6, 2023 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

v1.0.72

Dec 21, 2022 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

v1.0.62

Oct 26, 2022 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

Changes in this version

type SshPiperPluginConfig

+ NoClientAuthCallback func(conn ConnMetadata) (*Upstream, error)

v1.0.50

Aug 5, 2022 GO-2024-2853

GO-2024-2853: sshpiper's enabling of proxy protocol without proper feature flagging allows faking source address in github.com/tg123/sshpiper

Changes in this version

+ var AuthMethod_name = map[int32]string

+ var AuthMethod_value = map[string]int32

+ var File_plugin_proto protoreflect.FileDescriptor

+ var SshPiperPlugin_ServiceDesc = grpc.ServiceDesc

+ func AuthMethodTypeToName(a AuthMethod) string

+ func ConfigStdioLogrus(p SshPiperPlugin, logger *logrus.Logger)

+ func CreateAndRunPluginTemplate(t *PluginTemplate)

+ func DialForSSH(addr string) (net.Conn, error)

+ func RegisterSshPiperPluginServer(s grpc.ServiceRegistrar, srv SshPiperPluginServer)

+ func SplitHostPortForSSH(addr string) (host string, port int, err error)

+ type AuthMethod int32

+ const AuthMethod_KEYBOARD_INTERACTIVE

+ const AuthMethod_NONE

+ const AuthMethod_PASSWORD

+ const AuthMethod_PUBLICKEY

+ func AuthMethodFromName(n string) AuthMethod

+ func (AuthMethod) Descriptor() protoreflect.EnumDescriptor

+ func (AuthMethod) EnumDescriptor() ([]byte, []int)

+ func (AuthMethod) Type() protoreflect.EnumType

+ func (x AuthMethod) Enum() *AuthMethod

+ func (x AuthMethod) Number() protoreflect.EnumNumber

+ func (x AuthMethod) String() string

+ type BannerRequest struct

+ Meta *ConnMeta

+ func (*BannerRequest) Descriptor() ([]byte, []int)

+ func (*BannerRequest) ProtoMessage()

+ func (x *BannerRequest) GetMeta() *ConnMeta

+ func (x *BannerRequest) ProtoReflect() protoreflect.Message

+ func (x *BannerRequest) Reset()

+ func (x *BannerRequest) String() string

+ type BannerResponse struct

+ Message string

+ func (*BannerResponse) Descriptor() ([]byte, []int)

+ func (*BannerResponse) ProtoMessage()

+ func (x *BannerResponse) GetMessage() string

+ func (x *BannerResponse) ProtoReflect() protoreflect.Message

+ func (x *BannerResponse) Reset()

+ func (x *BannerResponse) String() string

+ type ConnMeta struct

+ FromAddr string

+ UniqId string

+ UserName string

+ func (*ConnMeta) Descriptor() ([]byte, []int)

+ func (*ConnMeta) ProtoMessage()

+ func (c *ConnMeta) RemoteAddr() string

+ func (c *ConnMeta) UniqueID() string

+ func (c *ConnMeta) User() string

+ func (x *ConnMeta) GetFromAddr() string

+ func (x *ConnMeta) GetUniqId() string

+ func (x *ConnMeta) GetUserName() string

+ func (x *ConnMeta) ProtoReflect() protoreflect.Message

+ func (x *ConnMeta) Reset()

+ func (x *ConnMeta) String() string

+ type ConnMetadata interface

+ RemoteAddr func() string

+ UniqueID func() string

+ User func() string

+ type KeyboardInteractiveAuthMessage struct

+ Message isKeyboardInteractiveAuthMessage_Message

+ func (*KeyboardInteractiveAuthMessage) Descriptor() ([]byte, []int)

+ func (*KeyboardInteractiveAuthMessage) ProtoMessage()

+ func (m *KeyboardInteractiveAuthMessage) GetMessage() isKeyboardInteractiveAuthMessage_Message

+ func (x *KeyboardInteractiveAuthMessage) GetFinishRequest() *KeyboardInteractiveFinishRequest

+ func (x *KeyboardInteractiveAuthMessage) GetMetaRequest() *KeyboardInteractiveMetaRequest

+ func (x *KeyboardInteractiveAuthMessage) GetMetaResponse() *KeyboardInteractiveMetaResponse

+ func (x *KeyboardInteractiveAuthMessage) GetPromptRequest() *KeyboardInteractivePromptRequest

+ func (x *KeyboardInteractiveAuthMessage) GetUserResponse() *KeyboardInteractiveUserResponse

+ func (x *KeyboardInteractiveAuthMessage) ProtoReflect() protoreflect.Message

+ func (x *KeyboardInteractiveAuthMessage) Reset()

+ func (x *KeyboardInteractiveAuthMessage) String() string

+ type KeyboardInteractiveAuthMessage_FinishRequest struct

+ FinishRequest *KeyboardInteractiveFinishRequest

+ type KeyboardInteractiveAuthMessage_MetaRequest struct

+ MetaRequest *KeyboardInteractiveMetaRequest

+ type KeyboardInteractiveAuthMessage_MetaResponse struct

+ MetaResponse *KeyboardInteractiveMetaResponse

+ type KeyboardInteractiveAuthMessage_PromptRequest struct

+ PromptRequest *KeyboardInteractivePromptRequest

+ type KeyboardInteractiveAuthMessage_UserResponse struct

+ UserResponse *KeyboardInteractiveUserResponse

+ type KeyboardInteractiveChallenge func(user, instruction string, question string, echo bool) (answer string, err error)

+ type KeyboardInteractiveFinishRequest struct

+ Upstream *Upstream

+ func (*KeyboardInteractiveFinishRequest) Descriptor() ([]byte, []int)

+ func (*KeyboardInteractiveFinishRequest) ProtoMessage()

+ func (x *KeyboardInteractiveFinishRequest) GetUpstream() *Upstream

+ func (x *KeyboardInteractiveFinishRequest) ProtoReflect() protoreflect.Message

+ func (x *KeyboardInteractiveFinishRequest) Reset()

+ func (x *KeyboardInteractiveFinishRequest) String() string

+ type KeyboardInteractiveMetaRequest struct

+ func (*KeyboardInteractiveMetaRequest) Descriptor() ([]byte, []int)

+ func (*KeyboardInteractiveMetaRequest) ProtoMessage()

+ func (x *KeyboardInteractiveMetaRequest) ProtoReflect() protoreflect.Message

+ func (x *KeyboardInteractiveMetaRequest) Reset()

+ func (x *KeyboardInteractiveMetaRequest) String() string

+ type KeyboardInteractiveMetaResponse struct

+ Meta *ConnMeta

+ func (*KeyboardInteractiveMetaResponse) Descriptor() ([]byte, []int)

+ func (*KeyboardInteractiveMetaResponse) ProtoMessage()

+ func (x *KeyboardInteractiveMetaResponse) GetMeta() *ConnMeta

+ func (x *KeyboardInteractiveMetaResponse) ProtoReflect() protoreflect.Message

+ func (x *KeyboardInteractiveMetaResponse) Reset()

+ func (x *KeyboardInteractiveMetaResponse) String() string

+ type KeyboardInteractivePromptRequest struct

+ Instruction string

+ Name string

+ Questions []*KeyboardInteractivePromptRequest_Question

+ func (*KeyboardInteractivePromptRequest) Descriptor() ([]byte, []int)

+ func (*KeyboardInteractivePromptRequest) ProtoMessage()

+ func (x *KeyboardInteractivePromptRequest) GetInstruction() string

+ func (x *KeyboardInteractivePromptRequest) GetName() string

+ func (x *KeyboardInteractivePromptRequest) GetQuestions() []*KeyboardInteractivePromptRequest_Question

+ func (x *KeyboardInteractivePromptRequest) ProtoReflect() protoreflect.Message

+ func (x *KeyboardInteractivePromptRequest) Reset()

+ func (x *KeyboardInteractivePromptRequest) String() string

+ type KeyboardInteractivePromptRequest_Question struct

+ Echo bool

+ Text string

+ func (*KeyboardInteractivePromptRequest_Question) Descriptor() ([]byte, []int)

+ func (*KeyboardInteractivePromptRequest_Question) ProtoMessage()

+ func (x *KeyboardInteractivePromptRequest_Question) GetEcho() bool

+ func (x *KeyboardInteractivePromptRequest_Question) GetText() string

+ func (x *KeyboardInteractivePromptRequest_Question) ProtoReflect() protoreflect.Message

+ func (x *KeyboardInteractivePromptRequest_Question) Reset()

+ func (x *KeyboardInteractivePromptRequest_Question) String() string

+ type KeyboardInteractiveUserResponse struct

+ Answers []string

+ func (*KeyboardInteractiveUserResponse) Descriptor() ([]byte, []int)

+ func (*KeyboardInteractiveUserResponse) ProtoMessage()

+ func (x *KeyboardInteractiveUserResponse) GetAnswers() []string

+ func (x *KeyboardInteractiveUserResponse) ProtoReflect() protoreflect.Message

+ func (x *KeyboardInteractiveUserResponse) Reset()

+ func (x *KeyboardInteractiveUserResponse) String() string

+ type ListCallbackRequest struct

+ func (*ListCallbackRequest) Descriptor() ([]byte, []int)

+ func (*ListCallbackRequest) ProtoMessage()

+ func (x *ListCallbackRequest) ProtoReflect() protoreflect.Message

+ func (x *ListCallbackRequest) Reset()

+ func (x *ListCallbackRequest) String() string

+ type ListCallbackResponse struct

+ Callbacks []string

+ func (*ListCallbackResponse) Descriptor() ([]byte, []int)

+ func (*ListCallbackResponse) ProtoMessage()

+ func (x *ListCallbackResponse) GetCallbacks() []string

+ func (x *ListCallbackResponse) ProtoReflect() protoreflect.Message

+ func (x *ListCallbackResponse) Reset()

+ func (x *ListCallbackResponse) String() string

+ type Log struct

+ Message string

+ func (*Log) Descriptor() ([]byte, []int)

+ func (*Log) ProtoMessage()

+ func (x *Log) GetMessage() string

+ func (x *Log) ProtoReflect() protoreflect.Message

+ func (x *Log) Reset()

+ func (x *Log) String() string

+ type NewConnectionRequest struct

+ Meta *ConnMeta

+ func (*NewConnectionRequest) Descriptor() ([]byte, []int)

+ func (*NewConnectionRequest) ProtoMessage()

+ func (x *NewConnectionRequest) GetMeta() *ConnMeta

+ func (x *NewConnectionRequest) ProtoReflect() protoreflect.Message

+ func (x *NewConnectionRequest) Reset()

+ func (x *NewConnectionRequest) String() string

+ type NewConnectionResponse struct

+ func (*NewConnectionResponse) Descriptor() ([]byte, []int)

+ func (*NewConnectionResponse) ProtoMessage()

+ func (x *NewConnectionResponse) ProtoReflect() protoreflect.Message

+ func (x *NewConnectionResponse) Reset()

+ func (x *NewConnectionResponse) String() string

+ type NextAuthMethodsRequest struct

+ Meta *ConnMeta

+ func (*NextAuthMethodsRequest) Descriptor() ([]byte, []int)

+ func (*NextAuthMethodsRequest) ProtoMessage()

+ func (x *NextAuthMethodsRequest) GetMeta() *ConnMeta

+ func (x *NextAuthMethodsRequest) ProtoReflect() protoreflect.Message

+ func (x *NextAuthMethodsRequest) Reset()

+ func (x *NextAuthMethodsRequest) String() string

+ type NextAuthMethodsResponse struct

+ Methods []AuthMethod

+ func (*NextAuthMethodsResponse) Descriptor() ([]byte, []int)

+ func (*NextAuthMethodsResponse) ProtoMessage()

+ func (x *NextAuthMethodsResponse) GetMethods() []AuthMethod

+ func (x *NextAuthMethodsResponse) ProtoReflect() protoreflect.Message

+ func (x *NextAuthMethodsResponse) Reset()

+ func (x *NextAuthMethodsResponse) String() string

+ type NoneAuthRequest struct

+ Meta *ConnMeta

+ func (*NoneAuthRequest) Descriptor() ([]byte, []int)

+ func (*NoneAuthRequest) ProtoMessage()

+ func (x *NoneAuthRequest) GetMeta() *ConnMeta

+ func (x *NoneAuthRequest) ProtoReflect() protoreflect.Message

+ func (x *NoneAuthRequest) Reset()

+ func (x *NoneAuthRequest) String() string

+ type NoneAuthResponse struct

+ Upstream *Upstream

+ func (*NoneAuthResponse) Descriptor() ([]byte, []int)

+ func (*NoneAuthResponse) ProtoMessage()

+ func (x *NoneAuthResponse) GetUpstream() *Upstream

+ func (x *NoneAuthResponse) ProtoReflect() protoreflect.Message

+ func (x *NoneAuthResponse) Reset()

+ func (x *NoneAuthResponse) String() string

+ type PasswordAuthRequest struct

+ Meta *ConnMeta

+ Password []byte

+ func (*PasswordAuthRequest) Descriptor() ([]byte, []int)

+ func (*PasswordAuthRequest) ProtoMessage()

+ func (x *PasswordAuthRequest) GetMeta() *ConnMeta

+ func (x *PasswordAuthRequest) GetPassword() []byte

+ func (x *PasswordAuthRequest) ProtoReflect() protoreflect.Message

+ func (x *PasswordAuthRequest) Reset()

+ func (x *PasswordAuthRequest) String() string

+ type PasswordAuthResponse struct

+ Upstream *Upstream

+ func (*PasswordAuthResponse) Descriptor() ([]byte, []int)

+ func (*PasswordAuthResponse) ProtoMessage()

+ func (x *PasswordAuthResponse) GetUpstream() *Upstream

+ func (x *PasswordAuthResponse) ProtoReflect() protoreflect.Message

+ func (x *PasswordAuthResponse) Reset()

+ func (x *PasswordAuthResponse) String() string

+ type PluginTemplate struct

+ CreateConfig func(c *cli.Context) (*SshPiperPluginConfig, error)

+ Flags []cli.Flag

+ Name string

+ Usage string

+ type PublicKeyAuthRequest struct

+ Meta *ConnMeta

+ PublicKey []byte

+ func (*PublicKeyAuthRequest) Descriptor() ([]byte, []int)

+ func (*PublicKeyAuthRequest) ProtoMessage()

+ func (x *PublicKeyAuthRequest) GetMeta() *ConnMeta

+ func (x *PublicKeyAuthRequest) GetPublicKey() []byte

+ func (x *PublicKeyAuthRequest) ProtoReflect() protoreflect.Message

+ func (x *PublicKeyAuthRequest) Reset()

+ func (x *PublicKeyAuthRequest) String() string

+ type PublicKeyAuthResponse struct

+ Upstream *Upstream

+ func (*PublicKeyAuthResponse) Descriptor() ([]byte, []int)

+ func (*PublicKeyAuthResponse) ProtoMessage()

+ func (x *PublicKeyAuthResponse) GetUpstream() *Upstream

+ func (x *PublicKeyAuthResponse) ProtoReflect() protoreflect.Message

+ func (x *PublicKeyAuthResponse) Reset()

+ func (x *PublicKeyAuthResponse) String() string

+ type SshPiperPlugin interface

+ Serve func() error

+ SetConfigLoggerCallback func(cb func(w io.Writer, level string, tty bool))

+ func NewFromGrpc(config SshPiperPluginConfig, grpc *grpc.Server, listener net.Listener) (SshPiperPlugin, error)

+ func NewFromStdio(config SshPiperPluginConfig) (SshPiperPlugin, error)

+ type SshPiperPluginClient interface

+ Banner func(ctx context.Context, in *BannerRequest, opts ...grpc.CallOption) (*BannerResponse, error)

+ KeyboardInteractiveAuth func(ctx context.Context, opts ...grpc.CallOption) (SshPiperPlugin_KeyboardInteractiveAuthClient, error)

+ ListCallbacks func(ctx context.Context, in *ListCallbackRequest, opts ...grpc.CallOption) (*ListCallbackResponse, error)

+ Logs func(ctx context.Context, in *StartLogRequest, opts ...grpc.CallOption) (SshPiperPlugin_LogsClient, error)

+ NewConnection func(ctx context.Context, in *NewConnectionRequest, opts ...grpc.CallOption) (*NewConnectionResponse, error)

+ NextAuthMethods func(ctx context.Context, in *NextAuthMethodsRequest, opts ...grpc.CallOption) (*NextAuthMethodsResponse, error)

+ NoneAuth func(ctx context.Context, in *NoneAuthRequest, opts ...grpc.CallOption) (*NoneAuthResponse, error)

+ PasswordAuth func(ctx context.Context, in *PasswordAuthRequest, opts ...grpc.CallOption) (*PasswordAuthResponse, error)

+ PublicKeyAuth func(ctx context.Context, in *PublicKeyAuthRequest, opts ...grpc.CallOption) (*PublicKeyAuthResponse, error)

+ UpstreamAuthFailureNotice func(ctx context.Context, in *UpstreamAuthFailureNoticeRequest, ...) (*UpstreamAuthFailureNoticeResponse, error)

+ VerifyHostKey func(ctx context.Context, in *VerifyHostKeyRequest, opts ...grpc.CallOption) (*VerifyHostKeyReply, error)

+ func NewSshPiperPluginClient(cc grpc.ClientConnInterface) SshPiperPluginClient

+ type SshPiperPluginConfig struct

+ BannerCallback func(conn ConnMetadata) string

+ KeyboardInteractiveCallback func(conn ConnMetadata, client KeyboardInteractiveChallenge) (*Upstream, error)

+ NewConnectionCallback func(conn ConnMetadata) error

+ NextAuthMethodsCallback func(conn ConnMetadata) ([]string, error)

+ NoneAuthCallback func(conn ConnMetadata) (*Upstream, error)

+ PasswordCallback func(conn ConnMetadata, password []byte) (*Upstream, error)

+ PublicKeyCallback func(conn ConnMetadata, key []byte) (*Upstream, error)

+ UpstreamAuthFailureCallback func(conn ConnMetadata, method string, err error, allowmethods []string)

+ VerifyHostKeyCallback func(conn ConnMetadata, hostname, netaddr string, key []byte) error

+ type SshPiperPluginServer interface

+ Banner func(context.Context, *BannerRequest) (*BannerResponse, error)

+ KeyboardInteractiveAuth func(SshPiperPlugin_KeyboardInteractiveAuthServer) error

+ ListCallbacks func(context.Context, *ListCallbackRequest) (*ListCallbackResponse, error)

+ Logs func(*StartLogRequest, SshPiperPlugin_LogsServer) error

+ NewConnection func(context.Context, *NewConnectionRequest) (*NewConnectionResponse, error)

+ NextAuthMethods func(context.Context, *NextAuthMethodsRequest) (*NextAuthMethodsResponse, error)

+ NoneAuth func(context.Context, *NoneAuthRequest) (*NoneAuthResponse, error)

+ PasswordAuth func(context.Context, *PasswordAuthRequest) (*PasswordAuthResponse, error)

+ PublicKeyAuth func(context.Context, *PublicKeyAuthRequest) (*PublicKeyAuthResponse, error)

+ UpstreamAuthFailureNotice func(context.Context, *UpstreamAuthFailureNoticeRequest) (*UpstreamAuthFailureNoticeResponse, error)

+ VerifyHostKey func(context.Context, *VerifyHostKeyRequest) (*VerifyHostKeyReply, error)

+ type SshPiperPlugin_KeyboardInteractiveAuthClient interface

+ Recv func() (*KeyboardInteractiveAuthMessage, error)

+ Send func(*KeyboardInteractiveAuthMessage) error

+ type SshPiperPlugin_KeyboardInteractiveAuthServer interface

+ Recv func() (*KeyboardInteractiveAuthMessage, error)

+ Send func(*KeyboardInteractiveAuthMessage) error

+ type SshPiperPlugin_LogsClient interface

+ Recv func() (*Log, error)

+ type SshPiperPlugin_LogsServer interface

+ Send func(*Log) error

+ type StartLogRequest struct

+ Level string

+ Tty bool

+ UniqId string

+ func (*StartLogRequest) Descriptor() ([]byte, []int)

+ func (*StartLogRequest) ProtoMessage()

+ func (x *StartLogRequest) GetLevel() string

+ func (x *StartLogRequest) GetTty() bool

+ func (x *StartLogRequest) GetUniqId() string

+ func (x *StartLogRequest) ProtoReflect() protoreflect.Message

+ func (x *StartLogRequest) Reset()

+ func (x *StartLogRequest) String() string

+ type UnimplementedSshPiperPluginServer struct

+ func (UnimplementedSshPiperPluginServer) Banner(context.Context, *BannerRequest) (*BannerResponse, error)

+ func (UnimplementedSshPiperPluginServer) KeyboardInteractiveAuth(SshPiperPlugin_KeyboardInteractiveAuthServer) error

+ func (UnimplementedSshPiperPluginServer) ListCallbacks(context.Context, *ListCallbackRequest) (*ListCallbackResponse, error)

+ func (UnimplementedSshPiperPluginServer) Logs(*StartLogRequest, SshPiperPlugin_LogsServer) error

+ func (UnimplementedSshPiperPluginServer) NewConnection(context.Context, *NewConnectionRequest) (*NewConnectionResponse, error)

+ func (UnimplementedSshPiperPluginServer) NextAuthMethods(context.Context, *NextAuthMethodsRequest) (*NextAuthMethodsResponse, error)

+ func (UnimplementedSshPiperPluginServer) NoneAuth(context.Context, *NoneAuthRequest) (*NoneAuthResponse, error)

+ func (UnimplementedSshPiperPluginServer) PasswordAuth(context.Context, *PasswordAuthRequest) (*PasswordAuthResponse, error)

+ func (UnimplementedSshPiperPluginServer) PublicKeyAuth(context.Context, *PublicKeyAuthRequest) (*PublicKeyAuthResponse, error)

+ func (UnimplementedSshPiperPluginServer) UpstreamAuthFailureNotice(context.Context, *UpstreamAuthFailureNoticeRequest) (*UpstreamAuthFailureNoticeResponse, error)

+ func (UnimplementedSshPiperPluginServer) VerifyHostKey(context.Context, *VerifyHostKeyRequest) (*VerifyHostKeyReply, error)

+ type UnsafeSshPiperPluginServer interface

+ type Upstream struct

+ Auth isUpstream_Auth

+ Host string

+ IgnoreHostKey bool

+ Port int32

+ UserName string

+ func (*Upstream) Descriptor() ([]byte, []int)

+ func (*Upstream) ProtoMessage()

+ func (m *Upstream) GetAuth() isUpstream_Auth

+ func (x *Upstream) GetHost() string

+ func (x *Upstream) GetIgnoreHostKey() bool

+ func (x *Upstream) GetNextPlugin() *UpstreamNextPluginAuth

+ func (x *Upstream) GetNone() *UpstreamNoneAuth

+ func (x *Upstream) GetPassword() *UpstreamPasswordAuth

+ func (x *Upstream) GetPort() int32

+ func (x *Upstream) GetPrivateKey() *UpstreamPrivateKeyAuth

+ func (x *Upstream) GetRemoteSigner() *UpstreamRemoteSignerAuth

+ func (x *Upstream) GetUserName() string

+ func (x *Upstream) ProtoReflect() protoreflect.Message

+ func (x *Upstream) Reset()

+ func (x *Upstream) String() string

+ type UpstreamAuthFailureNoticeRequest struct

+ AllowedMethods []AuthMethod

+ Error string

+ Meta *ConnMeta

+ Method string

+ func (*UpstreamAuthFailureNoticeRequest) Descriptor() ([]byte, []int)

+ func (*UpstreamAuthFailureNoticeRequest) ProtoMessage()

+ func (x *UpstreamAuthFailureNoticeRequest) GetAllowedMethods() []AuthMethod

+ func (x *UpstreamAuthFailureNoticeRequest) GetError() string

+ func (x *UpstreamAuthFailureNoticeRequest) GetMeta() *ConnMeta

+ func (x *UpstreamAuthFailureNoticeRequest) GetMethod() string

+ func (x *UpstreamAuthFailureNoticeRequest) ProtoReflect() protoreflect.Message

+ func (x *UpstreamAuthFailureNoticeRequest) Reset()

+ func (x *UpstreamAuthFailureNoticeRequest) String() string

+ type UpstreamAuthFailureNoticeResponse struct

+ func (*UpstreamAuthFailureNoticeResponse) Descriptor() ([]byte, []int)

+ func (*UpstreamAuthFailureNoticeResponse) ProtoMessage()

+ func (x *UpstreamAuthFailureNoticeResponse) ProtoReflect() protoreflect.Message

+ func (x *UpstreamAuthFailureNoticeResponse) Reset()

+ func (x *UpstreamAuthFailureNoticeResponse) String() string

+ type UpstreamNextPluginAuth struct

+ Meta map[string]string

+ func (*UpstreamNextPluginAuth) Descriptor() ([]byte, []int)

+ func (*UpstreamNextPluginAuth) ProtoMessage()

+ func (x *UpstreamNextPluginAuth) GetMeta() map[string]string

+ func (x *UpstreamNextPluginAuth) ProtoReflect() protoreflect.Message

+ func (x *UpstreamNextPluginAuth) Reset()

+ func (x *UpstreamNextPluginAuth) String() string

+ type UpstreamNoneAuth struct

+ func (*UpstreamNoneAuth) Descriptor() ([]byte, []int)

+ func (*UpstreamNoneAuth) ProtoMessage()

+ func (x *UpstreamNoneAuth) ProtoReflect() protoreflect.Message

+ func (x *UpstreamNoneAuth) Reset()

+ func (x *UpstreamNoneAuth) String() string

+ type UpstreamPasswordAuth struct

+ Password string

+ func (*UpstreamPasswordAuth) Descriptor() ([]byte, []int)

+ func (*UpstreamPasswordAuth) ProtoMessage()

+ func (x *UpstreamPasswordAuth) GetPassword() string

+ func (x *UpstreamPasswordAuth) ProtoReflect() protoreflect.Message

+ func (x *UpstreamPasswordAuth) Reset()

+ func (x *UpstreamPasswordAuth) String() string

+ type UpstreamPrivateKeyAuth struct

+ PrivateKey []byte

+ func (*UpstreamPrivateKeyAuth) Descriptor() ([]byte, []int)

+ func (*UpstreamPrivateKeyAuth) ProtoMessage()

+ func (x *UpstreamPrivateKeyAuth) GetPrivateKey() []byte

+ func (x *UpstreamPrivateKeyAuth) ProtoReflect() protoreflect.Message

+ func (x *UpstreamPrivateKeyAuth) Reset()

+ func (x *UpstreamPrivateKeyAuth) String() string

+ type UpstreamRemoteSignerAuth struct

+ Meta string

+ func (*UpstreamRemoteSignerAuth) Descriptor() ([]byte, []int)

+ func (*UpstreamRemoteSignerAuth) ProtoMessage()

+ func (x *UpstreamRemoteSignerAuth) GetMeta() string

+ func (x *UpstreamRemoteSignerAuth) ProtoReflect() protoreflect.Message

+ func (x *UpstreamRemoteSignerAuth) Reset()

+ func (x *UpstreamRemoteSignerAuth) String() string

+ type Upstream_NextPlugin struct

+ NextPlugin *UpstreamNextPluginAuth

+ func CreateNextPluginAuth(meta map[string]string) *Upstream_NextPlugin

+ type Upstream_None struct

+ None *UpstreamNoneAuth

+ func CreateNoneAuth(password []byte) *Upstream_None

+ type Upstream_Password struct

+ Password *UpstreamPasswordAuth

+ func CreatePasswordAuth(password []byte) *Upstream_Password

+ func CreatePasswordAuthFromString(password string) *Upstream_Password

+ type Upstream_PrivateKey struct

+ PrivateKey *UpstreamPrivateKeyAuth

+ func CreatePrivateKeyAuth(key []byte) *Upstream_PrivateKey

+ type Upstream_RemoteSigner struct

+ RemoteSigner *UpstreamRemoteSignerAuth

+ func CreateRemoteSignerAuth(meta string) *Upstream_RemoteSigner

+ type VerifyHostKeyReply struct

+ Verified bool

+ func (*VerifyHostKeyReply) Descriptor() ([]byte, []int)

+ func (*VerifyHostKeyReply) ProtoMessage()

+ func (x *VerifyHostKeyReply) GetVerified() bool

+ func (x *VerifyHostKeyReply) ProtoReflect() protoreflect.Message

+ func (x *VerifyHostKeyReply) Reset()

+ func (x *VerifyHostKeyReply) String() string

+ type VerifyHostKeyRequest struct

+ Hostname string

+ Key []byte

+ Meta *ConnMeta

+ Netaddress string

+ func (*VerifyHostKeyRequest) Descriptor() ([]byte, []int)

+ func (*VerifyHostKeyRequest) ProtoMessage()

+ func (x *VerifyHostKeyRequest) GetHostname() string

+ func (x *VerifyHostKeyRequest) GetKey() []byte

+ func (x *VerifyHostKeyRequest) GetMeta() *ConnMeta

+ func (x *VerifyHostKeyRequest) GetNetaddress() string

+ func (x *VerifyHostKeyRequest) ProtoReflect() protoreflect.Message

+ func (x *VerifyHostKeyRequest) Reset()

+ func (x *VerifyHostKeyRequest) String() string

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