content

Documentation

Overview

Copyright 2017 Vector Creations Ltd

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.

Modifications copyright (C) 2020 Finogeeks Co., Ltd

Index

• func NewDatabase(driver, createAddr, address, underlying, topic string, useAsync bool) (interface{}, error)
• type Database
  • func (d *Database) InsertMediaDownload(ctx context.Context, roomID, eventID, event string) error
  • func (d *Database) SelectMediaDownload(ctx context.Context) (roomIDs, eventIDs, events []string, err error)
  • func (d *Database) SetGauge(qryDBGauge mon.LabeledGauge)
  • func (d *Database) UpdateMediaDownload(ctx context.Context, roomID, eventID string, finished bool) error

Functions

func NewDatabase

func NewDatabase(driver, createAddr, address, underlying, topic string, useAsync bool) (interface{}, error)

NewDatabase opens a new database

Types

type Database

type Database struct {
	AsyncSave bool
	// contains filtered or unexported fields
}

func (*Database) InsertMediaDownload

func (d *Database) InsertMediaDownload(
	ctx context.Context,
	roomID, eventID, event string,
) error

func (*Database) SelectMediaDownload

func (d *Database) SelectMediaDownload(ctx context.Context) (roomIDs, eventIDs, events []string, err error)

func (*Database) SetGauge

func (d *Database) SetGauge(qryDBGauge mon.LabeledGauge)

func (*Database) UpdateMediaDownload

func (d *Database) UpdateMediaDownload(ctx context.Context, roomID, eventID string, finished bool) error