streams

package
v1.11.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 2, 2021 License: Apache-2.0 Imports: 10 Imported by: 1

Documentation

Overview

Package streams -- generated by scloudgen !! DO NOT EDIT !!

Package streams -- generated by scloudgen !! DO NOT EDIT !!

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ActivatePipeline 

func ActivatePipeline(cmd *cobra.Command, args []string) error

ActivatePipeline Activates an existing pipeline.

func Compile added in v1.6.0 

func Compile(cmd *cobra.Command, args []string) error

Compile Compiles SPL2 and returns streams JSON.

func CompileOverride added in v1.7.0 

func CompileOverride(validate *bool, filename string) (*model.Pipeline, error)

CompileOverride

func CreateConnection 

func CreateConnection(cmd *cobra.Command, args []string) error

CreateConnection Create a new DSP connection.

func CreateDataStream added in v1.10.0 

func CreateDataStream(cmd *cobra.Command, args []string) error

CreateDataStream Creates a data stream for a tenant.

func CreatePipeline 

func CreatePipeline(cmd *cobra.Command, args []string) error

CreatePipeline Creates a pipeline.

func CreatePipelineOverride 

func CreatePipelineOverride(bypassValidation *bool, description *string, name string, filename string) (*model.PipelineResponse, error)

CreatePipeline

func CreateTemplate 

func CreateTemplate(cmd *cobra.Command, args []string) error

CreateTemplate Creates a template for a tenant.

func CreateTemplateOverride 

func CreateTemplateOverride(description string, name string, filename string) (*model.TemplateResponse, error)

CreateTemplateOverride

func DeactivatePipeline 

func DeactivatePipeline(cmd *cobra.Command, args []string) error

DeactivatePipeline Deactivates an existing pipeline.

func Decompile added in v1.6.0 

func Decompile(cmd *cobra.Command, args []string) error

Decompile Decompiles UPL and returns SPL.

func DeleteConnection 

func DeleteConnection(cmd *cobra.Command, args []string) error

DeleteConnection Delete all versions of a connection by its id.

func DeleteDataStream added in v1.10.0 

func DeleteDataStream(cmd *cobra.Command, args []string) error

DeleteDataStream Deletes a data stream for a tenant.

func DeleteFile added in v1.6.0 

func DeleteFile(cmd *cobra.Command, args []string) error

DeleteFile Delete file.

func DeleteLookupFile added in v1.11.0 

func DeleteLookupFile(cmd *cobra.Command, args []string) error

DeleteLookupFile Delete lookup file.

func DeletePipeline 

func DeletePipeline(cmd *cobra.Command, args []string) error

DeletePipeline Removes a pipeline.

func DeleteTemplate 

func DeleteTemplate(cmd *cobra.Command, args []string) error

DeleteTemplate Removes a template with a specific ID.

func DescribeDataStream added in v1.10.0 

func DescribeDataStream(cmd *cobra.Command, args []string) error

DescribeDataStream Describes a data stream for a tenant.

func GetFileMetadata added in v1.7.0 

func GetFileMetadata(cmd *cobra.Command, args []string) error

GetFileMetadata Get file metadata.

func GetFilesMetadata added in v1.6.0 

func GetFilesMetadata(cmd *cobra.Command, args []string) error

GetFilesMetadata Returns files metadata.

func GetInputSchema 

func GetInputSchema(cmd *cobra.Command, args []string) error

GetInputSchema Returns the input schema for a function in a pipeline.

func GetInputSchemaOverride 

func GetInputSchemaOverride(nodeUuid string, targetPortName string, filename string) (*model.UplType, error)

GetInputSchemaOverride

func GetLookupFileMetadata added in v1.11.0 

func GetLookupFileMetadata(cmd *cobra.Command, args []string) error

GetLookupFileMetadata Get lookup file metadata.

func GetLookupFilesMetadata added in v1.11.0 

func GetLookupFilesMetadata(cmd *cobra.Command, args []string) error

GetLookupFilesMetadata Returns lookup files metadata.

func GetLookupTable added in v1.6.0 

func GetLookupTable(cmd *cobra.Command, args []string) error

GetLookupTable Returns lookup table results.

func GetOutputSchema 

func GetOutputSchema(cmd *cobra.Command, args []string) error

GetOutputSchema Returns the output schema for a specified function in a pipeline.

func GetOutputSchemaOverride 

func GetOutputSchemaOverride(nodeUuid *string, sourcePortName *string, filename string) (map[string]model.UplType, error)

GetOutputSchemaOverride

func GetPipeline 

func GetPipeline(cmd *cobra.Command, args []string) error

GetPipeline Returns an individual pipeline by version.

func GetPipelineLatestMetrics 

func GetPipelineLatestMetrics(cmd *cobra.Command, args []string) error

GetPipelineLatestMetrics Returns the latest metrics for a single pipeline.

func GetPipelinesStatus 

func GetPipelinesStatus(cmd *cobra.Command, args []string) error

GetPipelinesStatus Returns the status of pipelines from the underlying streaming system.

func GetPreviewData 

func GetPreviewData(cmd *cobra.Command, args []string) error

GetPreviewData Returns the preview data for a session.

func GetPreviewSession 

func GetPreviewSession(cmd *cobra.Command, args []string) error

GetPreviewSession Returns information from a preview session.

func GetPreviewSessionLatestMetrics 

func GetPreviewSessionLatestMetrics(cmd *cobra.Command, args []string) error

GetPreviewSessionLatestMetrics Returns the latest metrics for a preview session.

func GetRegistry 

func GetRegistry(cmd *cobra.Command, args []string) error

GetRegistry Returns all functions in JSON format.

func GetTemplate 

func GetTemplate(cmd *cobra.Command, args []string) error

GetTemplate Returns an individual template by version.

func ListConnections 

func ListConnections(cmd *cobra.Command, args []string) error

ListConnections Returns a list of connections (latest versions only) by tenant ID.

func ListConnectors 

func ListConnectors(cmd *cobra.Command, args []string) error

ListConnectors Returns a list of the available connectors.

func ListDataStreams added in v1.10.0 

func ListDataStreams(cmd *cobra.Command, args []string) error

ListDataStreams Returns a list of datastreams for a tenant.

func ListPipelines 

func ListPipelines(cmd *cobra.Command, args []string) error

ListPipelines Returns all pipelines.

func ListTemplates 

func ListTemplates(cmd *cobra.Command, args []string) error

ListTemplates Returns a list of all templates.

func PatchPipeline added in v1.6.0 

func PatchPipeline(cmd *cobra.Command, args []string) error

PatchPipeline Patches an existing pipeline.

func PatchPipelineOverride added in v1.7.0 

func PatchPipelineOverride(id string, bypassValidation *bool, createUserId *string, description *string, name *string, filename string) (*model.PipelineResponse, error)

func PutConnection 

func PutConnection(cmd *cobra.Command, args []string) error

PutConnection Updates an existing DSP connection.

func PutTemplate 

func PutTemplate(cmd *cobra.Command, args []string) error

PutTemplate Updates an existing template.

func PutTemplateOverride 

func PutTemplateOverride(templateId string, filename string) (*model.TemplateResponse, error)

PutTemplateOverride

func ReactivatePipeline 

func ReactivatePipeline(cmd *cobra.Command, args []string) error

ReactivatePipeline Reactivate a pipeline

func StartPreview 

func StartPreview(cmd *cobra.Command, args []string) error

StartPreview Creates a preview session for a pipeline.

func StartPreviewOverride 

func StartPreviewOverride(recordsLimit *int32, recordsPerPipeline *int32, sessionLifetimeMsfilename *int64, filename string) (*model.PreviewStartResponse, error)

StartPreviewOverride

func StopPreview 

func StopPreview(cmd *cobra.Command, args []string) error

StopPreview Stops a preview session.

func UpdateConnection 

func UpdateConnection(cmd *cobra.Command, args []string) error

UpdateConnection Patches an existing DSP connection.

func UpdateDataStream added in v1.10.0 

func UpdateDataStream(cmd *cobra.Command, args []string) error

UpdateDataStream Patches an existing data stream for a tenant.

func UpdatePipeline 

func UpdatePipeline(cmd *cobra.Command, args []string) error

UpdatePipeline Updates an existing pipeline.

func UpdatePipelineOverride 

func UpdatePipelineOverride(id string, bypassValidation *bool, description *string, name string, filename string) (*model.PipelineResponse, error)

UpdatePipelineOverride

func UpdateTemplate 

func UpdateTemplate(cmd *cobra.Command, args []string) error

UpdateTemplate Patches an existing template.

func UpdateTemplateOverride 

func UpdateTemplateOverride(templateId string, description *string, name *string, filename string) (*model.TemplateResponse, error)

UpdateTemplateOverride

func UploadFile added in v1.6.0 

func UploadFile(cmd *cobra.Command, args []string) error

UploadFile Upload new file.

func ValidatePipeline 

func ValidatePipeline(cmd *cobra.Command, args []string) error

ValidatePipeline Verifies whether the Streams JSON is valid.

func ValidatePipelineOverride 

func ValidatePipelineOverride(filename string) (*model.ValidateResponse, error)

ValidatePipelineOverride

Types

type HttpResponse added in v1.6.0 

type HttpResponse struct {
	Code    *string                `json:"code,omitempty"`
	Details map[string]interface{} `json:"details,omitempty"`
	Message *string                `json:"message,omitempty"`
}

func UploadFileOverride added in v1.7.0 

func UploadFileOverride(arg string) (*HttpResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.