azure

Documentation

Index

• type AzureMessage
  • func (m *AzureMessage) Abort(error) bool
  • func (m *AzureMessage) Complete() error
  • func (m *AzureMessage) Data() string
  • func (m *AzureMessage) Id() string
• type AzureQueueClientFactory
  • func (factory *AzureQueueClientFactory) CreateConsumer(cfg *viper.Viper, logger *zerolog.Logger) v1.Consumer
  • func (factory *AzureQueueClientFactory) CreateProducer(cfg *viper.Viper, logger *zerolog.Logger) v1.Producer
• type ClientOptions

Types

type AzureMessage

type AzureMessage struct {
	*azqueue.DequeuedMessage
	// contains filtered or unexported fields
}

Message represents a message in a queue.

func (*AzureMessage) Abort

func (m *AzureMessage) Abort(error) bool

func (*AzureMessage) Complete

func (m *AzureMessage) Complete() error

func (*AzureMessage) Data

func (m *AzureMessage) Data() string

func (*AzureMessage) Id

func (m *AzureMessage) Id() string

type AzureQueueClientFactory

type AzureQueueClientFactory struct {
}

func (*AzureQueueClientFactory) CreateConsumer

func (factory *AzureQueueClientFactory) CreateConsumer(cfg *viper.Viper, logger *zerolog.Logger) v1.Consumer

func (*AzureQueueClientFactory) CreateProducer

func (factory *AzureQueueClientFactory) CreateProducer(cfg *viper.Viper, logger *zerolog.Logger) v1.Producer

type ClientOptions

type ClientOptions struct {
	StorageAccount, SasToken, Name string
	ServerTimeoutInSeconds         int
	VisibilityTimeoutInSeconds     int64
}