clustermesh

Documentation

Index

• type ClusterStats
• type ConnectivityStatus
• type K8sClusterMesh
  • 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) (*Status, error)
  • func (k *K8sClusterMesh) WriteExternalWorkloadInstallScript(ctx context.Context, writer io.Writer) error
• type Parameters
• type StatisticalStatus
• type Status

Types

type ClusterStats

type ClusterStats struct {
	Configured int
	Connected  int
}

type ConnectivityStatus

type ConnectivityStatus struct {
	GlobalServices StatisticalStatus
	Connected      StatisticalStatus
	Clusters       map[string]*ClusterStats
	Total          int64
	NotReady       int64
	Errors         status.ErrorCountMapMap
}

type K8sClusterMesh

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

func NewK8sClusterMesh

func NewK8sClusterMesh(client k8sClusterMeshImplementation, p Parameters) *K8sClusterMesh

func (*K8sClusterMesh) Connect

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

func (*K8sClusterMesh) CreateExternalWorkload

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

func (*K8sClusterMesh) DeleteExternalWorkload

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

func (*K8sClusterMesh) Disable

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

func (*K8sClusterMesh) Disconnect

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

func (*K8sClusterMesh) Enable

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

func (*K8sClusterMesh) ExternalWorkloadStatus

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

func (*K8sClusterMesh) GetClusterConfig

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

func (*K8sClusterMesh) Log

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

func (*K8sClusterMesh) Status

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

func (*K8sClusterMesh) WriteExternalWorkloadInstallScript

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

type Parameters

type Parameters struct {
	Namespace            string
	ServiceType          string
	DestinationContext   string
	Wait                 bool
	WaitDuration         time.Duration
	DestinationEndpoints []string
	SourceEndpoints      []string
	SkipServiceCheck     bool
	ApiserverImage       string
	ApiserverVersion     string
	CreateCA             bool
	Writer               io.Writer
	Labels               map[string]string
	IPv4AllocCIDR        string
	IPv6AllocCIDR        string
	All                  bool
	ConfigOverwrites     []string
	Retries              int
	HelmValuesSecretName string
}

type StatisticalStatus

type StatisticalStatus struct {
	Min int64
	Avg float64
	Max int64
}

type Status

type Status struct {
	AccessInformation *accessInformation
	Service           *corev1.Service
	Connectivity      *ConnectivityStatus
}