Documentation ¶
Index ¶
Constants ¶
View Source
const ( ConfigFilePathDefault string = "/etc/s3_data_watcher/config.yml" JobFilePathDefault string = "/etc/s3_data_watcher/jobs.yml" NatsUrlDefault string = "nats://nats:4222" NatsSubjectDefault string = "" NatsMaxReconnectsDefault int = -1 NatsReconnectWaitDefault int = -1 NatsRequestTimeoutDefault int = -1 ReconnectInterval time.Duration = 1 * time.Minute )
Variables ¶
This section is empty.
Functions ¶
func ExpandHomeDir ¶
func GetDefaultDataRootDirPath ¶
func GetDefaultDataRootDirPath() string
func GetReleaseVersion ¶
func GetReleaseVersion() string
GetReleaseVersion returns release version in string
func GetVersionJSON ¶
GetVersionJSON returns VersionInfo object in JSON string
func StackTraceFromPanic ¶
Types ¶
type Config ¶
type Config struct { DataRootPath string `yaml:"data_root_path,omitempty"` // S3 FS Event Publish NatsConfig NatsConfig `yaml:"nats_config,omitempty"` JobFilePath string `yaml:"job_file_path,omitempty"` // for Logging LogPath string `yaml:"log_path,omitempty"` Foreground bool `yaml:"foreground,omitempty"` Debug bool `yaml:"debug,omitempty"` ChildProcess bool `yaml:"childprocess,omitempty"` }
Config is a configuration struct
func NewConfigFromYAML ¶
NewConfigFromYAML creates Config from YAML
func (*Config) GetLogFilePath ¶
GetLogFilePath returns log file path
func (*Config) MakeLogDir ¶
MakeLogDir makes a log dir required
func (*Config) MakeWorkDirs ¶
type NatsConfig ¶
type NatsConfig struct { URL string `yaml:"url"` Subject string `yaml:"subject"` MaxReconnects int `yaml:"max_reconnects,omitempty"` ReconnectWait int `yaml:"reconnect_wait,omitempty"` RequestTimeout int `yaml:"request_timeout,omitempty"` }
NatsConfig is a configuration struct for Nats Message bus
type VersionInfo ¶
type VersionInfo struct { ReleaseVersion string `json:"releaseVersion"` GitCommit string `json:"gitCommit"` BuildDate string `json:"buildDate"` GoVersion string `json:"goVersion"` Compiler string `json:"compiler"` Platform string `json:"platform"` }
VersionInfo object contains version related info
Click to show internal directories.
Click to hide internal directories.