Documentation
¶
Index ¶
- Constants
- Variables
- func GetOutboundIP() net.IP
- func NewMqWorkerServer(frameworkIncoming dlframework.FrameworkManifest, ...) (*cobra.Command, error)
- func NewRootCommand(frameworkRegisterFunc FrameworkRegisterFunction, ...) (*cobra.Command, error)
- func SetupFlags(c *cobra.Command, workerHandler WorkerProcessInterface)
- func WorkerCommandWithOptions(workHandler WorkerProcessInterface) *cobra.Command
- type FrameworkRegisterFunction
- type StandardWorker
- type WorkerProcessInterface
Constants ¶
View Source
const DEFAULT_TIMEOUT_MS = 5000
Variables ¶
View Source
var (
DefaultChannelBuffer = 100000
)
Functions ¶
func GetOutboundIP ¶ added in v0.3.0
Get preferred outbound ip of this machine
func NewMqWorkerServer ¶ added in v1.4.5
func NewMqWorkerServer(frameworkIncoming dlframework.FrameworkManifest, workerHandler WorkerProcessInterface) (*cobra.Command, error)
func NewRootCommand ¶
func NewRootCommand(frameworkRegisterFunc FrameworkRegisterFunction, framework0 dlframework.FrameworkManifest) (*cobra.Command, error)
represents the base command when called without any subcommands
func SetupFlags ¶ added in v0.2.19
func SetupFlags(c *cobra.Command, workerHandler WorkerProcessInterface)
func WorkerCommandWithOptions ¶ added in v1.4.5
func WorkerCommandWithOptions(workHandler WorkerProcessInterface) *cobra.Command
Types ¶
type FrameworkRegisterFunction ¶ added in v0.2.19
type FrameworkRegisterFunction func()
type StandardWorker ¶ added in v1.4.5
type StandardWorker struct {
}
func (StandardWorker) ProcessJob ¶ added in v1.4.5
func (s StandardWorker) ProcessJob(jsonRunRequest string, frameworkManifest dlframework.FrameworkManifest) (string, error)
type WorkerProcessInterface ¶ added in v1.4.5
type WorkerProcessInterface interface {
ProcessJob(string, dlframework.FrameworkManifest) (string, error)
}
Source Files
Click to show internal directories.
Click to hide internal directories.