Documentation ¶
Index ¶
- func ValidateConsumerGroupID(input interface{}, key string) (warnings []string, errors []error)
- func ValidateEventhubID(input interface{}, key string) (warnings []string, errors []error)
- type ConsumerGroup
- type ConsumerGroupId
- type ConsumerGroupOperationPredicate
- type ConsumerGroupProperties
- type ConsumerGroupsClient
- func (c ConsumerGroupsClient) CreateOrUpdate(ctx context.Context, id ConsumerGroupId, input ConsumerGroup) (result CreateOrUpdateOperationResponse, err error)
- func (c ConsumerGroupsClient) Delete(ctx context.Context, id ConsumerGroupId) (result DeleteOperationResponse, err error)
- func (c ConsumerGroupsClient) Get(ctx context.Context, id ConsumerGroupId) (result GetOperationResponse, err error)
- func (c ConsumerGroupsClient) ListByEventHub(ctx context.Context, id EventhubId, options ListByEventHubOperationOptions) (result ListByEventHubOperationResponse, err error)
- func (c ConsumerGroupsClient) ListByEventHubComplete(ctx context.Context, id EventhubId, options ListByEventHubOperationOptions) (ListByEventHubCompleteResult, error)
- func (c ConsumerGroupsClient) ListByEventHubCompleteMatchingPredicate(ctx context.Context, id EventhubId, options ListByEventHubOperationOptions, ...) (result ListByEventHubCompleteResult, err error)
- type CreateOrUpdateOperationResponse
- type DeleteOperationResponse
- type EventhubId
- type GetOperationResponse
- type ListByEventHubCompleteResult
- type ListByEventHubOperationOptions
- type ListByEventHubOperationResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ValidateConsumerGroupID ¶
ValidateConsumerGroupID checks that 'input' can be parsed as a Consumer Group ID
func ValidateEventhubID ¶
ValidateEventhubID checks that 'input' can be parsed as a Eventhub ID
Types ¶
type ConsumerGroup ¶
type ConsumerGroup struct { Id *string `json:"id,omitempty"` Location *string `json:"location,omitempty"` Name *string `json:"name,omitempty"` Properties *ConsumerGroupProperties `json:"properties,omitempty"` SystemData *systemdata.SystemData `json:"systemData,omitempty"` Type *string `json:"type,omitempty"` }
type ConsumerGroupId ¶
type ConsumerGroupId struct { SubscriptionId string ResourceGroupName string NamespaceName string EventhubName string ConsumerGroupName string }
ConsumerGroupId is a struct representing the Resource ID for a Consumer Group
func NewConsumerGroupID ¶
func NewConsumerGroupID(subscriptionId string, resourceGroupName string, namespaceName string, eventhubName string, consumerGroupName string) ConsumerGroupId
NewConsumerGroupID returns a new ConsumerGroupId struct
func ParseConsumerGroupID ¶
func ParseConsumerGroupID(input string) (*ConsumerGroupId, error)
ParseConsumerGroupID parses 'input' into a ConsumerGroupId
func ParseConsumerGroupIDInsensitively ¶
func ParseConsumerGroupIDInsensitively(input string) (*ConsumerGroupId, error)
ParseConsumerGroupIDInsensitively parses 'input' case-insensitively into a ConsumerGroupId note: this method should only be used for API response data and not user input
func (ConsumerGroupId) ID ¶
func (id ConsumerGroupId) ID() string
ID returns the formatted Consumer Group ID
func (ConsumerGroupId) Segments ¶
func (id ConsumerGroupId) Segments() []resourceids.Segment
Segments returns a slice of Resource ID Segments which comprise this Consumer Group ID
func (ConsumerGroupId) String ¶
func (id ConsumerGroupId) String() string
String returns a human-readable description of this Consumer Group ID
type ConsumerGroupOperationPredicate ¶
type ConsumerGroupOperationPredicate struct { Id *string Location *string Name *string Type *string }
func (ConsumerGroupOperationPredicate) Matches ¶
func (p ConsumerGroupOperationPredicate) Matches(input ConsumerGroup) bool
type ConsumerGroupProperties ¶
type ConsumerGroupProperties struct { CreatedAt *string `json:"createdAt,omitempty"` UpdatedAt *string `json:"updatedAt,omitempty"` UserMetadata *string `json:"userMetadata,omitempty"` }
func (*ConsumerGroupProperties) GetCreatedAtAsTime ¶
func (o *ConsumerGroupProperties) GetCreatedAtAsTime() (*time.Time, error)
func (*ConsumerGroupProperties) GetUpdatedAtAsTime ¶
func (o *ConsumerGroupProperties) GetUpdatedAtAsTime() (*time.Time, error)
func (*ConsumerGroupProperties) SetCreatedAtAsTime ¶
func (o *ConsumerGroupProperties) SetCreatedAtAsTime(input time.Time)
func (*ConsumerGroupProperties) SetUpdatedAtAsTime ¶
func (o *ConsumerGroupProperties) SetUpdatedAtAsTime(input time.Time)
type ConsumerGroupsClient ¶
type ConsumerGroupsClient struct {
Client *resourcemanager.Client
}
func NewConsumerGroupsClientWithBaseURI ¶
func NewConsumerGroupsClientWithBaseURI(sdkApi sdkEnv.Api) (*ConsumerGroupsClient, error)
func (ConsumerGroupsClient) CreateOrUpdate ¶
func (c ConsumerGroupsClient) CreateOrUpdate(ctx context.Context, id ConsumerGroupId, input ConsumerGroup) (result CreateOrUpdateOperationResponse, err error)
CreateOrUpdate ...
func (ConsumerGroupsClient) Delete ¶
func (c ConsumerGroupsClient) Delete(ctx context.Context, id ConsumerGroupId) (result DeleteOperationResponse, err error)
Delete ...
func (ConsumerGroupsClient) Get ¶
func (c ConsumerGroupsClient) Get(ctx context.Context, id ConsumerGroupId) (result GetOperationResponse, err error)
Get ...
func (ConsumerGroupsClient) ListByEventHub ¶
func (c ConsumerGroupsClient) ListByEventHub(ctx context.Context, id EventhubId, options ListByEventHubOperationOptions) (result ListByEventHubOperationResponse, err error)
ListByEventHub ...
func (ConsumerGroupsClient) ListByEventHubComplete ¶
func (c ConsumerGroupsClient) ListByEventHubComplete(ctx context.Context, id EventhubId, options ListByEventHubOperationOptions) (ListByEventHubCompleteResult, error)
ListByEventHubComplete retrieves all the results into a single object
func (ConsumerGroupsClient) ListByEventHubCompleteMatchingPredicate ¶
func (c ConsumerGroupsClient) ListByEventHubCompleteMatchingPredicate(ctx context.Context, id EventhubId, options ListByEventHubOperationOptions, predicate ConsumerGroupOperationPredicate) (result ListByEventHubCompleteResult, err error)
ListByEventHubCompleteMatchingPredicate retrieves all the results and then applies the predicate
type CreateOrUpdateOperationResponse ¶
type CreateOrUpdateOperationResponse struct { HttpResponse *http.Response OData *odata.OData Model *ConsumerGroup }
type DeleteOperationResponse ¶
type EventhubId ¶
type EventhubId struct { SubscriptionId string ResourceGroupName string NamespaceName string EventhubName string }
EventhubId is a struct representing the Resource ID for a Eventhub
func NewEventhubID ¶
func NewEventhubID(subscriptionId string, resourceGroupName string, namespaceName string, eventhubName string) EventhubId
NewEventhubID returns a new EventhubId struct
func ParseEventhubID ¶
func ParseEventhubID(input string) (*EventhubId, error)
ParseEventhubID parses 'input' into a EventhubId
func ParseEventhubIDInsensitively ¶
func ParseEventhubIDInsensitively(input string) (*EventhubId, error)
ParseEventhubIDInsensitively parses 'input' case-insensitively into a EventhubId note: this method should only be used for API response data and not user input
func (EventhubId) Segments ¶
func (id EventhubId) Segments() []resourceids.Segment
Segments returns a slice of Resource ID Segments which comprise this Eventhub ID
func (EventhubId) String ¶
func (id EventhubId) String() string
String returns a human-readable description of this Eventhub ID
type GetOperationResponse ¶
type GetOperationResponse struct { HttpResponse *http.Response OData *odata.OData Model *ConsumerGroup }
type ListByEventHubCompleteResult ¶
type ListByEventHubCompleteResult struct {
Items []ConsumerGroup
}
type ListByEventHubOperationOptions ¶
func DefaultListByEventHubOperationOptions ¶
func DefaultListByEventHubOperationOptions() ListByEventHubOperationOptions
func (ListByEventHubOperationOptions) ToHeaders ¶
func (o ListByEventHubOperationOptions) ToHeaders() *client.Headers
func (ListByEventHubOperationOptions) ToOData ¶
func (o ListByEventHubOperationOptions) ToOData() *odata.Query
func (ListByEventHubOperationOptions) ToQuery ¶
func (o ListByEventHubOperationOptions) ToQuery() *client.QueryParams
type ListByEventHubOperationResponse ¶
type ListByEventHubOperationResponse struct { HttpResponse *http.Response OData *odata.OData Model *[]ConsumerGroup }