Versions in this module Expand all Collapse all v0 v0.0.2 Apr 12, 2020 Changes in this version + const EnvOperatorName v0.0.1 Mar 26, 2020 Changes in this version + const EnvConcurrentReconcile + const EnvConfigMapName + const EnvControllerName + const EnvOwnPodIp + const EnvPodIdLabels + const EnvRecordStatistics + const EnvRestApiPort + const POD_SEPARATOR + const PodEnvDataSource + const PodEnvOneToOneSourceLabels + const PodEnvOneToOneSourceName + const PodEnvOneToOneSourceUrl + const PodEnvStepName + const PodEnvStepType + const RestApiDataSourcesPath + const RestApiMatchingSourcesPath + const SOURCE_SEPARATOR + const STATE_VALIDATION_FAKE_STEP_NAME + const STEP_OUTPUT_PREFIX + const STEP_POD_SUFFIX + func Add(mgr manager.Manager, watchNamespace string) error + func CompareOneToOneSpec(source *bitflowv1.BitflowSource, pod *corev1.Pod, step *bitflowv1.BitflowStep) bool + func CompareSingletonSpec(pod *corev1.Pod, step *bitflowv1.BitflowStep) bool + func CompareSources(required *bitflowv1.BitflowSource, existing *bitflowv1.BitflowSource) bool + func ConstructReproduciblePodName(stepName, sourceName string) string + func ConstructSingletonPodName(stepName string) string + func ConstructSourceName(podName, sourceName string) string + func CreateOutputSource(step *bitflowv1.BitflowStep, pod *corev1.Pod, out *bitflowv1.StepOutput, ...) *bitflowv1.BitflowSource + func MergeLabels(sources []*bitflowv1.BitflowSource, newStepName string) map[string]string + func NewRequeueError(err error) error + func PatchOneToOnePod(pod *corev1.Pod, step *bitflowv1.BitflowStep, source *bitflowv1.BitflowSource, ...) + func PatchSingletonPod(pod *corev1.Pod, step *bitflowv1.BitflowStep, ...) + func ReplyError(c *gin.Context, statusCode int, err error) + func ReplyJSON(c *gin.Context, obj interface{}, err error) + type BitflowReconciler struct + func (r *BitflowReconciler) GetAllToOnePod(step *bitflowv1.BitflowStep, matchedSources []*bitflowv1.BitflowSource) ([]*corev1.Pod, error) + func (r *BitflowReconciler) GetOneToOnePods(step *bitflowv1.BitflowStep, matchedSources []*bitflowv1.BitflowSource) ([]*corev1.Pod, error) + func (r *BitflowReconciler) GetSingletonPod(step *bitflowv1.BitflowStep, matchedSources []*bitflowv1.BitflowSource) ([]*corev1.Pod, error) + func (r *BitflowReconciler) IsControlledObject(obj metav1.Object) bool + func (r *BitflowReconciler) IsWatchedObject(obj metav1.Object) bool + func (r *BitflowReconciler) Reconcile(req reconcile.Request) (reconcile.Result, error) + func (r *BitflowReconciler) SetupRestInterface(engine *gin.Engine) + type ControllerParameters struct + type PodCreation struct + func (c *PodCreation) Log(node *corev1.Node) *log.Entry + type PodOutputPair struct + type ReconcileStatisticData struct + Errors int + NodeResourceReconcileLoopDuration onlinestats.Running + NodeResourceReconcileLoops int + PodReconcileLoopDuration onlinestats.Running + PodReconcileLoops int + RestartedPods int + type ReconcileStatistics struct + func (stat *ReconcileStatistics) ErrorOccurred() + func (stat *ReconcileStatistics) GetData() ReconcileStatisticData + func (stat *ReconcileStatistics) NodeResourcesReconciled(duration time.Duration) + func (stat *ReconcileStatistics) PodRespawned() + func (stat *ReconcileStatistics) PodsReconciled(duration time.Duration) + type RequeueError struct + func (err *RequeueError) Error() string
Go to main page