sshforward

Documentation

Overview

Package sshforward is a generated protocol buffer package.

It is generated from these files:

ssh.proto

It has these top-level messages:

BytesMessage
CheckAgentRequest
CheckAgentResponse

Index

• Constants
• Variables
• func CheckSSHID(ctx context.Context, c session.Caller, id string) error
• func Copy(ctx context.Context, conn io.ReadWriteCloser, stream grpc.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
  • func (*BytesMessage) Descriptor() ([]byte, []int)
  • func (this *BytesMessage) Equal(that interface{}) bool
  • func (m *BytesMessage) GetData() []byte
  • func (this *BytesMessage) GoString() string
  • func (m *BytesMessage) Marshal() (dAtA []byte, err error)
  • func (m *BytesMessage) MarshalTo(dAtA []byte) (int, error)
  • func (*BytesMessage) ProtoMessage()
  • func (m *BytesMessage) Reset()
  • func (m *BytesMessage) Size() (n int)
  • func (this *BytesMessage) String() string
  • func (m *BytesMessage) Unmarshal(dAtA []byte) error
• type CheckAgentRequest
  • func (*CheckAgentRequest) Descriptor() ([]byte, []int)
  • func (this *CheckAgentRequest) Equal(that interface{}) bool
  • func (m *CheckAgentRequest) GetID() string
  • func (this *CheckAgentRequest) GoString() string
  • func (m *CheckAgentRequest) Marshal() (dAtA []byte, err error)
  • func (m *CheckAgentRequest) MarshalTo(dAtA []byte) (int, error)
  • func (*CheckAgentRequest) ProtoMessage()
  • func (m *CheckAgentRequest) Reset()
  • func (m *CheckAgentRequest) Size() (n int)
  • func (this *CheckAgentRequest) String() string
  • func (m *CheckAgentRequest) Unmarshal(dAtA []byte) error
• type CheckAgentResponse
  • func (*CheckAgentResponse) Descriptor() ([]byte, []int)
  • func (this *CheckAgentResponse) Equal(that interface{}) bool
  • func (this *CheckAgentResponse) GoString() string
  • func (m *CheckAgentResponse) Marshal() (dAtA []byte, err error)
  • func (m *CheckAgentResponse) MarshalTo(dAtA []byte) (int, error)
  • func (*CheckAgentResponse) ProtoMessage()
  • func (m *CheckAgentResponse) Reset()
  • func (m *CheckAgentResponse) Size() (n int)
  • func (this *CheckAgentResponse) String() string
  • func (m *CheckAgentResponse) Unmarshal(dAtA []byte) error
• type SSHClient
  • func NewSSHClient(cc *grpc.ClientConn) SSHClient
• type SSHServer
• type SSH_ForwardAgentClient
• type SSH_ForwardAgentServer
• type SocketOpt

Constants

const DefaultID = "default"

DefaultID is the default ssh ID

const KeySSHID = "buildkit.ssh.id"

Variables

var (
	ErrInvalidLengthSsh = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSsh   = fmt.Errorf("proto: integer overflow")
)

Functions

func CheckSSHID

func CheckSSHID(ctx context.Context, c session.Caller, id string) error

func Copy

func Copy(ctx context.Context, conn io.ReadWriteCloser, stream grpc.Stream) error

func MountSSHSocket

func MountSSHSocket(ctx context.Context, c session.Caller, opt SocketOpt) (sockPath string, closer func() error, err error)

func RegisterSSHServer

func RegisterSSHServer(s *grpc.Server, srv SSHServer)

Types

type BytesMessage

type BytesMessage struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

BytesMessage contains a chunk of byte data

func (*BytesMessage) Descriptor

func (*BytesMessage) Descriptor() ([]byte, []int)

func (*BytesMessage) Equal

func (this *BytesMessage) Equal(that interface{}) bool

func (*BytesMessage) GetData

func (m *BytesMessage) GetData() []byte

func (*BytesMessage) GoString

func (this *BytesMessage) GoString() string

func (*BytesMessage) Marshal

func (m *BytesMessage) Marshal() (dAtA []byte, err error)

func (*BytesMessage) MarshalTo

func (m *BytesMessage) MarshalTo(dAtA []byte) (int, error)

func (*BytesMessage) ProtoMessage

func (*BytesMessage) ProtoMessage()

func (*BytesMessage) Reset

func (m *BytesMessage) Reset()

func (*BytesMessage) Size

func (m *BytesMessage) Size() (n int)

func (*BytesMessage) String

func (this *BytesMessage) String() string

func (*BytesMessage) Unmarshal

func (m *BytesMessage) Unmarshal(dAtA []byte) error

type CheckAgentRequest

type CheckAgentRequest struct {
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
}

func (*CheckAgentRequest) Descriptor

func (*CheckAgentRequest) Descriptor() ([]byte, []int)

func (*CheckAgentRequest) Equal

func (this *CheckAgentRequest) Equal(that interface{}) bool

func (*CheckAgentRequest) GetID

func (m *CheckAgentRequest) GetID() string

func (*CheckAgentRequest) GoString

func (this *CheckAgentRequest) GoString() string

func (*CheckAgentRequest) Marshal

func (m *CheckAgentRequest) Marshal() (dAtA []byte, err error)

func (*CheckAgentRequest) MarshalTo

func (m *CheckAgentRequest) MarshalTo(dAtA []byte) (int, error)

func (*CheckAgentRequest) ProtoMessage

func (*CheckAgentRequest) ProtoMessage()

func (*CheckAgentRequest) Reset

func (m *CheckAgentRequest) Reset()

func (*CheckAgentRequest) Size

func (m *CheckAgentRequest) Size() (n int)

func (*CheckAgentRequest) String

func (this *CheckAgentRequest) String() string

func (*CheckAgentRequest) Unmarshal

func (m *CheckAgentRequest) Unmarshal(dAtA []byte) error

type CheckAgentResponse

type CheckAgentResponse struct {
}

func (*CheckAgentResponse) Descriptor

func (*CheckAgentResponse) Descriptor() ([]byte, []int)

func (*CheckAgentResponse) Equal

func (this *CheckAgentResponse) Equal(that interface{}) bool

func (*CheckAgentResponse) GoString

func (this *CheckAgentResponse) GoString() string

func (*CheckAgentResponse) Marshal

func (m *CheckAgentResponse) Marshal() (dAtA []byte, err error)

func (*CheckAgentResponse) MarshalTo

func (m *CheckAgentResponse) MarshalTo(dAtA []byte) (int, error)

func (*CheckAgentResponse) ProtoMessage

func (*CheckAgentResponse) ProtoMessage()

func (*CheckAgentResponse) Reset

func (m *CheckAgentResponse) Reset()

func (*CheckAgentResponse) Size

func (m *CheckAgentResponse) Size() (n int)

func (*CheckAgentResponse) String

func (this *CheckAgentResponse) String() string

func (*CheckAgentResponse) Unmarshal

func (m *CheckAgentResponse) Unmarshal(dAtA []byte) error

type SSHClient

type SSHClient interface {
	CheckAgent(ctx context.Context, in *CheckAgentRequest, opts ...grpc.CallOption) (*CheckAgentResponse, error)
	ForwardAgent(ctx context.Context, opts ...grpc.CallOption) (SSH_ForwardAgentClient, error)
}

func NewSSHClient

func NewSSHClient(cc *grpc.ClientConn) SSHClient

type SSHServer

type SSHServer interface {
	CheckAgent(context.Context, *CheckAgentRequest) (*CheckAgentResponse, error)
	ForwardAgent(SSH_ForwardAgentServer) error
}

type SSH_ForwardAgentClient

type SSH_ForwardAgentClient interface {
	Send(*BytesMessage) error
	Recv() (*BytesMessage, error)
	grpc.ClientStream
}

type SSH_ForwardAgentServer

type SSH_ForwardAgentServer interface {
	Send(*BytesMessage) error
	Recv() (*BytesMessage, error)
	grpc.ServerStream
}

type SocketOpt

type SocketOpt struct {
	ID   string
	UID  int
	GID  int
	Mode int
}