- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 77 for flags (0.69 sec)
-
internal/ioutil/append-file_nix.go
import ( "io" "os" ) // AppendFile - appends the file "src" to the file "dst" func AppendFile(dst string, src string, osync bool) error { flags := os.O_WRONLY | os.O_APPEND | os.O_CREATE if osync { flags |= os.O_SYNC } appendFile, err := os.OpenFile(dst, flags, 0o666) if err != nil { return err } defer appendFile.Close() srcFile, err := os.Open(src) if err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 1.3K bytes - Viewed (0) -
cmd/batch-replicate.go
return false } } // BatchJobReplicateV1 v1 of batch job replication type BatchJobReplicateV1 struct { APIVersion string `yaml:"apiVersion" json:"apiVersion"` Flags BatchJobReplicateFlags `yaml:"flags" json:"flags"` Target BatchJobReplicateTarget `yaml:"target" json:"target"` Source BatchJobReplicateSource `yaml:"source" json:"source"` clnt *miniogo.Core `msg:"-"` }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Nov 22 18:51:46 GMT 2023 - 6.3K bytes - Viewed (0) -
cmd/sftp-server-driver.go
} func (f *sftpDriver) Fileread(r *sftp.Request) (ra io.ReaderAt, err error) { stopFn := globalSftpMetrics.log(r, f.AccessKey()) defer stopFn(err) flags := r.Pflags() if !flags.Read { // sanity check return nil, os.ErrInvalid } bucket, object := path2BucketObject(r.Filepath) if bucket == "" { return nil, errors.New("bucket name cannot be empty") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 12.9K bytes - Viewed (0) -
cmd/batch-rotate_gen.go
err = z.Flags.Filter.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Flags", "Filter") return } case "Notify": err = z.Flags.Notify.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Flags", "Notify") return } case "Retry": err = z.Flags.Retry.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Flags", "Retry")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 02 10:51:33 GMT 2023 - 27.1K bytes - Viewed (0) -
docs/debugging/healing-bin/main.go
{{.Name}} - {{.Usage}} USAGE: {{.Name}} {{if .VisibleFlags}}[FLAGS]{{end}} [HEALINGBINFILE|INSPECTZIPFILE] files ending in '.zip' will be searched for '.healing.bin files recursively and printed together as a single JSON. FLAGS: {{range .VisibleFlags}}{{.}} {{end}} ` app.Flags = []cli.Flag{} app.Action = func(c *cli.Context) error { if !c.Args().Present() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 3.2K bytes - Viewed (0) -
cmd/xl-storage-format-v2-legacy.go
return } x.Type = VersionType(zb0002) } { var zb0003 uint8 zb0003, bts, err = msgp.ReadUint8Bytes(bts) if err != nil { err = msgp.WrapError(err, "Flags") return } x.Flags = xlFlags(zb0003) } o = bts return } // unmarshalV unmarshals with a specific metadata version. func (j *xlMetaV2Version) unmarshalV(v uint8, bts []byte) (o []byte, err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 5.7K bytes - Viewed (0) -
internal/grid/muxserver.go
return case <-outBlock: } msg := message{ MuxID: m.ID, Op: OpMuxServerMsg, Flags: c.baseFlags, } if !ok { hErr := handlerErr.Load() if debugPrint { fmt.Println("muxServer: Mux", m.ID, "send EOF", hErr) } msg.Flags |= FlagEOF if hErr != nil { msg.Flags |= FlagPayloadIsErr msg.Payload = []byte(*hErr) } msg.setZeroPayloadFlag() m.send(msg)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
cmd/main.go
"github.com/minio/pkg/v2/console" "github.com/minio/pkg/v2/env" "github.com/minio/pkg/v2/trie" "github.com/minio/pkg/v2/words" ) // GlobalFlags - global flags for minio. var GlobalFlags = []cli.Flag{ // Deprecated flag, so its hidden now - existing deployments will keep working. cli.StringFlag{ Name: "config-dir, C", Value: defaultConfigDir.Get(),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/xl-storage-format-v2_test.go
} } }) t.Run(fmt.Sprintf("flags-q%d", i), func(t *testing.T) { // Mutate signature, non strict vMod := make([][]xlMetaV2ShallowVersion, 0, len(vers)) for i, ver := range vers { newVers := make([]xlMetaV2ShallowVersion, 0, len(ver)) for _, v := range ver { v.header.Flags += xlFlags(i) newVers = append(newVers, v) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 36.4K bytes - Viewed (0) -
internal/pubsub/mask.go
func MaskFromMaskable(m Maskable) Mask { return Mask(m.Mask()) } // Contains returns whether *all* flags in other is present in t. func (t Mask) Contains(other Mask) bool { return t&other == other } // Overlaps returns whether *any* flags in t overlaps with other. func (t Mask) Overlaps(other Mask) bool { return t&other != 0 } // SingleType returns whether t has a single type set.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jul 05 21:45:49 GMT 2022 - 1.3K bytes - Viewed (0)