db

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 21, 2024 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source
const DriverName = "sqlite3"

DriverName is the default driver name for SQLite.

Variables

View Source
var (
	// ErrRecordNotFound - Record not found error
	ErrRecordNotFound = gorm.ErrRecordNotFound
	Client            *gorm.DB
)

Client - Database Client

Functions

func AddContent

func AddContent(pbWebContent *lispb.WebContent, webContentDir string) (*lispb.WebContent, error)

AddContent - Add content to website

func AddTask

func AddTask(typ string, task *core.Task, td *models.FileDescription) error

func AddWebSite

func AddWebSite(webSiteName string, webContentDir string) (*lispb.Website, error)

AddWebsite - Return website, create if it does not exist

func CreateListener

func CreateListener(name string) error

func CreateOperator

func CreateOperator(name string) error

func DeleteAllCertificates

func DeleteAllCertificates() error

DeleteAllCertificates

func DeleteCertificate

func DeleteCertificate(name string) error

DeleteCertificate

func DeleteSession

func DeleteSession(sessionID string) error

Basic Session OP

func FindAliveSessions

func FindAliveSessions() ([]*lispb.RegisterSession, error)

func FindAllSessions

func FindAllSessions() (*clientpb.Sessions, error)

func FindSession

func FindSession(sessionID string) (*lispb.RegisterSession, error)

func FindTaskAndMaxTasksID

func FindTaskAndMaxTasksID(sessionID string) ([]*models.Task, int, error)

func FindTasksWithNonOneCurTotal

func FindTasksWithNonOneCurTotal(session models.Session) ([]models.Task, error)

func GetAllTasks

func GetAllTasks(sessionID string) ([]models.Task, error)

Task

func GetTaskDescriptionByID

func GetTaskDescriptionByID(taskID string) (*models.FileDescription, error)

func GetWebContentIDByWebsiteID

func GetWebContentIDByWebsiteID(websiteID string) ([]string, error)

func ListListeners

func ListListeners() ([]models.Listener, error)

func ListOperators

func ListOperators() (*clientpb.Clients, error)

func NewDBClient

func NewDBClient() *gorm.DB

newDBClient - Initialize the db client

func Open

func Open(dsn string) gorm.Dialector

func RemoveContent

func RemoveContent(id string) error

func RemoveWebAllContent

func RemoveWebAllContent(id string) error

func RemoveWebSite

func RemoveWebSite(id string) error

func SaveCertificate

func SaveCertificate(certificate *models.Certificate) error

func Session

func Session() *gorm.DB

Session - Database session

func ToTask

func ToTask(task models.Task) (*core.Task, error)

func UpdateLast

func UpdateLast(sessionID string) error

func UpdateSession

func UpdateSession(sessionID, note, group string) error

func UpdateSessionInfo

func UpdateSessionInfo(coreSession *core.Session) error

func UpdateSessionStatus

func UpdateSessionStatus() error

func UpdateTask

func UpdateTask(task *core.Task, newCur int) error

func WebContentByIDAndPath

func WebContentByIDAndPath(id string, path string, webContentDir string, eager bool) (*lispb.WebContent, error)

WebContent by ID and path

func WebsiteByName

func WebsiteByName(name string, webContentDir string) (*lispb.Website, error)

website WebsiteByName - Get website by name

func Websites

func Websites(webContentDir string) ([]*lispb.Website, error)

Websites - Return all websites

Types

type Dialector

type Dialector struct {
	DriverName string
	DSN        string
	Conn       gorm.ConnPool
}

func (Dialector) BindVarTo

func (dialector Dialector) BindVarTo(writer clause.Writer, stmt *gorm.Statement, v interface{})

func (Dialector) ClauseBuilders

func (dialector Dialector) ClauseBuilders() map[string]clause.ClauseBuilder

func (Dialector) DataTypeOf

func (dialector Dialector) DataTypeOf(field *schema.Field) string

func (Dialector) DefaultValueOf

func (dialector Dialector) DefaultValueOf(field *schema.Field) clause.Expression

func (Dialector) Explain

func (dialector Dialector) Explain(sql string, vars ...interface{}) string

func (Dialector) Initialize

func (dialector Dialector) Initialize(db *gorm.DB) (err error)

func (Dialector) Migrator

func (dialector Dialector) Migrator(db *gorm.DB) gorm.Migrator

func (Dialector) Name

func (dialector Dialector) Name() string

func (Dialector) QuoteTo

func (dialector Dialector) QuoteTo(writer clause.Writer, str string)

func (Dialector) RollbackTo

func (dialectopr Dialector) RollbackTo(tx *gorm.DB, name string) error

func (Dialector) SavePoint

func (dialectopr Dialector) SavePoint(tx *gorm.DB, name string) error

type Migrator

type Migrator struct {
	migrator.Migrator
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL