dao

Documentation

Index

• type Dao
  • func New(c *conf.Config) (dao *Dao)
  • func (d *Dao) Close()
  • func (d *Dao) CreateCall(ctx context.Context, call *model.RtcCall) (uint32, error)
  • func (d *Dao) CreateMediaPublish(ctx context.Context, publish *model.RtcMediaPublish) error
  • func (d *Dao) CreateMediaSource(ctx context.Context, source *model.RtcMediaSource) (uint32, error)
  • func (d *Dao) GetChannelIP(ctx context.Context, channelID uint64) ([]string, error)
  • func (d *Dao) GetMediaPublishConfig(ctx context.Context, channelID uint64, callID uint32) (*model.RtcMediaPublish, error)
  • func (d *Dao) GetMediaSource(ctx context.Context, channelID uint64) ([]*model.RtcMediaSource, error)
  • func (d *Dao) GetToken(ctx context.Context, channelID uint64, callID uint32) (string, error)
  • func (d *Dao) Ping(ctx context.Context) error
  • func (d *Dao) TerminateStream(ctx context.Context, channelID uint64, callID uint32) error
  • func (d *Dao) UpdateCallStatus(ctx context.Context, channelID uint64, callID uint32, userID uint64, ...) error
  • func (d *Dao) UpdateMediaPublishConfig(ctx context.Context, channelID uint64, callID uint32, config string) error
  • func (d *Dao) UpdateMediaSourceStatus(ctx context.Context, channelID uint64, callID uint32, userID uint64, ...) error

Types

type Dao

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

Dao dao

func New

func New(c *conf.Config) (dao *Dao)

New init mysql db

func (*Dao) Close

func (d *Dao) Close()

Close close the resource.

func (*Dao) CreateCall

func (d *Dao) CreateCall(ctx context.Context, call *model.RtcCall) (uint32, error)

func (*Dao) CreateMediaPublish

func (d *Dao) CreateMediaPublish(ctx context.Context, publish *model.RtcMediaPublish) error

func (*Dao) CreateMediaSource

func (d *Dao) CreateMediaSource(ctx context.Context, source *model.RtcMediaSource) (uint32, error)

func (*Dao) GetChannelIP

func (d *Dao) GetChannelIP(ctx context.Context, channelID uint64) ([]string, error)

func (*Dao) GetMediaPublishConfig

func (d *Dao) GetMediaPublishConfig(ctx context.Context, channelID uint64, callID uint32) (*model.RtcMediaPublish, error)

func (*Dao) GetMediaSource

func (d *Dao) GetMediaSource(ctx context.Context, channelID uint64) ([]*model.RtcMediaSource, error)

func (*Dao) GetToken

func (d *Dao) GetToken(ctx context.Context, channelID uint64, callID uint32) (string, error)

func (*Dao) Ping

func (d *Dao) Ping(ctx context.Context) error

Ping dao ping

func (*Dao) TerminateStream

func (d *Dao) TerminateStream(ctx context.Context, channelID uint64, callID uint32) error

func (*Dao) UpdateCallStatus

func (d *Dao) UpdateCallStatus(ctx context.Context, channelID uint64, callID uint32, userID uint64, leave time.Time, status uint8) error

func (*Dao) UpdateMediaPublishConfig

func (d *Dao) UpdateMediaPublishConfig(ctx context.Context, channelID uint64, callID uint32, config string) error

func (*Dao) UpdateMediaSourceStatus

func (d *Dao) UpdateMediaSourceStatus(ctx context.Context, channelID uint64, callID uint32, userID uint64, status uint8) error