lib

package

Go to main page

Versions in this module

v0

v0.0.11

May 21, 2024

v0.0.10

May 21, 2024

v0.0.9

May 21, 2024

v0.0.8

May 21, 2024

v0.0.7

Feb 26, 2024

v0.0.6

Feb 19, 2024

v0.0.5

Feb 13, 2024

Changes in this version

type Driver

+ GetPipelineStatus func(pipelineId string) (PipelineStatus, error)

+ type PipelineStatus struct

+ Message string

+ Running bool

+ Transitioning bool

v0.0.4

Feb 5, 2024

Changes in this version

+ func GenerateFogOperatorStartCommand(operator Operator, pipelineID string, inputTopics []operatorLib.InputTopic) operatorLib.StartOperatorControlCommand

+ type DownstreamConfig struct

+ Enabled bool

+ InstanceID string

+ type Kafka2MqttApiService interface

+ RemoveInstance func(id, pipelineID, userID, token string) error

+ StartOperatorInstance func(operatorName, operatorID string, pipelineID, userI, token string) (kafka2mqtt_api.Instance, error)

type Operator

+ DownstreamConfig DownstreamConfig

+ UpstreamConfig UpstreamConfig

+ type UpstreamConfig struct

+ Enabled bool

v0.0.3

Jan 4, 2024

Changes in this version

+ var ErrSomethingWentWrong = errors.New("container API - something went wrong")

+ var ErrWorkloadNotFound = errors.New("container API - could not delete operator: workload not found")

v0.0.2

Jan 3, 2024

v0.0.1

Dec 18, 2023

Changes in this version

+ const PipelineRunning

+ const RequestDeviceId

+ const RequestOperatorId

+ var ErrNotFound = errors.New("not found")

+ func CloseMQTTConnection()

+ func ConnectMQTTBroker()

+ func GetEnv(key, fallback string) string

+ func IntInSlice(a int, list []int) bool

+ func StringInSlice(a string, list []string) bool

+ func ToJson(resp string) map[string]interface

+ type Claims struct

+ RealmAccess map[string][]string

+ Sub string

+ func (c Claims) Valid() error

+ type Driver interface

+ CreateOperators func(pipelineId string, input []Operator, pipelineConfig PipelineConfig) error

+ DeleteOperator func(pipelineId string, input Operator) error

+ type FlowEngine struct

+ func NewFlowEngine(driver Driver, parsingService ParsingApiService, ...) *FlowEngine

+ func (f *FlowEngine) DeletePipeline(id string, userId string, token string) (err error)

+ func (f *FlowEngine) GetPipelineStatus(id string) string

+ func (f *FlowEngine) StartPipeline(pipelineRequest PipelineRequest, userId string, token string) (pipeline Pipeline, err error)

+ func (f *FlowEngine) UpdatePipeline(pipelineRequest PipelineRequest, userId string, token string) (pipeline Pipeline, err error)

+ type InputSelection struct

+ AspectId string

+ CharacteristicIds []string

+ FunctionId string

+ InputName string

+ SelectableId string

+ type InputTopic struct

+ FilterType string

+ FilterValue string

+ FilterValue2 string

+ Mappings []Mapping

+ Name string

+ type LoggerMiddleWare struct

+ func NewLogger(handler http.Handler, logLevel string) *LoggerMiddleWare

+ func (this *LoggerMiddleWare) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Mapping struct

+ Dest string

+ Source string

+ type Metrics struct

+ Database string

+ Interval string

+ Password string

+ Url string

+ Username string

+ XmlUrl string

+ type MetricsApiService interface

+ RegisterPipeline func(id string) (metrics_api.MetricsConfig, error)

+ UnregisterPipeline func(id string) error

+ type NodeConfig struct

+ Name string

+ Value string

+ type NodeInput struct

+ FilterIds string

+ FilterType string

+ TopicName string

+ Values []NodeValue

+ type NodeValue struct

+ Name string

+ Path string

+ type Operator struct

+ ApplicationId uuid.UUID

+ Config map[string]string

+ Cost uint

+ DeploymentType string

+ Id string

+ ImageId string

+ InputSelections []InputSelection

+ InputTopics []InputTopic

+ Name string

+ OperatorId string

+ OutputTopic string

+ PersistData bool

+ type OperatorRequestConfig struct

+ Config map[string]string

+ InputTopics []InputTopic

+ type ParsingApiService interface

+ GetPipeline func(id string, userId string, authorization string) (p parsing_api.Pipeline, err error)

+ type PermissionApiService interface

+ UserHasDevicesReadAccess func(ids []string, authorization string) (bool, error)

+ type Pipeline struct

+ ConsumeAllMessages bool

+ Description string

+ FlowId string

+ Id uuid.UUID

+ Image string

+ MergeStrategy string

+ Metrics bool

+ MetricsData Metrics

+ Name string

+ Operators []Operator

+ WindowTime int

+ type PipelineConfig struct

+ ConsumerOffset string

+ FlowId string

+ MergeStrategy string

+ Metrics bool

+ MetricsData Metrics

+ PipelineId string

+ UserId string

+ WindowTime int

+ type PipelineNode struct

+ Config []NodeConfig

+ InputSelections []InputSelection

+ Inputs []NodeInput

+ NodeId string

+ PersistData bool

+ type PipelineRequest struct

+ ConsumeAllMessages bool

+ Description string

+ FlowId string

+ Id string

+ MergeStrategy string

+ Metrics bool

+ Name string

+ Nodes []PipelineNode

+ WindowTime int

+ type PipelineResponse struct

+ Id uuid.UUID

+ type Response struct

+ Message string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL