server

package
v0.0.0-...-e0c7ee5 Latest Latest
Warning

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

Go to latest
Published: Apr 18, 2024 License: Apache-2.0 Imports: 47 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DefaultHostName = `%`
)

Variables

This section is empty.

Functions

func GetParticipantInfos

func GetParticipantInfos(db *gorm.DB, partyCodes []string) ([]*translator.Participant, error)

one-to-one correspondence between in parameter `partyCodes` and return value `[]*translator.Participant` on success

func NewDbConnWithBootstrap

func NewDbConnWithBootstrap(conf *config.StorageConf) (*gorm.DB, error)

func NewServer

func NewServer(conf *config.Config, storage *gorm.DB, engineClient executor.EngineClient) (*http.Server, error)

func QueryTableSchemas

func QueryTableSchemas(store *gorm.DB, dbName string, tableNames []string) (tables []*scql.TableEntry, err error)

func SCDBFetchRequestToLogString

func SCDBFetchRequestToLogString(req *scql.SCDBFetchRequest) string

func SCDBQueryRequestToLogString

func SCDBQueryRequestToLogString(req *scql.SCDBQueryRequest) string

func ValidateParticipantInfos

func ValidateParticipantInfos(participants []*translator.Participant) error

Types

type App

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

func NewApp

func NewApp(conf *config.Config, storage *gorm.DB, engineClient executor.EngineClient) (*App, error)

func (*App) EngineHandler

func (app *App) EngineHandler(c *gin.Context)

func (*App) FetchHandler

func (app *App) FetchHandler(c *gin.Context)

func (*App) HealthHandler

func (app *App) HealthHandler(c *gin.Context)

func (*App) Port

func (app *App) Port() int

func (*App) SubmitAndGetHandler

func (app *App) SubmitAndGetHandler(c *gin.Context)

func (*App) SubmitHandler

func (app *App) SubmitHandler(c *gin.Context)

type ExecutionPlanInfo

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

type LogFormatter

type LogFormatter struct {
}

func (*LogFormatter) Format

func (f *LogFormatter) Format(entry *logrus.Entry) ([]byte, error)

type LogicalPlanInfo

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

Jump to

Keyboard shortcuts

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