api

Documentation

Index

• Variables
• func GetOzone(w http.ResponseWriter, req *http.Request)
• func GetVideoSlice(w http.ResponseWriter, req *http.Request)
• func GetVideoSliceCache(w http.ResponseWriter, req *http.Request)
• func PrepareSharedVideoFileCache(w http.ResponseWriter, req *http.Request)
• func PrepareVideoFileCache(w http.ResponseWriter, req *http.Request)
• func StartHTTPServ(ctx context.Context)
• type OzoneInfo
• type StreamInfo
• type StreamInfoRequest
• type StreamInfoResponse
• type StreamReqBody

Variables

var (
	//TODO to be replaced by other map implementation that has similar feature
	RequestInfoMap = utils.NewAutoCleanMap(1 * time.Hour)
)

Functions

func GetOzone

func GetOzone(w http.ResponseWriter, req *http.Request)

func GetVideoSlice

func GetVideoSlice(w http.ResponseWriter, req *http.Request)

func GetVideoSliceCache

func GetVideoSliceCache(w http.ResponseWriter, req *http.Request)

func PrepareSharedVideoFileCache

func PrepareSharedVideoFileCache(w http.ResponseWriter, req *http.Request)

func PrepareVideoFileCache

func PrepareVideoFileCache(w http.ResponseWriter, req *http.Request)

func StartHTTPServ

func StartHTTPServ(ctx context.Context)

Types

type OzoneInfo

type OzoneInfo struct {
	WalletAddress  string `json:"walletAddress"`
	SequenceNumber string `json:"sequenceNumber"`
	Ozone          string `json:"ozone"`
}

type StreamInfo

type StreamInfo struct {
	HeaderFile         string                               `json:"header_file"`
	FileHash           string                               `json:"file_hash"`
	SegmentToSliceInfo map[string]*protos.DownloadSliceInfo `json:"segment_to_slice_info"`
}

type StreamInfoRequest

type StreamInfoRequest struct {
	PubKey        string `json:"pubKey"`
	WalletAddress string `json:"walletAddress"`
	Signature     string `json:"signature"`
	ReqTime       int64  `json:"reqTime"`
}

type StreamInfoResponse

type StreamInfoResponse struct {
	HeaderFile string `json:"headerFile"`
	ReqId      string `json:"reqId"`
}

type StreamReqBody

type StreamReqBody struct {
	FileHash      string
	FileName      string
	WalletAddress string
	P2PAddress    string
	SpP2pAddress  string
	RestAddress   string
	Sign          []byte
	SavePath      string
	FileReqId     string
	FileTimestamp int64
	SliceInfo     *protos.DownloadSliceInfo
}