configMgr

Documentation

Index

• Constants
• func JobConfigMgr() (ret *configManager)
• func StartJobConfigManager(config *maestroConfig.YAMLMaestroConfig)
• type CompositeProcessConfigPayload
  • func NewCompositeProcessConfigPayload() (ret *CompositeProcessConfigPayload)
• type ConfigObjectError
  • func (this *ConfigObjectError) Error() string

Constants

const (
	CONFIG_NAME_INVALID = iota
	CONFIG_NO_STORAGE   = iota
)

Functions

func JobConfigMgr

func JobConfigMgr() (ret *configManager)

func StartJobConfigManager

func StartJobConfigManager(config *maestroConfig.YAMLMaestroConfig)

Types

type CompositeProcessConfigPayload

type CompositeProcessConfigPayload struct {
	Moduleconfigs map[string]maestroSpecs.JobDefinition `json:"moduleconfigs,omitempty"`
	ProcessConfig string                                `json:"process_config,omitempty"`
	// this is the path on the local file system to maestro local APIs
	// It is used for getting configs
	// Later this will be differentiated from a 'root' socket path
	// which will allow additional APIs.
	MaestroUserSocketPath string `json:"maestro_user_socket_path,omitempty"`
	// For privleged APIs, which will starting and stopping processes, etc.
	// UNIMPLEMENTED
	MaestroRootSocketPath string `json:"maestro_root_socket_path,omitempty"`
}

func NewCompositeProcessConfigPayload

func NewCompositeProcessConfigPayload() (ret *CompositeProcessConfigPayload)

type ConfigObjectError

type ConfigObjectError struct {
	Name string
	Job  string
	Code int
	Aux  string
}

func (*ConfigObjectError) Error

func (this *ConfigObjectError) Error() string