topic

Documentation

Index

• type ManagementOption
  • func SetDefaultHeader(headerName, msgKey string) ManagementOption
  • func WithConnectionString(connStr string) ManagementOption
  • func WithDuplicateDetection(window *time.Duration) ManagementOption
  • func WithEnvironmentName(environmentName string) ManagementOption
  • func WithManagedIdentityClientID(serviceBusNamespaceName, managedIdentityClientID string) ManagementOption
  • func WithManagedIdentityResourceID(serviceBusNamespaceName, managedIdentityResourceID string) ManagementOption
  • func WithToken(serviceBusNamespaceName string, spt *adal.ServicePrincipalToken) ManagementOption
• type Option
  • func SetCorrelationID(correlationID string) Option
  • func SetMessageDelay(delay time.Duration) Option
  • func SetMessageID(messageID string) Option
• type Publisher
  • func New(ctx context.Context, topicName string, opts ...ManagementOption) (*Publisher, error)

Types

type ManagementOption

type ManagementOption = topic.ManagementOption

Deprecated: use topic package

func SetDefaultHeader

func SetDefaultHeader(headerName, msgKey string) ManagementOption

Deprecated: use topic package

func WithConnectionString

func WithConnectionString(connStr string) ManagementOption

Deprecated: use topic package

func WithDuplicateDetection

func WithDuplicateDetection(window *time.Duration) ManagementOption

Deprecated: use topic package

func WithEnvironmentName

func WithEnvironmentName(environmentName string) ManagementOption

Deprecated: use topic package

func WithManagedIdentityClientID

func WithManagedIdentityClientID(serviceBusNamespaceName, managedIdentityClientID string) ManagementOption

Deprecated: use topic package

func WithManagedIdentityResourceID

func WithManagedIdentityResourceID(serviceBusNamespaceName, managedIdentityResourceID string) ManagementOption

Deprecated: use topic package

func WithToken

func WithToken(serviceBusNamespaceName string, spt *adal.ServicePrincipalToken) ManagementOption

Deprecated: use topic package

type Option

type Option = topic.Option

Deprecated: use topic package

func SetCorrelationID

func SetCorrelationID(correlationID string) Option

Deprecated: use topic package

func SetMessageDelay

func SetMessageDelay(delay time.Duration) Option

Deprecated: use topic package

func SetMessageID

func SetMessageID(messageID string) Option

Deprecated: use topic package

type Publisher

type Publisher = topic.Publisher

Deprecated: use topic package

func New

func New(ctx context.Context, topicName string, opts ...ManagementOption) (*Publisher, error)

Deprecated: use topic package