Versions in this module Expand all Collapse all v1 v1.5.1 May 26, 2023 Changes in this version + const EgressTypeRoomComposite + const EgressTypeTrack + const EgressTypeTrackComposite + const EgressTypeWeb + const OutputTypeFile + const OutputTypeMultiple + const OutputTypeSegments + const OutputTypeStream + const RequestExpiration + const Unknown + var ErrEgressTimedOut = errors.New("egress timed out") + var ErrNoResponse = errors.New("no response from egress service") + func BuildEgressToken(egressID, apiKey, secret, roomName string) (string, error) + func GetTypes(info *livekit.EgressInfo) (string, string) + type RPCClient interface + GetUpdateChannel func(ctx context.Context) (utils.PubSub, error) + SendRequest func(ctx context.Context, req proto.Message) (*livekit.EgressInfo, error) + func NewRedisRPCClient(nodeID livekit.NodeID, rc redis.UniversalClient) RPCClient + type RPCServer interface + ClaimRequest func(ctx context.Context, request *livekit.StartEgressRequest) (bool, error) + EgressSubscription func(ctx context.Context, egressID string) (utils.PubSub, error) + GetRequestChannel func(ctx context.Context) (utils.PubSub, error) + SendResponse func(ctx context.Context, request proto.Message, info *livekit.EgressInfo, ...) error + SendUpdate func(ctx context.Context, info *livekit.EgressInfo) error + func NewRedisRPCServer(rc redis.UniversalClient) RPCServer + type RedisRPC struct + func (r *RedisRPC) ClaimRequest(ctx context.Context, req *livekit.StartEgressRequest) (bool, error) + func (r *RedisRPC) EgressSubscription(ctx context.Context, egressID string) (utils.PubSub, error) + func (r *RedisRPC) GetRequestChannel(ctx context.Context) (utils.PubSub, error) + func (r *RedisRPC) GetUpdateChannel(ctx context.Context) (utils.PubSub, error) + func (r *RedisRPC) SendRequest(ctx context.Context, request proto.Message) (*livekit.EgressInfo, error) + func (r *RedisRPC) SendResponse(ctx context.Context, request proto.Message, info *livekit.EgressInfo, ...) error + func (r *RedisRPC) SendUpdate(ctx context.Context, info *livekit.EgressInfo) error
Go to main page