Documentation
¶
Overview ¶
Package mgmt provides functionality for calling the Event Hubs management operations
Index ¶
Constants ¶
View Source
const (
// MsftVendor is the Microsoft vendor identifier
MsftVendor = "com.microsoft"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client communicates with an AMQP management node
func NewClient ¶
func NewClient(namespace, hubName string, provider auth.TokenProvider, env azure.Environment) *Client
NewClient constructs a new AMQP management client
func (*Client) GetHubPartitionRuntimeInformation ¶
func (c *Client) GetHubPartitionRuntimeInformation(ctx context.Context, conn *amqp.Client, partitionID string) (*HubPartitionRuntimeInformation, error)
GetHubPartitionRuntimeInformation fetches runtime information from the AMQP management node for a given partition
func (*Client) GetHubRuntimeInformation ¶
func (c *Client) GetHubRuntimeInformation(ctx context.Context, conn *amqp.Client) (*HubRuntimeInformation, error)
GetHubRuntimeInformation requests runtime information for an Event Hub
type HubPartitionRuntimeInformation ¶
type HubPartitionRuntimeInformation struct {
HubPath string `mapstructure:"name"`
PartitionID string `mapstructure:"partition"`
BeginningSequenceNumber int64 `mapstructure:"begin_sequence_number"`
LastSequenceNumber int64 `mapstructure:"last_enqueued_sequence_number"`
LastEnqueuedOffset string `mapstructure:"last_enqueued_offset"`
LastEnqueuedTimeUtc time.Time `mapstructure:"last_enqueued_time_utc"`
}
HubPartitionRuntimeInformation provides management node information about a given Event Hub partition
type HubRuntimeInformation ¶
type HubRuntimeInformation struct {
Path string `mapstructure:"name"`
CreatedAt time.Time `mapstructure:"created_at"`
PartitionCount int `mapstructure:"partition_count"`
PartitionIDs []string `mapstructure:"partition_ids"`
}
HubRuntimeInformation provides management node information about a given Event Hub instance
Source Files
Click to show internal directories.
Click to hide internal directories.