eventhubs

package
v2.85.6 Latest Latest
Warning

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

Go to latest
Published: Nov 18, 2021 License: MPL-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AccessRights

type AccessRights string
const (
	AccessRightsListen AccessRights = "Listen"
	AccessRightsManage AccessRights = "Manage"
	AccessRightsSend   AccessRights = "Send"
)

type AuthorizationRule

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

type AuthorizationRuleId

type AuthorizationRuleId struct {
	SubscriptionId string
	ResourceGroup  string
	NamespaceName  string
	EventhubName   string
	Name           string
}

func NewAuthorizationRuleID

func NewAuthorizationRuleID(subscriptionId, resourceGroup, namespaceName, eventhubName, name string) AuthorizationRuleId

func ParseAuthorizationRuleID

func ParseAuthorizationRuleID(input string) (*AuthorizationRuleId, error)

ParseAuthorizationRuleID parses a AuthorizationRule ID into an AuthorizationRuleId struct

func ParseAuthorizationRuleIDInsensitively

func ParseAuthorizationRuleIDInsensitively(input string) (*AuthorizationRuleId, error)

ParseAuthorizationRuleIDInsensitively parses an AuthorizationRule ID into an AuthorizationRuleId struct, insensitively This should only be used to parse an ID for rewriting to a consistent casing, the ParseAuthorizationRuleID method should be used instead for validation etc.

func (AuthorizationRuleId) ID

func (id AuthorizationRuleId) ID() string

func (AuthorizationRuleId) String

func (id AuthorizationRuleId) String() string

type AuthorizationRuleProperties

type AuthorizationRuleProperties struct {
	Rights []AccessRights `json:"rights"`
}

type CaptureDescription

type CaptureDescription struct {
	Destination       *Destination                `json:"destination,omitempty"`
	Enabled           *bool                       `json:"enabled,omitempty"`
	Encoding          *EncodingCaptureDescription `json:"encoding,omitempty"`
	IntervalInSeconds *int64                      `json:"intervalInSeconds,omitempty"`
	SizeLimitInBytes  *int64                      `json:"sizeLimitInBytes,omitempty"`
	SkipEmptyArchives *bool                       `json:"skipEmptyArchives,omitempty"`
}

type CreateOrUpdateResponse

type CreateOrUpdateResponse struct {
	HttpResponse *http.Response
	Model        *Eventhub
}

type DeleteAuthorizationRuleResponse

type DeleteAuthorizationRuleResponse struct {
	HttpResponse *http.Response
}

type DeleteResponse

type DeleteResponse struct {
	HttpResponse *http.Response
}

type Destination

type Destination struct {
	Name       *string                `json:"name,omitempty"`
	Properties *DestinationProperties `json:"properties,omitempty"`
}

type DestinationProperties

type DestinationProperties struct {
	ArchiveNameFormat        *string `json:"archiveNameFormat,omitempty"`
	BlobContainer            *string `json:"blobContainer,omitempty"`
	StorageAccountResourceId *string `json:"storageAccountResourceId,omitempty"`
}

type EncodingCaptureDescription

type EncodingCaptureDescription string
const (
	EncodingCaptureDescriptionAvro        EncodingCaptureDescription = "Avro"
	EncodingCaptureDescriptionAvroDeflate EncodingCaptureDescription = "AvroDeflate"
)

type EntityStatus

type EntityStatus string
const (
	EntityStatusActive          EntityStatus = "Active"
	EntityStatusCreating        EntityStatus = "Creating"
	EntityStatusDeleting        EntityStatus = "Deleting"
	EntityStatusDisabled        EntityStatus = "Disabled"
	EntityStatusReceiveDisabled EntityStatus = "ReceiveDisabled"
	EntityStatusRenaming        EntityStatus = "Renaming"
	EntityStatusRestoring       EntityStatus = "Restoring"
	EntityStatusSendDisabled    EntityStatus = "SendDisabled"
	EntityStatusUnknown         EntityStatus = "Unknown"
)

type EventHubsClient

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

func NewEventHubsClientWithBaseURI

func NewEventHubsClientWithBaseURI(endpoint string) EventHubsClient

func (EventHubsClient) CreateOrUpdate

func (c EventHubsClient) CreateOrUpdate(ctx context.Context, id EventhubId, input Eventhub) (result CreateOrUpdateResponse, err error)

CreateOrUpdate ...

func (EventHubsClient) Delete

func (c EventHubsClient) Delete(ctx context.Context, id EventhubId) (result DeleteResponse, err error)

Delete ...

func (EventHubsClient) DeleteAuthorizationRule

func (c EventHubsClient) DeleteAuthorizationRule(ctx context.Context, id AuthorizationRuleId) (result DeleteAuthorizationRuleResponse, err error)

DeleteAuthorizationRule ...

func (EventHubsClient) Get

func (c EventHubsClient) Get(ctx context.Context, id EventhubId) (result GetResponse, err error)

Get ...

func (EventHubsClient) GetAuthorizationRule

func (c EventHubsClient) GetAuthorizationRule(ctx context.Context, id AuthorizationRuleId) (result GetAuthorizationRuleResponse, err error)

GetAuthorizationRule ...

func (EventHubsClient) ListByNamespace

func (c EventHubsClient) ListByNamespace(ctx context.Context, id NamespaceId, options ListByNamespaceOptions) (resp ListByNamespaceResponse, err error)

ListByNamespace ...

func (EventHubsClient) ListByNamespaceComplete

ListByNamespaceComplete retrieves all of the results into a single object

func (EventHubsClient) ListByNamespaceCompleteMatchingPredicate

func (c EventHubsClient) ListByNamespaceCompleteMatchingPredicate(ctx context.Context, id NamespaceId, options ListByNamespaceOptions, predicate EventhubPredicate) (resp ListByNamespaceCompleteResult, err error)

ListByNamespaceCompleteMatchingPredicate retrieves all of the results and then applied the predicate

type Eventhub

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

type EventhubId

type EventhubId struct {
	SubscriptionId string
	ResourceGroup  string
	NamespaceName  string
	Name           string
}

func NewEventhubID

func NewEventhubID(subscriptionId, resourceGroup, namespaceName, name string) EventhubId

func ParseEventhubID

func ParseEventhubID(input string) (*EventhubId, error)

ParseEventhubID parses a Eventhub ID into an EventhubId struct

func ParseEventhubIDInsensitively

func ParseEventhubIDInsensitively(input string) (*EventhubId, error)

ParseEventhubIDInsensitively parses an Eventhub ID into an EventhubId struct, insensitively This should only be used to parse an ID for rewriting to a consistent casing, the ParseEventhubID method should be used instead for validation etc.

func (EventhubId) ID

func (id EventhubId) ID() string

func (EventhubId) String

func (id EventhubId) String() string

type EventhubPredicate

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

func (EventhubPredicate) Matches

func (p EventhubPredicate) Matches(input Eventhub) bool

type EventhubProperties

type EventhubProperties struct {
	CaptureDescription     *CaptureDescription `json:"captureDescription,omitempty"`
	CreatedAt              *string             `json:"createdAt,omitempty"`
	MessageRetentionInDays *int64              `json:"messageRetentionInDays,omitempty"`
	PartitionCount         *int64              `json:"partitionCount,omitempty"`
	PartitionIds           *[]string           `json:"partitionIds,omitempty"`
	Status                 *EntityStatus       `json:"status,omitempty"`
	UpdatedAt              *string             `json:"updatedAt,omitempty"`
}

func (EventhubProperties) GetCreatedAtAsTime

func (o EventhubProperties) GetCreatedAtAsTime() (*time.Time, error)

func (EventhubProperties) GetUpdatedAtAsTime

func (o EventhubProperties) GetUpdatedAtAsTime() (*time.Time, error)

func (EventhubProperties) SetCreatedAtAsTime

func (o EventhubProperties) SetCreatedAtAsTime(input time.Time)

func (EventhubProperties) SetUpdatedAtAsTime

func (o EventhubProperties) SetUpdatedAtAsTime(input time.Time)

type GetAuthorizationRuleResponse

type GetAuthorizationRuleResponse struct {
	HttpResponse *http.Response
	Model        *AuthorizationRule
}

type GetResponse

type GetResponse struct {
	HttpResponse *http.Response
	Model        *Eventhub
}

type ListByNamespaceCompleteResult

type ListByNamespaceCompleteResult struct {
	Items []Eventhub
}

type ListByNamespaceOptions

type ListByNamespaceOptions struct {
	Skip *int64
	Top  *int64
}

func DefaultListByNamespaceOptions

func DefaultListByNamespaceOptions() ListByNamespaceOptions

type ListByNamespaceResponse

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

func (ListByNamespaceResponse) HasMore

func (r ListByNamespaceResponse) HasMore() bool

func (ListByNamespaceResponse) LoadMore

type NamespaceId

type NamespaceId struct {
	SubscriptionId string
	ResourceGroup  string
	Name           string
}

func NewNamespaceID

func NewNamespaceID(subscriptionId, resourceGroup, name string) NamespaceId

func ParseNamespaceID

func ParseNamespaceID(input string) (*NamespaceId, error)

ParseNamespaceID parses a Namespace ID into an NamespaceId struct

func ParseNamespaceIDInsensitively

func ParseNamespaceIDInsensitively(input string) (*NamespaceId, error)

ParseNamespaceIDInsensitively parses an Namespace ID into an NamespaceId struct, insensitively This should only be used to parse an ID for rewriting to a consistent casing, the ParseNamespaceID method should be used instead for validation etc.

func (NamespaceId) ID

func (id NamespaceId) ID() string

func (NamespaceId) String

func (id NamespaceId) String() string

Jump to

Keyboard shortcuts

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