- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 43 for encloses (0.14 sec)
-
update-credits.sh
To apply the Apache License to your work, attach the following boilerplate notice, with the fields enclosed by brackets "[]" replaced with your own identifying information. (Don't include the brackets!) The text should be enclosed in the appropriate comment syntax for the file format. We also recommend that a file or class name and description of purpose be included on the
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Aug 11 05:08:38 GMT 2023 - 11.4K bytes - Viewed (0) -
internal/event/name.go
return "s3:Scanner:ManyVersions" case ObjectLargeVersions: return "s3:Scanner:LargeVersions" case PrefixManyFolders: return "s3:Scanner:BigPrefix" } return "" } // MarshalXML - encodes to XML data. func (name Name) MarshalXML(e *xml.Encoder, start xml.StartElement) error { return e.EncodeElement(name.String(), start) } // UnmarshalXML - decodes XML data.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 10.4K bytes - Viewed (0) -
cmd/api-utils.go
t[j] = '%' t[j+1] = "0123456789ABCDEF"[c>>4] t[j+2] = "0123456789ABCDEF"[c&15] j += 3 default: t[j] = s[i] j++ } } return string(t) } // s3EncodeName encodes string in response when encodingType is specified in AWS S3 requests. func s3EncodeName(name, encodingType string) string { if strings.ToLower(encodingType) == "url" { return s3URLEncode(name) } return name }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 2.8K bytes - Viewed (0) -
internal/bucket/replication/destination.go
// used for multi-destination targets func (d Destination) TargetArn() bool { return strings.HasPrefix(d.ARN, DestinationARNMinIOPrefix) } // MarshalXML - encodes to XML data. func (d Destination) MarshalXML(e *xml.Encoder, start xml.StartElement) error { if err := e.EncodeToken(start); err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 4K bytes - Viewed (2) -
internal/config/lambda/event/targetlist.go
type TargetIDResult struct { // ID where the remove or send were initiated. ID TargetID // 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 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 4.3K bytes - Viewed (0) -
internal/config/dns/operator_dns.go
// DeleteRecord - Removes a specific DNS entry // No Op for Operator because operator deals on with bucket entries func (c *OperatorDNS) DeleteRecord(record SrvRecord) error { return ErrNotImplemented } // Close closes the internal http client func (c *OperatorDNS) Close() error { return nil } // List - Retrieves list of DNS entries for the domain. // This is a No Op for Operator because, there is no intent to enforce global
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 6.6K bytes - Viewed (0) -
internal/event/target/kafka.go
return nil, err } return &sarama.ProducerMessage{ Topic: target.args.Topic, Key: sarama.StringEncoder(key), Value: sarama.ByteEncoder(data), }, nil } // Close - closes underneath kafka connection. func (target *KafkaTarget) Close() error { close(target.quitCh) if target.producer != nil { target.producer.Close() return target.client.Close() } return nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
internal/event/target/nats.go
if os.IsNotExist(eErr) { return nil } return eErr } if err := target.send(eventData); err != nil { return err } return target.store.Del(key.Name) } // Close - closes underneath connections to NATS server. func (target *NATSTarget) Close() (err error) { close(target.quitCh) if target.stanConn != nil { // closing the streaming connection does not close the provided NATS connection.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0) -
internal/s3select/message.go
progressTickerC = progressTicker.C } recordStagingTicker := time.NewTicker(500 * time.Millisecond) // Exit conditions: // // 1. If a writer.write() returns false, select loop below exits and // closes `doneCh` to indicate to caller to also exit. // // 2. If caller (Evaluate()) has an error, it sends an error // message and waits for this go-routine to quit in // FinishWithError() //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
internal/s3select/select.go
} if !sendRecord() { break OuterLoop } } } } if err != nil { _ = writer.FinishWithError("InternalError", err.Error()) } } // Close - closes opened S3 object. func (s3Select *S3Select) Close() error { if s3Select.recordReader == nil { return nil } return s3Select.recordReader.Close() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0)