- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 339 for closes (0.04 seconds)
-
.github/workflows/close-linked-issue-when-merged-into-release.yml
name: Close linked issues when PR merged into release on: pull_request: types: [closed] branches: - release - release7x - release8x permissions: issues: write jobs: closeIssueOnPrMerge: runs-on: ubuntu-latest steps: - name: Closes issues related to a merged pull request. uses: ldez/gha-mjolnir@df0e84242364946fa3ad4e7556510e8086ad681a env:Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Wed Jul 16 09:18:51 GMT 2025 - 458 bytes - Click Count (0) -
internal/config/lambda/event/targetlist.go
// Stores any error while removing a target or while sending an event. Err error } // Remove - closes and removes targets by given target IDs. func (list *TargetList) Remove(targetIDSet TargetIDSet) { list.Lock() defer list.Unlock() for id := range targetIDSet { target, ok := list.targets[id] if ok { target.Close() delete(list.targets, id) } } } // Targets - list all targets
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 4.3K bytes - Click Count (0) -
internal/http/listener.go
case <-listener.ctxDoneCh: } return nil, syscall.EINVAL } // Close - closes underneath all TCP listeners. func (listener *httpListener) Close() (err error) { listener.ctxCanceler() for i := range listener.listeners { listener.listeners[i].Close() } return nil }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.8K bytes - Click Count (0) -
internal/logger/logrotate.go
// Write is blocking otherwise. func (w *Writer) Write(p []byte) (n int, err error) { return w.pw.Write(p) } // Close closes the writer. // Any accepted writes will be flushed. Any new writes will be rejected. // Once Close() exits, files are synchronized to disk. func (w *Writer) Close() error { w.pw.CloseWithError(nil) if w.f != nil { if err := w.closeCurrentFile(); err != nil { return err } }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 5.8K bytes - Click Count (0) -
prepare_stmt.go
} return nil, ErrInvalidDB } // Close closes all prepared statements in the store func (db *PreparedStmtDB) Close() { db.Mux.Lock() defer db.Mux.Unlock() for _, key := range db.Stmts.Keys() { db.Stmts.Delete(key) } } // Reset Deprecated use Close instead func (db *PreparedStmtDB) Reset() { db.Close() }Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Fri Apr 25 08:22:26 GMT 2025 - 5.7K bytes - Click Count (0) -
internal/ringbuffer/ring_buffer.go
// When the returned WriteCloser is closed, it will wait for all data to be read before returning. func (r *RingBuffer) WriteCloser() io.WriteCloser { return &writeCloser{RingBuffer: r} } type writeCloser struct { *RingBuffer } // Close provides a close method for the WriteCloser. func (wc *writeCloser) Close() error { wc.CloseWriter() return wc.Flush()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 13.3K bytes - Click Count (0) -
PULL_REQUESTS_ETIQUETTE.md
- Document testing steps in the PR summary if manual testing was performed. 4. **Before Submitting**: - Run `make verify` to check formatting, linting, and tests. - Reference related issues (e.g., “Closes #1234”). - Notify team members via GitHub `@mentions` if urgent or complex. ## Reviewing PRs Reviewers ensure MinIO’s commit history remains a clear, reliable record. Responsibilities include:
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun May 25 16:32:03 GMT 2025 - 4.7K bytes - Click Count (0) -
internal/event/target/nsq.go
} if err := target.send(eventData); err != nil { return err } // Delete the event from store. return target.store.Del(key) } // Close - closes underneath connections to NSQD server. func (target *NSQTarget) Close() (err error) { close(target.quitCh) if target.producer != nil { // this blocks until complete: target.producer.Stop() } return nil }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 7.1K bytes - Click Count (0) -
internal/s3select/json/preader.go
dstRec.SelectFormat = sql.SelectFmtJSON return dstRec, nil } // Close - closes underlying reader. func (r *PReader) Close() error { if r.close != nil { close(r.close) r.readerWg.Wait() r.close = nil } r.recordsRead = len(r.current) if r.err == nil { r.err = io.EOF } return r.readCloser.Close() } // nextSplit will attempt to skip a number of bytes andCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 6.5K bytes - Click Count (0) -
internal/s3select/csv/reader.go
dstRec.nameIndexMap = r.nameIndexMap return dstRec, nil } // Close - closes underlying reader. func (r *Reader) Close() error { if r.close != nil { close(r.close) r.readerWg.Wait() r.close = nil } r.recordsRead = len(r.current) if r.err == nil { r.err = io.EOF } return r.readCloser.Close() } // nextSplit will attempt to skip a number of bytes andCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 8.8K bytes - Click Count (0)