pipeline_api

Documentation

Index

• type InputSelection
• type InputTopic
• type Mapping
• type Metrics
• type Operator
• type Pipeline
• type PipelineApi
  • func NewPipelineApi(url string) *PipelineApi
  • func (p *PipelineApi) UserHasPipelineAccess(id string, authorization string) (hasAccess bool, err error)

Types

type InputSelection

type InputSelection struct {
	InputName         string   `json:"inputName,omitempty"`
	AspectId          string   `json:"aspectId,omitempty"`
	FunctionId        string   `json:"functionId,omitempty"`
	CharacteristicIds []string `json:"characteristicIds,omitempty"`
	SelectableId      string   `json:"selectableId,omitempty"`
}

type InputTopic

type InputTopic struct {
	Name         string    `json:"name,omitempty"`
	FilterType   string    `json:"filterType,omitempty"`
	FilterValue  string    `json:"filterValue,omitempty"`
	FilterValue2 string    `json:"filterValue2,omitempty"`
	Mappings     []Mapping `json:"mappings,omitempty"`
}

type Mapping

type Mapping struct {
	Dest   string `json:"dest,omitempty"`
	Source string `json:"source,omitempty"`
}

type Metrics

type Metrics struct {
	Database string `json:"database,omitempty"`
	Username string `json:"username,omitempty"`
	Password string `json:"password,omitempty"`
	Url      string `json:"url,omitempty"`
	Interval string `json:"interval,omitempty"`
	XmlUrl   string `json:"xmlurl,omitempty"`
}

type Operator

type Operator struct {
	Id              string            `json:"id,omitempty"`
	Name            string            `json:"name,omitempty"`
	ApplicationId   uuid.UUID         `json:"applicationId,omitempty"`
	ImageId         string            `json:"imageId,omitempty"`
	DeploymentType  string            `json:"deploymentType,omitempty"`
	OperatorId      string            `json:"operatorId,omitempty"`
	Config          map[string]string `json:"config,omitempty"`
	OutputTopic     string            `json:"outputTopic,omitempty"`
	InputTopics     []InputTopic
	InputSelections []InputSelection `json:"inputSelections,omitempty"`
}

type Pipeline

type Pipeline struct {
	Id                 uuid.UUID  `json:"id,omitempty"`
	FlowId             string     `json:"flowId,omitempty"`
	Name               string     `json:"name,omitempty"`
	Description        string     `json:"description,omitempty"`
	Image              string     `json:"image,omitempty"`
	WindowTime         int        `json:"windowTime,omitempty"`
	ConsumeAllMessages bool       `json:"consumeAllMessages,omitempty"`
	Metrics            bool       `json:"metrics,omitempty"`
	MetricsData        Metrics    `json:"metricsData,omitempty"`
	Operators          []Operator `json:"operators,omitempty"`
}

type PipelineApi

type PipelineApi struct {
	// contains filtered or unexported fields
}

func NewPipelineApi

func NewPipelineApi(url string) *PipelineApi

func (*PipelineApi) UserHasPipelineAccess

func (p *PipelineApi) UserHasPipelineAccess(id string, authorization string) (hasAccess bool, err error)