net

package
v0.0.0-...-75d348f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 2, 2021 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CIDResolver

type CIDResolver interface {
	Resolve(repo string, reference string) ([]string, error)
}

CIDResolver is the interface that maps container image repo[:reference] to content ID.

func NewDNSLinkResolver

func NewDNSLinkResolver(client *IpfsClient, domain string) (CIDResolver, error)

func NewFileResolver

func NewFileResolver(uri string) (CIDResolver, error)

func NewIPFSResolver

func NewIPFSResolver(client *IpfsClient, root string) (CIDResolver, error)

func NewResolver

func NewResolver(client *IpfsClient, list []string) CIDResolver

func NewScpResolver

func NewScpResolver(uri string) (CIDResolver, error)

type FileInfo

type FileInfo = scp.FileInfo

func NewFileInfo

func NewFileInfo(name string, size int64, mode os.FileMode, modTime, accessTime time.Time) *FileInfo

type IpfsClient

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

IpfsClient is the IPFS client

func NewIpfsClient

func NewIpfsClient(host string) *IpfsClient

func (*IpfsClient) AddImage

func (client *IpfsClient) AddImage(manifest map[string][]byte, layers map[string][]byte) (string, error)

AddImage adds components of an image recursively

func (*IpfsClient) Cat

func (client *IpfsClient) Cat(path string) (io.ReadCloser, error)

Cat the content at the given path. Callers need to drain and close the returned reader after usage.

func (*IpfsClient) List

func (client *IpfsClient) List(path string) ([]*api.LsLink, error)

List entries at the given path

type ScpShell

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

ScpShell for transferring files via ssh.

func NewScpShell

func NewScpShell(uri string) *ScpShell

NewScpShell parses URL and reads env for authentication. scp://user[:pass]@host:port/path SSH_PRIVATE_KEY= SSH_ID_FILE=$HOME/.ssh/id_rsa

func (*ScpShell) Connect

func (r *ScpShell) Connect(cb func(conn *ssh.Client) ([]byte, error)) ([]byte, error)

func (*ScpShell) CopyDirs

func (r *ScpShell) CopyDirs(remote string, local ...string) error

CopyDirs transfers local directories to the remote directory recursively.

func (*ScpShell) Dial

func (r *ScpShell) Dial() (cli *ssh.Client, err error)

Dial and recover from panic if any

func (*ScpShell) Do

func (r *ScpShell) Do(cb func(*Transfer) ([]byte, error)) ([]byte, error)

func (*ScpShell) FileExist

func (r *ScpShell) FileExist(filename string) bool

func (*ScpShell) List

func (r *ScpShell) List(filename string) ([]string, error)

func (*ScpShell) ReadFile

func (r *ScpShell) ReadFile(filename string) ([]byte, error)

func (*ScpShell) String

func (r *ScpShell) String() string

type Transfer

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

func (*Transfer) Mkdir

func (r *Transfer) Mkdir(dirs ...string) error

func (*Transfer) Receive

func (r *Transfer) Receive(filename string, w io.Writer) (*FileInfo, error)

func (*Transfer) Send

func (r *Transfer) Send(info *FileInfo, rd io.Reader, filename string) error

Jump to

Keyboard shortcuts

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