Versions in this module Expand all Collapse all v0 v0.19.2 Jul 10, 2024 Changes in this version + var ErrStreamExists = errors.New("stream already exists") + func SetLogger(l *zap.SugaredLogger) + type LocalStorage struct + func Local(path string) LocalStorage + func (s LocalStorage) Delete(sdHash string) error + func (s LocalStorage) Path() string + type S3Configuration struct + func S3Configure() *S3Configuration + func (c *S3Configuration) Bucket(b string) *S3Configuration + func (c *S3Configuration) CreateBucket() *S3Configuration + func (c *S3Configuration) Credentials(accessKey, secretKey string) *S3Configuration + func (c *S3Configuration) DisableSSL() *S3Configuration + func (c *S3Configuration) Endpoint(e string) *S3Configuration + func (c *S3Configuration) Name(n string) *S3Configuration + func (c *S3Configuration) Region(r string) *S3Configuration + type S3Driver struct + func InitS3Driver(cfg *S3Configuration) (*S3Driver, error) + func (s *S3Driver) Delete(streamTID string) error + func (s *S3Driver) GetFragment(streamTID, name string) (StreamFragment, error) + func (s *S3Driver) GetURL(streamTID string) string + func (s *S3Driver) Name() string + func (s *S3Driver) Put(stream *library.Stream, overwrite bool) error + func (s *S3Driver) PutWithContext(ctx context.Context, stream *library.Stream, overwrite bool) error + type StreamFragment interface
Go to main page