analytics

Documentation

Index

• Variables
• func InitializeAnalytics(configuration *config.Config) error
• func Start()
• type AnalyticsSender
• type DatabaseClient
• type MongoDatabaseClient
  • func NewMongoDatabaseClient(conf *openviduconfig.AnalyticsConfig) (*MongoDatabaseClient, error)
  • func (m *MongoDatabaseClient) InitializeDatabase() error
  • func (m *MongoDatabaseClient) SendBatch()
• type OpenViduEventsIngestClient
  • func NewOpenViduEventsIngestClient() OpenViduEventsIngestClient
  • func (client OpenViduEventsIngestClient) CloseAndRecv() (*emptypb.Empty, error)
  • func (client OpenViduEventsIngestClient) Send(events *livekit.AnalyticsEvents) error
• type OpenViduStatsIngestClient
  • func NewOpenViduStatsIngestClient() OpenViduStatsIngestClient
  • func (client OpenViduStatsIngestClient) CloseAndRecv() (*emptypb.Empty, error)
  • func (client OpenViduStatsIngestClient) Send(stats *livekit.AnalyticsStats) error
• type RedisDatabaseClient
  • func NewRedisDatabaseClient(conf *openviduconfig.AnalyticsConfig, redisConfig *redisLiveKit.RedisConfig) (*RedisDatabaseClient, error)
  • func (m *RedisDatabaseClient) InitializeDatabase() error
  • func (r *RedisDatabaseClient) SendBatch()

Variables

var ANALYTICS_CONFIGURATION *openviduconfig.AnalyticsConfig

var ANALYTICS_SENDERS []*AnalyticsSender

Functions

func InitializeAnalytics

func InitializeAnalytics(configuration *config.Config) error

func Start

func Start()

Blocking method. Launch in goroutine

Types

type AnalyticsSender

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

type DatabaseClient

type DatabaseClient interface {
	InitializeDatabase() error
	SendBatch()
}

type MongoDatabaseClient

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

func NewMongoDatabaseClient

func NewMongoDatabaseClient(conf *openviduconfig.AnalyticsConfig) (*MongoDatabaseClient, error)

func (*MongoDatabaseClient) InitializeDatabase

func (m *MongoDatabaseClient) InitializeDatabase() error

func (*MongoDatabaseClient) SendBatch

func (m *MongoDatabaseClient) SendBatch()

type OpenViduEventsIngestClient

type OpenViduEventsIngestClient struct {
	// Must have this empty property to implement interface livekit.AnalyticsRecorderService_IngestEventsClient
	grpc.ClientStream
}

func NewOpenViduEventsIngestClient

func NewOpenViduEventsIngestClient() OpenViduEventsIngestClient

func (OpenViduEventsIngestClient) CloseAndRecv

func (client OpenViduEventsIngestClient) CloseAndRecv() (*emptypb.Empty, error)

We don't implement grpc, so this is an empty method

func (OpenViduEventsIngestClient) Send

func (client OpenViduEventsIngestClient) Send(events *livekit.AnalyticsEvents) error

type OpenViduStatsIngestClient

type OpenViduStatsIngestClient struct {
	// Must have this empty property to implement interface livekit.AnalyticsRecorderService_IngestStatsClient
	grpc.ClientStream
}

func NewOpenViduStatsIngestClient

func NewOpenViduStatsIngestClient() OpenViduStatsIngestClient

func (OpenViduStatsIngestClient) CloseAndRecv

func (client OpenViduStatsIngestClient) CloseAndRecv() (*emptypb.Empty, error)

We don't implement grpc, so this is an empty method

func (OpenViduStatsIngestClient) Send

func (client OpenViduStatsIngestClient) Send(stats *livekit.AnalyticsStats) error

type RedisDatabaseClient

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

func NewRedisDatabaseClient

func NewRedisDatabaseClient(conf *openviduconfig.AnalyticsConfig, redisConfig *redisLiveKit.RedisConfig) (*RedisDatabaseClient, error)

func (*RedisDatabaseClient) InitializeDatabase

func (m *RedisDatabaseClient) InitializeDatabase() error

func (*RedisDatabaseClient) SendBatch

func (r *RedisDatabaseClient) SendBatch()