siddhiprocess

Documentation

Index

• Constants
• func Add(mgr manager.Manager) error
• type IntOrString
• type ReconcileSiddhiProcess
  • func (reconcileSiddhiProcess *ReconcileSiddhiProcess) Reconcile(request reconcile.Request) (reconcile.Result, error)
• type SiddhiApp
• type SiddhiAppConfig
• type SiddhiParserRequest
• type SiddhiParserResponse
• type SourceDeploymentConfig
• type SourceList
• type Status
• type TemplatedApp
• type Type

Constants

const (
	Int intstr.Type = iota
	String
)

Int - Type

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 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

func (reconcileSiddhiProcess *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 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"`
}

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"`
}

SourceDeploymentConfig hold deployment configs

type SourceList

type SourceList struct {
	SourceDeploymentConfigs []SourceDeploymentConfig `json:"sourceDeploymentConfigs"`
}

SourceList hold source list object

type Status

type Status int

Status of a Siddhi process

const (
	PENDING Status = iota
	READY
	RUNNING
	ERROR
)

Tye of status

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

type Type

type Type int

Type represents the stored type of IntOrString.