Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1301 - 1310 of 1,387 for funcs (0.09 sec)

  1. cmd/object-api-common.go

    var globalObjectAPI ObjectLayer
    
    type storageOpts struct {
    	cleanUp     bool
    	healthCheck bool
    }
    
    // Depending on the disk type network or local, initialize storage API.
    func newStorageAPI(endpoint Endpoint, opts storageOpts) (storage StorageAPI, err error) {
    	if endpoint.IsLocal {
    		storage, err := newXLStorage(endpoint, opts.cleanUp)
    		if err != nil {
    			return nil, err
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  2. internal/config/api/api.go

    }
    
    // UnmarshalJSON - Validate SS and RRS parity when unmarshalling JSON.
    func (sCfg *Config) UnmarshalJSON(data []byte) error {
    	type Alias Config
    	aux := &struct {
    		*Alias
    	}{
    		Alias: (*Alias)(sCfg),
    	}
    	return json.Unmarshal(data, &aux)
    }
    
    // LookupConfig - lookup api config and override with valid environment settings if any.
    func LookupConfig(kvs config.KVS) (cfg Config, err error) {
    	deprecatedKeys := []string{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  3. internal/s3select/sql/value_contrib.go

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package sql
    
    import "time"
    
    func timestampCompare(op string, left, right time.Time) bool {
    	switch op {
    	case opLt:
    		return left.Before(right)
    	case opLte:
    		return left.Before(right) || left.Equal(right)
    	case opGt:
    		return left.After(right)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1K bytes
    - Viewed (0)
  4. main.go

    package main // import "github.com/minio/minio"
    
    import (
    	"os"
    
    	// MUST be first import.
    	_ "github.com/minio/minio/internal/init"
    
    	minio "github.com/minio/minio/cmd"
    )
    
    func main() {
    	minio.Main(os.Args)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 973 bytes
    - Viewed (0)
  5. tensorflow/c/eager/c_api_remote_test_util.h

    // which creates a remote input, to simulate a scenario that the remote input
    // is not ready when we start running an op or a function.
    void TestRemoteExecuteSilentCopies(bool async, bool remote, bool func,
                                       bool heavy_load_on_streaming_rpc,
                                       bool remote_func_outputs = false,
                                       bool has_packed_input = false);
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Dec 11 22:56:03 UTC 2020
    - 1.4K bytes
    - Viewed (0)
  6. internal/bucket/encryption/bucket-sse-config_test.go

    package sse
    
    import (
    	"bytes"
    	"encoding/xml"
    	"errors"
    	"testing"
    )
    
    // TestParseBucketSSEConfig performs basic sanity tests on ParseBucketSSEConfig
    func TestParseBucketSSEConfig(t *testing.T) {
    	actualAES256NoNSConfig := &BucketSSEConfig{
    		XMLName: xml.Name{
    			Local: "ServerSideEncryptionConfiguration",
    		},
    		Rules: []Rule{
    			{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 16 18:28:30 UTC 2022
    - 6.1K bytes
    - Viewed (0)
  7. cmd/api-datatypes.go

    // DeleteMarkerMTime is an embedded type containing time.Time for XML marshal
    type DeleteMarkerMTime struct {
    	time.Time
    }
    
    // MarshalXML encodes expiration date if it is non-zero and encodes
    // empty string otherwise
    func (t DeleteMarkerMTime) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error {
    	if t.Time.IsZero() {
    		return nil
    	}
    	return e.EncodeElement(t.Time.Format(time.RFC3339), startElement)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 14 07:26:50 UTC 2024
    - 3K bytes
    - Viewed (0)
  8. src/cmd/cgo/doc.go

    	// if C.free is needed).
    	func C.CString(string) *C.char
    
    	// Go []byte slice to C array
    	// The C array is allocated in the C heap using malloc.
    	// It is the caller's responsibility to arrange for it to be
    	// freed, such as by calling C.free (be sure to include stdlib.h
    	// if C.free is needed).
    	func C.CBytes([]byte) unsafe.Pointer
    
    	// C string to Go string
    	func C.GoString(*C.char) string
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Oct 01 22:52:54 UTC 2024
    - 44K bytes
    - Viewed (0)
  9. cmd/bucket-metadata_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *BucketMetadata) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 25.4K bytes
    - Viewed (0)
  10. docs/debugging/inspect/decrypt-v2.go

    package main
    
    import (
    	"errors"
    	"fmt"
    	"io"
    	"os"
    
    	"github.com/minio/madmin-go/v3/estream"
    )
    
    type keepFileErr struct {
    	error
    }
    
    func extractInspectV2(pk []byte, r io.Reader, w io.Writer, okMsg string) error {
    	privKey, err := bytesToPrivateKey(pk)
    	if err != nil {
    		return fmt.Errorf("decoding key returned: %w", err)
    	}
    
    	sr, err := estream.NewReader(r)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 11 21:22:47 UTC 2024
    - 2.2K bytes
    - Viewed (0)
Back to top