Documentation
¶
Index ¶
- Constants
- func Add(mgr manager.Manager) error
- func GetAppName(app string) (appName string)
- type Configs
- type IntOrString
- type ReconcileSiddhiProcess
- type SiddhiApp
- type SiddhiAppConfig
- type SiddhiParserRequest
- type SiddhiParserResponse
- type SourceDeploymentConfig
- type SourceList
- type Status
- type TemplatedApp
- type Type
Constants ¶
const ( SiddhiHome string = "/home/siddhi_user/siddhi-runner-0.1.0/" SiddhiRunnerImage string = "siddhiio/siddhi-runner-alpine" SiddhiRunnerImageTag string = "0.1.0" HostName string = "siddhi" OperatorName string = "siddhi-operator" OperatorVersion string = "0.1.1" CRDName string = "SiddhiProcess" )
Default configs
const ( Push string = "PUSH" Pull string = "PULL" )
Other constants
const ( Int intstr.Type = iota String )
Int - Type
Variables ¶
This section is empty.
Functions ¶
func Add ¶
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.
func GetAppName ¶ added in v0.1.1
GetAppName return the app name for given siddhiAPP
Types ¶
type Configs ¶ added in v0.1.1
type Configs struct {
SiddhiHome string
SiddhiRunnerImage string
SiddhiRunnerImageTag string
HostName string
OperatorName string
OperatorVersion string
CRDName string
}
Configs contains siddhi default configs
type IntOrString ¶
type IntOrString struct {
Type Type `protobuf:"varint,1,opt,name=type,casttype=Type"`
IntVal int32 `protobuf:"varint,2,opt,name=intVal"`
StrVal string `protobuf:"bytes,3,opt,name=strVal"`
}
IntOrString integer or string
type ReconcileSiddhiProcess ¶
type ReconcileSiddhiProcess struct {
// contains filtered or unexported fields
}
ReconcileSiddhiProcess reconciles a SiddhiProcess object
func (*ReconcileSiddhiProcess) Reconcile ¶
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 Note: The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.
type SiddhiApp ¶
type SiddhiApp struct {
Name string `json:"appName"`
Ports []int `json:"ports"`
Protocols []string `json:"protocols"`
TLS []bool `json:"tls"`
App string `json:"app"`
CreateSVC bool `json:"createSVC"`
}
SiddhiApp contains details about the siddhi app which need by K8s
type SiddhiAppConfig ¶
type SiddhiAppConfig struct {
SiddhiApp string `json:"siddhiApp"`
SiddhiSourceList SourceList `json:"sourceList"`
}
SiddhiAppConfig holds siddhi app config details
type SiddhiParserRequest ¶
type SiddhiParserRequest struct {
SiddhiApps []string `json:"siddhiApps"`
PropertyMap map[string]string `json:"propertyMap"`
}
SiddhiParserRequest is request struct of siddhi-parser
type SiddhiParserResponse ¶
type SiddhiParserResponse struct {
AppConfig []SiddhiAppConfig `json:"siddhiAppConfigs"`
}
SiddhiParserResponse siddhi-parser response
type SourceDeploymentConfig ¶
type SourceDeploymentConfig struct {
ServiceProtocol string `json:"serviceProtocol"`
Secured bool `json:"secured"`
Port int `json:"port"`
Strategy string `json:"strategy"`
}
SourceDeploymentConfig hold deployment configs
type SourceList ¶
type SourceList struct {
SourceDeploymentConfigs []SourceDeploymentConfig `json:"sourceDeploymentConfigs"`
}
SourceList hold source list object
type TemplatedApp ¶
type TemplatedApp struct {
App string `json:"siddhiApp"`
PropertyMap map[string]string `json:"propertyMap"`
}
TemplatedApp contains the templated siddhi app and relevant properties to pass into the parser service
Source Files