Method ChangeState

test/hook/context/state.go:58–103

ChangeState apply changes to current objects state

(newRawState string)

// ChangeState apply changes to current objects state
func (c *StateController) ChangeState(newRawState string) error {
	newManifests, err := manifest.ListFromYamlDocs(newRawState)
	if err != nil {
		return fmt.Errorf("error while changing state: %v", err)
	}

	newState := make(map[string]manifest.Manifest)

	// Create new objects in FakeCluster
	for _, m := range newManifests {
		// save manifest to new State
		newState[m.Id()] = m

		currM, ok := c.CurrentState[m.Id()]
		if !ok {
			// Create object if not exist
			if err := c.fakeCluster.Create(m.Namespace(defaultNamespace), m); err != nil {
				return err
			}
			c.CurrentState[m.Id()] = m
		} else if !reflect.DeepEqual(currM, m) {
			// Update object
			if err := c.fakeCluster.Update(m.Namespace(defaultNamespace), m); err != nil {
				return err
			}
			c.CurrentState[m.Id()] = m
		}
	}
	// Remove obsolete objects
	for currID, currM := range c.CurrentState {
		if _, ok := newState[currID]; !ok {
			// Delete object
			if err := c.fakeCluster.Delete(currM.Namespace(defaultNamespace), currM); err != nil {
				return err
			}
			delete(c.CurrentState, currID)
		}
	}

	go func() {
		time.Sleep(100 * time.Millisecond)
		c.stopCh <- types.KubeEvent{MonitorId: "STOP_EVENTS"}
	}()

	return nil
}