servicebus

Documentation

Index

• type ServiceBusClient
  • func (sb *ServiceBusClient) HealthStatus() v1.HealthStatus
  • func (sb *ServiceBusClient) Iter(ctx context.Context, next v1.NextMessage) error
  • func (c *ServiceBusClient) Produce(ctx context.Context, m *v1.RawMessage) error
• type ServiceBusClientFactory
  • func (factory *ServiceBusClientFactory) CreateConsumer(cfg *viper.Viper, logger *zerolog.Logger) v1.Consumer
  • func (factory *ServiceBusClientFactory) CreateProducer(cfg *viper.Viper, logger *zerolog.Logger) v1.Producer
• type ServiceBusMessage
  • func (m *ServiceBusMessage) Abort(error) bool
  • func (m *ServiceBusMessage) Complete() error
  • func (m *ServiceBusMessage) Data() string
  • func (m *ServiceBusMessage) Id() string

Types

type ServiceBusClient

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

func (*ServiceBusClient) HealthStatus

func (sb *ServiceBusClient) HealthStatus() v1.HealthStatus

func (*ServiceBusClient) Iter

func (sb *ServiceBusClient) Iter(ctx context.Context, next v1.NextMessage) error

func (*ServiceBusClient) Produce

func (c *ServiceBusClient) Produce(ctx context.Context, m *v1.RawMessage) error

type ServiceBusClientFactory

type ServiceBusClientFactory struct {
}

func (*ServiceBusClientFactory) CreateConsumer

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

func (*ServiceBusClientFactory) CreateProducer

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

type ServiceBusMessage

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

func (*ServiceBusMessage) Abort

func (m *ServiceBusMessage) Abort(error) bool

func (*ServiceBusMessage) Complete

func (m *ServiceBusMessage) Complete() error

func (*ServiceBusMessage) Data

func (m *ServiceBusMessage) Data() string

func (*ServiceBusMessage) Id

func (m *ServiceBusMessage) Id() string