files

Documentation

Index

• func PatchChunk(s Service) gin.HandlerFunc
• func ReceiveFirstChunk(s Service) gin.HandlerFunc
• func RemoveChunk(s Service) gin.HandlerFunc
• type FileFeed
  • func NewFeed(ws *gorilla_ws.Conn, hub websocket.IHub, service Service) *FileFeed
  • func (f *FileFeed) Stop()
• type Service
  • func NewService() Service
• type ServiceImpl
  • func (*ServiceImpl) AppendChunk(f *model.FileChunk) (float64, error)
  • func (s *ServiceImpl) CreateFile(f *model.InitialFileData) (float64, error)
  • func (s *ServiceImpl) Remove(name string) error
  • func (s *ServiceImpl) Start()
  • func (s *ServiceImpl) Stop()

Functions

func PatchChunk

func PatchChunk(s Service) gin.HandlerFunc

func ReceiveFirstChunk

func ReceiveFirstChunk(s Service) gin.HandlerFunc

func RemoveChunk

func RemoveChunk(s Service) gin.HandlerFunc

Types

type FileFeed

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

func NewFeed

func NewFeed(ws *gorilla_ws.Conn, hub websocket.IHub, service Service) *FileFeed

func (*FileFeed) Stop

func (f *FileFeed) Stop()

type Service

type Service interface {
	CreateFile(f *model.InitialFileData) (float64, error)
	AppendChunk(f *model.FileChunk) (float64, error)
	Remove(name string) error
	Start()
	Stop()
}

func NewService

func NewService() Service

type ServiceImpl

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

func (*ServiceImpl) AppendChunk

func (*ServiceImpl) AppendChunk(f *model.FileChunk) (float64, error)

func (*ServiceImpl) CreateFile

func (s *ServiceImpl) CreateFile(f *model.InitialFileData) (float64, error)

func (*ServiceImpl) Remove

func (s *ServiceImpl) Remove(name string) error

func (*ServiceImpl) Start

func (s *ServiceImpl) Start()

func (*ServiceImpl) Stop

func (s *ServiceImpl) Stop()