streams

package

v1.4.0 Latest Latest Go to latest Published: Mar 27, 2020 License: Apache-2.0 Imports: 9 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/splunk/splunk-cloud-sdk-go

Links

Open Source Insights

Documentation ¶

Overview ¶

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

Index ¶

func ActivatePipeline(cmd *cobra.Command, args []string) error
func CompileDSL(cmd *cobra.Command, args []string) error
func CompileDSLOverride(filename string) (*model.UplPipeline, error)
func CompileSPL(cmd *cobra.Command, args []string) error
func CompileSPLOverride(filename string) (*model.UplPipeline, error)
func CreateConnection(cmd *cobra.Command, args []string) error
func CreateGroup(cmd *cobra.Command, args []string) error
func CreateGroupOverride(filename string) (*model.GroupResponse, error)
func CreatePipeline(cmd *cobra.Command, args []string) error
func CreatePipelineOverride(bypassValidation *bool, description *string, name string, filename string) (*model.PipelineResponse, error)
func CreateTemplate(cmd *cobra.Command, args []string) error
func CreateTemplateOverride(description string, name string, filename string) (*model.TemplateResponse, error)
func DeactivatePipeline(cmd *cobra.Command, args []string) error
func DeleteConnection(cmd *cobra.Command, args []string) error
func DeleteGroup(cmd *cobra.Command, args []string) error
func DeletePipeline(cmd *cobra.Command, args []string) error
func DeleteTemplate(cmd *cobra.Command, args []string) error
func ExpandGroup(cmd *cobra.Command, args []string) error
func ExpandPipeline(cmd *cobra.Command, args []string) error
func ExpandPipelineOverride(filename string) (*model.UplPipeline, error)
func GetGroup(cmd *cobra.Command, args []string) error
func GetInputSchema(cmd *cobra.Command, args []string) error
func GetInputSchemaOverride(nodeUuid string, targetPortName string, filename string) (*model.UplType, error)
func GetOutputSchema(cmd *cobra.Command, args []string) error
func GetOutputSchemaOverride(nodeUuid *string, sourcePortName *string, filename string) (map[string]model.UplType, 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 MergePipelines(cmd *cobra.Command, args []string) error
func MergePipelinesOverride(targetNode string, targetPort string, inputTreeFilename string, ...) (*model.UplPipeline, error)
func PutConnection(cmd *cobra.Command, args []string) error
func PutConnectionOverride(id string, filename string) (*model.ConnectionSaveResponse, error)
func PutGroup(cmd *cobra.Command, args []string) error
func PutGroupOverride(groupId string, filename string) (*model.GroupResponse, error)
func PutTemplate(cmd *cobra.Command, args []string) error
func PutTemplateOverride(templateId string, filename string) (*model.TemplateResponse, error)
func ReactivatePipeline(cmd *cobra.Command, args []string) error
func StartPreview(cmd *cobra.Command, args []string) error
func StartPreviewOverride(filename string) (*model.PreviewStartResponse, error)
func StopPreview(cmd *cobra.Command, args []string) error
func UpdateConnection(cmd *cobra.Command, args []string) error
func UpdateConnectionOverride(id string, filename string) (*model.ConnectionSaveResponse, error)
func UpdateGroup(cmd *cobra.Command, args []string) error
func UpdateGroupOverride(groupId string, filename string) (*model.GroupResponse, error)
func UpdatePipeline(cmd *cobra.Command, args []string) error
func UpdatePipelineOverride(id string, bypassValidation *bool, createUserId *string, description *string, ...) (*model.PipelineResponse, error)
func UpdateTemplate(cmd *cobra.Command, args []string) error
func UpdateTemplateOverride(templateId string, description *string, name *string, filename string) (*model.TemplateResponse, error)
func ValidatePipeline(cmd *cobra.Command, args []string) error
func ValidatePipelineOverride(filename string) (*model.ValidateResponse, error)

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 CompileDSL ¶

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

CompileDSL Compiles the Streams DSL and returns Streams JSON.

func CompileDSLOverride ¶

func CompileDSLOverride(filename string) (*model.UplPipeline, error)

CompileDSLOverride

func CompileSPL ¶

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

CompileSPL Compiles SPL2 and returns Streams JSON.

func CompileSPLOverride ¶

func CompileSPLOverride(filename string) (*model.UplPipeline, error)

CompileSPLOverride

func CreateConnection ¶

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

CreateConnection Create a new DSP connection.

func CreateGroup ¶

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

CreateGroup Create a new group function by combining the Streams JSON of two or more functions.

func CreateGroupOverride ¶

func CreateGroupOverride(filename string) (*model.GroupResponse, error)

CreateGroupOverride

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 DeleteConnection ¶

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

DeleteConnection Delete all versions of a connection by its id.

func DeleteGroup ¶

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

DeleteGroup Removes an existing group.

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 ExpandGroup ¶

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

ExpandGroup Creates and returns the expanded version of a group.

func ExpandPipeline ¶

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

ExpandPipeline Returns the entire Streams JSON, including the expanded Streams JSON of any group functions in the pipeline.

func ExpandPipelineOverride ¶

func ExpandPipelineOverride(filename string) (*model.UplPipeline, error)

ExpandPipelineOverride

func GetGroup ¶

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

GetGroup Returns the full Streams JSON of a group.

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 GetOutputSchema ¶

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

GetOutputSchema Returns the output schema for a specified function in a pipeline. If no function ID is specified, the request returns the output schema for all functions 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 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 MergePipelines ¶

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

MergePipelines Combines two Streams JSON programs.

func MergePipelinesOverride ¶

func MergePipelinesOverride(targetNode string, targetPort string, inputTreeFilename string, mainTreeFilename string) (*model.UplPipeline, error)

MergePipelinesOverride

func PutConnection ¶

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

PutConnection Modifies an existing DSP connection.

func PutConnectionOverride ¶

func PutConnectionOverride(id string, filename string) (*model.ConnectionSaveResponse, error)

PutConnectionOverride

func PutGroup ¶

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

PutGroup Update a group function combining the Streams JSON of two or more functions.

func PutGroupOverride ¶

func PutGroupOverride(groupId string, filename string) (*model.GroupResponse, error)

PutGroupOverride

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(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 Partially modifies an existing DSP connection.

func UpdateConnectionOverride ¶

func UpdateConnectionOverride(id string, filename string) (*model.ConnectionSaveResponse, error)

UpdateConnectionOverride

func UpdateGroup ¶

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

UpdateGroup Modify a group function by combining the Streams JSON of two or more functions.

func UpdateGroupOverride ¶

func UpdateGroupOverride(groupId string, filename string) (*model.GroupResponse, error)

UpdateGroupOverride

func UpdatePipeline ¶

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

UpdatePipeline Partially modifies an existing pipeline.

func UpdatePipelineOverride ¶

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

UpdatePipelineOverride

func UpdateTemplate ¶

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

UpdateTemplate Partially modifies an existing template.

func UpdateTemplateOverride ¶

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

UpdateTemplateOverride

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 ¶

This section is empty.

Source Files ¶

View all Source files

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