consumergroups

Jun 10, 2022

Changes in this version

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

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

+ type ConsumerGroup struct

+ Id *string

+ Name *string

+ Properties *ConsumerGroupProperties

+ Type *string

+ type ConsumerGroupId struct

+ ConsumerGroupName string

+ EventHubName string

+ NamespaceName string

+ ResourceGroupName string

+ SubscriptionId string

+ func NewConsumerGroupID(subscriptionId string, resourceGroupName string, namespaceName string, ...) ConsumerGroupId

+ func ParseConsumerGroupID(input string) (*ConsumerGroupId, error)

+ func ParseConsumerGroupIDInsensitively(input string) (*ConsumerGroupId, error)

+ func (id ConsumerGroupId) ID() string

+ func (id ConsumerGroupId) Segments() []resourceids.Segment

+ func (id ConsumerGroupId) String() string

+ type ConsumerGroupOperationPredicate struct

+ Id *string

+ Name *string

+ Type *string

+ func (p ConsumerGroupOperationPredicate) Matches(input ConsumerGroup) bool

+ type ConsumerGroupProperties struct

+ CreatedAt *string

+ UpdatedAt *string

+ UserMetadata *string

+ func (o *ConsumerGroupProperties) GetCreatedAtAsTime() (*time.Time, error)

+ func (o *ConsumerGroupProperties) GetUpdatedAtAsTime() (*time.Time, error)

+ func (o *ConsumerGroupProperties) SetCreatedAtAsTime(input time.Time)

+ func (o *ConsumerGroupProperties) SetUpdatedAtAsTime(input time.Time)

+ type ConsumerGroupsClient struct

+ Client autorest.Client

+ func NewConsumerGroupsClientWithBaseURI(endpoint string) 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) (resp 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, ...) (resp ListByEventHubCompleteResult, err error)

+ type CreateOrUpdateOperationResponse struct

+ HttpResponse *http.Response

+ Model *ConsumerGroup

+ type DeleteOperationResponse struct

+ HttpResponse *http.Response

+ type EventhubId struct

+ EventHubName string

+ NamespaceName string

+ ResourceGroupName string

+ SubscriptionId string

+ func NewEventhubID(subscriptionId string, resourceGroupName string, namespaceName string, ...) EventhubId

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

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

+ func (id EventhubId) ID() string

+ func (id EventhubId) Segments() []resourceids.Segment

+ func (id EventhubId) String() string

+ type GetOperationResponse struct

+ HttpResponse *http.Response

+ Model *ConsumerGroup

+ type ListByEventHubCompleteResult struct

+ Items []ConsumerGroup

+ type ListByEventHubOperationOptions struct

+ Skip *int64

+ Top *int64

+ func DefaultListByEventHubOperationOptions() ListByEventHubOperationOptions

+ type ListByEventHubOperationResponse struct

+ HttpResponse *http.Response

+ Model *[]ConsumerGroup

+ func (r ListByEventHubOperationResponse) HasMore() bool

+ func (r ListByEventHubOperationResponse) LoadMore(ctx context.Context) (resp ListByEventHubOperationResponse, err error)