client

package

v1.11.3 Latest Latest Go to latest Published: Oct 7, 2024 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/s0rg/decompose

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func Inodes(pid int, cb func(uint64)) error
func Nsenter(pid int, proto graph.NetProto, onconn func(int, *graph.Connection)) (err error)
type Docker
- func NewDocker(opts ...Option) (rv *Docker, err error)
type DockerClient
- func Default() (rv DockerClient, err error)
type InodesMap
type Option

Constants ¶

View Source

const (
	None         mode = 0
	InContainer  mode = 1
	LinuxNsenter mode = 2
)

Variables ¶

View Source

var ErrModeNone = errors.New("mode not set")

Functions ¶

func Inodes ¶ added in v1.11.0

func Inodes(
	pid int,
	cb func(uint64),
) error

func Nsenter ¶ added in v1.7.4

func Nsenter(
	pid int,
	proto graph.NetProto,
	onconn func(int, *graph.Connection),
) (
	err error,
)

Types ¶

type Docker ¶

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

func NewDocker ¶

func NewDocker(opts ...Option) (rv *Docker, err error)

func (*Docker) Close ¶

func (d *Docker) Close() (err error)

func (*Docker) Containers ¶

func (d *Docker) Containers(
	ctx context.Context,
	proto graph.NetProto,
	deep bool,
	skipkeys []string,
	progress func(int, int),
) (rv []*graph.Container, err error)

func (*Docker) Mode ¶ added in v1.7.4

func (d *Docker) Mode() string

type DockerClient ¶ added in v1.7.4

type DockerClient interface {
	ContainerList(context.Context, container.ListOptions) ([]types.Container, error)
	ContainerInspect(context.Context, string) (types.ContainerJSON, error)
	ContainerExecCreate(context.Context, string, container.ExecOptions) (types.IDResponse, error)
	ContainerExecAttach(context.Context, string, container.ExecStartOptions) (types.HijackedResponse, error)
	ContainerTop(ctx context.Context, containerID string, arguments []string) (container.ContainerTopOKBody, error)
	Close() error
}

func Default ¶ added in v1.7.4

func Default() (rv DockerClient, err error)

type InodesMap ¶ added in v1.11.0

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

func (*InodesMap) AddInode ¶ added in v1.11.0

func (m *InodesMap) AddInode(containerID string, pid int, inode uint64)

func (*InodesMap) AddProcess ¶ added in v1.11.0

func (m *InodesMap) AddProcess(containerID string, pid int, name string)

func (*InodesMap) Has ¶ added in v1.11.0

func (m *InodesMap) Has(containerID string, pid int, inode uint64) (yes bool)

func (*InodesMap) MarkListener ¶ added in v1.11.0

func (m *InodesMap) MarkListener(containerID string, pid int, path string)

func (*InodesMap) MarkUnknown ¶ added in v1.11.0

func (m *InodesMap) MarkUnknown(containerID string, pid int, inode uint64)

func (*InodesMap) ResolveUnknown ¶ added in v1.11.0

func (m *InodesMap) ResolveUnknown(
	cb func(srcCID, dstCID, srcName, dstName, path string),
)

type Option ¶ added in v1.7.4

type Option func(*options)

func WithClientCreator ¶ added in v1.7.4

func WithClientCreator(c createClient) Option

func WithInodesFn ¶ added in v1.11.0

func WithInodesFn(f inodes) Option

func WithMode ¶ added in v1.7.4

func WithMode(m mode) Option

func WithNsenterFn ¶ added in v1.11.0

func WithNsenterFn(f nsenter) Option

Source Files ¶

View all Source files

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