Versions in this module Expand all Collapse all v1 v1.1.10 Dec 12, 2023 Changes in this version + const DefaultID + const KeySSHID + var ErrIntOverflowSsh = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthSsh = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupSsh = fmt.Errorf("proto: unexpected end of group") + func CheckSSHID(ctx context.Context, c session.Caller, id string) error + func Copy(ctx context.Context, conn io.ReadWriteCloser, stream Stream, ...) error + func MountSSHSocket(ctx context.Context, c session.Caller, opt SocketOpt) (sockPath string, closer func() error, err error) + func RegisterSSHServer(s *grpc.Server, srv SSHServer) + type BytesMessage struct + Data []byte + func (*BytesMessage) Descriptor() ([]byte, []int) + func (*BytesMessage) ProtoMessage() + func (m *BytesMessage) GetData() []byte + func (m *BytesMessage) Marshal() (dAtA []byte, err error) + func (m *BytesMessage) MarshalTo(dAtA []byte) (int, error) + func (m *BytesMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BytesMessage) Reset() + func (m *BytesMessage) Size() (n int) + func (m *BytesMessage) Unmarshal(dAtA []byte) error + func (m *BytesMessage) XXX_DiscardUnknown() + func (m *BytesMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BytesMessage) XXX_Merge(src proto.Message) + func (m *BytesMessage) XXX_Size() int + func (m *BytesMessage) XXX_Unmarshal(b []byte) error + func (this *BytesMessage) Equal(that interface{}) bool + func (this *BytesMessage) GoString() string + func (this *BytesMessage) String() string + type CheckAgentRequest struct + ID string + func (*CheckAgentRequest) Descriptor() ([]byte, []int) + func (*CheckAgentRequest) ProtoMessage() + func (m *CheckAgentRequest) GetID() string + func (m *CheckAgentRequest) Marshal() (dAtA []byte, err error) + func (m *CheckAgentRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CheckAgentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CheckAgentRequest) Reset() + func (m *CheckAgentRequest) Size() (n int) + func (m *CheckAgentRequest) Unmarshal(dAtA []byte) error + func (m *CheckAgentRequest) XXX_DiscardUnknown() + func (m *CheckAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CheckAgentRequest) XXX_Merge(src proto.Message) + func (m *CheckAgentRequest) XXX_Size() int + func (m *CheckAgentRequest) XXX_Unmarshal(b []byte) error + func (this *CheckAgentRequest) Equal(that interface{}) bool + func (this *CheckAgentRequest) GoString() string + func (this *CheckAgentRequest) String() string + type CheckAgentResponse struct + func (*CheckAgentResponse) Descriptor() ([]byte, []int) + func (*CheckAgentResponse) ProtoMessage() + func (m *CheckAgentResponse) Marshal() (dAtA []byte, err error) + func (m *CheckAgentResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CheckAgentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CheckAgentResponse) Reset() + func (m *CheckAgentResponse) Size() (n int) + func (m *CheckAgentResponse) Unmarshal(dAtA []byte) error + func (m *CheckAgentResponse) XXX_DiscardUnknown() + func (m *CheckAgentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CheckAgentResponse) XXX_Merge(src proto.Message) + func (m *CheckAgentResponse) XXX_Size() int + func (m *CheckAgentResponse) XXX_Unmarshal(b []byte) error + func (this *CheckAgentResponse) Equal(that interface{}) bool + func (this *CheckAgentResponse) GoString() string + func (this *CheckAgentResponse) String() string + type SSHClient interface + CheckAgent func(ctx context.Context, in *CheckAgentRequest, opts ...grpc.CallOption) (*CheckAgentResponse, error) + ForwardAgent func(ctx context.Context, opts ...grpc.CallOption) (SSH_ForwardAgentClient, error) + func NewSSHClient(cc *grpc.ClientConn) SSHClient + type SSHServer interface + CheckAgent func(context.Context, *CheckAgentRequest) (*CheckAgentResponse, error) + ForwardAgent func(SSH_ForwardAgentServer) error + type SSH_ForwardAgentClient interface + Recv func() (*BytesMessage, error) + Send func(*BytesMessage) error + type SSH_ForwardAgentServer interface + Recv func() (*BytesMessage, error) + Send func(*BytesMessage) error + type SocketOpt struct + GID int + ID string + Mode int + UID int + type Stream interface + RecvMsg func(m interface{}) error + SendMsg func(m interface{}) error + type UnimplementedSSHServer struct + func (*UnimplementedSSHServer) CheckAgent(ctx context.Context, req *CheckAgentRequest) (*CheckAgentResponse, error) + func (*UnimplementedSSHServer) ForwardAgent(srv SSH_ForwardAgentServer) error