server

Documentation

Index

• Constants
• func GetParticipantInfos(db *gorm.DB, partyCodes []string) ([]*graph.Participant, error)
• func NewDbConnWithBootstrap(conf *config.StorageConf) (*gorm.DB, error)
• func NewServer(conf *config.Config, storage *gorm.DB, engineClient executor.EngineClient) (*http.Server, error)
• func QueryTableSchemas(store *gorm.DB, dbName string, tableNames []string) (tables []*scql.TableEntry, err error)
• func SCDBFetchRequestToLogString(req *scql.SCDBFetchRequest) string
• func SCDBQueryRequestToLogString(req *scql.SCDBQueryRequest) string
• func ValidateParticipantInfos(participants []*graph.Participant) error
• type App
  • func NewApp(conf *config.Config, storage *gorm.DB, engineClient executor.EngineClient) (*App, error)
  • func (app *App) EngineHandler(c *gin.Context)
  • func (app *App) FetchHandler(c *gin.Context)
  • func (app *App) HealthHandler(c *gin.Context)
  • func (app *App) Port() int
  • func (app *App) SubmitAndGetHandler(c *gin.Context)
  • func (app *App) SubmitHandler(c *gin.Context)
• type ExecutionPlanInfo
• type LogFormatter
  • func (f *LogFormatter) Format(entry *logrus.Entry) ([]byte, error)
• type LogicalPlanInfo

Constants

const (
	DefaultHostName = `%`
)

Functions

func GetParticipantInfos

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

one-to-one correspondence between in parameter `partyCodes` and return value `[]*graph.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 []*graph.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
}