MCPcopy
hub / github.com/mudler/LocalAI / StopGRPC

Method StopGRPC

pkg/model/process.go:92–110  ·  view source on GitHub ↗
(filter GRPCProcessFilter)

Source from the content-addressed store, hash-verified

90 return err
91}
92func (ml *ModelLoader) StopGRPC(filter GRPCProcessFilter) error {
93 var err error = nil
94 ml.mu.Lock()
95 defer ml.mu.Unlock()
96
97 // Collect matching keys first — can't mutate store during Range
98 var toDelete []string
99 ml.store.Range(func(k string, m *Model) bool {
100 if filter(k, m.Process()) {
101 toDelete = append(toDelete, k)
102 }
103 return true
104 })
105 for _, k := range toDelete {
106 e := ml.deleteProcess(k)
107 err = errors.Join(err, e)
108 }
109 return err
110}
111
112func (ml *ModelLoader) StopAllGRPC() error {
113 return ml.StopGRPC(all)

Callers 2

StopAllGRPCMethod · 0.95
backendLoaderMethod · 0.95

Calls 5

deleteProcessMethod · 0.95
ProcessMethod · 0.80
LockMethod · 0.65
UnlockMethod · 0.65
RangeMethod · 0.65

Tested by

no test coverage detected