docker

package

Go to main page

Versions in this module

v0

v0.14.1

Jan 9, 2025

v0.14.0

Sep 10, 2024

Changes in this version

type DockerClusterOptions

+ Envs []string

v0.13.0

May 23, 2024

v0.12.0

Apr 11, 2024

v0.11.1

Mar 13, 2024

Changes in this version

type DockerClusterOptions

+ DisableTLS bool

v0.11.0

Feb 8, 2024

Changes in this version

type DockerCluster

+ func (dc *DockerCluster) GetActiveClusterNode() *DockerClusterNode

type DockerClusterNode

+ func (n *DockerClusterNode) Restart(ctx context.Context) error

v0.10.2

Oct 9, 2023

v0.10.1

Oct 9, 2023

Changes in this version

type DockerClusterNode

+ func (n *DockerClusterNode) PartitionFromCluster(ctx context.Context) error

+ func (n *DockerClusterNode) UnpartitionFromCluster(ctx context.Context) error

type DockerClusterOptions

+ Storage testcluster.ClusterStorage

v0.10.0

Sep 5, 2023

Changes in this version

type DockerClusterNode

+ AllClients []*api.Client

+ func (n *DockerClusterNode) APIClientN(listenerNumber int) (*api.Client, error)

v0.9.2

Jul 25, 2023

v0.9.1

May 26, 2023

Changes in this version

+ const DefaultNumCores

+ const MaxClusterNameLength

+ func NewReplicationSetDocker(t *testing.T, opts *DockerClusterOptions) (*testcluster.ReplicationSet, error)

+ type CertificateGetter struct

+ func NewCertificateGetter(certFile, keyFile, passphrase string) *CertificateGetter

+ func (cg *CertificateGetter) GetCertificate(clientHello *tls.ClientHelloInfo) (*tls.Certificate, error)

+ func (cg *CertificateGetter) Reload() error

+ type DockerCluster struct

+ ClusterName string

+ ClusterNodes []*DockerClusterNode

+ DockerAPI *docker.Client

+ ID string

+ Logger log.Logger

+ RaftStorage bool

+ RootCAs *x509.CertPool

+ func NewDockerCluster(ctx context.Context, opts *DockerClusterOptions) (*DockerCluster, error)

+ func NewTestDockerCluster(t *testing.T, opts *DockerClusterOptions) *DockerCluster

+ func (dc *DockerCluster) AddNode(ctx context.Context, opts *DockerClusterOptions) error

+ func (dc *DockerCluster) Cleanup()

+ func (dc *DockerCluster) ClusterID() string

+ func (dc *DockerCluster) GetBarrierKeys() [][]byte

+ func (dc *DockerCluster) GetBarrierOrRecoveryKeys() [][]byte

+ func (dc *DockerCluster) GetCACertPEMFile() string

+ func (dc *DockerCluster) GetRecoveryKeys() [][]byte

+ func (dc *DockerCluster) GetRootToken() string

+ func (dc *DockerCluster) NamedLogger(s string) log.Logger

+ func (dc *DockerCluster) Nodes() []testcluster.VaultClusterNode

+ func (dc *DockerCluster) SetBarrierKeys(keys [][]byte)

+ func (dc *DockerCluster) SetRecoveryKeys(keys [][]byte)

+ func (dc *DockerCluster) SetRootToken(s string)

+ type DockerClusterNode struct

+ Cluster *DockerCluster

+ Container *types.ContainerJSON

+ ContainerIPAddress string

+ ContainerNetworkName string

+ DataVolumeName string

+ DockerAPI *docker.Client

+ HostPort string

+ ImageRepo string

+ ImageTag string

+ Logger log.Logger

+ NodeID string

+ RealAPIAddr string

+ ServerCert *x509.Certificate

+ ServerCertBytes []byte

+ ServerCertPEM []byte

+ ServerCertPEMFile string

+ ServerKey *ecdsa.PrivateKey

+ ServerKeyPEM []byte

+ ServerKeyPEMFile string

+ WorkDir string

+ func (n *DockerClusterNode) APIClient() *api.Client

+ func (n *DockerClusterNode) AddNetworkDelay(ctx context.Context, delay time.Duration, targetIP string) error

+ func (n *DockerClusterNode) Cleanup()

+ func (n *DockerClusterNode) Name() string

+ func (n *DockerClusterNode) Pause(ctx context.Context) error

+ func (n *DockerClusterNode) Start(ctx context.Context, opts *DockerClusterOptions) error

+ func (n *DockerClusterNode) Stop()

+ func (n *DockerClusterNode) TLSConfig() *tls.Config

+ type DockerClusterOptions struct

+ Args []string

+ CA *testcluster.CA

+ CAKey *ecdsa.PrivateKey

+ ImageRepo string

+ ImageTag string

+ NetworkName string

+ StartProbe func(*api.Client) error

+ VaultBinary string

+ func DefaultOptions(t *testing.T) *DockerClusterOptions

+ type LogConsumerWriter struct

+ func (l LogConsumerWriter) Write(p []byte) (n int, err error)

+ type ReloadFunc func() error

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