state

Documentation

Index

• type ClusterMeshCluster
• type ClusterMeshState
  • func NewClusterMeshState(logger *zap.Logger) *ClusterMeshState
  • func (p *ClusterMeshState) AddOrUpdate(cluster *ClusterMeshCluster) error
  • func (p *ClusterMeshState) Delete(clusterName string)
  • func (p *ClusterMeshState) GetAll() map[string]*ClusterMeshCluster
  • func (p *ClusterMeshState) UpdateChannel() chan struct{}

Types

type ClusterMeshCluster

type ClusterMeshCluster struct {
	ClusterName                 string `json:",omitempty"`
	ClusterMeshAPIServerIP      string `json:",omitempty"`
	ClusterMeshAPIServerAddress string `json:",omitempty"`
	ClusterMeshAPIServerTLSCA   string `json:",omitempty"`
	ClusterMeshAPIServerTLSCert string `json:",omitempty"`
	ClusterMeshAPIServerTLSKey  string `json:",omitempty"`
	Tombstone                   int64  `json:",omitempty"`
}

type ClusterMeshState

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

func NewClusterMeshState

func NewClusterMeshState(logger *zap.Logger) *ClusterMeshState

func (*ClusterMeshState) AddOrUpdate

func (p *ClusterMeshState) AddOrUpdate(cluster *ClusterMeshCluster) error

func (*ClusterMeshState) Delete

func (p *ClusterMeshState) Delete(clusterName string)

func (*ClusterMeshState) GetAll

func (p *ClusterMeshState) GetAll() map[string]*ClusterMeshCluster

func (*ClusterMeshState) UpdateChannel

func (p *ClusterMeshState) UpdateChannel() chan struct{}