Documentation
¶
Index ¶
- func DeleteMedia(ctx rcontext.RequestContext, hash string) error
- func GetMutex(key string, expiration time.Duration) *redsync.Mutex
- func Publish(ctx rcontext.RequestContext, channel string, payload string) error
- func Reconnect()
- func Stop()
- func StoreMedia(ctx rcontext.RequestContext, hash string, content io.Reader, size int64) error
- func Subscribe(channel string) <-chan string
- func TryGetMedia(ctx rcontext.RequestContext, hash string) (io.ReadSeeker, error)
- type PubSubValue
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeleteMedia ¶
func DeleteMedia(ctx rcontext.RequestContext, hash string) error
func StoreMedia ¶
func TryGetMedia ¶
func TryGetMedia(ctx rcontext.RequestContext, hash string) (io.ReadSeeker, error)
Types ¶
type PubSubValue ¶
Click to show internal directories.
Click to hide internal directories.