mirror of
https://github.com/livekit/livekit.git
synced 2026-04-05 14:35:59 +00:00
a877ba2352
- Store agent dispaches independently of room agents on rtc.Room - Serialize agent dispatches in rtc.Room - Support for agent dispatch and job serialization in redis The agent Job object references denormalized Room and ParticipantInfo object. When storing Jobs, this sets the Room to nil, and only stores the Participant identity field. When read back, these fields need to be set to their current value.
108 lines
5.0 KiB
Go
108 lines
5.0 KiB
Go
// Copyright 2023 LiveKit, Inc.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package service
|
|
|
|
import (
|
|
"context"
|
|
"time"
|
|
|
|
"github.com/livekit/protocol/livekit"
|
|
)
|
|
|
|
//go:generate go run github.com/maxbrunsfeld/counterfeiter/v6 -generate
|
|
|
|
// encapsulates CRUD operations for room settings
|
|
//
|
|
//counterfeiter:generate . ObjectStore
|
|
type ObjectStore interface {
|
|
ServiceStore
|
|
|
|
// enable locking on a specific room to prevent race
|
|
// returns a (lock uuid, error)
|
|
LockRoom(ctx context.Context, roomName livekit.RoomName, duration time.Duration) (string, error)
|
|
UnlockRoom(ctx context.Context, roomName livekit.RoomName, uid string) error
|
|
|
|
StoreRoom(ctx context.Context, room *livekit.Room, internal *livekit.RoomInternal) error
|
|
|
|
StoreParticipant(ctx context.Context, roomName livekit.RoomName, participant *livekit.ParticipantInfo) error
|
|
DeleteParticipant(ctx context.Context, roomName livekit.RoomName, identity livekit.ParticipantIdentity) error
|
|
}
|
|
|
|
//counterfeiter:generate . ServiceStore
|
|
type ServiceStore interface {
|
|
LoadRoom(ctx context.Context, roomName livekit.RoomName, includeInternal bool) (*livekit.Room, *livekit.RoomInternal, error)
|
|
DeleteRoom(ctx context.Context, roomName livekit.RoomName) error
|
|
|
|
// ListRooms returns currently active rooms. if names is not nil, it'll filter and return
|
|
// only rooms that match
|
|
ListRooms(ctx context.Context, roomNames []livekit.RoomName) ([]*livekit.Room, error)
|
|
LoadParticipant(ctx context.Context, roomName livekit.RoomName, identity livekit.ParticipantIdentity) (*livekit.ParticipantInfo, error)
|
|
ListParticipants(ctx context.Context, roomName livekit.RoomName) ([]*livekit.ParticipantInfo, error)
|
|
}
|
|
|
|
//counterfeiter:generate . EgressStore
|
|
type EgressStore interface {
|
|
StoreEgress(ctx context.Context, info *livekit.EgressInfo) error
|
|
LoadEgress(ctx context.Context, egressID string) (*livekit.EgressInfo, error)
|
|
ListEgress(ctx context.Context, roomName livekit.RoomName, active bool) ([]*livekit.EgressInfo, error)
|
|
UpdateEgress(ctx context.Context, info *livekit.EgressInfo) error
|
|
}
|
|
|
|
//counterfeiter:generate . IngressStore
|
|
type IngressStore interface {
|
|
StoreIngress(ctx context.Context, info *livekit.IngressInfo) error
|
|
LoadIngress(ctx context.Context, ingressID string) (*livekit.IngressInfo, error)
|
|
LoadIngressFromStreamKey(ctx context.Context, streamKey string) (*livekit.IngressInfo, error)
|
|
ListIngress(ctx context.Context, roomName livekit.RoomName) ([]*livekit.IngressInfo, error)
|
|
UpdateIngress(ctx context.Context, info *livekit.IngressInfo) error
|
|
UpdateIngressState(ctx context.Context, ingressId string, state *livekit.IngressState) error
|
|
DeleteIngress(ctx context.Context, info *livekit.IngressInfo) error
|
|
}
|
|
|
|
//counterfeiter:generate . RoomAllocator
|
|
type RoomAllocator interface {
|
|
CreateRoom(ctx context.Context, req *livekit.CreateRoomRequest) (*livekit.Room, bool, error)
|
|
ValidateCreateRoom(ctx context.Context, roomName livekit.RoomName) error
|
|
}
|
|
|
|
//counterfeiter:generate . SIPStore
|
|
type SIPStore interface {
|
|
StoreSIPTrunk(ctx context.Context, info *livekit.SIPTrunkInfo) error
|
|
StoreSIPInboundTrunk(ctx context.Context, info *livekit.SIPInboundTrunkInfo) error
|
|
StoreSIPOutboundTrunk(ctx context.Context, info *livekit.SIPOutboundTrunkInfo) error
|
|
LoadSIPTrunk(ctx context.Context, sipTrunkID string) (*livekit.SIPTrunkInfo, error)
|
|
LoadSIPInboundTrunk(ctx context.Context, sipTrunkID string) (*livekit.SIPInboundTrunkInfo, error)
|
|
LoadSIPOutboundTrunk(ctx context.Context, sipTrunkID string) (*livekit.SIPOutboundTrunkInfo, error)
|
|
ListSIPTrunk(ctx context.Context) ([]*livekit.SIPTrunkInfo, error)
|
|
ListSIPInboundTrunk(ctx context.Context) ([]*livekit.SIPInboundTrunkInfo, error)
|
|
ListSIPOutboundTrunk(ctx context.Context) ([]*livekit.SIPOutboundTrunkInfo, error)
|
|
DeleteSIPTrunk(ctx context.Context, info *livekit.SIPTrunkInfo) error
|
|
|
|
StoreSIPDispatchRule(ctx context.Context, info *livekit.SIPDispatchRuleInfo) error
|
|
LoadSIPDispatchRule(ctx context.Context, sipDispatchRuleID string) (*livekit.SIPDispatchRuleInfo, error)
|
|
ListSIPDispatchRule(ctx context.Context) ([]*livekit.SIPDispatchRuleInfo, error)
|
|
DeleteSIPDispatchRule(ctx context.Context, info *livekit.SIPDispatchRuleInfo) error
|
|
}
|
|
|
|
//counterfeiter:generate . AgentStore
|
|
type AgentStore interface {
|
|
StoreAgentDispatch(ctx context.Context, dispatch *livekit.AgentDispatch) error
|
|
DeleteAgentDispatch(ctx context.Context, dispatch *livekit.AgentDispatch) error
|
|
ListAgentDispatches(ctx context.Context, roomName livekit.RoomName) ([]*livekit.AgentDispatch, error)
|
|
|
|
StoreAgentJob(ctx context.Context, job *livekit.Job) error
|
|
DeleteAgentJob(ctx context.Context, job *livekit.Job) error
|
|
}
|