cloud

Documentation

Overview

Package cloud contains the Dropbox implementation of the Cloud interface. It uses the Dropbox SDK to upload files to Dropbox.

Index

• Variables
• func GetSystemInfo() (models.System, error)
• func HandleHeartBeat(configuration *models.Configuration, communication *models.Communication, ...)
• func HandleLiveStreamHD(livestreamCursor *packets.QueueCursor, configuration *models.Configuration, ...)
• func HandleLiveStreamSD(livestreamCursor *packets.QueueCursor, configuration *models.Configuration, ...)
• func HandleRealtimeProcessing(processingCursor *packets.QueueCursor, configuration *models.Configuration, ...)
• func HandleUpload(configDirectory string, configuration *models.Configuration, ...)
• func PendingUpload(configDirectory string)
• func UploadDropbox(configuration *models.Configuration, fileName string) (bool, bool, error)
• func UploadKerberosHub(configuration *models.Configuration, fileName string) (bool, bool, error)
• func UploadKerberosVault(configuration *models.Configuration, fileName string) (bool, bool, error)
• func UploadS3(configuration *models.Configuration, fileName string) (bool, bool, error)
• func VerifyDropbox(config models.Config, c *gin.Context)
• func VerifyHub(c *gin.Context)
• func VerifyPersistence(c *gin.Context, configDirectory string)

Variables

var TestFile = []byte{} /* 331079 elements not displayed */

This is the Kerberos.io intro video -> https://www.youtube.com/@kerberos-io

Functions

func GetSystemInfo

func GetSystemInfo() (models.System, error)

func HandleHeartBeat

func HandleHeartBeat(configuration *models.Configuration, communication *models.Communication, uptimeStart time.Time)

func HandleLiveStreamHD

func HandleLiveStreamHD(livestreamCursor *packets.QueueCursor, configuration *models.Configuration, communication *models.Communication, mqttClient mqtt.Client, rtspClient capture.RTSPClient)

func HandleLiveStreamSD

func HandleLiveStreamSD(livestreamCursor *packets.QueueCursor, configuration *models.Configuration, communication *models.Communication, mqttClient mqtt.Client, rtspClient capture.RTSPClient)

func HandleRealtimeProcessing

func HandleRealtimeProcessing(processingCursor *packets.QueueCursor, configuration *models.Configuration, communication *models.Communication, mqttClient mqtt.Client, rtspClient capture.RTSPClient)

func HandleUpload

func HandleUpload(configDirectory string, configuration *models.Configuration, communication *models.Communication)

func PendingUpload

func PendingUpload(configDirectory string)

func UploadDropbox

func UploadDropbox(configuration *models.Configuration, fileName string) (bool, bool, error)

UploadDropbox uploads the file to your Dropbox account using the access token and directory.

func UploadKerberosHub

func UploadKerberosHub(configuration *models.Configuration, fileName string) (bool, bool, error)

func UploadKerberosVault

func UploadKerberosVault(configuration *models.Configuration, fileName string) (bool, bool, error)

func UploadS3

func UploadS3(configuration *models.Configuration, fileName string) (bool, bool, error)

func VerifyDropbox

func VerifyDropbox(config models.Config, c *gin.Context)

VerifyDropbox verifies if the Dropbox token is valid and it is able to upload a file.

func VerifyHub

func VerifyHub(c *gin.Context)

VerifyHub godoc @Router /api/hub/verify [post] @ID verify-hub @Security Bearer @securityDefinitions.apikey Bearer @in header @name Authorization @Tags persistence @Param config body models.Config true "Config" @Summary Will verify the hub connectivity. @Description Will verify the hub connectivity. @Success 200 {object} models.APIResponse

func VerifyPersistence

func VerifyPersistence(c *gin.Context, configDirectory string)

VerifyPersistence godoc @Router /api/persistence/verify [post] @ID verify-persistence @Security Bearer @securityDefinitions.apikey Bearer @in header @name Authorization @Tags persistence @Param config body models.Config true "Config" @Summary Will verify the persistence. @Description Will verify the persistence. @Success 200 {object} models.APIResponse