- Sort Score
- Result 10 results
- Languages All
Results 811 - 820 of 1,384 for funcs (0.02 sec)
-
docs/auditlog/auditlog-echo.go
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") } func mainHandler(w http.ResponseWriter, r *http.Request) { body, err := io.ReadAll(r.Body) defer r.Body.Close() if err != nil { log.Printf("Error reading request body: %v", err)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 01 21:31:13 UTC 2024 - 1.5K bytes - Viewed (0) -
cmd/xl-storage-format-utils.go
// // Note: Only the scanner requires fivs.Versions to have exclusively non-free versions. This is used while enforcing NewerNoncurrentVersions lifecycle element. func getFileInfoVersions(xlMetaBuf []byte, volume, path string, inclFreeVersions bool) (FileInfoVersions, error) { fivs, err := getAllFileInfoVersions(xlMetaBuf, volume, path, true) if err != nil { return fivs, err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 08 15:29:58 UTC 2024 - 5.5K bytes - Viewed (0) -
internal/event/rulesmap_test.go
// // 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 event import ( "reflect" "testing" ) func TestRulesMapClone(t *testing.T) { rulesMapCase1 := make(RulesMap) rulesMapToAddCase1 := NewRulesMap([]Name{ObjectCreatedAll}, "*", TargetID{"1", "webhook"})
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jan 05 18:43:06 UTC 2024 - 6.8K bytes - Viewed (0) -
cmd/peer-s3-server.go
Deleted: v.Created, }) } } return buckets, nil } func cloneDrives(drives map[string]StorageAPI) []StorageAPI { copyDrives := make([]StorageAPI, 0, len(drives)) for _, drive := range drives { copyDrives = append(copyDrives, drive) } return copyDrives } func getBucketInfoLocal(ctx context.Context, bucket string, opts BucketOptions) (BucketInfo, error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 22 21:57:20 UTC 2024 - 8.1K bytes - Viewed (0) -
src/cmd/asm/internal/arch/arm.go
"BGE": true, "BLT": true, "BGT": true, "BLE": true, "CALL": true, "JMP": true, } func jumpArm(word string) bool { return armJump[word] } // IsARMCMP reports whether the op (as defined by an arm.A* constant) is // one of the comparison instructions that require special handling. func IsARMCMP(op obj.As) bool { switch op { case arm.ACMN, arm.ACMP, arm.ATEQ, arm.ATST: return true }
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Oct 23 15:18:14 UTC 2024 - 6.1K bytes - Viewed (0) -
internal/s3select/csv/record.go
func (r *Record) Raw() (sql.SelectObjectFormat, interface{}) { return sql.SelectFmtCSV, r } // Replace - is not supported for CSV func (r *Record) Replace(_ interface{}) error { return errors.New("Replace is not supported for CSV") } // NewRecord - creates new CSV record. func NewRecord() *Record { return &Record{}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 4.1K bytes - Viewed (0) -
statement.go
} // WriteByte write byte func (stmt *Statement) WriteByte(c byte) error { return stmt.SQL.WriteByte(c) } // WriteQuoted write quoted value func (stmt *Statement) WriteQuoted(value interface{}) { stmt.QuoteTo(&stmt.SQL, value) } // QuoteTo write quoted value to writer func (stmt *Statement) QuoteTo(writer clause.Writer, field interface{}) { write := func(raw bool, str string) { if raw {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Mon Jun 24 09:42:59 UTC 2024 - 19.9K bytes - Viewed (0) -
cmd/sftp-server.go
} func sshPubKeyAuth(c ssh.ConnMetadata, key ssh.PublicKey) (*ssh.Permissions, error) { return authenticateSSHConnection(c, key, nil) } func sshPasswordAuth(c ssh.ConnMetadata, pass []byte) (*ssh.Permissions, error) { return authenticateSSHConnection(c, nil, pass) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 20 20:00:29 UTC 2024 - 16K bytes - Viewed (0) -
internal/disk/stat_solaris.go
package disk import ( "errors" "fmt" "golang.org/x/sys/unix" ) // GetInfo returns total and free bytes available in a directory, e.g. `/`. func GetInfo(path string, _ bool) (info Info, err error) { s := unix.Statvfs_t{} if err = unix.Statvfs(path, &s); err != nil { return Info{}, err } reservedBlocks := uint64(s.Bfree) - uint64(s.Bavail) info = Info{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 26 19:34:50 UTC 2024 - 1.8K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
type clusterOrigin struct{} func (o clusterOrigin) ClusterName() istiocluster.ID { return "Cluster" } func (o clusterOrigin) String() string { return "" } func (o clusterOrigin) FriendlyName() string { return "Cluster" } func (o clusterOrigin) Comparator() string { return o.FriendlyName() } func (o clusterOrigin) Namespace() resource.Namespace { return ""
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Oct 24 02:31:32 UTC 2024 - 15.3K bytes - Viewed (0)