outputs

package
v0.20230206.1135314 Latest Latest
Warning

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

Go to latest
Published: Feb 6, 2023 License: MPL-2.0 Imports: 10 Imported by: 1

README

github.com/hashicorp/go-azure-sdk/resource-manager/streamanalytics/2020-03-01/outputs Documentation

The outputs SDK allows for interaction with the Azure Resource Manager Service streamanalytics (API Version 2020-03-01).

This readme covers example usages, but further information on using this SDK can be found in the project root.

Import Path

import "github.com/hashicorp/go-azure-sdk/resource-manager/streamanalytics/2020-03-01/outputs"

Client Initialization

client := outputs.NewOutputsClientWithBaseURI("https://management.azure.com")
client.Client.Authorizer = authorizer

Example Usage: OutputsClient.CreateOrReplace

ctx := context.TODO()
id := outputs.NewOutputID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobValue", "outputValue")

payload := outputs.Output{
	// ...
}


read, err := client.CreateOrReplace(ctx, id, payload, outputs.DefaultCreateOrReplaceOperationOptions())
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: OutputsClient.Delete

ctx := context.TODO()
id := outputs.NewOutputID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobValue", "outputValue")

read, err := client.Delete(ctx, id)
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: OutputsClient.Get

ctx := context.TODO()
id := outputs.NewOutputID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobValue", "outputValue")

read, err := client.Get(ctx, id)
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: OutputsClient.ListByStreamingJob

ctx := context.TODO()
id := outputs.NewStreamingJobID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobValue")

// alternatively `client.ListByStreamingJob(ctx, id, outputs.DefaultListByStreamingJobOperationOptions())` can be used to do batched pagination
items, err := client.ListByStreamingJobComplete(ctx, id, outputs.DefaultListByStreamingJobOperationOptions())
if err != nil {
	// handle the error
}
for _, item := range items {
	// do something
}

Example Usage: OutputsClient.Test

ctx := context.TODO()
id := outputs.NewOutputID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobValue", "outputValue")

payload := outputs.Output{
	// ...
}


if err := client.TestThenPoll(ctx, id, payload); err != nil {
	// handle the error
}

Example Usage: OutputsClient.Update

ctx := context.TODO()
id := outputs.NewOutputID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobValue", "outputValue")

payload := outputs.Output{
	// ...
}


read, err := client.Update(ctx, id, payload, outputs.DefaultUpdateOperationOptions())
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PossibleValuesForAuthenticationMode

func PossibleValuesForAuthenticationMode() []string

func PossibleValuesForEncoding added in v0.20220715.1104737

func PossibleValuesForEncoding() []string

func PossibleValuesForEventSerializationType

func PossibleValuesForEventSerializationType() []string

func PossibleValuesForJsonOutputSerializationFormat added in v0.20220715.1104737

func PossibleValuesForJsonOutputSerializationFormat() []string

func ValidateOutputID

func ValidateOutputID(input interface{}, key string) (warnings []string, errors []error)

ValidateOutputID checks that 'input' can be parsed as a Output ID

func ValidateStreamingJobID

func ValidateStreamingJobID(input interface{}, key string) (warnings []string, errors []error)

ValidateStreamingJobID checks that 'input' can be parsed as a Streaming Job ID

Types

type AuthenticationMode

type AuthenticationMode string
const (
	AuthenticationModeConnectionString AuthenticationMode = "ConnectionString"
	AuthenticationModeMsi              AuthenticationMode = "Msi"
	AuthenticationModeUserToken        AuthenticationMode = "UserToken"
)

type AvroSerialization added in v0.20220715.1104737

type AvroSerialization struct {
	Properties *interface{} `json:"properties,omitempty"`
}

func (AvroSerialization) MarshalJSON added in v0.20220715.1104737

func (s AvroSerialization) MarshalJSON() ([]byte, error)

type AzureDataLakeStoreOutputDataSource

type AzureDataLakeStoreOutputDataSource struct {
	Properties *AzureDataLakeStoreOutputDataSourceProperties `json:"properties,omitempty"`
}

func (AzureDataLakeStoreOutputDataSource) MarshalJSON

func (s AzureDataLakeStoreOutputDataSource) MarshalJSON() ([]byte, error)

type AzureDataLakeStoreOutputDataSourceProperties

type AzureDataLakeStoreOutputDataSourceProperties struct {
	AccountName            *string             `json:"accountName,omitempty"`
	AuthenticationMode     *AuthenticationMode `json:"authenticationMode,omitempty"`
	DateFormat             *string             `json:"dateFormat,omitempty"`
	FilePathPrefix         *string             `json:"filePathPrefix,omitempty"`
	RefreshToken           *string             `json:"refreshToken,omitempty"`
	TenantId               *string             `json:"tenantId,omitempty"`
	TimeFormat             *string             `json:"timeFormat,omitempty"`
	TokenUserDisplayName   *string             `json:"tokenUserDisplayName,omitempty"`
	TokenUserPrincipalName *string             `json:"tokenUserPrincipalName,omitempty"`
}

type AzureFunctionOutputDataSource

type AzureFunctionOutputDataSource struct {
	Properties *AzureFunctionOutputDataSourceProperties `json:"properties,omitempty"`
}

func (AzureFunctionOutputDataSource) MarshalJSON

func (s AzureFunctionOutputDataSource) MarshalJSON() ([]byte, error)

type AzureFunctionOutputDataSourceProperties

type AzureFunctionOutputDataSourceProperties struct {
	ApiKey          *string  `json:"apiKey,omitempty"`
	FunctionAppName *string  `json:"functionAppName,omitempty"`
	FunctionName    *string  `json:"functionName,omitempty"`
	MaxBatchCount   *float64 `json:"maxBatchCount,omitempty"`
	MaxBatchSize    *float64 `json:"maxBatchSize,omitempty"`
}

type AzureSqlDatabaseDataSourceProperties

type AzureSqlDatabaseDataSourceProperties struct {
	AuthenticationMode *AuthenticationMode `json:"authenticationMode,omitempty"`
	Database           *string             `json:"database,omitempty"`
	MaxBatchCount      *float64            `json:"maxBatchCount,omitempty"`
	MaxWriterCount     *float64            `json:"maxWriterCount,omitempty"`
	Password           *string             `json:"password,omitempty"`
	Server             *string             `json:"server,omitempty"`
	Table              *string             `json:"table,omitempty"`
	User               *string             `json:"user,omitempty"`
}

type AzureSqlDatabaseOutputDataSource

type AzureSqlDatabaseOutputDataSource struct {
	Properties *AzureSqlDatabaseDataSourceProperties `json:"properties,omitempty"`
}

func (AzureSqlDatabaseOutputDataSource) MarshalJSON

func (s AzureSqlDatabaseOutputDataSource) MarshalJSON() ([]byte, error)

type AzureSynapseDataSourceProperties

type AzureSynapseDataSourceProperties struct {
	Database *string `json:"database,omitempty"`
	Password *string `json:"password,omitempty"`
	Server   *string `json:"server,omitempty"`
	Table    *string `json:"table,omitempty"`
	User     *string `json:"user,omitempty"`
}

type AzureSynapseOutputDataSource

type AzureSynapseOutputDataSource struct {
	Properties *AzureSynapseDataSourceProperties `json:"properties,omitempty"`
}

func (AzureSynapseOutputDataSource) MarshalJSON

func (s AzureSynapseOutputDataSource) MarshalJSON() ([]byte, error)

type AzureTableOutputDataSource

type AzureTableOutputDataSource struct {
	Properties *AzureTableOutputDataSourceProperties `json:"properties,omitempty"`
}

func (AzureTableOutputDataSource) MarshalJSON

func (s AzureTableOutputDataSource) MarshalJSON() ([]byte, error)

type AzureTableOutputDataSourceProperties

type AzureTableOutputDataSourceProperties struct {
	AccountKey      *string   `json:"accountKey,omitempty"`
	AccountName     *string   `json:"accountName,omitempty"`
	BatchSize       *int64    `json:"batchSize,omitempty"`
	ColumnsToRemove *[]string `json:"columnsToRemove,omitempty"`
	PartitionKey    *string   `json:"partitionKey,omitempty"`
	RowKey          *string   `json:"rowKey,omitempty"`
	Table           *string   `json:"table,omitempty"`
}

type BlobOutputDataSource

type BlobOutputDataSource struct {
	Properties *BlobOutputDataSourceProperties `json:"properties,omitempty"`
}

func (BlobOutputDataSource) MarshalJSON

func (s BlobOutputDataSource) MarshalJSON() ([]byte, error)

type BlobOutputDataSourceProperties added in v0.20220706.1192509

type BlobOutputDataSourceProperties struct {
	AuthenticationMode *AuthenticationMode `json:"authenticationMode,omitempty"`
	BlobPathPrefix     *string             `json:"blobPathPrefix,omitempty"`
	Container          *string             `json:"container,omitempty"`
	DateFormat         *string             `json:"dateFormat,omitempty"`
	PathPattern        *string             `json:"pathPattern,omitempty"`
	StorageAccounts    *[]StorageAccount   `json:"storageAccounts,omitempty"`
	TimeFormat         *string             `json:"timeFormat,omitempty"`
}

type CreateOrReplaceOperationOptions

type CreateOrReplaceOperationOptions struct {
	IfMatch     *string
	IfNoneMatch *string
}

func DefaultCreateOrReplaceOperationOptions

func DefaultCreateOrReplaceOperationOptions() CreateOrReplaceOperationOptions

type CreateOrReplaceOperationResponse

type CreateOrReplaceOperationResponse struct {
	HttpResponse *http.Response
	Model        *Output
}

type CsvSerialization added in v0.20220715.1104737

type CsvSerialization struct {
	Properties *CsvSerializationProperties `json:"properties,omitempty"`
}

func (CsvSerialization) MarshalJSON added in v0.20220715.1104737

func (s CsvSerialization) MarshalJSON() ([]byte, error)

type CsvSerializationProperties added in v0.20220715.1104737

type CsvSerializationProperties struct {
	Encoding       *Encoding `json:"encoding,omitempty"`
	FieldDelimiter *string   `json:"fieldDelimiter,omitempty"`
}

type DeleteOperationResponse

type DeleteOperationResponse struct {
	HttpResponse *http.Response
}

type DiagnosticCondition

type DiagnosticCondition struct {
	Code    *string `json:"code,omitempty"`
	Message *string `json:"message,omitempty"`
	Since   *string `json:"since,omitempty"`
}

type Diagnostics

type Diagnostics struct {
	Conditions *[]DiagnosticCondition `json:"conditions,omitempty"`
}

type DocumentDbOutputDataSource

type DocumentDbOutputDataSource struct {
	Properties *DocumentDbOutputDataSourceProperties `json:"properties,omitempty"`
}

func (DocumentDbOutputDataSource) MarshalJSON

func (s DocumentDbOutputDataSource) MarshalJSON() ([]byte, error)

type DocumentDbOutputDataSourceProperties

type DocumentDbOutputDataSourceProperties struct {
	AccountId             *string `json:"accountId,omitempty"`
	AccountKey            *string `json:"accountKey,omitempty"`
	CollectionNamePattern *string `json:"collectionNamePattern,omitempty"`
	Database              *string `json:"database,omitempty"`
	DocumentId            *string `json:"documentId,omitempty"`
	PartitionKey          *string `json:"partitionKey,omitempty"`
}

type Encoding added in v0.20220715.1104737

type Encoding string
const (
	EncodingUTFEight Encoding = "UTF8"
)

type ErrorResponse

type ErrorResponse struct {
	Code    *string `json:"code,omitempty"`
	Message *string `json:"message,omitempty"`
}

type EventHubOutputDataSource

type EventHubOutputDataSource struct {
	Properties *EventHubOutputDataSourceProperties `json:"properties,omitempty"`
}

func (EventHubOutputDataSource) MarshalJSON

func (s EventHubOutputDataSource) MarshalJSON() ([]byte, error)

type EventHubOutputDataSourceProperties

type EventHubOutputDataSourceProperties struct {
	AuthenticationMode     *AuthenticationMode `json:"authenticationMode,omitempty"`
	EventHubName           *string             `json:"eventHubName,omitempty"`
	PartitionKey           *string             `json:"partitionKey,omitempty"`
	PropertyColumns        *[]string           `json:"propertyColumns,omitempty"`
	ServiceBusNamespace    *string             `json:"serviceBusNamespace,omitempty"`
	SharedAccessPolicyKey  *string             `json:"sharedAccessPolicyKey,omitempty"`
	SharedAccessPolicyName *string             `json:"sharedAccessPolicyName,omitempty"`
}

type EventHubV2OutputDataSource

type EventHubV2OutputDataSource struct {
	Properties *EventHubOutputDataSourceProperties `json:"properties,omitempty"`
}

func (EventHubV2OutputDataSource) MarshalJSON

func (s EventHubV2OutputDataSource) MarshalJSON() ([]byte, error)

type EventSerializationType

type EventSerializationType string
const (
	EventSerializationTypeAvro    EventSerializationType = "Avro"
	EventSerializationTypeCsv     EventSerializationType = "Csv"
	EventSerializationTypeJson    EventSerializationType = "Json"
	EventSerializationTypeParquet EventSerializationType = "Parquet"
)

type GatewayMessageBusOutputDataSource added in v0.20220706.1192509

type GatewayMessageBusOutputDataSource struct {
	Properties *GatewayMessageBusSourceProperties `json:"properties,omitempty"`
}

func (GatewayMessageBusOutputDataSource) MarshalJSON added in v0.20220706.1192509

func (s GatewayMessageBusOutputDataSource) MarshalJSON() ([]byte, error)

type GatewayMessageBusSourceProperties added in v0.20220706.1192509

type GatewayMessageBusSourceProperties struct {
	Topic *string `json:"topic,omitempty"`
}

type GetOperationResponse

type GetOperationResponse struct {
	HttpResponse *http.Response
	Model        *Output
}

type JsonOutputSerializationFormat added in v0.20220715.1104737

type JsonOutputSerializationFormat string
const (
	JsonOutputSerializationFormatArray         JsonOutputSerializationFormat = "Array"
	JsonOutputSerializationFormatLineSeparated JsonOutputSerializationFormat = "LineSeparated"
)

type JsonSerialization added in v0.20220715.1104737

type JsonSerialization struct {
	Properties *JsonSerializationProperties `json:"properties,omitempty"`
}

func (JsonSerialization) MarshalJSON added in v0.20220715.1104737

func (s JsonSerialization) MarshalJSON() ([]byte, error)

type JsonSerializationProperties added in v0.20220715.1104737

type JsonSerializationProperties struct {
	Encoding *Encoding                      `json:"encoding,omitempty"`
	Format   *JsonOutputSerializationFormat `json:"format,omitempty"`
}

type ListByStreamingJobCompleteResult

type ListByStreamingJobCompleteResult struct {
	Items []Output
}

type ListByStreamingJobOperationOptions

type ListByStreamingJobOperationOptions struct {
	Select *string
}

func DefaultListByStreamingJobOperationOptions

func DefaultListByStreamingJobOperationOptions() ListByStreamingJobOperationOptions

type ListByStreamingJobOperationResponse

type ListByStreamingJobOperationResponse struct {
	HttpResponse *http.Response
	Model        *[]Output
	// contains filtered or unexported fields
}

func (ListByStreamingJobOperationResponse) HasMore

func (ListByStreamingJobOperationResponse) LoadMore

type Output

type Output struct {
	Id         *string           `json:"id,omitempty"`
	Name       *string           `json:"name,omitempty"`
	Properties *OutputProperties `json:"properties,omitempty"`
	Type       *string           `json:"type,omitempty"`
}

type OutputDataSource

type OutputDataSource interface {
}

type OutputId

type OutputId struct {
	SubscriptionId    string
	ResourceGroupName string
	StreamingJobName  string
	OutputName        string
}

OutputId is a struct representing the Resource ID for a Output

func NewOutputID

func NewOutputID(subscriptionId string, resourceGroupName string, streamingJobName string, outputName string) OutputId

NewOutputID returns a new OutputId struct

func ParseOutputID

func ParseOutputID(input string) (*OutputId, error)

ParseOutputID parses 'input' into a OutputId

func ParseOutputIDInsensitively

func ParseOutputIDInsensitively(input string) (*OutputId, error)

ParseOutputIDInsensitively parses 'input' case-insensitively into a OutputId note: this method should only be used for API response data and not user input

func (OutputId) ID

func (id OutputId) ID() string

ID returns the formatted Output ID

func (OutputId) Segments

func (id OutputId) Segments() []resourceids.Segment

Segments returns a slice of Resource ID Segments which comprise this Output ID

func (OutputId) String

func (id OutputId) String() string

String returns a human-readable description of this Output ID

type OutputOperationPredicate

type OutputOperationPredicate struct {
	Id   *string
	Name *string
	Type *string
}

func (OutputOperationPredicate) Matches

func (p OutputOperationPredicate) Matches(input Output) bool

type OutputProperties

type OutputProperties struct {
	Datasource    OutputDataSource `json:"datasource"`
	Diagnostics   *Diagnostics     `json:"diagnostics,omitempty"`
	Etag          *string          `json:"etag,omitempty"`
	Serialization Serialization    `json:"serialization"`
	SizeWindow    *int64           `json:"sizeWindow,omitempty"`
	TimeWindow    *string          `json:"timeWindow,omitempty"`
}

func (*OutputProperties) UnmarshalJSON

func (s *OutputProperties) UnmarshalJSON(bytes []byte) error

type OutputsClient

type OutputsClient struct {
	Client autorest.Client
	// contains filtered or unexported fields
}

func NewOutputsClientWithBaseURI

func NewOutputsClientWithBaseURI(endpoint string) OutputsClient

func (OutputsClient) CreateOrReplace

func (c OutputsClient) CreateOrReplace(ctx context.Context, id OutputId, input Output, options CreateOrReplaceOperationOptions) (result CreateOrReplaceOperationResponse, err error)

CreateOrReplace ...

func (OutputsClient) Delete

func (c OutputsClient) Delete(ctx context.Context, id OutputId) (result DeleteOperationResponse, err error)

Delete ...

func (OutputsClient) Get

func (c OutputsClient) Get(ctx context.Context, id OutputId) (result GetOperationResponse, err error)

Get ...

func (OutputsClient) ListByStreamingJob

ListByStreamingJob ...

func (OutputsClient) ListByStreamingJobComplete

ListByStreamingJobComplete retrieves all of the results into a single object

func (OutputsClient) ListByStreamingJobCompleteMatchingPredicate

func (c OutputsClient) ListByStreamingJobCompleteMatchingPredicate(ctx context.Context, id StreamingJobId, options ListByStreamingJobOperationOptions, predicate OutputOperationPredicate) (resp ListByStreamingJobCompleteResult, err error)

ListByStreamingJobCompleteMatchingPredicate retrieves all of the results and then applied the predicate

func (OutputsClient) Test

func (c OutputsClient) Test(ctx context.Context, id OutputId, input Output) (result TestOperationResponse, err error)

Test ...

func (OutputsClient) TestThenPoll

func (c OutputsClient) TestThenPoll(ctx context.Context, id OutputId, input Output) error

TestThenPoll performs Test then polls until it's completed

func (OutputsClient) Update

func (c OutputsClient) Update(ctx context.Context, id OutputId, input Output, options UpdateOperationOptions) (result UpdateOperationResponse, err error)

Update ...

type ParquetSerialization added in v0.20220715.1104737

type ParquetSerialization struct {
	Properties *interface{} `json:"properties,omitempty"`
}

func (ParquetSerialization) MarshalJSON added in v0.20220715.1104737

func (s ParquetSerialization) MarshalJSON() ([]byte, error)

type PowerBIOutputDataSource

type PowerBIOutputDataSource struct {
	Properties *PowerBIOutputDataSourceProperties `json:"properties,omitempty"`
}

func (PowerBIOutputDataSource) MarshalJSON

func (s PowerBIOutputDataSource) MarshalJSON() ([]byte, error)

type PowerBIOutputDataSourceProperties

type PowerBIOutputDataSourceProperties struct {
	AuthenticationMode     *AuthenticationMode `json:"authenticationMode,omitempty"`
	Dataset                *string             `json:"dataset,omitempty"`
	GroupId                *string             `json:"groupId,omitempty"`
	GroupName              *string             `json:"groupName,omitempty"`
	RefreshToken           *string             `json:"refreshToken,omitempty"`
	Table                  *string             `json:"table,omitempty"`
	TokenUserDisplayName   *string             `json:"tokenUserDisplayName,omitempty"`
	TokenUserPrincipalName *string             `json:"tokenUserPrincipalName,omitempty"`
}

type ResourceTestStatus

type ResourceTestStatus struct {
	Error  *ErrorResponse `json:"error,omitempty"`
	Status *string        `json:"status,omitempty"`
}

type Serialization

type Serialization interface {
}

type ServiceBusQueueOutputDataSource

type ServiceBusQueueOutputDataSource struct {
	Properties *ServiceBusQueueOutputDataSourceProperties `json:"properties,omitempty"`
}

func (ServiceBusQueueOutputDataSource) MarshalJSON

func (s ServiceBusQueueOutputDataSource) MarshalJSON() ([]byte, error)

type ServiceBusQueueOutputDataSourceProperties

type ServiceBusQueueOutputDataSourceProperties struct {
	AuthenticationMode     *AuthenticationMode `json:"authenticationMode,omitempty"`
	PropertyColumns        *[]string           `json:"propertyColumns,omitempty"`
	QueueName              *string             `json:"queueName,omitempty"`
	ServiceBusNamespace    *string             `json:"serviceBusNamespace,omitempty"`
	SharedAccessPolicyKey  *string             `json:"sharedAccessPolicyKey,omitempty"`
	SharedAccessPolicyName *string             `json:"sharedAccessPolicyName,omitempty"`
	SystemPropertyColumns  *interface{}        `json:"systemPropertyColumns,omitempty"`
}

type ServiceBusTopicOutputDataSource

type ServiceBusTopicOutputDataSource struct {
	Properties *ServiceBusTopicOutputDataSourceProperties `json:"properties,omitempty"`
}

func (ServiceBusTopicOutputDataSource) MarshalJSON

func (s ServiceBusTopicOutputDataSource) MarshalJSON() ([]byte, error)

type ServiceBusTopicOutputDataSourceProperties

type ServiceBusTopicOutputDataSourceProperties struct {
	AuthenticationMode     *AuthenticationMode `json:"authenticationMode,omitempty"`
	PropertyColumns        *[]string           `json:"propertyColumns,omitempty"`
	ServiceBusNamespace    *string             `json:"serviceBusNamespace,omitempty"`
	SharedAccessPolicyKey  *string             `json:"sharedAccessPolicyKey,omitempty"`
	SharedAccessPolicyName *string             `json:"sharedAccessPolicyName,omitempty"`
	SystemPropertyColumns  *map[string]string  `json:"systemPropertyColumns,omitempty"`
	TopicName              *string             `json:"topicName,omitempty"`
}

type StorageAccount

type StorageAccount struct {
	AccountKey  *string `json:"accountKey,omitempty"`
	AccountName *string `json:"accountName,omitempty"`
}

type StreamingJobId

type StreamingJobId struct {
	SubscriptionId    string
	ResourceGroupName string
	StreamingJobName  string
}

StreamingJobId is a struct representing the Resource ID for a Streaming Job

func NewStreamingJobID

func NewStreamingJobID(subscriptionId string, resourceGroupName string, streamingJobName string) StreamingJobId

NewStreamingJobID returns a new StreamingJobId struct

func ParseStreamingJobID

func ParseStreamingJobID(input string) (*StreamingJobId, error)

ParseStreamingJobID parses 'input' into a StreamingJobId

func ParseStreamingJobIDInsensitively

func ParseStreamingJobIDInsensitively(input string) (*StreamingJobId, error)

ParseStreamingJobIDInsensitively parses 'input' case-insensitively into a StreamingJobId note: this method should only be used for API response data and not user input

func (StreamingJobId) ID

func (id StreamingJobId) ID() string

ID returns the formatted Streaming Job ID

func (StreamingJobId) Segments

func (id StreamingJobId) Segments() []resourceids.Segment

Segments returns a slice of Resource ID Segments which comprise this Streaming Job ID

func (StreamingJobId) String

func (id StreamingJobId) String() string

String returns a human-readable description of this Streaming Job ID

type TestOperationResponse

type TestOperationResponse struct {
	Poller       polling.LongRunningPoller
	HttpResponse *http.Response
}

type UpdateOperationOptions

type UpdateOperationOptions struct {
	IfMatch *string
}

func DefaultUpdateOperationOptions

func DefaultUpdateOperationOptions() UpdateOperationOptions

type UpdateOperationResponse

type UpdateOperationResponse struct {
	HttpResponse *http.Response
	Model        *Output
}

Source Files

Jump to

Keyboard shortcuts

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