utils

Documentation

Index

• Constants
• Variables
• func EndRecordingChannel(id string) string
• func NewGuid(prefix string) string
• func RandomSecret() string
• func ReservationResponseChannel(id string) string
• func StartRecordingChannel(id string) string
• type AtomicFlag
  • func (b *AtomicFlag) Get() bool
  • func (b *AtomicFlag) TrySet(bVal bool) bool
• type MessageBus
  • func NewRedisMessageBus(rc *redis.Client) MessageBus
• type PubSub
• type RedisMessageBus
  • func (r *RedisMessageBus) Lock(ctx context.Context, key string, expiration time.Duration) (bool, error)
  • func (r *RedisMessageBus) Publish(ctx context.Context, channel string, message interface{}) error
  • func (r *RedisMessageBus) Subscribe(ctx context.Context, channel string) (PubSub, error)
• type RedisPubSub
  • func (r *RedisPubSub) Channel() <-chan interface{}
  • func (r *RedisPubSub) Close() error
  • func (r *RedisPubSub) Payload(msg interface{}) []byte

Constants

const (
	RoomPrefix        = "RM_"
	NodePrefix        = "ND_"
	ParticipantPrefix = "PA_"
	TrackPrefix       = "TR_"
	APIKeyPrefix      = "API"
	RecordingPrefix   = "RR_"
)

const (
	ReservationChannel = "RESERVE_RECORDER"
	RecorderTimeout    = time.Second * 3
	ReservationTimeout = time.Second * 2
)

Variables

var (
	ErrChannelClosed = errors.New("cannot write to closed channel")
)

Functions

func EndRecordingChannel

func EndRecordingChannel(id string) string

func NewGuid

func NewGuid(prefix string) string

func RandomSecret

func RandomSecret() string

func ReservationResponseChannel

func ReservationResponseChannel(id string) string

func StartRecordingChannel

func StartRecordingChannel(id string) string

Types

type AtomicFlag

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

func (*AtomicFlag) Get

func (b *AtomicFlag) Get() bool

func (*AtomicFlag) TrySet

func (b *AtomicFlag) TrySet(bVal bool) bool

set flag to value if existing flag is different, otherwise return

type MessageBus

type MessageBus interface {
	Lock(ctx context.Context, key string, expiration time.Duration) (acquired bool, err error)
	Subscribe(ctx context.Context, channel string) (PubSub, error)
	Publish(ctx context.Context, channel string, msg interface{}) error
}

func NewRedisMessageBus

func NewRedisMessageBus(rc *redis.Client) MessageBus

type PubSub

type PubSub interface {
	Channel() <-chan interface{}
	Payload(msg interface{}) []byte
	Close() error
}

type RedisMessageBus

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

func (*RedisMessageBus) Lock

func (r *RedisMessageBus) Lock(ctx context.Context, key string, expiration time.Duration) (bool, error)

func (*RedisMessageBus) Publish

func (r *RedisMessageBus) Publish(ctx context.Context, channel string, message interface{}) error

func (*RedisMessageBus) Subscribe

func (r *RedisMessageBus) Subscribe(ctx context.Context, channel string) (PubSub, error)

type RedisPubSub

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

func (*RedisPubSub) Channel

func (r *RedisPubSub) Channel() <-chan interface{}

func (*RedisPubSub) Close

func (r *RedisPubSub) Close() error

func (*RedisPubSub) Payload

func (r *RedisPubSub) Payload(msg interface{}) []byte