application

Documentation

Index

• Constants
• Variables
• func ConsumeUserRegistrationEvents(consumer sarama.PartitionConsumer, ...)
• func NewKafkaConsumer() sarama.Consumer
• func NewKafkaSyncProducer() sarama.SyncProducer
• func SubmitEvent(kafka sarama.SyncProducer, event interface{}) error
• type AuthService
  • func (s AuthService) Create(r *domain.UserRegistration) error
  • func (s AuthService) GetRegistrationByEmail(email string) (*domain.UserRegistration, error)
• type UserService
  • func (s UserService) Create(u *domain.User) error
  • func (s UserService) OnEventTypeHandle(msgVal []byte, eventType interface{})
  • func (s UserService) Update(u *domain.User) error
  • func (s UserService) Users() ([]*domain.User, error)

Constants

const (
	Secret = "secret"
)

Variables

var (
	Topic           = "user-transactions"
	Partition int32 = 0
)

Functions

func ConsumeUserRegistrationEvents

func ConsumeUserRegistrationEvents(consumer sarama.PartitionConsumer, handleEventType func(msgVal []byte, e interface{}))

func NewKafkaConsumer

func NewKafkaConsumer() sarama.Consumer

func NewKafkaSyncProducer

func NewKafkaSyncProducer() sarama.SyncProducer

func SubmitEvent

func SubmitEvent(kafka sarama.SyncProducer, event interface{}) error

Types

type AuthService

type AuthService struct {
	AuthRepository domain.AuthRepository
}

func (AuthService) Create

func (s AuthService) Create(r *domain.UserRegistration) error

Create a new User Registration

func (AuthService) GetRegistrationByEmail

func (s AuthService) GetRegistrationByEmail(email string) (*domain.UserRegistration, error)

Returns a User Registration by email

type UserService

type UserService struct {
	UsersRepository domain.UserRepository
	EventsConsumer  sarama.Consumer
}

func (UserService) Create

func (s UserService) Create(u *domain.User) error

Creates a User

func (UserService) OnEventTypeHandle

func (s UserService) OnEventTypeHandle(msgVal []byte, eventType interface{})

func (UserService) Update

func (s UserService) Update(u *domain.User) error

Updates a User

func (UserService) Users

func (s UserService) Users() ([]*domain.User, error)

Returns all the Users