package
Version:
v1.6.0
Opens a new window with list of versions in this module.
Published: Mar 16, 2024
License: BSD-3-Clause
Opens a new window with license information.
Imports: 3
Opens a new window with list of imports.
Imported by: 2
Opens a new window with list of known importers.
Documentation
¶
type HttpOption struct {
Method string `json:"method" msgpack:"method"`
Url string `json:"url" msgpack:"url"`
Body map[string]interface{} `json:"body" msgpack:"body"`
}
type Inject struct {
V *Values
Log *zap.Logger
Nats *nats.Conn
KeyValue nats.KeyValue
}
type Job struct {
Key string `msgpack:"key"`
Index int `msgpack:"index"`
Mode string `msgpack:"mode"`
Option interface{} `msgpack:"option"`
}
type ScheduleJob struct {
Mode string `json:"mode" msgpack:"mode"`
Spec string `json:"spec" msgpack:"spec"`
Option interface{} `json:"option" msgpack:"option"`
ScheduleState `json:"schedule_state" msgpack:"state"`
}
type ScheduleOption struct {
Status bool `json:"status" msgpack:"status" `
Jobs []ScheduleJob `json:"jobs" msgpack:"jobs" `
}
type ScheduleState struct {
Next time.Time `json:"next" msgpack:"next"`
Prev time.Time `json:"prev" msgpack:"prev"`
}
type ScheduleStatus struct {
Key string `msgpack:"key"`
Value bool `msgpack:"value"`
}
type Values struct {
Node string `env:"NODE,required"`
Nats struct {
Hosts []string `env:"HOSTS,required" envSeparator:","`
Nkey string `env:"NKEY,required"`
} `envPrefix:"NATS_"`
}
Source Files
¶
Click to show internal directories.
Click to hide internal directories.