Examples of trackConfiguration()

Examples of io.fabric8.api.DataStore.trackConfiguration()

150
151
152
153
154
155
156
157
158
159
160
                    ControllerNode state = createState();
                    group.update(state);
                }
                if (dataStore != null) {
                    if (group.isMaster()) {
                        dataStore.trackConfiguration(runnable);
                        onConfigurationChanged();
                    } else {
                        dataStore.untrackConfiguration(runnable);
                    }
                }
View Full Code Here

Examples of io.fabric8.api.DataStore.trackConfiguration()

112
113
114
115
116
117
118
119
120
121
122
            }
        };
        keepAliveTimer.schedule(timerTask, monitorPollTime, monitorPollTime);

        DataStore dataStore = fabricService.get().adapt(DataStore.class);
        dataStore.trackConfiguration(configurationChangeHandler);
    }

    @Deactivate
    void deactivate() {
        if (zkMasterCache != null) {
View Full Code Here

Examples of io.fabric8.api.DataStore.trackConfiguration()

123
124
125
126
127
128
129
130
131
132
133
                    try {
                        if (group.isMaster()) {
                            enableMasterZkCache(curator.get());
                            LOGGER.info("AutoScaleController is the master");
                            group.update(state);
                            dataStore.trackConfiguration(runnable);
                            enableTimer();
                            onConfigurationChanged();
                        } else {
                            LOGGER.info("AutoScaleController is not the master");
                            group.update(state);
View Full Code Here

Examples of io.fabric8.api.DataStore.trackConfiguration()

145
146
147
148
149
150
151
152
153
154
155
                    try {
                        if (group.isMaster()) {
                            enableMasterZkCache(getCuratorFramework());
                            LOGGER.info("KubernetesHeathChecker is the master");
                            group.update(state);
                            dataStore.trackConfiguration(runnable);
                            enableTimer();
                            onConfigurationChanged();
                        } else {
                            LOGGER.info("KubernetesHeathChecker is not the master");
                            group.update(state);
View Full Code Here

Examples of io.fabric8.api.DataStore.trackConfiguration()

118
119
120
121
122
123
124
125
126
127
128
                    try {
                        if (group.isMaster()) {
                            enableMasterZkCache(curator.get());
                            LOGGER.info("ProfileReplicationController is the master");
                            group.update(state);
                            dataStore.trackConfiguration(runnable);
                            enableTimer();
                            onConfigurationChanged();
                        } else {
                            LOGGER.info("ProfileReplicationController is not the master");
                            group.update(state);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.