MCPcopy Create free account

hub / github.com/ZeStream/zestream-server / functions

Functions65 in github.com/ZeStream/zestream-server

↓ 7 callersFunctionLogErr
LogErr logs the given error
utils/helper.go:42
↓ 4 callersFunctionGetDownloadFilePathName
* GetDownloadFilePathName returns the absolute path of the file present in downloads folder takes fileName as argument */
utils/files.go:17
↓ 3 callersFunctionFetch
* Fetch downlods a file to downloads folder from the given url, and names it as given fileName */
utils/fetch.go:17
↓ 3 callersFunctionGetCloudSession
()
configs/cloud.go:48
↓ 3 callersFunctionfailOnError
(err error)
configs/rabbitmq.go:49
↓ 2 callersFunctionCheckFileExistsAndAppendToBuffer
checkFileExistsAndAppendToBuffer checks if the given output file exits, then appends the path to buffer.
utils/files.go:116
↓ 2 callersFunctionDeleteFile
DeleteFile deletes the given file
utils/files.go:107
↓ 2 callersFunctionFileIDGen
* FileIDGen returns an unique videoID and appends the fileExtension to it, it takes the fileExtensionas parameter */
utils/helper.go:17
↓ 2 callersFunctionGetGCPClient
(isServiceUser bool)
configs/cloud.go:83
↓ 2 callersFunctionGetOutputFilePathName
* GetOutputFilePathName returns the absolute path of the file present in output folder takes fileName as argument */
utils/files.go:41
↓ 2 callersFunctionGetWhichCloudIsEnabled
()
utils/upload.go:232
↓ 2 callersMethodIsEmpty
()
types/video.go:40
↓ 2 callersFunctionIsFileValid
IsFileValid checks if the file is present on that path, returns true, if file is there else false
utils/files.go:82
↓ 2 callersMethodUpload
(walker fileWalk)
utils/upload.go:30
↓ 2 callersFunctioncreateDirPath
createDirPath creates a directory at the given path
utils/files.go:65
↓ 1 callersMethodGet
(c *gin.Context)
controllers/image.go:11
↓ 1 callersFunctionGetCloudStoragePath
(basePath, fileName string)
utils/upload.go:355
↓ 1 callersFunctionGetQueryHash
GetQueryHash returns the md5 hash of the query string
utils/helper.go:60
↓ 1 callersFunctionGetRabbitMQ
()
configs/rabbitmq.go:45
↓ 1 callersFunctionGetSignedURL
(fileID string, basePath string)
utils/upload.go:248
↓ 1 callersFunctionGetUploader
(containerName string, videoId string)
utils/upload.go:33
↓ 1 callersFunctionInit
Init function will perform all route operations
routes/routes.go:11
↓ 1 callersFunctionInitCloud
()
configs/cloud.go:24
↓ 1 callersFunctionInitRabbitMQ
()
configs/rabbitmq.go:18
↓ 1 callersFunctionLoadEnv
()
configs/configs.go:69
↓ 1 callersFunctionPublishEvent
(ch *rmq.Channel, q *rmq.Queue, ctx context.Context, body []byte)
utils/rabbitmq.go:9
↓ 1 callersFunctionRemoveExtensionFromFile
RemoveExtensionFromFile returns the fileName without the extension, if fileName doesn't end with ext, it returns the fileName
utils/files.go:77
↓ 1 callersFunctionSortString
sortString sorts the given string
utils/helper.go:49
↓ 1 callersFunctionStringToArgsGenerator
StringToArgsGenerator takes a map of arguments, and it returns the command line form of arguments
utils/files.go:90
↓ 1 callersFunctionUploadToCloudStorage
(uploader Uploader, path string)
utils/upload.go:65
↓ 1 callersFunctionVideoProcessConsumer
(ch *rmq.Channel, q *rmq.Queue)
service/consumer.go:16
↓ 1 callersFunctionWrapStringInQuotes
WrapStringInQuotes returns the string wrapped in quotes
utils/helper.go:32
↓ 1 callersFunctiondeleteVideoFiles
deleteVideoFiles deletes the videos given in the path
service/dash.go:168
↓ 1 callersFunctionfailOnError
(err error)
main.go:39
↓ 1 callersFunctiongenerateAWSSignedURL
(filePath string)
utils/upload.go:286
↓ 1 callersFunctiongenerateAudioFiles
(targetFile string, outputPath string, wg *sync.WaitGroup)
service/dash.go:48
↓ 1 callersFunctiongenerateAzureSignedURL
(filePath string)
utils/upload.go:329
↓ 1 callersFunctiongenerateBlobSAS
(blobURL azblob.BlobURL, permissions string)
utils/upload.go:308
↓ 1 callersFunctiongenerateDash
(fileName string, watermark types.WaterMark)
service/dash.go:16
↓ 1 callersFunctiongenerateGCPSignedURL
(filePath string)
utils/upload.go:269
↓ 1 callersFunctiongenerateMPD
generateMPD (Media Presentation Description), generates the XML description file for the given output path.
service/dash.go:135
↓ 1 callersFunctiongenerateMultiBitrateAudio
(targetFile string, outputFile string, fileType constants.FILE_TYPE, wg *sync.WaitGroup)
service/dash.go:72
↓ 1 callersFunctiongenerateMultiBitrateVideo
(targetFile string, outputFile string, fileType constants.FILE_TYPE, watermark types.WaterMark, wg *sync.WaitG
service/dash.go:91
↓ 1 callersFunctiongenerateThumbnailFiles
(targetFile string, outputPath string, wg *sync.WaitGroup)
service/dash.go:64
↓ 1 callersFunctiongenerateThumbnails
generateThumbnail generates a thumbnail at given timestamp, from the target file and write it to output file
service/dash.go:116
↓ 1 callersFunctiongenerateVideoFiles
(targetFile string, outputPath string, watermark types.WaterMark, wg *sync.WaitGroup)
service/dash.go:56
↓ 1 callersFunctiongetAWSSession
()
configs/cloud.go:52
↓ 1 callersFunctiongetAzureCreds
()
configs/cloud.go:70
↓ 1 callersFunctiongetEnv
(key, fallback string)
configs/configs.go:81
↓ 1 callersFunctiongetInput
Returns input based on if the watermark is needed or not
service/dash.go:177
↓ 1 callersFunctiongetOverlay
Returns an overlay of watermark which can be used in Filter
service/dash.go:199
↓ 1 callersFunctionmakeRequest
* MakeRequest is a helper function that creates an HTTP request and sends it to the router, returning the response that the router returns. It takes i
controllers/test.go:32
↓ 1 callersFunctionprocessVideo
(video *types.Video, guard <-chan int)
service/consumer.go:67
↓ 1 callersFunctionrouter
router is a function that returns a new instance of the Gin router with a single route defined:
controllers/test.go:12
FunctionGetPresignedURL
(c *gin.Context)
controllers/upload.go:11
FunctionPing
(c *gin.Context)
controllers/ping.go:9
FunctionTestFetch
(t *testing.T)
utils/fetch_test.go:11
FunctionTestFileIDGen
(t *testing.T)
utils/helper_test.go:10
FunctionTestPing
* TestPing is a test function that sends a GET request to the "/api/v1/ping" route and verifies that the response has a 200 OK status code and a body
controllers/ping_test.go:13
MethodUpload
(walker fileWalk)
utils/upload.go:99
MethodUpload
(walker fileWalk)
utils/upload.go:141
MethodUpload
(walker fileWalk)
utils/upload.go:189
MethodVideo
(c *gin.Context)
controllers/process.go:15
MethodWalkFunc
(path string, info os.FileInfo, err error)
utils/upload.go:80
Functionmain
()
main.go:13