clustermesh

Mar 28, 2024

Changes in this version

type Parameters

+ HelmReleaseName string

Oct 4, 2023

Changes in this version

type Parameters

+ ServiceAnnotations map[string]string

Jun 23, 2023

Changes in this version

type K8sClusterMesh

+ func (k *K8sClusterMesh) DisconnectWithHelm(ctx context.Context) error

type Parameters

+ EnableKVStoreMesh bool

Jun 14, 2023

Changes in this version

type K8sClusterMesh

+ func (k *K8sClusterMesh) ConnectWithHelm(ctx context.Context) error

May 25, 2023

Changes in this version

type Parameters

+ EnableExternalWorkloads bool

May 3, 2023

Changes in this version

+ func DisableWithHelm(ctx context.Context, k8sClient *k8s.Client, params Parameters) error

+ func EnableWithHelm(ctx context.Context, k8sClient *k8s.Client, params Parameters) error

Feb 15, 2023

Changes in this version

type Parameters

+ Output string

Dec 1, 2022

Changes in this version

type Parameters

+ HelmValuesSecretName string

Jun 21, 2021

Changes in this version

+ type ClusterStats struct

+ Configured int

+ Connected int

+ type ConnectivityStatus struct

+ Clusters map[string]*ClusterStats

+ Connected StatisticalStatus

+ Errors status.ErrorCountMapMap

+ GlobalServices StatisticalStatus

+ NotReady int64

+ Total int64

+ type K8sClusterMesh struct

+ func NewK8sClusterMesh(client k8sClusterMeshImplementation, p Parameters) *K8sClusterMesh

+ func (k *K8sClusterMesh) Connect(ctx context.Context) error

+ func (k *K8sClusterMesh) CreateExternalWorkload(ctx context.Context, names []string) error

+ func (k *K8sClusterMesh) DeleteExternalWorkload(ctx context.Context, names []string) error

+ func (k *K8sClusterMesh) Disable(ctx context.Context) error

+ func (k *K8sClusterMesh) Disconnect(ctx context.Context) error

+ func (k *K8sClusterMesh) Enable(ctx context.Context) error

+ func (k *K8sClusterMesh) ExternalWorkloadStatus(ctx context.Context, names []string) error

+ func (k *K8sClusterMesh) GetClusterConfig(ctx context.Context) error

+ func (k *K8sClusterMesh) Log(format string, a ...interface{})

+ func (k *K8sClusterMesh) Status(ctx context.Context, log bool) (*Status, error)

+ func (k *K8sClusterMesh) WriteExternalWorkloadInstallScript(ctx context.Context, writer io.Writer) error

+ type Parameters struct

+ All bool

+ ApiserverImage string

+ ApiserverVersion string

+ ConfigOverwrites []string

+ CreateCA bool

+ DestinationContext string

+ DestinationEndpoints []string

+ IPv4AllocCIDR string

+ IPv6AllocCIDR string

+ Labels map[string]string

+ Namespace string

+ Retries int

+ ServiceType string

+ SkipServiceCheck bool

+ SourceEndpoints []string

+ Wait bool

+ WaitDuration time.Duration

+ Writer io.Writer

+ type StatisticalStatus struct

+ Avg float64

+ Max int64

+ Min int64

+ type Status struct

+ AccessInformation *accessInformation

+ Connectivity *ConnectivityStatus

+ Service *corev1.Service