services

Documentation

Index

• type TabletRepo
• type TabletService
  • func NewTabletService(repo TabletRepo, kafkaUrl string, kafkaCfg *sarama.Config) (*TabletService, error)
  • func (ts *TabletService) Close()
  • func (ts *TabletService) Create(ctx context.Context, createDTO *dto.CreateTabletDTO) (*models.Tablet, error)

Types

type TabletRepo

type TabletRepo interface {
	GetAll(ctx context.Context) ([]*models.Tablet, error)
	Insert(ctx context.Context, ts *models.Tablet) error
}

type TabletService

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

func NewTabletService

func NewTabletService(repo TabletRepo, kafkaUrl string, kafkaCfg *sarama.Config) (*TabletService, error)

func (*TabletService) Close

func (ts *TabletService) Close()

func (*TabletService) Create

func (ts *TabletService) Create(ctx context.Context, createDTO *dto.CreateTabletDTO) (*models.Tablet, error)