siddhiprocess

package
v0.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 13, 2019 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ReconcileTime       int = 2
	ParserFailRetryTime int = 1
)

siddhiprocess package constants

Variables

View Source 
var CMContainer map[string]siddhicontroller.ConfigMapListner

CMContainer holds the config map name along with CM listner for listen changes of the CM

View Source 
var ER record.EventRecorder

ER recoder

View Source 
var SPContainer map[string][]deploymanager.Application

SPContainer holds siddhi apps

Functions

func Add 

func Add(mgr manager.Manager) error

Add creates a new SiddhiProcess Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started.

Types

type EventType added in v0.2.1 

type EventType int

EventType holds the type of a event 

const (
	CREATE EventType = iota
	UPDATE
	DELETE
	GENERIC
	TIMER
)

Type of events that publishes to the reconcile loop

type ReconcileSiddhiProcess 

type ReconcileSiddhiProcess struct {
	// contains filtered or unexported fields
}

ReconcileSiddhiProcess reconciles a SiddhiProcess object

func (*ReconcileSiddhiProcess) Reconcile 

func (rsp *ReconcileSiddhiProcess) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a SiddhiProcess object and makes changes based on the state read and what is in the SiddhiProcess.Spec

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.