lib

Nov 17, 2025

Changes in this version

+ type DownstreamConfig struct

+ Enabled bool

+ type InputTopic struct

+ FilterType string

+ FilterValue string

+ Mappings []Mapping

+ TopicName string

+ type Mapping struct

+ Dest string

+ Source string

+ type Operator struct

+ Cost uint

+ DeploymentType string

+ DownstreamConfig DownstreamConfig

+ Id string

+ ImageId string

+ InputTopics []InputTopic

+ Name string

+ OperatorId string

+ UpstreamConfig UpstreamConfig

+ type Pipeline struct

+ FlowId string

+ Image string

+ Operators map[string]Operator

+ type UpstreamConfig struct

+ Enabled bool

Sep 1, 2025

Changes in this version

+ func GetLogger() *slog.Logger

Dec 19, 2023

Changes in this version

+ func GetEnv(key, fallback string) string

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

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

+ type Claims struct

+ RealmAccess map[string][]string

+ Sub string

+ func (c Claims) Valid() error

+ type FlowApiService interface

+ GetFlowData func(id string, userId string, authorization string) (flows_api.Flow, error)

+ type LoggerMiddleWare struct

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

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

+ type Response struct

+ Message string