- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for op (0.92 sec)
-
internal/s3select/sql/value.go
func (v *Value) compareOp(op string, a *Value) (res bool, err error) { if !isValidComparisonOperator(op) { return false, errArithInvalidOperator } switch op { case opIs: if a.IsNull() { // Missing is null return v.IsNull() || v.IsMissing(), nil } if a.IsMissing() { return v.IsMissing(), nil } // Forward to Equal op = opEq case opIsNot: if a.IsNull() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 25 20:31:19 GMT 2022 - 20.2K bytes - Viewed (0) -
internal/grid/msg_gen.go
return } // DecodeMsg implements msgp.Decodable func (z *Op) DecodeMsg(dc *msgp.Reader) (err error) { { var zb0001 uint8 zb0001, err = dc.ReadUint8() if err != nil { err = msgp.WrapError(err) return } (*z) = Op(zb0001) } return } // EncodeMsg implements msgp.Encodable func (z Op) EncodeMsg(en *msgp.Writer) (err error) { err = en.WriteUint8(uint8(z))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 18.8K bytes - Viewed (0) -
internal/grid/types.go
// Msgsize returns 0. func (p NoPayload) Msgsize() int { return 0 } // UnmarshalMsg satisfies the interface, but is a no-op. func (NoPayload) UnmarshalMsg(bytes []byte) ([]byte, error) { return bytes, nil } // MarshalMsg satisfies the interface, but is a no-op. func (NoPayload) MarshalMsg(bytes []byte) ([]byte, error) { return bytes, nil } // NewNoPayload returns an empty NoPayload struct.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 01 23:42:09 GMT 2024 - 15.4K bytes - Viewed (0) -
internal/grid/connection.go
b, op, err := wsutil.ReadData(conn, c.side) if err != nil { return err } if op != ws.OpBinary { return fmt.Errorf("unexpected connect response type %v", op) } if c.incomingBytes != nil { c.incomingBytes(int64(len(b))) } var m message _, _, err = m.parse(b) if err != nil { return err } if m.Op != r.Op() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
internal/grid/muxclient.go
func (m *muxClient) roundtrip(h HandlerID, req []byte) ([]byte, error) { if m.init { return nil, errors.New("mux client already used") } m.init = true m.singleResp = true msg := message{ Op: OpRequest, MuxID: m.MuxID, Handler: h, Flags: m.BaseFlags | FlagEOF, Payload: req, DeadlineMS: uint32(m.deadline.Milliseconds()), } if m.subroute != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/grid/benchmark_test.go
latency := float64(atomic.LoadInt64(&lat)) / float64(time.Millisecond) b.ReportMetric(float64(n)*float64(ops)/spent.Seconds(), "vops/s") b.ReportMetric(latency/float64(ops), "ms/op") } }) } }) b.Run("rpc", func(b *testing.B) { for par := 1; par <= 32; par *= 2 { b.Run("par="+strconv.Itoa(par*runtime.GOMAXPROCS(0)), func(b *testing.B) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
} ) // logSuccess will update the last successful operation time. func (h *healthDiskCtxValue) logSuccess() { atomic.StoreInt64(h.lastSuccess, time.Now().UnixNano()) } // noopDoneFunc is a no-op done func. // Can be reused. var noopDoneFunc = func(_ *error) {} // TrackDiskHealth for this request. // When a non-nil error is returned 'done' MUST be called
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
if len(logger.AuditTargets()) == 0 { return } op := auditTierOp{ Tier: tier, OutputBytes: bytes, } if err == nil { since := time.Since(startTime) op.TimeToResponseNS = since.Nanoseconds() globalTierMetrics.Observe(tier, since) globalTierMetrics.logSuccess(tier) } else { op.Error = err.Error() globalTierMetrics.logFailure(tier) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
if tgt.Empty() { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrRemoteTargetNotFoundError, err), r.URL) return } for _, op := range ops { switch op { case madmin.CredentialsUpdateType: if !globalSiteReplicationSys.isEnabled() { // credentials update is possible only in bucket replication. User will never // know the site replicator creds.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 32.5K bytes - Viewed (0) -
cmd/admin-router.go
adminRouter.Methods(http.MethodPut).Path(adminVersion + "/site-replication/peer/remove").HandlerFunc(adminMiddleware(adminAPI.SRPeerRemove)) adminRouter.Methods(http.MethodPut).Path(adminVersion+"/site-replication/resync/op").HandlerFunc(adminMiddleware(adminAPI.SiteReplicationResyncOp)).Queries("operation", "{operation:.*}")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 25.5K bytes - Viewed (0)