mcagent

Documentation

Index

• func StartAgent(client client.Client, statusUpdateChannel chan clusters.StatusUpdateMessage, ...)
• type Syncer
  • func (s *Syncer) AgentReadyToSync() bool
  • func (s *Syncer) GetAPIServerURL() (string, error)
  • func (s *Syncer) GetPrometheusHost() (string, error)
  • func (s *Syncer) ProcessAgentThread() error
  • func (s *Syncer) SyncMultiClusterResources()

Functions

func StartAgent

func StartAgent(client client.Client, statusUpdateChannel chan clusters.StatusUpdateMessage, log logr.Logger)

StartAgent - start the agent thread for syncing multi-cluster objects

Types

type Syncer

type Syncer struct {
	AdminClient           client.Client
	LocalClient           client.Client
	Log                   logr.Logger
	ManagedClusterName    string
	Context               context.Context
	AgentSecretFound      bool
	AgentSecretValid      bool
	SecretResourceVersion string

	// List of namespaces to watch for multi-cluster objects.
	ProjectNamespaces   []string
	StatusUpdateChannel chan clusters.StatusUpdateMessage
}

Syncer contains context for synchronize operations

func (*Syncer) AgentReadyToSync

func (s *Syncer) AgentReadyToSync() bool

AgentReadyToSync - the agent has all the information it needs to sync resources i.e. there is an agent secret and a kubernetes client to the Admin cluster was created

func (*Syncer) GetAPIServerURL

func (s *Syncer) GetAPIServerURL() (string, error)

GetAPIServerURL returns the API Server URL for Verrazzano instance.

func (*Syncer) GetPrometheusHost

func (s *Syncer) GetPrometheusHost() (string, error)

GetPrometheusHost returns the prometheus host for Verrazzano instance.

func (*Syncer) ProcessAgentThread

func (s *Syncer) ProcessAgentThread() error

ProcessAgentThread - process one iteration of the agent thread

func (*Syncer) SyncMultiClusterResources

func (s *Syncer) SyncMultiClusterResources()

SyncMultiClusterResources - sync multi-cluster objects