Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

utils

package

Go to main page

Versions in this module

v0

v0.2.1

May 25, 2024

v0.2.0

May 25, 2024

v0.1.3

May 13, 2024

v0.1.2

May 9, 2024

Changes in this version

type S3Client

+ ListObjects func(ctxt context.Context, bucket string, prefix *string) ([]string, error)

v0.1.1

Feb 10, 2024

v0.1.0

Jan 7, 2024

Changes in this version

+ const MetricsNameControlCentralSegmentMgmtSegmentReadCount

+ const MetricsNameControlCentralSegmentMgmtSegmentReadLen

+ const MetricsNameControlManagerActiveRecordingCount

+ const MetricsNameControlManagerConnectedSourceCount

+ const MetricsNameControlManagerRegisteredRecordingCount

+ const MetricsNameControlManagerRegisteredSourceCount

+ const MetricsNameEdgeManagerActiveRecordingCount

+ const MetricsNameEdgeManagerSegmentReadCount

+ const MetricsNameEdgeManagerSegmentReadLen

+ const MetricsNameForwarderSenderSegmentForwardCount

+ const MetricsNameForwarderSenderSegmentForwardLatency

+ const MetricsNameForwarderSenderSegmentForwardLen

+ const MetricsNameTrackerMonitorNewSegmentCount

+ const MetricsNameTrackerMonitorPlaylistReadCount

+ const MetricsNameTrackerMonitorSegmentForwardCount

+ const MetricsNameTrackerMonitorSegmentForwardLen

+ const MetricsNameTrackerMonitorSegmentReadCount

+ const MetricsNameTrackerMonitorSegmentReadLen

+ const MetricsNameUtilCacheCurrentCount

+ const MetricsNameUtilCacheIOCount

+ const MetricsNameUtilCacheIOLatency

+ const MetricsNameUtilCacheSegmentLen

+ const MetricsNameUtilFetcherIOCount

+ const MetricsNameUtilFetcherReadLatency

+ const MetricsNameUtilFetcherSegmentLen

+ const MetricsNameVODPlaylistBuiltCount

+ const MetricsNameVODSegmentMgmtIOCount

+ const MetricsNameVODSegmentMgmtSegmentLen

+ func CleanupObjectKey(orig string) string

+ func ReadPlaylistFile(playlistFile string) (uri string, content []string, err error)

+ type Broadcaster interface

+ Broadcast func(ctxt context.Context, message interface{}) error

+ func NewPubSubBroadcaster(psClient goutils.PubSubClient, broadcastTopic string) (Broadcaster, error)

+ type FSEvent struct

+ Meta fs.FileInfo

+ type FileSystemWatcher interface

+ AddPath func(ctxt context.Context, newPath string) error

+ RemovePath func(ctxt context.Context, path string) error

+ Start func(ctxt, runtimeCtxt context.Context) error

+ Stop func(ctxt context.Context) error

+ func NewFileSystemWatcher(eventChan chan FSEvent) (FileSystemWatcher, error)

+ type S3BulkDeleteError struct

+ Err error

+ Object string

+ func (e S3BulkDeleteError) Error() string

+ type S3Client interface

+ CreateBucket func(ctxt context.Context, bucketName string) error

+ DeleteBucket func(ctxt context.Context, bucketName string) error

+ DeleteObject func(ctxt context.Context, bucketName, objectKey string) error

+ DeleteObjects func(ctxt context.Context, bucketName string, objectKeys []string) []S3BulkDeleteError

+ GetObject func(ctxt context.Context, bucketName, objectKey string) ([]byte, error)

+ ListBuckets func(ctxt context.Context) ([]string, error)

+ PutObject func(ctxt context.Context, bucketName, objectKey string, content []byte) error

+ func NewS3Client(config common.S3Config) (S3Client, error)

+ type SegmentMetricsAgent interface

+ RecordSegment func(segmentSize int, labels map[string]string)

+ func NewSegmentMetricsAgent(ctxt context.Context, collector goutils.MetricsCollector, ...) (SegmentMetricsAgent, error)

+ type SegmentReader interface

+ ReadSegment func(ctxt context.Context, segment common.VideoSegment, ...) error

+ Stop func(ctxt context.Context) error

+ func NewSegmentReader(parentContext context.Context, workerCount int, s3 S3Client, ...) (SegmentReader, error)

+ type SegmentReturnCallback func(ctxt context.Context, segmentID string, content []byte) error

+ type VideoSegmentCache interface

+ CacheSegment func(ctxt context.Context, segment common.VideoSegmentWithData, ttl time.Duration) error

+ GetSegment func(ctxt context.Context, segment common.VideoSegment) ([]byte, error)

+ GetSegments func(ctxt context.Context, segments []common.VideoSegment) (map[string][]byte, error)

+ PurgeSegments func(ctxt context.Context, segments []common.VideoSegment) error

+ func NewLocalVideoSegmentCache(parentContext context.Context, retentionCheckInterval time.Duration, ...) (VideoSegmentCache, error)

+ func NewMemcachedVideoSegmentCache(ctxt context.Context, servers []string, metrics goutils.MetricsCollector) (VideoSegmentCache, error)