outputs

package
v0.20241009.1142232 Latest Latest
Warning

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

 Go to latest Published: Oct 9, 2024 License: MPL-2.0 Imports: 11 Imported by: 1

README

github.com/hashicorp/go-azure-sdk/resource-manager/streamanalytics/2021-10-01-preview/outputs Documentation

The outputs SDK allows for interaction with Azure Resource Manager streamanalytics (API Version 2021-10-01-preview).

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/2021-10-01-preview/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", "streamingJobName", "outputName")

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", "streamingJobName", "outputName")

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", "streamingJobName", "outputName")

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", "streamingJobName")

// 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", "streamingJobName", "outputName")

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", "streamingJobName", "outputName")

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 PossibleValuesForBlobWriteMode 

func PossibleValuesForBlobWriteMode() []string

func PossibleValuesForEncoding 

func PossibleValuesForEncoding() []string

func PossibleValuesForEventSerializationType 

func PossibleValuesForEventSerializationType() []string

func PossibleValuesForJsonOutputSerializationFormat 

func PossibleValuesForJsonOutputSerializationFormat() []string

func PossibleValuesForOutputWatermarkMode 

func PossibleValuesForOutputWatermarkMode() []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"
)

func (*AuthenticationMode) UnmarshalJSON added in v0.20240208.1095436 

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

type AvroSerialization 

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

	Type EventSerializationType `json:"type"`
}

func (AvroSerialization) MarshalJSON 

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

func (AvroSerialization) Serialization added in v0.20240920.1135249 

func (s AvroSerialization) Serialization() BaseSerializationImpl

type AzureDataExplorerOutputDataSource 

type AzureDataExplorerOutputDataSource struct {
	Properties *AzureDataExplorerOutputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (AzureDataExplorerOutputDataSource) MarshalJSON 

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

func (AzureDataExplorerOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s AzureDataExplorerOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type AzureDataExplorerOutputDataSourceProperties 

type AzureDataExplorerOutputDataSourceProperties struct {
	AuthenticationMode *AuthenticationMode `json:"authenticationMode,omitempty"`
	Cluster            *string             `json:"cluster,omitempty"`
	Database           *string             `json:"database,omitempty"`
	Table              *string             `json:"table,omitempty"`
}

type AzureDataLakeStoreOutputDataSource 

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

	Type string `json:"type"`
}

func (AzureDataLakeStoreOutputDataSource) MarshalJSON 

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

func (AzureDataLakeStoreOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s AzureDataLakeStoreOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

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"`

	Type string `json:"type"`
}

func (AzureFunctionOutputDataSource) MarshalJSON 

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

func (AzureFunctionOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s AzureFunctionOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

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"`

	Type string `json:"type"`
}

func (AzureSqlDatabaseOutputDataSource) MarshalJSON 

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

func (AzureSqlDatabaseOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s AzureSqlDatabaseOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type AzureSynapseDataSourceProperties 

type AzureSynapseDataSourceProperties struct {
	AuthenticationMode *AuthenticationMode `json:"authenticationMode,omitempty"`
	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"`

	Type string `json:"type"`
}

func (AzureSynapseOutputDataSource) MarshalJSON 

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

func (AzureSynapseOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s AzureSynapseOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type AzureTableOutputDataSource 

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

	Type string `json:"type"`
}

func (AzureTableOutputDataSource) MarshalJSON 

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

func (AzureTableOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s AzureTableOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

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 BaseOutputDataSourceImpl added in v0.20240920.1135249 

type BaseOutputDataSourceImpl struct {
	Type string `json:"type"`
}

func (BaseOutputDataSourceImpl) OutputDataSource added in v0.20240920.1135249 

func (s BaseOutputDataSourceImpl) OutputDataSource() BaseOutputDataSourceImpl

type BaseSerializationImpl added in v0.20240920.1135249 

type BaseSerializationImpl struct {
	Type EventSerializationType `json:"type"`
}

func (BaseSerializationImpl) Serialization added in v0.20240920.1135249 

func (s BaseSerializationImpl) Serialization() BaseSerializationImpl

type BlobOutputDataSource 

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

	Type string `json:"type"`
}

func (BlobOutputDataSource) MarshalJSON 

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

func (BlobOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s BlobOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type BlobOutputDataSourceProperties 

type BlobOutputDataSourceProperties struct {
	AuthenticationMode *AuthenticationMode `json:"authenticationMode,omitempty"`
	BlobPathPrefix     *string             `json:"blobPathPrefix,omitempty"`
	BlobWriteMode      *BlobWriteMode      `json:"blobWriteMode,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 BlobWriteMode 

type BlobWriteMode string
const (
	BlobWriteModeAppend BlobWriteMode = "Append"
	BlobWriteModeOnce   BlobWriteMode = "Once"
)

func (*BlobWriteMode) UnmarshalJSON added in v0.20240208.1095436 

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

type CreateOrReplaceOperationOptions 

type CreateOrReplaceOperationOptions struct {
	IfMatch     *string
	IfNoneMatch *string
}

func DefaultCreateOrReplaceOperationOptions 

func DefaultCreateOrReplaceOperationOptions() CreateOrReplaceOperationOptions

func (CreateOrReplaceOperationOptions) ToHeaders added in v0.20240208.1095436 

func (o CreateOrReplaceOperationOptions) ToHeaders() *client.Headers

func (CreateOrReplaceOperationOptions) ToOData added in v0.20240208.1095436 

func (o CreateOrReplaceOperationOptions) ToOData() *odata.Query

func (CreateOrReplaceOperationOptions) ToQuery added in v0.20240208.1095436 

func (o CreateOrReplaceOperationOptions) ToQuery() *client.QueryParams

type CreateOrReplaceOperationResponse 

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

type CsvSerialization 

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

	Type EventSerializationType `json:"type"`
}

func (CsvSerialization) MarshalJSON 

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

func (CsvSerialization) Serialization added in v0.20240920.1135249 

func (s CsvSerialization) Serialization() BaseSerializationImpl

type CsvSerializationProperties 

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

type CustomClrSerialization 

type CustomClrSerialization struct {
	Properties *CustomClrSerializationProperties `json:"properties,omitempty"`

	Type EventSerializationType `json:"type"`
}

func (CustomClrSerialization) MarshalJSON 

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

func (CustomClrSerialization) Serialization added in v0.20240920.1135249 

func (s CustomClrSerialization) Serialization() BaseSerializationImpl

type CustomClrSerializationProperties 

type CustomClrSerializationProperties struct {
	SerializationClassName *string `json:"serializationClassName,omitempty"`
	SerializationDllPath   *string `json:"serializationDllPath,omitempty"`
}

type DeleteOperationResponse 

type DeleteOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
}

type DeltaSerialization 

type DeltaSerialization struct {
	Properties *DeltaSerializationProperties `json:"properties,omitempty"`

	Type EventSerializationType `json:"type"`
}

func (DeltaSerialization) MarshalJSON 

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

func (DeltaSerialization) Serialization added in v0.20240920.1135249 

func (s DeltaSerialization) Serialization() BaseSerializationImpl

type DeltaSerializationProperties 

type DeltaSerializationProperties struct {
	DeltaTablePath   string    `json:"deltaTablePath"`
	PartitionColumns *[]string `json:"partitionColumns,omitempty"`
}

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"`

	Type string `json:"type"`
}

func (DocumentDbOutputDataSource) MarshalJSON 

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

func (DocumentDbOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s DocumentDbOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type DocumentDbOutputDataSourceProperties 

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

type Encoding 

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

func (*Encoding) UnmarshalJSON added in v0.20240208.1095436 

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

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"`

	Type string `json:"type"`
}

func (EventHubOutputDataSource) MarshalJSON 

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

func (EventHubOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s EventHubOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type EventHubOutputDataSourceProperties 

type EventHubOutputDataSourceProperties struct {
	AuthenticationMode     *AuthenticationMode `json:"authenticationMode,omitempty"`
	EventHubName           *string             `json:"eventHubName,omitempty"`
	PartitionCount         *int64              `json:"partitionCount,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"`

	Type string `json:"type"`
}

func (EventHubV2OutputDataSource) MarshalJSON 

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

func (EventHubV2OutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s EventHubV2OutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type EventSerializationType 

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

func (*EventSerializationType) UnmarshalJSON added in v0.20240208.1095436 

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

type GatewayMessageBusOutputDataSource 

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

	Type string `json:"type"`
}

func (GatewayMessageBusOutputDataSource) MarshalJSON 

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

func (GatewayMessageBusOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s GatewayMessageBusOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type GatewayMessageBusSourceProperties 

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

type GetOperationResponse 

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

type JsonOutputSerializationFormat 

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

func (*JsonOutputSerializationFormat) UnmarshalJSON added in v0.20240208.1095436 

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

type JsonSerialization 

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

	Type EventSerializationType `json:"type"`
}

func (JsonSerialization) MarshalJSON 

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

func (JsonSerialization) Serialization added in v0.20240920.1135249 

func (s JsonSerialization) Serialization() BaseSerializationImpl

type JsonSerializationProperties 

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

type LastOutputEventTimestamp 

type LastOutputEventTimestamp struct {
	LastOutputEventTime *string `json:"lastOutputEventTime,omitempty"`
	LastUpdateTime      *string `json:"lastUpdateTime,omitempty"`
}

type ListByStreamingJobCompleteResult 

type ListByStreamingJobCompleteResult struct {
	LatestHttpResponse *http.Response
	Items              []Output
}

type ListByStreamingJobCustomPager added in v0.20240628.1153531 

type ListByStreamingJobCustomPager struct {
	NextLink *odata.Link `json:"nextLink"`
}
func (p *ListByStreamingJobCustomPager) NextPageLink() *odata.Link

type ListByStreamingJobOperationOptions 

type ListByStreamingJobOperationOptions struct {
	Select *string
}

func DefaultListByStreamingJobOperationOptions 

func DefaultListByStreamingJobOperationOptions() ListByStreamingJobOperationOptions

func (ListByStreamingJobOperationOptions) ToHeaders added in v0.20240208.1095436 

func (o ListByStreamingJobOperationOptions) ToHeaders() *client.Headers

func (ListByStreamingJobOperationOptions) ToOData added in v0.20240208.1095436 

func (o ListByStreamingJobOperationOptions) ToOData() *odata.Query

func (ListByStreamingJobOperationOptions) ToQuery added in v0.20240208.1095436 

func (o ListByStreamingJobOperationOptions) ToQuery() *client.QueryParams

type ListByStreamingJobOperationResponse 

type ListByStreamingJobOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *[]Output
}

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 {
	OutputDataSource() BaseOutputDataSourceImpl
}

func UnmarshalOutputDataSourceImplementation added in v0.20240920.1135249 

func UnmarshalOutputDataSourceImplementation(input []byte) (OutputDataSource, error)

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) FromParseResult 

func (id *OutputId) FromParseResult(input resourceids.ParseResult) error

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"`
	LastOutputEventTimestamps *[]LastOutputEventTimestamp `json:"lastOutputEventTimestamps,omitempty"`
	Serialization             Serialization               `json:"serialization"`
	SizeWindow                *int64                      `json:"sizeWindow,omitempty"`
	TimeWindow                *string                     `json:"timeWindow,omitempty"`
	WatermarkSettings         *OutputWatermarkProperties  `json:"watermarkSettings,omitempty"`
}

func (*OutputProperties) UnmarshalJSON 

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

type OutputWatermarkMode 

type OutputWatermarkMode string
const (
	OutputWatermarkModeNone                                OutputWatermarkMode = "None"
	OutputWatermarkModeSendCurrentPartitionWatermark       OutputWatermarkMode = "SendCurrentPartitionWatermark"
	OutputWatermarkModeSendLowestWatermarkAcrossPartitions OutputWatermarkMode = "SendLowestWatermarkAcrossPartitions"
)

func (*OutputWatermarkMode) UnmarshalJSON added in v0.20240208.1095436 

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

type OutputWatermarkProperties 

type OutputWatermarkProperties struct {
	MaxWatermarkDifferenceAcrossPartitions *string              `json:"maxWatermarkDifferenceAcrossPartitions,omitempty"`
	WatermarkMode                          *OutputWatermarkMode `json:"watermarkMode,omitempty"`
}

type OutputsClient 

type OutputsClient struct {
	Client *resourcemanager.Client
}

func NewOutputsClientWithBaseURI 

func NewOutputsClientWithBaseURI(sdkApi sdkEnv.Api) (*OutputsClient, error)

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 

func (c OutputsClient) ListByStreamingJob(ctx context.Context, id StreamingJobId, options ListByStreamingJobOperationOptions) (result ListByStreamingJobOperationResponse, err error)

ListByStreamingJob ...

func (OutputsClient) ListByStreamingJobComplete 

func (c OutputsClient) ListByStreamingJobComplete(ctx context.Context, id StreamingJobId, options ListByStreamingJobOperationOptions) (ListByStreamingJobCompleteResult, error)

ListByStreamingJobComplete retrieves all the results into a single object

func (OutputsClient) ListByStreamingJobCompleteMatchingPredicate 

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

ListByStreamingJobCompleteMatchingPredicate retrieves all the results and then applies the predicate

func (OutputsClient) Update 

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

Update ...

type ParquetSerialization 

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

	Type EventSerializationType `json:"type"`
}

func (ParquetSerialization) MarshalJSON 

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

func (ParquetSerialization) Serialization added in v0.20240920.1135249 

func (s ParquetSerialization) Serialization() BaseSerializationImpl

type PostgreSQLDataSourceProperties 

type PostgreSQLDataSourceProperties struct {
	AuthenticationMode *AuthenticationMode `json:"authenticationMode,omitempty"`
	Database           *string             `json:"database,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 PostgreSQLOutputDataSource 

type PostgreSQLOutputDataSource struct {
	Properties *PostgreSQLDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (PostgreSQLOutputDataSource) MarshalJSON 

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

func (PostgreSQLOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s PostgreSQLOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type PowerBIOutputDataSource 

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

	Type string `json:"type"`
}

func (PowerBIOutputDataSource) MarshalJSON 

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

func (PowerBIOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s PowerBIOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

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 RawOutputDataSourceImpl 

type RawOutputDataSourceImpl struct {
	Type   string
	Values map[string]interface{}
	// contains filtered or unexported fields
}

RawOutputDataSourceImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).

func (RawOutputDataSourceImpl) OutputDataSource added in v0.20240920.1135249 

func (s RawOutputDataSourceImpl) OutputDataSource() BaseOutputDataSourceImpl

type RawOutputDatasource 

type RawOutputDatasource struct {
	Properties *RawOutputDatasourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (RawOutputDatasource) MarshalJSON 

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

func (RawOutputDatasource) OutputDataSource added in v0.20240920.1135249 

func (s RawOutputDatasource) OutputDataSource() BaseOutputDataSourceImpl

type RawOutputDatasourceProperties 

type RawOutputDatasourceProperties struct {
	PayloadUri *string `json:"payloadUri,omitempty"`
}

type RawSerializationImpl 

type RawSerializationImpl struct {
	Type   string
	Values map[string]interface{}
	// contains filtered or unexported fields
}

RawSerializationImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).

func (RawSerializationImpl) Serialization added in v0.20240920.1135249 

func (s RawSerializationImpl) Serialization() BaseSerializationImpl

type ResourceTestStatus 

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

type Serialization 

type Serialization interface {
	Serialization() BaseSerializationImpl
}

func UnmarshalSerializationImplementation added in v0.20240920.1135249 

func UnmarshalSerializationImplementation(input []byte) (Serialization, error)

type ServiceBusQueueOutputDataSource 

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

	Type string `json:"type"`
}

func (ServiceBusQueueOutputDataSource) MarshalJSON 

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

func (ServiceBusQueueOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s ServiceBusQueueOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

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"`

	Type string `json:"type"`
}

func (ServiceBusTopicOutputDataSource) MarshalJSON 

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

func (ServiceBusTopicOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s ServiceBusTopicOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

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"`
	AuthenticationMode *AuthenticationMode `json:"authenticationMode,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) FromParseResult 

func (id *StreamingJobId) FromParseResult(input resourceids.ParseResult) error

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 UpdateOperationOptions 

type UpdateOperationOptions struct {
	IfMatch *string
}

func DefaultUpdateOperationOptions 

func DefaultUpdateOperationOptions() UpdateOperationOptions

func (UpdateOperationOptions) ToHeaders added in v0.20240208.1095436 

func (o UpdateOperationOptions) ToHeaders() *client.Headers

func (UpdateOperationOptions) ToOData added in v0.20240208.1095436 

func (o UpdateOperationOptions) ToOData() *odata.Query

func (UpdateOperationOptions) ToQuery added in v0.20240208.1095436 

func (o UpdateOperationOptions) ToQuery() *client.QueryParams

type UpdateOperationResponse 

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

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.