Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dialer ¶
type Dialer struct {
// Dial is a function used to establish a network connection to a remote snapshotter.
Dial func(context.Context, string) (net.Conn, error)
// Timeout is the time required to establish a connection to a remote snapshotter.
Timeout time.Duration
}
Dialer captures commonly grouped dial functionality and configuration.
type RemoteSnapshotter ¶
type RemoteSnapshotter struct {
snapshots.Snapshotter
// contains filtered or unexported fields
}
RemoteSnapshotter embeds a snapshots.Snapshotter and its metrics proxy.
func NewRemoteSnapshotter ¶
func NewRemoteSnapshotter(ctx context.Context, address string, dialer func(context.Context, string) (net.Conn, error), metricsProxy *metrics.Proxy) (*RemoteSnapshotter, error)
NewRemoteSnapshotter creates a proxy snapshotter using gRPC over vsock connection.
func (*RemoteSnapshotter) Cleanup ¶
func (rs *RemoteSnapshotter) Cleanup(ctx context.Context) error
Cleanup implements the Cleaner interface for snapshotters. This enables asynchronous resource cleanup by remote snapshotters.
See https://github.com/containerd/containerd/blob/v1.6.4/snapshots/snapshotter.go
func (*RemoteSnapshotter) Close ¶
func (rs *RemoteSnapshotter) Close() error
Close closes the remote snapshotter's snapshotter and shuts down its metrics proxy server.
func (*RemoteSnapshotter) MetricsProxyLabels ¶
func (rs *RemoteSnapshotter) MetricsProxyLabels() map[string]string
MetricsProxyLabels returns the metrics labels for a remote snapshotter.
func (*RemoteSnapshotter) MetricsProxyPort ¶
func (rs *RemoteSnapshotter) MetricsProxyPort() int
MetricsProxyPort returns the metrics proxy port for a remote snapshotter.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.