consumer

Documentation

Index

• type DynamicIntegrationConsumerGroupHandler
  • func NewDynamicIntegrationConsumerHandler(subscriptionsManager *cqrs.IEventBusSubscriptionsManager, ...) *DynamicIntegrationConsumerGroupHandler
  • func (d DynamicIntegrationConsumerGroupHandler) Cleanup(session sarama.ConsumerGroupSession) error
  • func (d DynamicIntegrationConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (d DynamicIntegrationConsumerGroupHandler) Setup(session sarama.ConsumerGroupSession) error
• type IntegrationConsumerGroupHandler
  • func NewIntegrationConsumerHandler(subscriptionsManager *cqrs.IEventBusSubscriptionsManager, ...) IntegrationConsumerGroupHandler
  • func (d IntegrationConsumerGroupHandler) Cleanup(session sarama.ConsumerGroupSession) error
  • func (d IntegrationConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (d IntegrationConsumerGroupHandler) Setup(session sarama.ConsumerGroupSession) error

Types

type DynamicIntegrationConsumerGroupHandler

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

func NewDynamicIntegrationConsumerHandler

func NewDynamicIntegrationConsumerHandler(subscriptionsManager *cqrs.IEventBusSubscriptionsManager, config cqrs.EventBusConfig) *DynamicIntegrationConsumerGroupHandler

func (DynamicIntegrationConsumerGroupHandler) Cleanup

func (d DynamicIntegrationConsumerGroupHandler) Cleanup(session sarama.ConsumerGroupSession) error

func (DynamicIntegrationConsumerGroupHandler) ConsumeClaim

func (d DynamicIntegrationConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (DynamicIntegrationConsumerGroupHandler) Setup

func (d DynamicIntegrationConsumerGroupHandler) Setup(session sarama.ConsumerGroupSession) error

type IntegrationConsumerGroupHandler

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

func NewIntegrationConsumerHandler

func NewIntegrationConsumerHandler(subscriptionsManager *cqrs.IEventBusSubscriptionsManager, config cqrs.EventBusConfig) IntegrationConsumerGroupHandler

func (IntegrationConsumerGroupHandler) Cleanup

func (d IntegrationConsumerGroupHandler) Cleanup(session sarama.ConsumerGroupSession) error

func (IntegrationConsumerGroupHandler) ConsumeClaim

func (d IntegrationConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (IntegrationConsumerGroupHandler) Setup

func (d IntegrationConsumerGroupHandler) Setup(session sarama.ConsumerGroupSession) error