handler

Documentation

Index

• Constants
• Variables
• type CatalogHandler
  • func NewCatalogHandler(config utils.Configuration) CatalogHandler
• type EngineCompartment
• type JobHandler
  • func NewJobHandler(cfg utils.Configuration) JobHandler
• type PrepHandler
  • func NewPrepHandler(config utils.Configuration) PrepHandler
• type QueryHandler
  • func NewQueryHandler(config utils.Configuration) QueryHandler
• type Response
• type SpoutHandler
  • func NewSpoutHandler(config utils.Configuration) SpoutHandler

Constants

const (
	WebSocketURLPrefix = "ws://"

	WebSocketClientBinary         = "demo-pipe-client"
	WebSocketServerBinary         = "demo-pipe-server"
	DashboardBinary               = "demo-web-server"
	DemoFinancialDataServerBinary = "demo-findata-server"
	DemoSyslogBinary              = "syslog"
	DemoThrottleBinary            = "throttle"
	DemoGeneratorBinary           = "generator"
	DashboardTemplateFile         = "dashboard-template.html"

	// FilePermissionReadable   = 0644
	// FilePermissionExecutable = 0755
	FilePermissionReadable   = 0666
	FilePermissionExecutable = 0777
)

Variables

var CatalogsDirectoryPath string

var PrepsDirectoryPath string

var QueriesDirectoryPath string

var SpoutsDirectoryPath string

Types

type CatalogHandler

type CatalogHandler interface {
	UploadFile(*gin.Context)
	Delete(*gin.Context)
}

func NewCatalogHandler

func NewCatalogHandler(config utils.Configuration) CatalogHandler

type EngineCompartment

type EngineCompartment struct {
	JobId string
}

type JobHandler

type JobHandler interface {
	Add(*gin.Context)
	Delete(*gin.Context)
	List(*gin.Context)
	Start(*gin.Context)
	Stop(*gin.Context)
}

func NewJobHandler

func NewJobHandler(cfg utils.Configuration) JobHandler

type PrepHandler

type PrepHandler interface {
	UploadFile(*gin.Context)
	Delete(*gin.Context)
}

func NewPrepHandler

func NewPrepHandler(config utils.Configuration) PrepHandler

type QueryHandler

type QueryHandler interface {
	UploadFile(*gin.Context)
	Delete(*gin.Context)
}

func NewQueryHandler

func NewQueryHandler(config utils.Configuration) QueryHandler

type Response

type Response struct {
	Id      string `json:"id"`
	Message string `json:"message"`
}

type SpoutHandler

type SpoutHandler interface {
	UploadFile(*gin.Context)
	Delete(*gin.Context)
}

func NewSpoutHandler

func NewSpoutHandler(config utils.Configuration) SpoutHandler