Documentation
¶
Index ¶
Constants ¶
const ( NATSMessagingType string = "nats" NATSDefaultURL string = "nats://siddhi-nats:4222" ParserParameter string = "-Dsiddhi-parser " ParserName string = "parser" ParserHTTP string = "http://" ParserExtension string = "-parser" ParserHealth string = ".svc.cluster.local:9090/health" ParserContext string = ".svc.cluster.local:9090/siddhi-parser/parse" ParserPort int32 = 9090 ParserReplicas int32 = 1 ParserMinWait int = 3 ParserMaxWait int = 10 ParserMaxRetry int = 6 )
Constants for the parser
Variables ¶
This section is empty.
Functions ¶
func ContainsInt ¶
ContainsInt function to check given int is in the given slice or not
Types ¶
type AppConfig ¶
type AppConfig struct {
SiddhiApp string `json:"siddhiApp"`
DeploymentConfigs []DeploymentConfig `json:"sourceDeploymentConfigs"`
PersistenceEnabled bool `json:"persistenceEnabled"`
Replicas int32 `json:"replicas"`
}
AppConfig holds response of the parser
type DeploymentConfig ¶
type DeploymentConfig struct {
ServiceProtocol string `json:"serviceProtocol"`
Secured bool `json:"secured"`
Port int `json:"port"`
IsPulling bool `json:"isPulling"`
}
DeploymentConfig hold deployment configs of a particular siddhi app
type Parser ¶
type Parser struct {
Name string
Namespace string
Apps []string
Env map[string]string
MessagingSystem siddhiv1alpha2.MessagingSystem
Request Request
Logger logr.Logger
KubeClient artifact.KubeClient
Image deploymanager.Image
SiddhiProcess *siddhiv1alpha2.SiddhiProcess
}
Parser parse the application using parser deployment
func (*Parser) Parse ¶
func (p *Parser) Parse() (applications []deploymanager.Application, err error)
Parse call MSF4J service and parse a given siddhiApp. Here parser call an endpoint according to the deployment type - default, failover, and distributed After that REST call, the siddhi parser returns relevant details of the deployment. This function get those details and encapsulate all the details into a common structure(SiddhiApp) regarless of the deployment type. Siddhi operator used this general SiddhiApp object to the further process.
type Request ¶
type Request struct {
Apps []string `json:"siddhiApps"`
PropertyMap map[string]string `json:"propertyMap"`
MessagingSystem *siddhiv1alpha2.MessagingSystem `json:"messagingSystem,omitempty"`
}
Request is request struct of the siddhi-parser
Source Files