- Sort Score
- Result 10 results
- Languages All
Results 21 - 28 of 28 for main (0.14 sec)
-
docs/debugging/inspect/decrypt-v2.go
// GNU Affero General Public License for more details. // // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package main import ( "errors" "fmt" "io" "os" "github.com/minio/madmin-go/v3/estream" ) type keepFileErr struct { error }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 21:22:47 GMT 2024 - 2.2K bytes - Viewed (0) -
docs/auditlog/auditlog-echo.go
// GNU Affero General Public License for more details. // // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package main import ( "bytes" "encoding/json" "flag" "fmt" "io" "log" "net/http" ) var port int func init() { flag.IntVar(&port, "port", 8080, "Port to listen on") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 21:31:13 GMT 2024 - 1.5K bytes - Viewed (0) -
buildscripts/heal-manual.go
// See the License for the specific language governing permissions and // limitations under the License. // package main import ( "context" "encoding/json" "fmt" "log" "os" "time" "github.com/minio/madmin-go/v3" ) func main() { // Note: YOUR-ACCESSKEYID, YOUR-SECRETACCESSKEY are // dummy values, please replace them with original values.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 09:47:58 GMT 2024 - 2.3K bytes - Viewed (0) -
cmd/healthcheck-handler.go
writeErrorResponse(r.Context(), w, toAPIError(r.Context(), err), r.URL) } return } } if globalEtcdClient != nil { // Borrowed from // https://github.com/etcd-io/etcd/blob/main/etcdctl/ctlv3/command/ep_command.go#L118 ctx, cancel := context.WithTimeout(r.Context(), defaultContextTimeout) defer cancel() if _, err := globalEtcdClient.Get(ctx, "health"); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 03 21:13:20 GMT 2024 - 6.5K bytes - Viewed (0) -
internal/s3select/sql/statement.go
return } } // Validate table name err = validateTableName(selectAST.From) if err != nil { return } // Analyze main select expression stmt.selectQProp = selectAST.Expression.analyze(&selectAST) err = stmt.selectQProp.err if err != nil { err = errQueryAnalysisFailure(err) } // Set table alias
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 09 17:19:11 GMT 2024 - 8.9K bytes - Viewed (0) -
cmd/metacache-set.go
Limit int // The number of disks to ask. AskDisks string // InclDeleted will keep all entries where latest version is a delete marker. InclDeleted bool // Scan recursively. // If false only main directory will be scanned. // Should always be true if Separator is n SlashSeparator. Recursive bool // Separator to use. Separator string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/admin-handlers.go
scheme := "https" if !globalIsTLS { scheme = "http" } // save MinIO start script to inspect command var scrb bytes.Buffer fmt.Fprintf(&scrb, `#!/usr/bin/env bash function main() { for file in $(ls -1); do dest_file=$(echo "$file" | cut -d ":" -f1) mv "$file" "$dest_file" done # Read content of inspect-input.txt
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2) -
internal/logger/target/http/http.go
continue } } } lastBatchProcess = time.Now() retry: // If the channel reaches above half capacity // we spawn more workers. The workers spawned // from this main worker routine will exit // once the channel drops below half capacity // and when it's been at least 30 seconds since // we launched a new worker. if mainWorker && len(h.logCh) > cap(h.logCh)/2 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0)