mgmt

Documentation

Overview

Package mgmt provides functionality for calling the Event Hubs management operations

Index

• Constants
• type Client
  • func NewClient(namespace, hubName string, provider auth.TokenProvider, env azure.Environment) *Client
  • func (c *Client) GetHubPartitionRuntimeInformation(ctx context.Context, conn *amqp.Client, partitionID string) (*HubPartitionRuntimeInformation, error)
  • func (c *Client) GetHubRuntimeInformation(ctx context.Context, conn *amqp.Client) (*HubRuntimeInformation, error)
• type HubPartitionRuntimeInformation
• type HubRuntimeInformation

Constants

const (
	// MsftVendor is the Microsoft vendor identifier
	MsftVendor = "com.microsoft"
)

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