Documentation
¶
Overview ¶
Package streams -- generated by scloudgen !! DO NOT EDIT !!
Index ¶
- func ActivatePipeline(cmd *cobra.Command, args []string) error
- func Compile(cmd *cobra.Command, args []string) error
- func CreateConnection(cmd *cobra.Command, args []string) error
- func CreatePipeline(cmd *cobra.Command, args []string) error
- func CreateTemplate(cmd *cobra.Command, args []string) error
- func DeactivatePipeline(cmd *cobra.Command, args []string) error
- func Decompile(cmd *cobra.Command, args []string) error
- func DeleteConnection(cmd *cobra.Command, args []string) error
- func DeleteFile(cmd *cobra.Command, args []string) error
- func DeleteLookupFile(cmd *cobra.Command, args []string) error
- func DeletePipeline(cmd *cobra.Command, args []string) error
- func DeleteSource(cmd *cobra.Command, args []string) error
- func DeleteTemplate(cmd *cobra.Command, args []string) error
- func GetFileMetadata(cmd *cobra.Command, args []string) error
- func GetFilesMetadata(cmd *cobra.Command, args []string) error
- func GetInputSchema(cmd *cobra.Command, args []string) error
- func GetLookupFileMetadata(cmd *cobra.Command, args []string) error
- func GetLookupFilesMetadata(cmd *cobra.Command, args []string) error
- func GetLookupTable(cmd *cobra.Command, args []string) error
- func GetOutputSchema(cmd *cobra.Command, args []string) error
- func GetPipeline(cmd *cobra.Command, args []string) error
- func GetPipelineLatestMetrics(cmd *cobra.Command, args []string) error
- func GetPipelinesStatus(cmd *cobra.Command, args []string) error
- func GetPreviewData(cmd *cobra.Command, args []string) error
- func GetPreviewSession(cmd *cobra.Command, args []string) error
- func GetPreviewSessionLatestMetrics(cmd *cobra.Command, args []string) error
- func GetRegistry(cmd *cobra.Command, args []string) error
- func GetTemplate(cmd *cobra.Command, args []string) error
- func ListConnections(cmd *cobra.Command, args []string) error
- func ListConnectors(cmd *cobra.Command, args []string) error
- func ListPipelines(cmd *cobra.Command, args []string) error
- func ListTemplates(cmd *cobra.Command, args []string) error
- func PatchPipeline(cmd *cobra.Command, args []string) error
- func PutConnection(cmd *cobra.Command, args []string) error
- func PutTemplate(cmd *cobra.Command, args []string) error
- func ReactivatePipeline(cmd *cobra.Command, args []string) error
- func ReactivationStatus(cmd *cobra.Command, args []string) error
- func StartPreview(cmd *cobra.Command, args []string) error
- func StopPreview(cmd *cobra.Command, args []string) error
- func UpdateConnection(cmd *cobra.Command, args []string) error
- func UpdatePipeline(cmd *cobra.Command, args []string) error
- func UpdateTemplate(cmd *cobra.Command, args []string) error
- func UpgradePipeline(cmd *cobra.Command, args []string) error
- func UploadFile(cmd *cobra.Command, args []string) error
- func UploadLookupFile(cmd *cobra.Command, args []string) error
- func ValidateConnection(cmd *cobra.Command, args []string) error
- func ValidatePipeline(cmd *cobra.Command, args []string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ActivatePipeline ¶
ActivatePipeline Activates an existing pipeline.
func CreateConnection ¶
CreateConnection Create a new DSP connection.
func CreatePipeline ¶
CreatePipeline Creates a pipeline.
func CreateTemplate ¶
CreateTemplate Creates a template for a tenant.
func DeactivatePipeline ¶
DeactivatePipeline Deactivates an existing pipeline.
func DeleteConnection ¶
DeleteConnection Delete all versions of a connection by its id.
func DeleteFile ¶ added in v1.6.0
DeleteFile Delete file.
func DeleteLookupFile ¶ added in v1.11.0
DeleteLookupFile Delete lookup file.
func DeletePipeline ¶
DeletePipeline Removes a pipeline.
func DeleteSource ¶
DeleteSource Delete a source.
func DeleteTemplate ¶
DeleteTemplate Removes a template with a specific ID.
func GetFileMetadata ¶ added in v1.7.0
GetFileMetadata Get file metadata.
func GetFilesMetadata ¶ added in v1.6.0
GetFilesMetadata Returns files metadata.
func GetInputSchema ¶
GetInputSchema Returns the input schema for a function in a pipeline.
func GetLookupFileMetadata ¶ added in v1.11.0
GetLookupFileMetadata Get lookup file metadata.
func GetLookupFilesMetadata ¶ added in v1.11.0
GetLookupFilesMetadata Returns lookup files metadata.
func GetLookupTable ¶ added in v1.6.0
GetLookupTable Returns lookup table results.
func GetOutputSchema ¶
GetOutputSchema Returns the output schema for a specified function in a pipeline.
func GetPipeline ¶
GetPipeline Returns an individual pipeline by version.
func GetPipelineLatestMetrics ¶
GetPipelineLatestMetrics Returns the latest metrics for a single pipeline.
func GetPipelinesStatus ¶
GetPipelinesStatus Returns the status of pipelines from the underlying streaming system.
func GetPreviewData ¶
GetPreviewData Returns the preview data for a session.
func GetPreviewSession ¶
GetPreviewSession Returns information from a preview session.
func GetPreviewSessionLatestMetrics ¶
GetPreviewSessionLatestMetrics Returns the latest metrics for a preview session.
func GetRegistry ¶
GetRegistry Returns all functions in JSON format.
func GetTemplate ¶
GetTemplate Returns an individual template by version.
func ListConnections ¶
ListConnections Returns a list of connections (latest versions only) by tenant ID.
func ListConnectors ¶
ListConnectors Returns a list of the available connectors.
func ListPipelines ¶
ListPipelines Returns all pipelines.
func ListTemplates ¶
ListTemplates Returns a list of all templates.
func PatchPipeline ¶ added in v1.6.0
PatchPipeline Patches an existing pipeline.
func PutConnection ¶
PutConnection Updates an existing DSP connection.
func PutTemplate ¶
PutTemplate Updates an existing template.
func ReactivatePipeline ¶
ReactivatePipeline Reactivate a pipeline
func ReactivationStatus ¶
ReactivationStatus Get pipeline reactivation status
func StartPreview ¶
StartPreview Creates a preview session for a pipeline.
func StopPreview ¶
StopPreview Stops a preview session.
func UpdateConnection ¶
UpdateConnection Patches an existing DSP connection.
func UpdatePipeline ¶
UpdatePipeline Updates an existing pipeline.
func UpdateTemplate ¶
UpdateTemplate Patches an existing template.
func UpgradePipeline ¶
UpgradePipeline Upgrades a pipeline async
func UploadFile ¶ added in v1.6.0
UploadFile Upload new file.
func UploadLookupFile ¶
UploadLookupFile Upload new lookup file.
func ValidateConnection ¶
ValidateConnection Validates the configuration of a DSP connection.
Types ¶
This section is empty.
Source Files