stream

Documentation

Index

• Variables
• type IFileInfo
  • func NewFileInfo(pName, pHash string, pSize uint64) IFileInfo
• type IReadSeeker
  • func BuildStream(pCtx context.Context, pRetryNum uint64, pHlsClient hls_client.IClient, ...) (IReadSeeker, error)
• type SStreamError
  • func (err *SStreamError) Error() string

Variables

var (
	ErrWriteFileChunk   = &SStreamError{"write file chunk"}
	ErrLoadFileChunk    = &SStreamError{"load file chunk"}
	ErrInvalidHash      = &SStreamError{"invalid hash"}
	ErrRetryFailed      = &SStreamError{"retry failed"}
	ErrInvalidWhence    = &SStreamError{"invalid whence"}
	ErrNegativePosition = &SStreamError{"negative position"}
	ErrGetMessageLimit  = &SStreamError{"get message limit"}
)

Types

type IFileInfo

type IFileInfo interface {
	GetName() string
	GetHash() string
	GetSize() uint64
}

func NewFileInfo

func NewFileInfo(pName, pHash string, pSize uint64) IFileInfo

type IReadSeeker

type IReadSeeker io.ReadSeeker

func BuildStream

func BuildStream(
	pCtx context.Context,
	pRetryNum uint64,
	pHlsClient hls_client.IClient,
	pAliasName string,
	pFileInfo IFileInfo,
) (IReadSeeker, error)

type SStreamError

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

func (*SStreamError) Error

func (err *SStreamError) Error() string