azext_iot/monitor/models/target.py

# coding=utf-8
# --------------------------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for license information.
# --------------------------------------------------------------------------------------------


class Target:
    def __init__(
        self,
        hostname: str,
        path: str,
        partitions: list,
        auth,  # : uamqp.authentication.SASTokenAsync,
    ):
        self.hostname = hostname
        self.path = path
        self.auth = auth
        self.partitions = partitions
        self.consumer_group = None

    def add_consumer_group(self, consumer_group: str):
        self.consumer_group = consumer_group