data

package

v0.0.0-...-7d1b39b Latest Latest Go to latest Published: Sep 21, 2023 License: Apache-2.0 Imports: 27 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/toomanysource/atreus

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func InitDB(db *gorm.DB)
func NewKafkaWriter(c *conf.Data, l log.Logger) *kafka.Writer
func NewMinioConn(c *conf.Minio, extraConn minioX.ExtraConn, intraConn minioX.IntraConn, ...) *minioX.Client
func NewMinioExtraConn(c *conf.Minio, l log.Logger) minioX.ExtraConn
func NewMinioIntraConn(c *conf.Minio, l log.Logger) minioX.IntraConn
func NewMysqlConn(c *conf.Data, l log.Logger) *gorm.DB
func NewPublishRepo(data *Data, userConn userv1.UserServiceClient, ...) biz.PublishRepo
type Data
- func NewData(db *gorm.DB, minioClient *minioX.Client, kfkWriter *kafka.Writer, ...) (*Data, func(), error)
type FavoriteRepo
- func NewFavoriteRepo(conn pb.FavoriteServiceClient) FavoriteRepo
type KfkReader
- func NewKafkaReader(c *conf.Data, l log.Logger) KfkReader
type UserRepo
- func NewUserRepo(conn pb.UserServiceClient) UserRepo
type Video

Constants ¶

View Source

const (
	VideoCount  = 30
	FrameNumber = 60
)

Variables ¶

View Source

var (
	ErrCopy                    = errors.New("copy error")
	ErrMysqlInsert             = errors.New("mysql insert error")
	ErrMysqlQuery              = errors.New("mysql query error")
	ErrUserServiceResponse     = errors.New("user service response error")
	ErrKafkaReader             = errors.New("kafka reader error")
	ErrFileCreate              = errors.New("file create error")
	ErrFileRead                = errors.New("file read error")
	ErrFileWrite               = errors.New("file write error")
	ErrMysqlUpdate             = errors.New("mysql update error")
	ErrFavoriteServiceResponse = errors.New("favorite service response error")
)

View Source

var ErrVideoMissing = errors.New("video missing")

View Source

var ProviderSet = wire.NewSet(NewData, NewKafkaReader, NewKafkaWriter, NewPublishRepo, NewMysqlConn, NewMinioConn, NewMinioExtraConn, NewMinioIntraConn)

Functions ¶

func InitDB ¶

func InitDB(db *gorm.DB)

func NewKafkaWriter ¶

func NewKafkaWriter(c *conf.Data, l log.Logger) *kafka.Writer

func NewMinioConn ¶

func NewMinioConn(c *conf.Minio, extraConn minioX.ExtraConn, intraConn minioX.IntraConn, l log.Logger) *minioX.Client

func NewMinioExtraConn ¶

func NewMinioExtraConn(c *conf.Minio, l log.Logger) minioX.ExtraConn

func NewMinioIntraConn ¶

func NewMinioIntraConn(c *conf.Minio, l log.Logger) minioX.IntraConn

func NewMysqlConn ¶

func NewMysqlConn(c *conf.Data, l log.Logger) *gorm.DB

func NewPublishRepo ¶

func NewPublishRepo(
	data *Data, userConn userv1.UserServiceClient, favoriteConn favoritev1.FavoriteServiceClient, logger log.Logger,
) biz.PublishRepo

Types ¶

type Data ¶

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

func NewData ¶

func NewData(db *gorm.DB, minioClient *minioX.Client, kfkWriter *kafka.Writer, kfkReader KfkReader, logger log.Logger) (*Data, func(), error)

type FavoriteRepo ¶

type FavoriteRepo interface {
	IsFavorite(context.Context, uint32, []uint32) ([]bool, error)
}

func NewFavoriteRepo ¶

func NewFavoriteRepo(conn pb.FavoriteServiceClient) FavoriteRepo

type KfkReader ¶

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

func NewKafkaReader ¶

func NewKafkaReader(c *conf.Data, l log.Logger) KfkReader

type UserRepo ¶

type UserRepo interface {
	GetUserInfos(context.Context, uint32, []uint32) ([]*biz.User, error)
}

func NewUserRepo ¶

func NewUserRepo(conn pb.UserServiceClient) UserRepo

type Video ¶

type Video struct {
	Id            uint32 `gorm:"column:id;primary_key;auto_increment"`
	AuthorID      uint32 `gorm:"column:author_id;not null;index:idx_author_id"`
	Title         string `gorm:"column:title;not null;size:255"`
	PlayUrl       string `gorm:"column:play_url;not null"`
	CoverUrl      string `gorm:"column:cover_url;not null"`
	FavoriteCount uint32 `gorm:"column:favorite_count;not null;default:0"`
	CommentCount  uint32 `gorm:"column:comment_count;not null;default:0"`
	CreatedAt     int64  `gorm:"column:created_at"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL