sqlmodel

package
v0.0.0-...-73c04d8 Latest Latest
Warning

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

 Go to latest Published: Aug 19, 2025 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CredentialTableName     = "arc_credential"
	CredentialDefaultSortBy = "arc_credential_id"

	ECode040E01 = e.Code040E + "01"
	ECode040E02 = e.Code040E + "02"
	ECode040E03 = e.Code040E + "03"
	ECode040E04 = e.Code040E + "04"
	ECode040E05 = e.Code040E + "05"
	ECode040E06 = e.Code040E + "06"
)
View Source 
const (
	DataTableName = "arc_data"

	ECode040F01 = e.Code040F + "01"
	ECode040F02 = e.Code040F + "02"
	ECode040F03 = e.Code040F + "03"
	ECode040F04 = e.Code040F + "04"
	ECode040F05 = e.Code040F + "05"
	ECode040F06 = e.Code040F + "06"
	ECode040F07 = e.Code040F + "07"
	ECode040F08 = e.Code040F + "08"
	ECode040F09 = e.Code040F + "09"
	ECode040F0A = e.Code040F + "0A"
	ECode040F0B = e.Code040F + "0B"
)
View Source 
const (
	DeploymentTableName     = "arc_deployment"
	DeploymentDefaultSortBy = "arc_deployment_id"

	ECode040H01 = e.Code040H + "01"
	ECode040H02 = e.Code040H + "02"
	ECode040H03 = e.Code040H + "03"
	ECode040H04 = e.Code040H + "04"
	ECode040H05 = e.Code040H + "05"
	ECode040H06 = e.Code040H + "06"
	ECode040H07 = e.Code040H + "07"
)
View Source 
const (
	DeploymentGrantTableName     = "arc_deployment_grant"
	DeploymentGrantDefaultSortBy = "arc_deployment_grant_id"

	ECode040G01 = e.Code040G + "01"
	ECode040G02 = e.Code040G + "02"
	ECode040G03 = e.Code040G + "03"
	ECode040G04 = e.Code040G + "04"
	ECode040G05 = e.Code040G + "05"
	ECode040G06 = e.Code040G + "06"
	ECode040G07 = e.Code040G + "07"
	ECode040G08 = e.Code040G + "08"
	ECode040G09 = e.Code040G + "09"
	ECode040G0A = e.Code040G + "0A"
)

Variables

This section is empty.

Functions

func CredentialGet 

func CredentialGet(ctx context.Context, db *sql.Connection,
	p *CredentialGetParam) (cList []*model.Credential, count int, err error)

CredentialGet performs select

func CredentialGetByID 

func CredentialGetByID(ctx context.Context, db *sql.Connection, id int) (c *model.Credential, err error)

CredentialGetByID returns the deployment with the specified code

func DataGet 

func DataGet(ctx context.Context, db *sql.Connection,
	p *DataGetParam) (dList []*model.Data, count int, err error)

DataGet performs select

func DataGetByObjectID 

func DataGetByObjectID(ctx context.Context, db *sql.Connection, deploymentID int, appCode model.AppCode,
	appCoreID uint, t model.DataType, objectID uint) (d *model.Data, err error)

DataGetByObjectID returns record associated with the object id, must also include the app code, app core id and data type to be unique

func DataSetStatus 

func DataSetStatus(ctx context.Context, db *sql.Connection, s model.DataStatus, d *model.Data) (err error)

DataSetStatus set the status for the specified data record

func DataSetStatusProcessed 

func DataSetStatusProcessed(ctx context.Context, db *sql.Connection) (err error)

DataSetStatusProcessed set all records that are processing to processed

func DataSetStatusProcessing 

func DataSetStatusProcessing(ctx context.Context, db *sql.Connection) (err error)

DataSetStatusProcessing set all records that are pending to processing

func DataUpsert 

func DataUpsert(ctx context.Context, db *sql.Connection, deploymentID int, d *model.Data) (err error)

DataUpsert upserts the record and only updates an existing record if the hash has changed or if the deleted flag has changed. When updating, it will calculate the hash and set the new object, hash and/or deleted flag. Also, it sets the status to pending in this scenario

func DeploymentGet 

func DeploymentGet(ctx context.Context, db *sql.Connection,
	p *DeploymentGetParam) (dList []*model.Deployment, count int, err error)

DeploymentGet performs select

func DeploymentGetByCode 

func DeploymentGetByCode(ctx context.Context, db *sql.Connection, code string) (d *model.Deployment, err error)

DeploymentGetByCode returns the deployment with the specified code

func DeploymentGrantGet 

func DeploymentGrantGet(ctx context.Context, db *sql.Connection,
	p *DeploymentGrantGetParam) (dgList []*model.DeploymentGrant, count int, err error)

DeploymentGrantGet performs select

func DeploymentGrantGetByToken 

func DeploymentGrantGetByToken(ctx context.Context, db *sql.Connection, token string) (dg *model.DeploymentGrant, err error)

DeploymentGrantGetByToken returns the deployment with the specified token

func DeploymentGrantInsert 

func DeploymentGrantInsert(ctx context.Context, db *sql.Connection, ip *DeploymentGrantInsertParam) (id int, err error)

DeploymentGrantInsert performs insert

func DeploymentGrantPurgeByExpiredRefreshToken 

func DeploymentGrantPurgeByExpiredRefreshToken(ctx context.Context, db *sql.Connection, refreshTokenExpiry int) (err error)

DeploymentGrantPurgeByExpiredRefreshToken purges all grants where the refresh token has expired and is no longer useable (the token should have expired as well at this point because refresh tokens are periodically updated when fetching new tokens)

func DeploymentGrantPurgeByToken 

func DeploymentGrantPurgeByToken(ctx context.Context, db *sql.Connection, token string) (err error)

DeploymentGrantPurgeByToken purges a record by the token

func DeploymentGrantUpdate 

func DeploymentGrantUpdate(ctx context.Context, db *sql.Connection, id int, up *DeploymentGrantUpdateParam) (err error)

DeploymentGrantUpdate performs update, setting token/refresh token (and expiries)

func DeploymentUpdate 

func DeploymentUpdate(ctx context.Context, db *sql.Connection, id int, dup *DeploymentUpdateParam) (err error)

DeploymentUpdate performs update, setting token/refresh token (and expiries)

Types

type CredentialGetParam 

type CredentialGetParam struct {
	Limit        uint64
	Offset       uint64
	ID           *int
	DeploymentID *int
	FlagCount    bool
	OrderByID    string
	OrderByCode  string
}

UserGetParam model

type DataGetParam 

type DataGetParam struct {
	Limit           uint64
	Offset          uint64
	DeploymentID    *int
	AppCode         *model.AppCode
	AppCoreID       *uint
	Type            *model.DataType
	ObjectID        *uint
	Status          *model.DataStatus
	FlagCount       bool
	OrderBy         string
	OrderByTypeList []model.DataType
	Handle          func(*model.Data) error
}

DataGetParam model

type DeploymentGetParam 

type DeploymentGetParam struct {
	Limit       uint64
	Offset      uint64
	ID          *int
	Code        *string
	FlagCount   bool
	OrderByID   string
	OrderByCode string
}

UserGetParam model

type DeploymentGrantGetParam 

type DeploymentGrantGetParam struct {
	Limit                     uint64
	Offset                    uint64
	ID                        *int
	DeploymentID              *int
	Token                     *string
	FlagCount                 bool
	OrderByID                 string
	OrderByRefreshTokenExpiry string
}

DeploymentGrantGetParam get params

type DeploymentGrantInsertParam 

type DeploymentGrantInsertParam struct {
	DeploymentID       int
	ArcUserID          int
	CredentialID       int
	Token              string
	TokenExpiry        int
	RefreshToken       string
	RefreshTokenExpiry int
}

DeploymentGrantInsertParam insert params

type DeploymentGrantUpdateParam 

type DeploymentGrantUpdateParam struct {
	Token              *string
	TokenExpiry        *int
	RefreshToken       *string
	RefreshTokenExpiry *int
}

DeploymentGrantUpdateParam update params

type DeploymentUpdateParam 

type DeploymentUpdateParam struct {
	Token              *string
	TokenExpiry        *int
	RefreshToken       *string
	RefreshTokenExpiry *int
}

UserUpdateParam model

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.