mirror of
https://github.com/moby/moby.git
synced 2022-11-09 12:21:53 -05:00
38d914cc96
Move plugins to shared distribution stack with images.
Create immutable plugin config that matches schema2 requirements.
Ensure data being pushed is same as pulled/created.
Store distribution artifacts in a blobstore.
Run init layer setup for every plugin start.
Fix breakouts from unsafe file accesses.
Add support for `docker plugin install --alias`
Uses normalized references for default names to avoid collisions when using default hosts/tags.
Some refactoring of the plugin manager to support the change, like removing the singleton manager and adding manager config struct.
Signed-off-by: Tonis Tiigi <tonistiigi@gmail.com>
Signed-off-by: Derek McGowan <derek@mcgstyle.net>
(cherry picked from commit 3d86b0c79b)
59 lines
3.1 KiB
Go
59 lines
3.1 KiB
Go
package executor
|
|
|
|
import (
|
|
"io"
|
|
"time"
|
|
|
|
"github.com/docker/distribution"
|
|
"github.com/docker/docker/api/types"
|
|
"github.com/docker/docker/api/types/backend"
|
|
"github.com/docker/docker/api/types/container"
|
|
"github.com/docker/docker/api/types/events"
|
|
"github.com/docker/docker/api/types/filters"
|
|
"github.com/docker/docker/api/types/network"
|
|
swarmtypes "github.com/docker/docker/api/types/swarm"
|
|
clustertypes "github.com/docker/docker/daemon/cluster/provider"
|
|
"github.com/docker/docker/plugin"
|
|
"github.com/docker/docker/reference"
|
|
"github.com/docker/libnetwork"
|
|
"github.com/docker/libnetwork/cluster"
|
|
networktypes "github.com/docker/libnetwork/types"
|
|
"github.com/docker/swarmkit/agent/exec"
|
|
"golang.org/x/net/context"
|
|
)
|
|
|
|
// Backend defines the executor component for a swarm agent.
|
|
type Backend interface {
|
|
CreateManagedNetwork(clustertypes.NetworkCreateRequest) error
|
|
DeleteManagedNetwork(name string) error
|
|
FindNetwork(idName string) (libnetwork.Network, error)
|
|
SetupIngress(req clustertypes.NetworkCreateRequest, nodeIP string) error
|
|
PullImage(ctx context.Context, image, tag string, metaHeaders map[string][]string, authConfig *types.AuthConfig, outStream io.Writer) error
|
|
CreateManagedContainer(config types.ContainerCreateConfig) (container.ContainerCreateCreatedBody, error)
|
|
ContainerStart(name string, hostConfig *container.HostConfig, checkpoint string, checkpointDir string) error
|
|
ContainerStop(name string, seconds *int) error
|
|
ContainerLogs(context.Context, string, *backend.ContainerLogsConfig, chan struct{}) error
|
|
ConnectContainerToNetwork(containerName, networkName string, endpointConfig *network.EndpointSettings) error
|
|
ActivateContainerServiceBinding(containerName string) error
|
|
DeactivateContainerServiceBinding(containerName string) error
|
|
UpdateContainerServiceConfig(containerName string, serviceConfig *clustertypes.ServiceConfig) error
|
|
ContainerInspectCurrent(name string, size bool) (*types.ContainerJSON, error)
|
|
ContainerWaitWithContext(ctx context.Context, name string) error
|
|
ContainerRm(name string, config *types.ContainerRmConfig) error
|
|
ContainerKill(name string, sig uint64) error
|
|
SetContainerSecretStore(name string, store exec.SecretGetter) error
|
|
SetContainerSecretReferences(name string, refs []*swarmtypes.SecretReference) error
|
|
SystemInfo() (*types.Info, error)
|
|
VolumeCreate(name, driverName string, opts, labels map[string]string) (*types.Volume, error)
|
|
Containers(config *types.ContainerListOptions) ([]*types.Container, error)
|
|
SetNetworkBootstrapKeys([]*networktypes.EncryptionKey) error
|
|
SetClusterProvider(provider cluster.Provider)
|
|
IsSwarmCompatible() error
|
|
SubscribeToEvents(since, until time.Time, filter filters.Args) ([]events.Message, chan interface{})
|
|
UnsubscribeFromEvents(listener chan interface{})
|
|
UpdateAttachment(string, string, string, *network.NetworkingConfig) error
|
|
WaitForDetachment(context.Context, string, string, string, string) error
|
|
GetRepository(context.Context, reference.NamedTagged, *types.AuthConfig) (distribution.Repository, bool, error)
|
|
LookupImage(name string) (*types.ImageInspect, error)
|
|
PluginManager() *plugin.Manager
|
|
}
|