| /dports/net/syncthing/syncthing-1.18.1/syncthing/vendor/github.com/thejerf/suture/v4/ |
| H A D | supervisor.go | 59 type Supervisor struct { struct
60 Name string
62 spec Spec
68 failures float64
80 ctxMutex sync.Mutex
81 ctx context.Context
83 ctxCancel func()
88 m sync.Mutex
95 id supervisorID
96 state uint8
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/orchestrator/restart/ |
| H A D | restart.go | 54 type Supervisor struct { struct
55 mu sync.Mutex
56 store *store.MemoryStore
57 delays map[string]*delayedStart
58 historyByService map[string]map[orchestrator.SlotTuple]*instanceRestartInfo
59 TaskTimeout time.Duration
195 func (r *Supervisor) shouldRestart(ctx context.Context, t *api.Task, service *api.Service) bool {
496 func (r *Supervisor) StartNow(tx store.Tx, taskID string) error {
506 func (r *Supervisor) Cancel(taskID string) {
520 func (r *Supervisor) CancelAll() {
[all …]
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/orchestrator/restart/ |
| H A D | restart.go | 54 type Supervisor struct { struct
55 mu sync.Mutex
56 store *store.MemoryStore
57 delays map[string]*delayedStart
58 historyByService map[string]map[orchestrator.SlotTuple]*instanceRestartInfo
59 TaskTimeout time.Duration
195 func (r *Supervisor) shouldRestart(ctx context.Context, t *api.Task, service *api.Service) bool {
488 func (r *Supervisor) StartNow(tx store.Tx, taskID string) error {
498 func (r *Supervisor) Cancel(taskID string) {
513 func (r *Supervisor) CancelAll() {
[all …]
|
| /dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/orchestrator/restart/ |
| H A D | restart.go | 54 type Supervisor struct { struct
55 mu sync.Mutex
56 store *store.MemoryStore
57 delays map[string]*delayedStart
58 historyByService map[string]map[orchestrator.SlotTuple]*instanceRestartInfo
59 TaskTimeout time.Duration
195 func (r *Supervisor) shouldRestart(ctx context.Context, t *api.Task, service *api.Service) bool {
496 func (r *Supervisor) StartNow(tx store.Tx, taskID string) error {
506 func (r *Supervisor) Cancel(taskID string) {
521 func (r *Supervisor) CancelAll() {
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/orchestrator/restart/ |
| H A D | restart.go | 54 type Supervisor struct { struct
55 mu sync.Mutex
56 store *store.MemoryStore
57 delays map[string]*delayedStart
58 historyByService map[string]map[orchestrator.SlotTuple]*instanceRestartInfo
59 TaskTimeout time.Duration
195 func (r *Supervisor) shouldRestart(ctx context.Context, t *api.Task, service *api.Service) bool {
488 func (r *Supervisor) StartNow(tx store.Tx, taskID string) error {
498 func (r *Supervisor) Cancel(taskID string) {
513 func (r *Supervisor) CancelAll() {
[all …]
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/orchestrator/restart/ |
| H A D | restart.go | 54 type Supervisor struct { struct
55 mu sync.Mutex
56 store *store.MemoryStore
57 delays map[string]*delayedStart
58 historyByService map[string]map[orchestrator.SlotTuple]*instanceRestartInfo
59 TaskTimeout time.Duration
195 func (r *Supervisor) shouldRestart(ctx context.Context, t *api.Task, service *api.Service) bool {
488 func (r *Supervisor) StartNow(tx store.Tx, taskID string) error {
498 func (r *Supervisor) Cancel(taskID string) {
513 func (r *Supervisor) CancelAll() {
[all …]
|
| /dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/orchestrator/restart/ |
| H A D | restart.go | 54 type Supervisor struct { struct
55 mu sync.Mutex
56 store *store.MemoryStore
57 delays map[string]*delayedStart
58 historyByService map[string]map[orchestrator.SlotTuple]*instanceRestartInfo
59 TaskTimeout time.Duration
195 func (r *Supervisor) shouldRestart(ctx context.Context, t *api.Task, service *api.Service) bool {
488 func (r *Supervisor) StartNow(tx store.Tx, taskID string) error {
498 func (r *Supervisor) Cancel(taskID string) {
513 func (r *Supervisor) CancelAll() {
[all …]
|
| /dports/sysutils/docker/docker-ce-18.09.5/components/engine/vendor/github.com/docker/swarmkit/manager/orchestrator/restart/ |
| H A D | restart.go | 54 type Supervisor struct { struct
55 mu sync.Mutex
56 store *store.MemoryStore
57 delays map[string]*delayedStart
58 historyByService map[string]map[orchestrator.SlotTuple]*instanceRestartInfo
59 TaskTimeout time.Duration
195 func (r *Supervisor) shouldRestart(ctx context.Context, t *api.Task, service *api.Service) bool {
488 func (r *Supervisor) StartNow(tx store.Tx, taskID string) error {
498 func (r *Supervisor) Cancel(taskID string) {
513 func (r *Supervisor) CancelAll() {
[all …]
|
| /dports/sysutils/immortal/immortal-0.24.3/ |
| H A D | supervise.go | 13 type Supervisor struct { struct
14 daemon *Daemon
15 process *process
16 pid int
17 wait time.Duration
35 func (s *Supervisor) Start() error {
82 func (s *Supervisor) ReStart() {
98 func (s *Supervisor) Terminate(err error) bool {
143 func (s *Supervisor) FollowPid(err error) {
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/docker/swarmkit/manager/orchestrator/restart/ |
| H A D | restart.go | 52 type Supervisor struct { struct
53 mu sync.Mutex
54 store *store.MemoryStore
55 delays map[string]*delayedStart
56 history map[instanceTuple]*instanceRestartInfo
57 historyByService map[string]map[instanceTuple]struct{}
58 TaskTimeout time.Duration
392 func (r *Supervisor) StartNow(tx store.Tx, taskID string) error {
402 func (r *Supervisor) Cancel(taskID string) {
417 func (r *Supervisor) CancelAll() {
[all …]
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/orchestrator/restart/ |
| H A D | restart.go | 68 type Supervisor struct { struct
69 mu sync.Mutex
70 store *store.MemoryStore
71 delays map[string]*delayedStart
72 historyByService map[string]map[orchestrator.SlotTuple]*instanceRestartInfo
73 TaskTimeout time.Duration
215 func (r *Supervisor) shouldRestart(ctx context.Context, t *api.Task, service *api.Service) bool {
526 func (r *Supervisor) StartNow(tx store.Tx, taskID string) error {
544 func (r *Supervisor) Cancel(taskID string) {
558 func (r *Supervisor) CancelAll() {
[all …]
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/orchestrator/restart/ |
| H A D | restart.go | 68 type Supervisor struct { struct
69 mu sync.Mutex
70 store *store.MemoryStore
71 delays map[string]*delayedStart
72 historyByService map[string]map[orchestrator.SlotTuple]*instanceRestartInfo
73 TaskTimeout time.Duration
215 func (r *Supervisor) shouldRestart(ctx context.Context, t *api.Task, service *api.Service) bool {
526 func (r *Supervisor) StartNow(tx store.Tx, taskID string) error {
544 func (r *Supervisor) Cancel(taskID string) {
558 func (r *Supervisor) CancelAll() {
[all …]
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/orchestrator/restart/ |
| H A D | restart.go | 68 type Supervisor struct { struct
69 mu sync.Mutex
70 store *store.MemoryStore
71 delays map[string]*delayedStart
72 historyByService map[string]map[orchestrator.SlotTuple]*instanceRestartInfo
73 TaskTimeout time.Duration
215 func (r *Supervisor) shouldRestart(ctx context.Context, t *api.Task, service *api.Service) bool {
526 func (r *Supervisor) StartNow(tx store.Tx, taskID string) error {
544 func (r *Supervisor) Cancel(taskID string) {
558 func (r *Supervisor) CancelAll() {
[all …]
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/vendor/github.com/docker/swarmkit/manager/orchestrator/restart/ |
| H A D | restart.go | 68 type Supervisor struct { struct
69 mu sync.Mutex
70 store *store.MemoryStore
71 delays map[string]*delayedStart
72 historyByService map[string]map[orchestrator.SlotTuple]*instanceRestartInfo
73 TaskTimeout time.Duration
215 func (r *Supervisor) shouldRestart(ctx context.Context, t *api.Task, service *api.Service) bool {
526 func (r *Supervisor) StartNow(tx store.Tx, taskID string) error {
544 func (r *Supervisor) Cancel(taskID string) {
558 func (r *Supervisor) CancelAll() {
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/orchestrator/update/ |
| H A D | updater.go | 26 type Supervisor struct { struct
27 store *store.MemoryStore
28 restarts *restart.Supervisor
29 updates map[string]*Updater
30 l sync.Mutex
34 func NewSupervisor(store *store.MemoryStore, restartSupervisor *restart.Supervisor) *Supervisor {
49 …pdate(ctx context.Context, cluster *api.Cluster, service *api.Service, slots []orchestrator.Slot) {
76 func (u *Supervisor) CancelAll() {
104 func NewUpdater(store *store.MemoryStore, restartSupervisor *restart.Supervisor, cluster *api.Clust…
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/docker/swarmkit/manager/orchestrator/update/ |
| H A D | updater.go | 27 type Supervisor struct { struct
28 store *store.MemoryStore
29 restarts *restart.Supervisor
30 updates map[string]*Updater
31 l sync.Mutex
35 func NewSupervisor(store *store.MemoryStore, restartSupervisor *restart.Supervisor) *Supervisor {
50 …pdate(ctx context.Context, cluster *api.Cluster, service *api.Service, slots []orchestrator.Slot) {
77 func (u *Supervisor) CancelAll() {
105 func NewUpdater(store *store.MemoryStore, restartSupervisor *restart.Supervisor, cluster *api.Clust…
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/orchestrator/update/ |
| H A D | updater.go | 26 type Supervisor struct { struct
27 store *store.MemoryStore
28 restarts *restart.Supervisor
29 updates map[string]*Updater
30 l sync.Mutex
34 func NewSupervisor(store *store.MemoryStore, restartSupervisor *restart.Supervisor) *Supervisor {
49 …pdate(ctx context.Context, cluster *api.Cluster, service *api.Service, slots []orchestrator.Slot) {
76 func (u *Supervisor) CancelAll() {
104 func NewUpdater(store *store.MemoryStore, restartSupervisor *restart.Supervisor, cluster *api.Clust…
|
| /dports/sysutils/docker/docker-ce-18.09.5/components/engine/vendor/github.com/docker/swarmkit/manager/orchestrator/update/ |
| H A D | updater.go | 26 type Supervisor struct { struct
27 store *store.MemoryStore
28 restarts *restart.Supervisor
29 updates map[string]*Updater
30 l sync.Mutex
34 func NewSupervisor(store *store.MemoryStore, restartSupervisor *restart.Supervisor) *Supervisor {
49 …pdate(ctx context.Context, cluster *api.Cluster, service *api.Service, slots []orchestrator.Slot) {
76 func (u *Supervisor) CancelAll() {
104 func NewUpdater(store *store.MemoryStore, restartSupervisor *restart.Supervisor, cluster *api.Clust…
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/orchestrator/update/ |
| H A D | updater.go | 27 type Supervisor struct { struct
28 store *store.MemoryStore
29 restarts *restart.Supervisor
30 updates map[string]*Updater
31 l sync.Mutex
35 func NewSupervisor(store *store.MemoryStore, restartSupervisor *restart.Supervisor) *Supervisor {
50 …pdate(ctx context.Context, cluster *api.Cluster, service *api.Service, slots []orchestrator.Slot) {
77 func (u *Supervisor) CancelAll() {
105 func NewUpdater(store *store.MemoryStore, restartSupervisor *restart.Supervisor, cluster *api.Clust…
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/orchestrator/update/ |
| H A D | updater.go | 26 type Supervisor struct { struct
27 store *store.MemoryStore
28 restarts *restart.Supervisor
29 updates map[string]*Updater
30 l sync.Mutex
34 func NewSupervisor(store *store.MemoryStore, restartSupervisor *restart.Supervisor) *Supervisor {
49 …pdate(ctx context.Context, cluster *api.Cluster, service *api.Service, slots []orchestrator.Slot) {
76 func (u *Supervisor) CancelAll() {
104 func NewUpdater(store *store.MemoryStore, restartSupervisor *restart.Supervisor, cluster *api.Clust…
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/orchestrator/update/ |
| H A D | updater.go | 26 type Supervisor struct { struct
27 store *store.MemoryStore
28 restarts *restart.Supervisor
29 updates map[string]*Updater
30 l sync.Mutex
34 func NewSupervisor(store *store.MemoryStore, restartSupervisor *restart.Supervisor) *Supervisor {
49 …pdate(ctx context.Context, cluster *api.Cluster, service *api.Service, slots []orchestrator.Slot) {
76 func (u *Supervisor) CancelAll() {
104 func NewUpdater(store *store.MemoryStore, restartSupervisor *restart.Supervisor, cluster *api.Clust…
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/orchestrator/update/ |
| H A D | updater.go | 27 type Supervisor struct { struct
28 store *store.MemoryStore
29 restarts *restart.Supervisor
30 updates map[string]*Updater
31 l sync.Mutex
35 func NewSupervisor(store *store.MemoryStore, restartSupervisor *restart.Supervisor) *Supervisor {
50 …pdate(ctx context.Context, cluster *api.Cluster, service *api.Service, slots []orchestrator.Slot) {
77 func (u *Supervisor) CancelAll() {
105 func NewUpdater(store *store.MemoryStore, restartSupervisor *restart.Supervisor, cluster *api.Clust…
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/orchestrator/update/ |
| H A D | updater.go | 27 type Supervisor struct { struct
28 store *store.MemoryStore
29 restarts *restart.Supervisor
30 updates map[string]*Updater
31 l sync.Mutex
35 func NewSupervisor(store *store.MemoryStore, restartSupervisor *restart.Supervisor) *Supervisor {
50 …pdate(ctx context.Context, cluster *api.Cluster, service *api.Service, slots []orchestrator.Slot) {
77 func (u *Supervisor) CancelAll() {
105 func NewUpdater(store *store.MemoryStore, restartSupervisor *restart.Supervisor, cluster *api.Clust…
|
| /dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/orchestrator/update/ |
| H A D | updater.go | 27 type Supervisor struct { struct
28 store *store.MemoryStore
29 restarts *restart.Supervisor
30 updates map[string]*Updater
31 l sync.Mutex
35 func NewSupervisor(store *store.MemoryStore, restartSupervisor *restart.Supervisor) *Supervisor {
50 …pdate(ctx context.Context, cluster *api.Cluster, service *api.Service, slots []orchestrator.Slot) {
77 func (u *Supervisor) CancelAll() {
105 func NewUpdater(store *store.MemoryStore, restartSupervisor *restart.Supervisor, cluster *api.Clust…
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/vendor/github.com/docker/swarmkit/manager/orchestrator/update/ |
| H A D | updater.go | 26 type Supervisor struct { struct
27 store *store.MemoryStore
28 restarts *restart.Supervisor
29 updates map[string]*Updater
30 l sync.Mutex
34 func NewSupervisor(store *store.MemoryStore, restartSupervisor *restart.Supervisor) *Supervisor {
49 …pdate(ctx context.Context, cluster *api.Cluster, service *api.Service, slots []orchestrator.Slot) {
76 func (u *Supervisor) CancelAll() {
104 func NewUpdater(store *store.MemoryStore, restartSupervisor *restart.Supervisor, cluster *api.Clust…
|