Documentation
¶
Index ¶
- type Auth
- type Buy
- type Company
- type KafkaSender
- type Portfolio
- type Sale
- func (s *Sale) Create(ctx context.Context, userId, companyId int, price int) error
- func (s *Sale) GetAllSales(ctx context.Context, companyId int, limit, offset uint64) (price []int, err error)
- func (s *Sale) GetAllSalesByCompanyId(ctx context.Context, companyId int, limit, offset uint64) (price []int, err error)
- type Ttl
- type User
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Auth ¶
type Auth struct {
// contains filtered or unexported fields
}
func NewAuth ¶
func NewAuth(repos *repository.Repositories) *Auth
type Buy ¶
type Buy struct {
// contains filtered or unexported fields
}
func NewBuy ¶
func NewBuy(repos *repository.Repositories) *Buy
type Company ¶
type Company struct {
// contains filtered or unexported fields
}
func NewCompany ¶
func NewCompany(repos *repository.Repositories) *Company
type KafkaSender ¶
type KafkaSender struct {
// contains filtered or unexported fields
}
func NewKafkaSender ¶
func NewKafkaSender(producer sarama.SyncProducer, topic string) *KafkaSender
func (*KafkaSender) SendMessage ¶
func (s *KafkaSender) SendMessage(message kafka.RequestMessage) error
type Portfolio ¶
type Portfolio struct {
// contains filtered or unexported fields
}
func NewPortfolio ¶
func NewPortfolio(repos *repository.Repositories) *Portfolio
type Sale ¶
type Sale struct {
// contains filtered or unexported fields
}
func NewSale ¶
func NewSale(repos *repository.Repositories) *Sale
func (*Sale) GetAllSales ¶
type Ttl ¶
type Ttl struct {
// contains filtered or unexported fields
}
func NewTtl ¶
func NewTtl(repos *repository.Repositories) *Ttl
type User ¶
type User struct {
// contains filtered or unexported fields
}
func NewUser ¶
func NewUser(repos *repository.Repositories) *User
Source Files
Click to show internal directories.
Click to hide internal directories.