resolve

Documentation

Index

• Variables
• func Resolve(uri string) (*ljsonrpc.Claim, error)
• func SetBlobServer(s string)
• func SetEdgeToken(s string)
• func SetLogger(l *zap.SugaredLogger)
• type ResolvedStream
  • func ResolveStream(uri string) (*ResolvedStream, error)
  • func (c *ResolvedStream) Download(dstDir string) (*os.File, int64, error)
• type WriteCounter
  • func (wc *WriteCounter) Write(p []byte) (int, error)

Variables

var (
	ErrTranscodingUnderway  = errors.New("transcoding is in progress")
	ErrTranscodingQueued    = errors.New("transcoding queued")
	ErrTranscodingForbidden = errors.New("transcoding is disabled for this channel")
	ErrChannelNotEnabled    = errors.New("transcoding is not enabled for this channel")

	ErrClaimNotFound    = errors.New("could not resolve stream URI")
	ErrNoSigningChannel = errors.New("no signing channel for stream")
)

var (
	ErrNotReflected = errors.New("stream not fully reflected")
	ErrNetwork      = errors.New("network error")
)

Functions

func Resolve

func Resolve(uri string) (*ljsonrpc.Claim, error)

func SetBlobServer

func SetBlobServer(s string)

func SetEdgeToken

func SetEdgeToken(s string)

func SetLogger

func SetLogger(l *zap.SugaredLogger)

Types

type ResolvedStream

type ResolvedStream struct {
	URI, Name, ClaimID, SDHash, ChannelURI,
	ChannelClaimID, NormalizedName string
	ChannelSupportAmount int64
}

func ResolveStream

func ResolveStream(uri string) (*ResolvedStream, error)

func (*ResolvedStream) Download

func (c *ResolvedStream) Download(dstDir string) (*os.File, int64, error)

Download retrieves a stream from LBRY CDN and saves it into dstDir folder under original name.

type WriteCounter

type WriteCounter struct {
	Loaded, Size uint64
	Started      time.Time
	URL          string
	// contains filtered or unexported fields
}

func (*WriteCounter) Write

func (wc *WriteCounter) Write(p []byte) (int, error)