service

Documentation

Index

• type S3Service
  • func NewS3Service(region, endpoint, secretId, secretKey, bucket string) (*S3Service, error)
  • func (s *S3Service) DeleteFile(filePath string) error
  • func (s *S3Service) GetFile(filePath string) (io.Reader, error)
  • func (s *S3Service) SaveFile(filePath string, file []byte) error
• type VideoService
  • func NewVideoService(s3Conf conf.S3, neo4jConf conf.Neo4j, secret conf.Secret, ...) (*VideoService, error)
  • func (v *VideoService) CreateVideo(file io.Reader, autherId uint32, title string) (*model.VideoInfo, error)
  • func (v *VideoService) GetVideo(videoId int64) (*model.VideoInfo, error)
  • func (v *VideoService) ListVideosByAuthor(ctx context.Context, req *feed.ListPublishVideosRequest) (*feed.ListPublishVideosResponse, error)
  • func (v *VideoService) ListWatchVideos(ctx context.Context, req *feed.ListWatchVideosRequest) (*feed.ListWatchVideosResponse, error)

Types

type S3Service

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

func NewS3Service

func NewS3Service(region, endpoint, secretId, secretKey, bucket string) (*S3Service, error)

func (*S3Service) DeleteFile

func (s *S3Service) DeleteFile(filePath string) error

func (*S3Service) GetFile

func (s *S3Service) GetFile(filePath string) (io.Reader, error)

GetFile 获取文件

func (*S3Service) SaveFile

func (s *S3Service) SaveFile(filePath string, file []byte) error

SaveFile 保存文件至S3

type VideoService

type VideoService struct {
	feed.UnimplementedFeedServiceServer
	// contains filtered or unexported fields
}

func NewVideoService

func NewVideoService(
	s3Conf conf.S3,
	neo4jConf conf.Neo4j,
	secret conf.Secret,
	userService user.UserServiceClient,
	node int64) (*VideoService, error)

func (*VideoService) CreateVideo

func (v *VideoService) CreateVideo(file io.Reader, autherId uint32, title string) (*model.VideoInfo, error)

func (*VideoService) GetVideo

func (v *VideoService) GetVideo(videoId int64) (*model.VideoInfo, error)

func (*VideoService) ListVideosByAuthor

func (v *VideoService) ListVideosByAuthor(ctx context.Context, req *feed.ListPublishVideosRequest) (*feed.ListPublishVideosResponse, error)

func (*VideoService) ListWatchVideos

func (v *VideoService) ListWatchVideos(ctx context.Context, req *feed.ListWatchVideosRequest) (*feed.ListWatchVideosResponse, error)