// Init installs app by AppDescription
Init installs app by AppDescription
// Init installs app by AppDescription
func (m *AppManager) Init() error {
	if _, err := m.GetOrCreateNamespace(); err != nil {
		return err
	}
	if err := m.Dispose(); err != nil {
		return err
	}
	if _, err := m.Deploy(); err != nil {
		return err
	}
	if _, err := m.WaitUntilDeploymentState(m.IsDeploymentDone); err != nil {
		return err
	}
	if ok, err := m.ValidiateSideCar(); err != nil || ok != m.app.IngressEnabled {
		return err
	}
	if _, err := m.CreateIngressService(); err != nil {
		return err
	}
	m.stopChannel = make(chan struct{}, 1)
	m.readyChannel = make(chan struct{})
	return nil
}
func ( m * AppManager ) Init ( ) error { if _ , err := m . GetOrCreateNamespace ( ) ; err != nil { return err } if err := m . Dispose ( ) ; err != nil { return err } if _ , err := m . Deploy ( ) ; err != nil { return err } if _ , err := m . WaitUntilDeploymentState ( m . IsDeploymentDone ) ; err != nil { return err } if ok , err := m . ValidiateSideCar ( ) ; err != nil || ok != m . app . IngressEnabled { return err } if _ , err := m . CreateIngressService ( ) ; err != nil { return err } m . stopChannel = make ( chan struct { } , 1 ) m . readyChannel = make ( chan struct { } ) return nil }
Init installs app by AppDescription
Init installs app by AppDescription
// Get or create test namespaces // TODO: Dispose app if option is required // Deploy app and wait until deployment is done // Wait until app is deployed completely // Validate daprd side car is injected // Create Ingress endpoint // stopChannel control the port forwarding lifecycle. When it gets closed the port forward will terminate // readyChannel communicate when the port forward is ready to get traffic