common

Documentation

Index

• type HttpOption
• type Inject
• type Job
• type ScheduleJob
• type ScheduleOption
• type ScheduleState
• type ScheduleStatus
• type Values

Types

type HttpOption

type HttpOption struct {
	Method  string                 `json:"method" msgpack:"method"`
	Url     string                 `json:"url" msgpack:"url"`
	Headers map[string]string      `json:"headers" msgpack:"headers"`
	Body    map[string]interface{} `json:"body" msgpack:"body"`
}

type Inject

type Inject struct {
	V        *Values
	Log      *zap.Logger
	Nats     *nats.Conn
	KeyValue nats.KeyValue
}

type Job

type Job struct {
	Key    string      `msgpack:"key"`
	Index  int         `msgpack:"index"`
	Mode   string      `msgpack:"mode"`
	Option interface{} `msgpack:"option"`
}

type ScheduleJob

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

type ScheduleOption struct {
	Status bool          `json:"status" msgpack:"status" `
	Jobs   []ScheduleJob `json:"jobs" msgpack:"jobs" `
}

type ScheduleState

type ScheduleState struct {
	Next time.Time `json:"next" msgpack:"next"`
	Prev time.Time `json:"prev" msgpack:"prev"`
}

type ScheduleStatus

type ScheduleStatus struct {
	Key   string `msgpack:"key"`
	Value bool   `msgpack:"value"`
}

type Values

type Values struct {
	Node string `env:"NODE,required"`
	Nats struct {
		Hosts []string `env:"HOSTS,required" envSeparator:","`
		Nkey  string   `env:"NKEY,required"`
	} `envPrefix:"NATS_"`
}