streams

package
v1.8.0 Latest Latest
Warning

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

 Go to latest Published: Aug 25, 2020 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 CreateCollectJob added in v1.8.0 

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

CreateCollectJob Create a new collect job.

func CreateConnection 

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

CreateConnection Create a new DSP connection.

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 DeleteCollectJob added in v1.8.0 

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

DeleteCollectJob Delete a collect job.

func DeleteConnection 

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

DeleteConnection Delete all versions of a connection by its id.

func DeleteFile added in v1.6.0 

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

DeleteFile Delete file.

func DeletePipeline 

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

DeletePipeline Removes a pipeline.

func DeletePlugin added in v1.8.0 

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

DeletePlugin Delete an admin plugin

func DeleteTemplate 

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

DeleteTemplate Removes a template with a specific ID.

func GetCollectJob added in v1.8.0 

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

GetCollectJob Get a collect job.

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 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 GetPlugins added in v1.8.0 

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

GetPlugins Returns all the plugins that are available for all tenants.

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 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 PatchPlugin added in v1.8.0 

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

PatchPlugin Patch an existing admin plugin.

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 RegisterPlugin added in v1.8.0 

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

RegisterPlugin Register a new plugin that's available for all tenants.

func StartCollectJob added in v1.8.0 

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

StartCollectJob Start a collect job.

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 StopCollectJob added in v1.8.0 

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

StopCollectJob Stop a collect job.

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 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 UpdatePlugin added in v1.8.0 

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

UpdatePlugin Update admin plugin info.

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 UploadPlugin added in v1.8.0 

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

UploadPlugin Upload a new plugin that's available for all tenants.

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.