inputs

package
v0.20241126.2320 Latest Latest
Warning

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

 Go to latest Published: Nov 26, 2024 License: MPL-2.0 Imports: 11 Imported by: 0

README

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

The inputs SDK allows for interaction with Azure Resource Manager 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/inputs"

Client Initialization

client := inputs.NewInputsClientWithBaseURI("https://management.azure.com")
client.Client.Authorizer = authorizer

Example Usage: InputsClient.CreateOrReplace

ctx := context.TODO()
id := inputs.NewInputID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobName", "inputName")

payload := inputs.Input{
	// ...
}


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

Example Usage: InputsClient.Delete

ctx := context.TODO()
id := inputs.NewInputID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobName", "inputName")

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: InputsClient.Get

ctx := context.TODO()
id := inputs.NewInputID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobName", "inputName")

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: InputsClient.ListByStreamingJob

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

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

Example Usage: InputsClient.Test

ctx := context.TODO()
id := inputs.NewInputID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobName", "inputName")

payload := inputs.Input{
	// ...
}


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

Example Usage: InputsClient.Update

ctx := context.TODO()
id := inputs.NewInputID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobName", "inputName")

payload := inputs.Input{
	// ...
}


read, err := client.Update(ctx, id, payload, inputs.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 PossibleValuesForCompressionType 

func PossibleValuesForCompressionType() []string

func PossibleValuesForEncoding 

func PossibleValuesForEncoding() []string

func PossibleValuesForEventSerializationType 

func PossibleValuesForEventSerializationType() []string

func PossibleValuesForJsonOutputSerializationFormat 

func PossibleValuesForJsonOutputSerializationFormat() []string

func PossibleValuesForRefreshType 

func PossibleValuesForRefreshType() []string

func ValidateInputID 

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

ValidateInputID checks that 'input' can be parsed as a Input 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 

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 

func (s AvroSerialization) Serialization() BaseSerializationImpl

type AzureSqlReferenceInputDataSource 

type AzureSqlReferenceInputDataSource struct {
	Properties *AzureSqlReferenceInputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (AzureSqlReferenceInputDataSource) MarshalJSON 

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

func (AzureSqlReferenceInputDataSource) ReferenceInputDataSource 

func (s AzureSqlReferenceInputDataSource) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl

type AzureSqlReferenceInputDataSourceProperties 

type AzureSqlReferenceInputDataSourceProperties struct {
	Database           *string      `json:"database,omitempty"`
	DeltaSnapshotQuery *string      `json:"deltaSnapshotQuery,omitempty"`
	FullSnapshotQuery  *string      `json:"fullSnapshotQuery,omitempty"`
	Password           *string      `json:"password,omitempty"`
	RefreshRate        *string      `json:"refreshRate,omitempty"`
	RefreshType        *RefreshType `json:"refreshType,omitempty"`
	Server             *string      `json:"server,omitempty"`
	Table              *string      `json:"table,omitempty"`
	User               *string      `json:"user,omitempty"`
}

type BaseInputPropertiesImpl 

type BaseInputPropertiesImpl struct {
	Compression   *Compression  `json:"compression,omitempty"`
	Diagnostics   *Diagnostics  `json:"diagnostics,omitempty"`
	Etag          *string       `json:"etag,omitempty"`
	PartitionKey  *string       `json:"partitionKey,omitempty"`
	Serialization Serialization `json:"serialization"`
	Type          string        `json:"type"`
}

func (BaseInputPropertiesImpl) InputProperties 

func (s BaseInputPropertiesImpl) InputProperties() BaseInputPropertiesImpl

func (*BaseInputPropertiesImpl) UnmarshalJSON 

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

type BaseReferenceInputDataSourceImpl 

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

func (BaseReferenceInputDataSourceImpl) ReferenceInputDataSource 

func (s BaseReferenceInputDataSourceImpl) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl

type BaseSerializationImpl 

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

func (BaseSerializationImpl) Serialization 

func (s BaseSerializationImpl) Serialization() BaseSerializationImpl

type BaseStreamInputDataSourceImpl 

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

func (BaseStreamInputDataSourceImpl) StreamInputDataSource 

func (s BaseStreamInputDataSourceImpl) StreamInputDataSource() BaseStreamInputDataSourceImpl

type BlobDataSourceProperties 

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

type BlobReferenceInputDataSource struct {
	Properties *BlobDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (BlobReferenceInputDataSource) MarshalJSON 

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

func (BlobReferenceInputDataSource) ReferenceInputDataSource 

func (s BlobReferenceInputDataSource) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl

type BlobStreamInputDataSource 

type BlobStreamInputDataSource struct {
	Properties *BlobStreamInputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (BlobStreamInputDataSource) MarshalJSON 

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

func (BlobStreamInputDataSource) StreamInputDataSource 

func (s BlobStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type BlobStreamInputDataSourceProperties 

type BlobStreamInputDataSourceProperties struct {
	AuthenticationMode   *AuthenticationMode `json:"authenticationMode,omitempty"`
	Container            *string             `json:"container,omitempty"`
	DateFormat           *string             `json:"dateFormat,omitempty"`
	PathPattern          *string             `json:"pathPattern,omitempty"`
	SourcePartitionCount *int64              `json:"sourcePartitionCount,omitempty"`
	StorageAccounts      *[]StorageAccount   `json:"storageAccounts,omitempty"`
	TimeFormat           *string             `json:"timeFormat,omitempty"`
}

type Compression 

type Compression struct {
	Type CompressionType `json:"type"`
}

type CompressionType 

type CompressionType string
const (
	CompressionTypeDeflate CompressionType = "Deflate"
	CompressionTypeGZip    CompressionType = "GZip"
	CompressionTypeNone    CompressionType = "None"
)

func (*CompressionType) UnmarshalJSON 

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

type CreateOrReplaceOperationOptions 

type CreateOrReplaceOperationOptions struct {
	IfMatch     *string
	IfNoneMatch *string
}

func DefaultCreateOrReplaceOperationOptions 

func DefaultCreateOrReplaceOperationOptions() CreateOrReplaceOperationOptions

func (CreateOrReplaceOperationOptions) ToHeaders 

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

func (CreateOrReplaceOperationOptions) ToOData 

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

func (CreateOrReplaceOperationOptions) ToQuery 

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

type CreateOrReplaceOperationResponse 

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

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 

func (s CsvSerialization) Serialization() BaseSerializationImpl

type CsvSerializationProperties 

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

type DeleteOperationResponse 

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

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 Encoding 

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

func (*Encoding) UnmarshalJSON 

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

type ErrorResponse 

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

type EventHubStreamInputDataSource 

type EventHubStreamInputDataSource struct {
	Properties *EventHubStreamInputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (EventHubStreamInputDataSource) MarshalJSON 

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

func (EventHubStreamInputDataSource) StreamInputDataSource 

func (s EventHubStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type EventHubStreamInputDataSourceProperties 

type EventHubStreamInputDataSourceProperties struct {
	AuthenticationMode     *AuthenticationMode `json:"authenticationMode,omitempty"`
	ConsumerGroupName      *string             `json:"consumerGroupName,omitempty"`
	EventHubName           *string             `json:"eventHubName,omitempty"`
	ServiceBusNamespace    *string             `json:"serviceBusNamespace,omitempty"`
	SharedAccessPolicyKey  *string             `json:"sharedAccessPolicyKey,omitempty"`
	SharedAccessPolicyName *string             `json:"sharedAccessPolicyName,omitempty"`
}

type EventHubV2StreamInputDataSource 

type EventHubV2StreamInputDataSource struct {
	Properties *EventHubStreamInputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (EventHubV2StreamInputDataSource) MarshalJSON 

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

func (EventHubV2StreamInputDataSource) StreamInputDataSource 

func (s EventHubV2StreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type EventSerializationType 

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

func (*EventSerializationType) UnmarshalJSON 

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

type FileReferenceInputDataSource 

type FileReferenceInputDataSource struct {
	Properties *FileReferenceInputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (FileReferenceInputDataSource) MarshalJSON 

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

func (FileReferenceInputDataSource) ReferenceInputDataSource 

func (s FileReferenceInputDataSource) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl

type FileReferenceInputDataSourceProperties 

type FileReferenceInputDataSourceProperties struct {
	Path *string `json:"path,omitempty"`
}

type GatewayMessageBusSourceProperties 

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

type GatewayMessageBusStreamInputDataSource 

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

	Type string `json:"type"`
}

func (GatewayMessageBusStreamInputDataSource) MarshalJSON 

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

func (GatewayMessageBusStreamInputDataSource) StreamInputDataSource 

func (s GatewayMessageBusStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type GetOperationResponse 

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

type Input 

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

func (*Input) UnmarshalJSON 

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

type InputId 

type InputId struct {
	SubscriptionId    string
	ResourceGroupName string
	StreamingJobName  string
	InputName         string
}

InputId is a struct representing the Resource ID for a Input

func NewInputID 

func NewInputID(subscriptionId string, resourceGroupName string, streamingJobName string, inputName string) InputId

NewInputID returns a new InputId struct

func ParseInputID 

func ParseInputID(input string) (*InputId, error)

ParseInputID parses 'input' into a InputId

func ParseInputIDInsensitively 

func ParseInputIDInsensitively(input string) (*InputId, error)

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

func (*InputId) FromParseResult 

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

func (InputId) ID 

func (id InputId) ID() string

ID returns the formatted Input ID

func (InputId) Segments 

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

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

func (InputId) String 

func (id InputId) String() string

String returns a human-readable description of this Input ID

type InputOperationPredicate 

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

func (InputOperationPredicate) Matches 

func (p InputOperationPredicate) Matches(input Input) bool

type InputProperties 

type InputProperties interface {
	InputProperties() BaseInputPropertiesImpl
}

func UnmarshalInputPropertiesImplementation 

func UnmarshalInputPropertiesImplementation(input []byte) (InputProperties, error)

type InputsClient 

type InputsClient struct {
	Client *resourcemanager.Client
}

func NewInputsClientWithBaseURI 

func NewInputsClientWithBaseURI(sdkApi sdkEnv.Api) (*InputsClient, error)

func (InputsClient) CreateOrReplace 

func (c InputsClient) CreateOrReplace(ctx context.Context, id InputId, input Input, options CreateOrReplaceOperationOptions) (result CreateOrReplaceOperationResponse, err error)

CreateOrReplace ...

func (InputsClient) Delete 

func (c InputsClient) Delete(ctx context.Context, id InputId) (result DeleteOperationResponse, err error)

Delete ...

func (InputsClient) Get 

func (c InputsClient) Get(ctx context.Context, id InputId) (result GetOperationResponse, err error)

Get ...

func (InputsClient) ListByStreamingJob 

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

ListByStreamingJob ...

func (InputsClient) ListByStreamingJobComplete 

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

ListByStreamingJobComplete retrieves all the results into a single object

func (InputsClient) ListByStreamingJobCompleteMatchingPredicate 

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

ListByStreamingJobCompleteMatchingPredicate retrieves all the results and then applies the predicate

func (InputsClient) Update 

func (c InputsClient) Update(ctx context.Context, id InputId, input Input, options UpdateOperationOptions) (result UpdateOperationResponse, err error)

Update ...

type IoTHubStreamInputDataSource 

type IoTHubStreamInputDataSource struct {
	Properties *IoTHubStreamInputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (IoTHubStreamInputDataSource) MarshalJSON 

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

func (IoTHubStreamInputDataSource) StreamInputDataSource 

func (s IoTHubStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type IoTHubStreamInputDataSourceProperties 

type IoTHubStreamInputDataSourceProperties struct {
	ConsumerGroupName      *string `json:"consumerGroupName,omitempty"`
	Endpoint               *string `json:"endpoint,omitempty"`
	IotHubNamespace        *string `json:"iotHubNamespace,omitempty"`
	SharedAccessPolicyKey  *string `json:"sharedAccessPolicyKey,omitempty"`
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty"`
}

type JsonOutputSerializationFormat 

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

func (*JsonOutputSerializationFormat) UnmarshalJSON 

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 

func (s JsonSerialization) Serialization() BaseSerializationImpl

type JsonSerializationProperties 

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

type ListByStreamingJobCompleteResult 

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

type ListByStreamingJobCustomPager 

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 

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

func (ListByStreamingJobOperationOptions) ToOData 

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

func (ListByStreamingJobOperationOptions) ToQuery 

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

type ListByStreamingJobOperationResponse 

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

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 

func (s ParquetSerialization) Serialization() BaseSerializationImpl

type RawInputPropertiesImpl 

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

RawInputPropertiesImpl 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 (RawInputPropertiesImpl) InputProperties 

func (s RawInputPropertiesImpl) InputProperties() BaseInputPropertiesImpl

type RawReferenceInputDataSourceImpl 

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

RawReferenceInputDataSourceImpl 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 (RawReferenceInputDataSourceImpl) ReferenceInputDataSource 

func (s RawReferenceInputDataSourceImpl) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl

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 

func (s RawSerializationImpl) Serialization() BaseSerializationImpl

type RawStreamInputDataSourceImpl 

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

RawStreamInputDataSourceImpl 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 (RawStreamInputDataSourceImpl) StreamInputDataSource 

func (s RawStreamInputDataSourceImpl) StreamInputDataSource() BaseStreamInputDataSourceImpl

type ReferenceInputDataSource 

type ReferenceInputDataSource interface {
	ReferenceInputDataSource() BaseReferenceInputDataSourceImpl
}

func UnmarshalReferenceInputDataSourceImplementation 

func UnmarshalReferenceInputDataSourceImplementation(input []byte) (ReferenceInputDataSource, error)

type ReferenceInputProperties 

type ReferenceInputProperties struct {
	Datasource ReferenceInputDataSource `json:"datasource"`

	Compression   *Compression  `json:"compression,omitempty"`
	Diagnostics   *Diagnostics  `json:"diagnostics,omitempty"`
	Etag          *string       `json:"etag,omitempty"`
	PartitionKey  *string       `json:"partitionKey,omitempty"`
	Serialization Serialization `json:"serialization"`
	Type          string        `json:"type"`
}

func (ReferenceInputProperties) InputProperties 

func (s ReferenceInputProperties) InputProperties() BaseInputPropertiesImpl

func (ReferenceInputProperties) MarshalJSON 

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

func (*ReferenceInputProperties) UnmarshalJSON 

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

type RefreshType 

type RefreshType string
const (
	RefreshTypeRefreshPeriodicallyWithDelta RefreshType = "RefreshPeriodicallyWithDelta"
	RefreshTypeRefreshPeriodicallyWithFull  RefreshType = "RefreshPeriodicallyWithFull"
	RefreshTypeStatic                       RefreshType = "Static"
)

func (*RefreshType) UnmarshalJSON 

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

type ResourceTestStatus 

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

type Serialization 

type Serialization interface {
	Serialization() BaseSerializationImpl
}

func UnmarshalSerializationImplementation 

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

type StorageAccount 

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

type StreamInputDataSource 

type StreamInputDataSource interface {
	StreamInputDataSource() BaseStreamInputDataSourceImpl
}

func UnmarshalStreamInputDataSourceImplementation 

func UnmarshalStreamInputDataSourceImplementation(input []byte) (StreamInputDataSource, error)

type StreamInputProperties 

type StreamInputProperties struct {
	Datasource StreamInputDataSource `json:"datasource"`

	Compression   *Compression  `json:"compression,omitempty"`
	Diagnostics   *Diagnostics  `json:"diagnostics,omitempty"`
	Etag          *string       `json:"etag,omitempty"`
	PartitionKey  *string       `json:"partitionKey,omitempty"`
	Serialization Serialization `json:"serialization"`
	Type          string        `json:"type"`
}

func (StreamInputProperties) InputProperties 

func (s StreamInputProperties) InputProperties() BaseInputPropertiesImpl

func (StreamInputProperties) MarshalJSON 

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

func (*StreamInputProperties) UnmarshalJSON 

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

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 

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

func (UpdateOperationOptions) ToOData 

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

func (UpdateOperationOptions) ToQuery 

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

type UpdateOperationResponse 

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

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.