Documentation
¶
Index ¶
- func NewAddressSubscriber(subscription map[string]*pubsub.Subscription, ...) subscriber.Subscriber
- func NewCustomerSubscriber() subscriber.Subscriber
- type AddressKafkaSubscriber
- func (s *AddressKafkaSubscriber) AddAddress(ctx context.Context)
- func (s *AddressKafkaSubscriber) EditAddress(ctx context.Context)
- func (s *AddressKafkaSubscriber) MultipleAddOrUpdateAddress(ctx context.Context)
- func (s *AddressKafkaSubscriber) RemoveAddress(ctx context.Context)
- func (s *AddressKafkaSubscriber) Run(ctx context.Context)
- type CustomerKafkaSubscriber
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAddressSubscriber ¶
func NewAddressSubscriber( subscription map[string]*pubsub.Subscription, repository repository.AddressRepository, ) subscriber.Subscriber
func NewCustomerSubscriber ¶
func NewCustomerSubscriber() subscriber.Subscriber
Types ¶
type AddressKafkaSubscriber ¶
type AddressKafkaSubscriber struct {
// contains filtered or unexported fields
}
func (*AddressKafkaSubscriber) AddAddress ¶
func (s *AddressKafkaSubscriber) AddAddress(ctx context.Context)
func (*AddressKafkaSubscriber) EditAddress ¶
func (s *AddressKafkaSubscriber) EditAddress(ctx context.Context)
func (*AddressKafkaSubscriber) MultipleAddOrUpdateAddress ¶
func (s *AddressKafkaSubscriber) MultipleAddOrUpdateAddress(ctx context.Context)
func (*AddressKafkaSubscriber) RemoveAddress ¶
func (s *AddressKafkaSubscriber) RemoveAddress(ctx context.Context)
func (*AddressKafkaSubscriber) Run ¶
func (s *AddressKafkaSubscriber) Run(ctx context.Context)
type CustomerKafkaSubscriber ¶
type CustomerKafkaSubscriber struct {
}
func (*CustomerKafkaSubscriber) Run ¶
func (s *CustomerKafkaSubscriber) Run(ctx context.Context)
Source Files
Click to show internal directories.
Click to hide internal directories.