common

Documentation

Index

• type Listener
• type ListenerSettings
  • func (l *ListenerSettings) LockDuration() time.Duration
  • func (l *ListenerSettings) LockRenewalInterval() *time.Duration
  • func (l *ListenerSettings) MaxConcurrency() *int
  • func (l *ListenerSettings) MaxDeliveryCount() int32
  • func (l *ListenerSettings) Namespace() *servicebus.Namespace
  • func (l *ListenerSettings) PrefetchCount() *uint32
  • func (l *ListenerSettings) SetLockDuration(lockDuration time.Duration)
  • func (l *ListenerSettings) SetLockRenewalInterval(lockRenewalInterval *time.Duration)
  • func (l *ListenerSettings) SetMaxConcurrency(maxConcurrency *int)
  • func (l *ListenerSettings) SetMaxDeliveryCount(maxDeliveryCount int32)
  • func (l *ListenerSettings) SetNamespace(namespace *servicebus.Namespace)
  • func (l *ListenerSettings) SetPrefetchCount(prefectCount *uint32)
• type Publisher
• type PublisherSettings
  • func (p *PublisherSettings) AppendHeader(key, value string)
  • func (p *PublisherSettings) Headers() map[string]string
  • func (p *PublisherSettings) Marshaller() marshal.Marshaller
  • func (p *PublisherSettings) Namespace() *servicebus.Namespace
  • func (p *PublisherSettings) SetMarshaller(marshaller marshal.Marshaller)
  • func (p *PublisherSettings) SetNamespace(namespace *servicebus.Namespace)

Types

type Listener

type Listener interface {
	MaxDeliveryCount() int32
	LockRenewalInterval() *time.Duration
	LockDuration() time.Duration
	PrefetchCount() *uint32
	MaxConcurrency() *int
	Namespace() *servicebus.Namespace
	SetMaxDeliveryCount(maxDeliveryCount int32)
	SetLockRenewalInterval(lockRenewalInterval *time.Duration)
	SetLockDuration(lockDuration time.Duration)
	SetPrefetchCount(prefectCount *uint32)
	SetMaxConcurrency(maxConcurrency *int)
	SetNamespace(namespace *servicebus.Namespace)
}

type ListenerSettings

type ListenerSettings struct {
	// contains filtered or unexported fields
}

ListenerSettings is a struct to contain service bus entities relevant to subscribing to a publisher queue

func (*ListenerSettings) LockDuration

func (l *ListenerSettings) LockDuration() time.Duration

func (*ListenerSettings) LockRenewalInterval

func (l *ListenerSettings) LockRenewalInterval() *time.Duration

func (*ListenerSettings) MaxConcurrency

func (l *ListenerSettings) MaxConcurrency() *int

func (*ListenerSettings) MaxDeliveryCount

func (l *ListenerSettings) MaxDeliveryCount() int32

func (*ListenerSettings) Namespace

func (l *ListenerSettings) Namespace() *servicebus.Namespace

func (*ListenerSettings) PrefetchCount

func (l *ListenerSettings) PrefetchCount() *uint32

func (*ListenerSettings) SetLockDuration

func (l *ListenerSettings) SetLockDuration(lockDuration time.Duration)

func (*ListenerSettings) SetLockRenewalInterval

func (l *ListenerSettings) SetLockRenewalInterval(lockRenewalInterval *time.Duration)

func (*ListenerSettings) SetMaxConcurrency

func (l *ListenerSettings) SetMaxConcurrency(maxConcurrency *int)

func (*ListenerSettings) SetMaxDeliveryCount

func (l *ListenerSettings) SetMaxDeliveryCount(maxDeliveryCount int32)

func (*ListenerSettings) SetNamespace

func (l *ListenerSettings) SetNamespace(namespace *servicebus.Namespace)

func (*ListenerSettings) SetPrefetchCount

func (l *ListenerSettings) SetPrefetchCount(prefectCount *uint32)

type Publisher

type Publisher interface {
	Namespace() *servicebus.Namespace
	Headers() map[string]string
	SetNamespace(namespace *servicebus.Namespace)
	AppendHeader(k, v string)
	Marshaller() marshal.Marshaller
	SetMarshaller(marshal.Marshaller)
}

type PublisherSettings

type PublisherSettings struct {
	// contains filtered or unexported fields
}

PublisherSettings is a struct to contain service bus entities relevant to publishing to a queue

func (*PublisherSettings) AppendHeader

func (p *PublisherSettings) AppendHeader(key, value string)

func (*PublisherSettings) Headers

func (p *PublisherSettings) Headers() map[string]string

func (*PublisherSettings) Marshaller

func (p *PublisherSettings) Marshaller() marshal.Marshaller

func (*PublisherSettings) Namespace

func (p *PublisherSettings) Namespace() *servicebus.Namespace

func (*PublisherSettings) SetMarshaller

func (p *PublisherSettings) SetMarshaller(marshaller marshal.Marshaller)

func (*PublisherSettings) SetNamespace

func (p *PublisherSettings) SetNamespace(namespace *servicebus.Namespace)