Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for writePing (0.16 sec)

  1. internal/grid/grid_types_msgp_test.go

    func (z testRequest) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 2
    	// write "Num"
    	err = en.Append(0x82, 0xa3, 0x4e, 0x75, 0x6d)
    	if err != nil {
    		return
    	}
    	err = en.WriteInt(z.Num)
    	if err != nil {
    		err = msgp.WrapError(err, "Num")
    		return
    	}
    	// write "String"
    	err = en.Append(0xa6, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67)
    	if err != nil {
    		return
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 8.1K bytes
    - Viewed (0)
  2. internal/s3select/sql/stringfuncs_contrib_test.go

     * you may not use this file except in compliance with the License.
     * You may obtain a copy of the License at
     *
     *      http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 1.2K bytes
    - Viewed (0)
  3. cmd/site-replication-utils_gen.go

    func (z *SiteResyncStatus) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 6
    	// write "v"
    	err = en.Append(0x86, 0xa1, 0x76)
    	if err != nil {
    		return
    	}
    	err = en.WriteInt(z.Version)
    	if err != nil {
    		err = msgp.WrapError(err, "Version")
    		return
    	}
    	// write "ss"
    	err = en.Append(0xa2, 0x73, 0x73)
    	if err != nil {
    		return
    	}
    	err = z.Status.EncodeMsg(en)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 14 15:16:40 GMT 2022
    - 7.2K bytes
    - Viewed (0)
  4. internal/s3select/sql/value_contrib.go

     * you may not use this file except in compliance with the License.
     * You may obtain a copy of the License at
     *
     *      http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 1K bytes
    - Viewed (0)
  5. internal/bucket/replication/datatypes_gen.go

    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = Type(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z Type) EncodeMsg(en *msgp.Writer) (err error) {
    	err = en.WriteInt(int(z))
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z Type) MarshalMsg(b []byte) (o []byte, err error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 2.3K bytes
    - Viewed (0)
  6. internal/event/target/nats_tls_contrib_test.go

     * you may not use this file except in compliance with the License.
     * You may obtain a copy of the License at
     *
     *      http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 2.1K bytes
    - Viewed (0)
  7. internal/logger/reqinfo.go

    }
    
    // ObjectVersion object version key/versionId
    type ObjectVersion struct {
    	ObjectName string
    	VersionID  string `json:"VersionId,omitempty"`
    }
    
    // ReqInfo stores the request info.
    // Reading/writing directly to struct requires appropriate R/W lock.
    type ReqInfo struct {
    	RemoteHost   string           // Client Host/IP
    	Host         string           // Node Host/IP
    	UserAgent    string           // User Agent
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 4.4K bytes
    - Viewed (0)
  8. cmd/storage-rest-common_gen.go

    		return
    	}
    	err = en.WriteString(z.DiskID)
    	if err != nil {
    		err = msgp.WrapError(err, "DiskID")
    		return
    	}
    	// write "m"
    	err = en.Append(0xa1, 0x6d)
    	if err != nil {
    		return
    	}
    	err = en.WriteInt(z.ScanMode)
    	if err != nil {
    		err = msgp.WrapError(err, "ScanMode")
    		return
    	}
    	// write "c"
    	err = en.Append(0xa1, 0x63)
    	if err != nil {
    		return
    	}
    	if z.Cache == nil {
    		err = en.WriteNil()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 7.9K bytes
    - Viewed (0)
  9. cmd/bootstrap-peer-server_gen.go

    	// map header, size 3
    	// write "NEndpoints"
    	err = en.Append(0x83, 0xaa, 0x4e, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x73)
    	if err != nil {
    		return
    	}
    	err = en.WriteInt(z.NEndpoints)
    	if err != nil {
    		err = msgp.WrapError(err, "NEndpoints")
    		return
    	}
    	// write "CmdLines"
    	err = en.Append(0xa8, 0x43, 0x6d, 0x64, 0x4c, 0x69, 0x6e, 0x65, 0x73)
    	if err != nil {
    		return
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 24 21:36:44 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  10. internal/event/target/nats_contrib_test.go

     * you may not use this file except in compliance with the License.
     * You may obtain a copy of the License at
     *
     *      http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 2.3K bytes
    - Viewed (0)
Back to top