db

Aug 15, 2024

Changes in this version

type Store

+ func (s *Store) GetRecordingJobsByDay() (map[string]int64, error)

+ func (s *Store) GetRecordingJobsByMonth() (map[string]int64, error)

Jul 12, 2024

Changes in this version

type Store

+ func (s *Store) IsUserInCall(userID, callID string, opts GetCallSessionOpts) (bool, error)

Jun 13, 2024

Changes in this version

type Store

+ func (s *Store) GetAvgCallDuration() (int64, error)

+ func (s *Store) GetAvgCallParticipants() (int64, error)

+ func (s *Store) GetCallActive(channelID string, opts GetCallOpts) (bool, error)

+ func (s *Store) GetCallSessionsCount(callID string, opts GetCallSessionOpts) (int, error)

+ func (s *Store) GetCallsByChannelType() (map[string]int64, error)

+ func (s *Store) GetCallsByDay() (map[string]int64, error)

+ func (s *Store) GetCallsByMonth() (map[string]int64, error)

+ func (s *Store) GetCallsStats() (*public.CallsStats, error)

+ func (s *Store) GetTotalActiveSessions() (int64, error)

+ func (s *Store) GetTotalCalls(active bool) (int64, error)

May 16, 2024

Changes in this version

+ var ErrNotFound = errors.New("not found")

+ type GetCallJobOpts struct

+ FromWriter bool

+ IncludeEnded bool

+ func (o GetCallJobOpts) UseWriter() bool

+ type GetCallOpts struct

+ FromWriter bool

+ func (o GetCallOpts) UseWriter() bool

+ type GetCallSessionOpts struct

+ FromWriter bool

+ func (o GetCallSessionOpts) UseWriter() bool

+ type GetCallsChannelOpts struct

+ FromWriter bool

+ func (o GetCallsChannelOpts) UseWriter() bool

+ type Store struct

+ func NewStore(settings model.SqlSettings, wConnector, rConnector driver.Connector, ...) (*Store, error)

+ func (s *Store) Close() error

+ func (s *Store) CreateCall(call *public.Call) error

+ func (s *Store) CreateCallJob(job *public.CallJob) error

+ func (s *Store) CreateCallSession(session *public.CallSession) error

+ func (s *Store) CreateCallsChannel(channel *public.CallsChannel) error

+ func (s *Store) DeleteCall(callID string) error

+ func (s *Store) DeleteCallByChannelID(channelID string) error

+ func (s *Store) DeleteCallSession(id string) error

+ func (s *Store) DeleteCallsSessions(callID string) error

+ func (s *Store) GetActiveCallByChannelID(channelID string, opts GetCallOpts) (*public.Call, error)

+ func (s *Store) GetActiveCallJobs(callID string, opts GetCallJobOpts) (map[public.JobType]*public.CallJob, error)

+ func (s *Store) GetAllActiveCalls(opts GetCallOpts) ([]*public.Call, error)

+ func (s *Store) GetAllCallsChannels(opts GetCallsChannelOpts) ([]*public.CallsChannel, error)

+ func (s *Store) GetCall(callID string, opts GetCallOpts) (*public.Call, error)

+ func (s *Store) GetCallJob(id string, opts GetCallJobOpts) (*public.CallJob, error)

+ func (s *Store) GetCallSession(id string, opts GetCallSessionOpts) (*public.CallSession, error)

+ func (s *Store) GetCallSessions(callID string, opts GetCallSessionOpts) (map[string]*public.CallSession, error)

+ func (s *Store) GetCallsChannel(channelID string, opts GetCallsChannelOpts) (*public.CallsChannel, error)

+ func (s *Store) GetPost(postID string) (*model.Post, error)

+ func (s *Store) GetRTCDHostForCall(callID string, opts GetCallOpts) (string, error)

+ func (s *Store) KVGet(pluginID, key string, fromWriter bool) ([]byte, error)

+ func (s *Store) Migrate(direction models.Direction, dryRun bool) error

+ func (s *Store) UpdateCall(call *public.Call) error

+ func (s *Store) UpdateCallJob(job *public.CallJob) error

+ func (s *Store) UpdateCallSession(session *public.CallSession) error

+ func (s *Store) UpdateCallsChannel(channel *public.CallsChannel) error

+ func (s *Store) UpdateFileInfoPostID(fileID, channelID, postID string) error

+ func (s *Store) WriterDB() *sql.DB