server

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
  • func (s StandardWorker) ProcessJob(jsonRunRequest string, frameworkManifest dlframework.FrameworkManifest) (string, error)
• type WorkerProcessInterface

Constants

const DEFAULT_TIMEOUT_MS = 5000

Variables

var (
	DefaultChannelBuffer = 100000
)

Functions

func GetOutboundIP

func GetOutboundIP() net.IP

Get preferred outbound ip of this machine

func NewMqWorkerServer

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

func SetupFlags(c *cobra.Command, workerHandler WorkerProcessInterface)

func WorkerCommandWithOptions

func WorkerCommandWithOptions(workHandler WorkerProcessInterface) *cobra.Command

Types

type FrameworkRegisterFunction

type FrameworkRegisterFunction func()

type StandardWorker

type StandardWorker struct {
}

func (StandardWorker) ProcessJob

func (s StandardWorker) ProcessJob(jsonRunRequest string, frameworkManifest dlframework.FrameworkManifest) (string, error)

type WorkerProcessInterface

type WorkerProcessInterface interface {
	ProcessJob(string, dlframework.FrameworkManifest) (string, error)
}