v1alpha1

package

Go to main page

Versions in this module

v1

v1.0.0

Jul 14, 2022

Changes in this version

+ const StorageAccountUndefined

+ type HelmValues struct

+ Labels map[string]string

+ UUID string

+ func (in *HelmValues) DeepCopy() *HelmValues

+ func (in *HelmValues) DeepCopyInto(out *HelmValues)

v0

v0.8.1

Apr 28, 2022

v0.8.0

Apr 28, 2022

v0.7.0

Jun 2, 2022

Changes in this version

+ const CSV

+ const JdbcDB2

type ApplicationDetails

+ Context taxonomy.AppInfo

+ WorkloadSelector metav1.LabelSelector

+ type AssetContext struct

+ Arguments []*DataStore

+ AssetID string

+ Capability taxonomy.Capability

+ Transformations []taxonomy.Action

+ func (in *AssetContext) DeepCopy() *AssetContext

+ func (in *AssetContext) DeepCopyInto(out *AssetContext)

type BlueprintSpec

+ Application *ApplicationDetails

type DataContext

+ Flow taxonomy.DataFlow

type DataRequirements

+ FlowParams FlowRequirements

type DatasetDetails

+ ResourceMetadata *datacatalog.ResourceMetadata

+ type FlowRequirements struct

+ Catalog string

+ IsNewDataSet bool

+ ResourceMetadata *datacatalog.ResourceMetadata

+ StorageEstimate datasize.ByteSize

+ func (in *FlowRequirements) DeepCopy() *FlowRequirements

+ func (in *FlowRequirements) DeepCopyInto(out *FlowRequirements)

type FybrikStorageAccountSpec

+ Region taxonomy.ProcessingLocation

type ModuleArguments

+ Assets []AssetContext

type ModuleInfo

+ Capability taxonomy.Capability

type PlotterSpec

+ AppInfo taxonomy.AppInfo

+ type SecretRef struct

+ Name string

+ Namespace string

+ func (in *SecretRef) DeepCopy() *SecretRef

+ func (in *SecretRef) DeepCopyInto(out *SecretRef)

+ type StepArgument struct

+ API *datacatalog.ResourceDetails

+ AssetID string

+ func (in *StepArgument) DeepCopy() *StepArgument

+ func (in *StepArgument) DeepCopyInto(out *StepArgument)

type StepParameters

+ Arguments []*StepArgument

v0.6.8

Jun 21, 2022

v0.6.7

Jun 15, 2022

v0.6.6

Apr 27, 2022

v0.6.5

Apr 8, 2022

v0.6.4

Mar 13, 2022

v0.6.3

Mar 1, 2022

v0.6.2

Feb 8, 2022

v0.6.1

Feb 6, 2022

v0.6.1-rc1

Jan 19, 2022

v0.6.0

Jan 11, 2022

Changes in this version

type BlueprintSpec

+ ModulesNamespace string

type Condition

+ ObservedGeneration int64

type ConditionType

+ const ValidCondition

type FybrikModule

+ Status FybrikModuleStatus

+ func (r *FybrikModule) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *FybrikModule) ValidateCreate() error

+ func (r *FybrikModule) ValidateDelete() error

+ func (r *FybrikModule) ValidateFybrikModule(taxonomyFile string) error

+ func (r *FybrikModule) ValidateUpdate(old runtime.Object) error

+ type FybrikModuleStatus struct

+ Conditions []Condition

+ func (in *FybrikModuleStatus) DeepCopy() *FybrikModuleStatus

+ func (in *FybrikModuleStatus) DeepCopyInto(out *FybrikModuleStatus)

type FybrikStorageAccountSpec

+ Endpoints map[string]string

+ ID string

+ type ModuleSupportedAction struct

+ Name taxonomy.ActionName

+ func (in *ModuleSupportedAction) DeepCopy() *ModuleSupportedAction

+ func (in *ModuleSupportedAction) DeepCopyInto(out *ModuleSupportedAction)

type PlotterSpec

+ ModulesNamespace string

v0.5.3

Jan 11, 2022

v0.5.2

Jan 10, 2022

v0.5.1

Dec 13, 2021

v0.5.0

Oct 27, 2021

Changes in this version

+ const InvalidAssetDataStore

+ type AssetDetails struct

+ AdvertisedAssetID string

+ DataStore DataStore

+ func (in *AssetDetails) DeepCopy() *AssetDetails

+ func (in *AssetDetails) DeepCopyInto(out *AssetDetails)

+ type AssetState struct

+ CatalogedAsset string

+ Conditions []Condition

+ Endpoint EndpointSpec

+ func (in *AssetState) DeepCopy() *AssetState

+ func (in *AssetState) DeepCopyInto(out *AssetState)

+ type BlueprintModule struct

+ Arguments ModuleArguments

+ AssetIDs []string

+ Chart ChartSpec

+ Name string

+ func (in *BlueprintModule) DeepCopy() *BlueprintModule

+ func (in *BlueprintModule) DeepCopyInto(out *BlueprintModule)

type BlueprintSpec

+ Cluster string

+ Modules map[string]BlueprintModule

type BlueprintStatus

+ ModulesState map[string]ObservedState

+ type CapabilityScope string

+ const Asset

+ const Cluster

+ const Workload

+ type CapabilityType string

+ const Transform

type ChartSpec

+ ChartPullSecret string

type CopyModuleArgs

+ AssetID string

type DataFlow

+ const CopyFlow

+ const DeleteFlow

+ const ReadFlow

+ const WriteFlow

+ type DataFlowStep struct

+ Cluster string

+ Name string

+ Parameters *StepParameters

+ Template string

+ func (in *DataFlowStep) DeepCopy() *DataFlowStep

+ func (in *DataFlowStep) DeepCopyInto(out *DataFlowStep)

+ type Flow struct

+ AssetID string

+ FlowType DataFlow

+ Name string

+ SubFlows []SubFlow

+ func (in *Flow) DeepCopy() *Flow

+ func (in *Flow) DeepCopyInto(out *Flow)

+ type FlowStatus struct

+ ObservedState ObservedState

+ SubFlows map[string]ObservedState

+ func (in *FlowStatus) DeepCopy() *FlowStatus

+ func (in *FlowStatus) DeepCopyInto(out *FlowStatus)

type FybrikApplication

+ func (r *FybrikApplication) ValidateFybrikApplication(taxonomyFile string) error

type FybrikApplicationStatus

+ AssetStates map[string]AssetState

+ ErrorMessage string

+ ValidApplication corev1.ConditionStatus

+ ValidatedGeneration int64

type FybrikModuleSpec

+ Description string

+ PluginType string

+ Type string

type ModuleArguments

+ AppSelector metav1.LabelSelector

+ Labels map[string]string

+ type ModuleCapability struct

+ API *ModuleAPI

+ Actions []SupportedAction

+ Capability CapabilityType

+ Plugins []Plugin

+ Scope CapabilityScope

+ SupportedInterfaces []ModuleInOut

+ func (in *ModuleCapability) DeepCopy() *ModuleCapability

+ func (in *ModuleCapability) DeepCopyInto(out *ModuleCapability)

+ type ModuleInfo struct

+ Chart ChartSpec

+ Name string

+ Scope CapabilityScope

+ Type string

+ func (in *ModuleInfo) DeepCopy() *ModuleInfo

+ func (in *ModuleInfo) DeepCopyInto(out *ModuleInfo)

type PlotterSpec

+ Assets map[string]AssetDetails

+ Flows []Flow

+ Templates map[string]Template

type PlotterStatus

+ Assets map[string]ObservedState

+ Conditions []Condition

+ Flows map[string]FlowStatus

+ type Plugin struct

+ DataFormat string

+ PluginType string

+ func (in *Plugin) DeepCopy() *Plugin

+ func (in *Plugin) DeepCopyInto(out *Plugin)

+ type Service struct

+ Endpoint EndpointSpec

+ Format string

+ func (in *Service) DeepCopy() *Service

+ func (in *Service) DeepCopyInto(out *Service)

+ type StepParameters struct

+ API *Service

+ Actions []SupportedAction

+ Sink *StepSink

+ Source *StepSource

+ func (in *StepParameters) DeepCopy() *StepParameters

+ func (in *StepParameters) DeepCopyInto(out *StepParameters)

+ type StepSink struct

+ AssetID string

+ func (in *StepSink) DeepCopy() *StepSink

+ func (in *StepSink) DeepCopyInto(out *StepSink)

+ type StepSource struct

+ API *Service

+ AssetID string

+ func (in *StepSource) DeepCopy() *StepSource

+ func (in *StepSource) DeepCopyInto(out *StepSource)

+ type SubFlow struct

+ FlowType DataFlow

+ Name string

+ Steps [][]DataFlowStep

+ Triggers []SubFlowTrigger

+ func (in *SubFlow) DeepCopy() *SubFlow

+ func (in *SubFlow) DeepCopyInto(out *SubFlow)

+ type SubFlowTrigger string

+ const InitTrigger

+ const TimerTrigger

+ const WorkloadTrigger

type SupportedAction

+ func (action *SupportedAction) MarshalJSON() ([]byte, error)

+ func (action *SupportedAction) UnmarshalJSON(data []byte) error

+ type Template struct

+ Modules []ModuleInfo

+ Name string

+ func (in *Template) DeepCopy() *Template

+ func (in *Template) DeepCopyInto(out *Template)

type WriteModuleArgs

+ AssetID string

v0.4.1

Aug 2, 2021

v0.4.0

Aug 2, 2021

Changes in this version

+ const ApplicationClusterLabel

+ const ApplicationNameLabel

+ const ApplicationNamespaceLabel

+ const Arrow

+ const ArrowFlight

+ const BlueprintNameLabel

+ const BlueprintNamespaceLabel

+ const CopyNotAllowed

+ const DenyConditionIndex

+ const ErrorConditionIndex

+ const InsufficientStorage

+ const InvalidAssetID

+ const InvalidClusterConfiguration

+ const JdbcDb2

+ const Kafka

+ const ModuleNotFound

+ const Parquet

+ const ReadAccessDenied

+ const ReadyConditionIndex

+ const S3

+ const Table

+ const WriteNotAllowed

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ type ApplicationDetails map[string]string

+ func (in ApplicationDetails) DeepCopy() ApplicationDetails

+ func (in ApplicationDetails) DeepCopyInto(out *ApplicationDetails)

+ type Blueprint struct

+ Spec BlueprintSpec

+ Status BlueprintStatus

+ func (in *Blueprint) DeepCopy() *Blueprint

+ func (in *Blueprint) DeepCopyInto(out *Blueprint)

+ func (in *Blueprint) DeepCopyObject() runtime.Object

+ type BlueprintList struct

+ Items []Blueprint

+ func (in *BlueprintList) DeepCopy() *BlueprintList

+ func (in *BlueprintList) DeepCopyInto(out *BlueprintList)

+ func (in *BlueprintList) DeepCopyObject() runtime.Object

+ type BlueprintSpec struct

+ Entrypoint string

+ Flow DataFlow

+ Templates []ComponentTemplate

+ func (in *BlueprintSpec) DeepCopy() *BlueprintSpec

+ func (in *BlueprintSpec) DeepCopyInto(out *BlueprintSpec)

+ type BlueprintStatus struct

+ ObservedGeneration int64

+ ObservedState ObservedState

+ Releases map[string]int64

+ func (in *BlueprintStatus) DeepCopy() *BlueprintStatus

+ func (in *BlueprintStatus) DeepCopyInto(out *BlueprintStatus)

+ type Capability struct

+ API *ModuleAPI

+ Actions []SupportedAction

+ SupportedInterfaces []ModuleInOut

+ func (in *Capability) DeepCopy() *Capability

+ func (in *Capability) DeepCopyInto(out *Capability)

+ type CatalogRequirements struct

+ CatalogID string

+ CatalogService string

+ func (in *CatalogRequirements) DeepCopy() *CatalogRequirements

+ func (in *CatalogRequirements) DeepCopyInto(out *CatalogRequirements)

+ type ChartSpec struct

+ Name string

+ Values map[string]string

+ func (in *ChartSpec) DeepCopy() *ChartSpec

+ func (in *ChartSpec) DeepCopyInto(out *ChartSpec)

+ type ComponentTemplate struct

+ Chart ChartSpec

+ Kind string

+ Name string

+ func (in *ComponentTemplate) DeepCopy() *ComponentTemplate

+ func (in *ComponentTemplate) DeepCopyInto(out *ComponentTemplate)

+ type Condition struct

+ Message string

+ Status corev1.ConditionStatus

+ Type ConditionType

+ func (in *Condition) DeepCopy() *Condition

+ func (in *Condition) DeepCopyInto(out *Condition)

+ type ConditionType string

+ const DenyCondition

+ const ErrorCondition

+ const ReadyCondition

+ type CopyModuleArgs struct

+ Destination DataStore

+ Source DataStore

+ Transformations []serde.Arbitrary

+ func (in *CopyModuleArgs) DeepCopy() *CopyModuleArgs

+ func (in *CopyModuleArgs) DeepCopyInto(out *CopyModuleArgs)

+ type CopyRequirements struct

+ Catalog CatalogRequirements

+ Required bool

+ func (in *CopyRequirements) DeepCopy() *CopyRequirements

+ func (in *CopyRequirements) DeepCopyInto(out *CopyRequirements)

+ type DataContext struct

+ CatalogService string

+ DataSetID string

+ Requirements DataRequirements

+ func (in *DataContext) DeepCopy() *DataContext

+ func (in *DataContext) DeepCopyInto(out *DataContext)

+ type DataFlow struct

+ Name string

+ Steps []FlowStep

+ func (in *DataFlow) DeepCopy() *DataFlow

+ func (in *DataFlow) DeepCopyInto(out *DataFlow)

+ type DataRequirements struct

+ Copy CopyRequirements

+ Interface InterfaceDetails

+ func (in *DataRequirements) DeepCopy() *DataRequirements

+ func (in *DataRequirements) DeepCopyInto(out *DataRequirements)

+ type DataStore struct

+ Connection serde.Arbitrary

+ Format string

+ Vault Vault

+ func (in *DataStore) DeepCopy() *DataStore

+ func (in *DataStore) DeepCopyInto(out *DataStore)

+ type DatasetDetails struct

+ DatasetRef string

+ Details serde.Arbitrary

+ SecretRef string

+ func (in *DatasetDetails) DeepCopy() *DatasetDetails

+ func (in *DatasetDetails) DeepCopyInto(out *DatasetDetails)

+ type Dependency struct

+ Name string

+ Type DependencyType

+ func (in *Dependency) DeepCopy() *Dependency

+ func (in *Dependency) DeepCopyInto(out *Dependency)

+ type DependencyType string

+ const Connector

+ const Feature

+ const Module

+ type EndpointSpec struct

+ Hostname string

+ Port int32

+ Scheme string

+ func (in *EndpointSpec) DeepCopy() *EndpointSpec

+ func (in *EndpointSpec) DeepCopyInto(out *EndpointSpec)

+ type FlowStep struct

+ Arguments ModuleArguments

+ Name string

+ Template string

+ func (in *FlowStep) DeepCopy() *FlowStep

+ func (in *FlowStep) DeepCopyInto(out *FlowStep)

+ type FybrikApplication struct

+ Spec FybrikApplicationSpec

+ Status FybrikApplicationStatus

+ func (in *FybrikApplication) DeepCopy() *FybrikApplication

+ func (in *FybrikApplication) DeepCopyInto(out *FybrikApplication)

+ func (in *FybrikApplication) DeepCopyObject() runtime.Object

+ func (r *FybrikApplication) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *FybrikApplication) ValidateCreate() error

+ func (r *FybrikApplication) ValidateDelete() error

+ func (r *FybrikApplication) ValidateUpdate(old runtime.Object) error

+ type FybrikApplicationList struct

+ Items []FybrikApplication

+ func (in *FybrikApplicationList) DeepCopy() *FybrikApplicationList

+ func (in *FybrikApplicationList) DeepCopyInto(out *FybrikApplicationList)

+ func (in *FybrikApplicationList) DeepCopyObject() runtime.Object

+ type FybrikApplicationSpec struct

+ AppInfo ApplicationDetails

+ Data []DataContext

+ SecretRef string

+ Selector Selector

+ func (in *FybrikApplicationSpec) DeepCopy() *FybrikApplicationSpec

+ func (in *FybrikApplicationSpec) DeepCopyInto(out *FybrikApplicationSpec)

+ type FybrikApplicationStatus struct

+ CatalogedAssets map[string]string

+ Conditions []Condition

+ DataAccessInstructions string

+ Generated *ResourceReference

+ ObservedGeneration int64

+ ProvisionedStorage map[string]DatasetDetails

+ ReadEndpointsMap map[string]EndpointSpec

+ Ready bool

+ func (in *FybrikApplicationStatus) DeepCopy() *FybrikApplicationStatus

+ func (in *FybrikApplicationStatus) DeepCopyInto(out *FybrikApplicationStatus)

+ type FybrikModule struct

+ Spec FybrikModuleSpec

+ func (in *FybrikModule) DeepCopy() *FybrikModule

+ func (in *FybrikModule) DeepCopyInto(out *FybrikModule)

+ func (in *FybrikModule) DeepCopyObject() runtime.Object

+ type FybrikModuleList struct

+ Items []FybrikModule

+ func (in *FybrikModuleList) DeepCopy() *FybrikModuleList

+ func (in *FybrikModuleList) DeepCopyInto(out *FybrikModuleList)

+ func (in *FybrikModuleList) DeepCopyObject() runtime.Object

+ type FybrikModuleSpec struct

+ Capabilities Capability

+ Chart ChartSpec

+ Dependencies []Dependency

+ Flows []ModuleFlow

+ StatusIndicators []ResourceStatusIndicator

+ func (in *FybrikModuleSpec) DeepCopy() *FybrikModuleSpec

+ func (in *FybrikModuleSpec) DeepCopyInto(out *FybrikModuleSpec)

+ type FybrikStorageAccount struct

+ Spec FybrikStorageAccountSpec

+ Status FybrikStorageAccountStatus

+ func (in *FybrikStorageAccount) DeepCopy() *FybrikStorageAccount

+ func (in *FybrikStorageAccount) DeepCopyInto(out *FybrikStorageAccount)

+ func (in *FybrikStorageAccount) DeepCopyObject() runtime.Object

+ type FybrikStorageAccountList struct

+ Items []FybrikStorageAccount

+ func (in *FybrikStorageAccountList) DeepCopy() *FybrikStorageAccountList

+ func (in *FybrikStorageAccountList) DeepCopyInto(out *FybrikStorageAccountList)

+ func (in *FybrikStorageAccountList) DeepCopyObject() runtime.Object

+ type FybrikStorageAccountSpec struct

+ Endpoint string

+ Regions []string

+ SecretRef string

+ func (in *FybrikStorageAccountSpec) DeepCopy() *FybrikStorageAccountSpec

+ func (in *FybrikStorageAccountSpec) DeepCopyInto(out *FybrikStorageAccountSpec)

+ type FybrikStorageAccountStatus struct

+ func (in *FybrikStorageAccountStatus) DeepCopy() *FybrikStorageAccountStatus

+ func (in *FybrikStorageAccountStatus) DeepCopyInto(out *FybrikStorageAccountStatus)

+ type InterfaceDetails struct

+ DataFormat string

+ Protocol string

+ func (in *InterfaceDetails) DeepCopy() *InterfaceDetails

+ func (in *InterfaceDetails) DeepCopyInto(out *InterfaceDetails)

+ type MetaBlueprint struct

+ Name string

+ Namespace string

+ Status BlueprintStatus

+ func CreateMetaBlueprint(blueprint *Blueprint) MetaBlueprint

+ func CreateMetaBlueprintWithoutState(blueprint *Blueprint) MetaBlueprint

+ func (in *MetaBlueprint) DeepCopy() *MetaBlueprint

+ func (in *MetaBlueprint) DeepCopyInto(out *MetaBlueprint)

+ type ModuleAPI struct

+ Endpoint EndpointSpec

+ func (in *ModuleAPI) DeepCopy() *ModuleAPI

+ func (in *ModuleAPI) DeepCopyInto(out *ModuleAPI)

+ type ModuleArguments struct

+ Copy *CopyModuleArgs

+ Read []ReadModuleArgs

+ Write []WriteModuleArgs

+ func (in *ModuleArguments) DeepCopy() *ModuleArguments

+ func (in *ModuleArguments) DeepCopyInto(out *ModuleArguments)

+ type ModuleFlow string

+ const Copy

+ const Read

+ const Write

+ type ModuleInOut struct

+ Flow ModuleFlow

+ Sink *InterfaceDetails

+ Source *InterfaceDetails

+ func (in *ModuleInOut) DeepCopy() *ModuleInOut

+ func (in *ModuleInOut) DeepCopyInto(out *ModuleInOut)

+ type ObservedState struct

+ DataAccessInstructions string

+ Error string

+ Ready bool

+ func (in *ObservedState) DeepCopy() *ObservedState

+ func (in *ObservedState) DeepCopyInto(out *ObservedState)

+ type Plotter struct

+ Spec PlotterSpec

+ Status PlotterStatus

+ func (in *Plotter) DeepCopy() *Plotter

+ func (in *Plotter) DeepCopyInto(out *Plotter)

+ func (in *Plotter) DeepCopyObject() runtime.Object

+ type PlotterList struct

+ Items []Plotter

+ func (in *PlotterList) DeepCopy() *PlotterList

+ func (in *PlotterList) DeepCopyInto(out *PlotterList)

+ func (in *PlotterList) DeepCopyObject() runtime.Object

+ type PlotterSpec struct

+ Blueprints map[string]BlueprintSpec

+ Selector metav1.LabelSelector

+ func (in *PlotterSpec) DeepCopy() *PlotterSpec

+ func (in *PlotterSpec) DeepCopyInto(out *PlotterSpec)

+ type PlotterStatus struct

+ Blueprints map[string]MetaBlueprint

+ ObservedGeneration int64

+ ObservedState ObservedState

+ ReadyTimestamp *metav1.Time

+ func (in *PlotterStatus) DeepCopy() *PlotterStatus

+ func (in *PlotterStatus) DeepCopyInto(out *PlotterStatus)

+ type ReadModuleArgs struct

+ AssetID string

+ Source DataStore

+ Transformations []serde.Arbitrary

+ func (in *ReadModuleArgs) DeepCopy() *ReadModuleArgs

+ func (in *ReadModuleArgs) DeepCopyInto(out *ReadModuleArgs)

+ type ResourceReference struct

+ AppVersion int64

+ Kind string

+ Name string

+ Namespace string

+ func (in *ResourceReference) DeepCopy() *ResourceReference

+ func (in *ResourceReference) DeepCopyInto(out *ResourceReference)

+ type ResourceStatusIndicator struct

+ ErrorMessage string

+ FailureCondition string

+ Kind string

+ SuccessCondition string

+ func (in *ResourceStatusIndicator) DeepCopy() *ResourceStatusIndicator

+ func (in *ResourceStatusIndicator) DeepCopyInto(out *ResourceStatusIndicator)

+ type Selector struct

+ ClusterName string

+ WorkloadSelector metav1.LabelSelector

+ func (in *Selector) DeepCopy() *Selector

+ func (in *Selector) DeepCopyInto(out *Selector)

+ type SupportedAction struct

+ ID string

+ Level connectors.EnforcementAction_EnforcementActionLevel

+ func (in *SupportedAction) DeepCopy() *SupportedAction

+ func (in *SupportedAction) DeepCopyInto(out *SupportedAction)

+ type Vault struct

+ Address string

+ AuthPath string

+ Role string

+ SecretPath string

+ func (in *Vault) DeepCopy() *Vault

+ func (in *Vault) DeepCopyInto(out *Vault)

+ type WriteModuleArgs struct

+ Destination DataStore

+ Transformations []serde.Arbitrary

+ func (in *WriteModuleArgs) DeepCopy() *WriteModuleArgs

+ func (in *WriteModuleArgs) DeepCopyInto(out *WriteModuleArgs)

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