Search Options

Results per page
Sort
Preferred Languages
Advance

Results 971 - 980 of 1,385 for _func (0.03 sec)

  1. cmd/erasure-healing_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    }
    
    func TestHealingDanglingObject(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	resetGlobalHealState()
    	defer resetGlobalHealState()
    
    	// Set globalStorageClass.STANDARD to EC:4 for this test
    	saveSC := globalStorageClass
    	defer func() {
    		globalStorageClass.Update(saveSC)
    	}()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  2. cmd/metacache_gen.go

    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *scanStatus) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint8
    		zb0001, err = dc.ReadUint8()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = scanStatus(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z scanStatus) EncodeMsg(en *msgp.Writer) (err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Nov 08 18:26:08 UTC 2021
    - 10K bytes
    - Viewed (0)
  3. internal/kms/dek_test.go

    		},
    	},
    }
    
    func TestEncodeDecodeDEK(t *testing.T) {
    	for i, test := range dekEncodeDecodeTests {
    		text, err := test.Key.MarshalText()
    		if err != nil {
    			t.Fatalf("Test %d: failed to marshal DEK: %v", i, err)
    		}
    
    		var key DEK
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  4. internal/logger/legacy.go

    const (
    	legacyEnvAuditLoggerHTTPEndpoint = "MINIO_AUDIT_LOGGER_HTTP_ENDPOINT"
    	legacyEnvLoggerHTTPEndpoint      = "MINIO_LOGGER_HTTP_ENDPOINT"
    )
    
    // SetLoggerHTTPAudit - helper for migrating older config to newer KV format.
    func SetLoggerHTTPAudit(scfg config.Config, k string, args http.Config) {
    	if !args.Enabled {
    		// Do not enable audit targets, if not enabled
    		return
    	}
    	scfg[config.AuditWebhookSubSys][k] = config.KVS{
    		config.KV{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 03 09:47:07 UTC 2023
    - 2K bytes
    - Viewed (0)
  5. callbacks/callbacks.go

    type Config struct {
    	LastInsertIDReversed bool
    	CreateClauses        []string
    	QueryClauses         []string
    	UpdateClauses        []string
    	DeleteClauses        []string
    }
    
    func RegisterDefaultCallbacks(db *gorm.DB, config *Config) {
    	enableTransaction := func(db *gorm.DB) bool {
    		return !db.SkipDefaultTransaction
    	}
    
    	if len(config.CreateClauses) == 0 {
    		config.CreateClauses = createClauses
    	}
    	if len(config.QueryClauses) == 0 {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Oct 27 23:56:55 UTC 2021
    - 3.3K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/healthServer_test.go

    // limitations under the License.
    
    package nodeagent
    
    import (
    	"net/http"
    	"net/http/httptest"
    	"testing"
    
    	"istio.io/istio/cni/pkg/constants"
    	"istio.io/istio/pkg/test/util/assert"
    )
    
    func TestServer(t *testing.T) {
    	router := http.NewServeMux()
    	installReady, watchReady := initRouter(router)
    
    	assert.Equal(t, installReady.Load(), false)
    	assert.Equal(t, watchReady.Load(), false)
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 2K bytes
    - Viewed (0)
  7. cmd/bitrot_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 cmd
    
    import (
    	"context"
    	"io"
    	"testing"
    )
    
    func testBitrotReaderWriterAlgo(t *testing.T, bitrotAlgo BitrotAlgorithm) {
    	tmpDir := t.TempDir()
    
    	volume := "testvol"
    	filePath := "testfile"
    
    	disk, err := newLocalXLStorage(tmpDir)
    	if err != nil {
    		t.Fatal(err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  8. istioctl/pkg/util/configdump/util.go

    	ecds      configTypeURL = "type.googleapis.com/envoy.admin.v3.EcdsConfigDump"
    )
    
    // getSection takes a TypeURL and returns the types.Any from the config dump corresponding to that URL
    func (w *Wrapper) getSection(sectionTypeURL configTypeURL) (*anypb.Any, error) {
    	var dumpAny *anypb.Any
    	for _, conf := range w.Configs {
    		if conf.TypeUrl == string(sectionTypeURL) {
    			dumpAny = conf
    		}
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sun Dec 24 08:16:26 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  9. istioctl/pkg/tag/generate.go

    }
    
    // Create applies the given tag manifests.
    func Create(client kube.CLIClient, manifests, ns string) error {
    	if err := client.ApplyYAMLContents(ns, manifests); err != nil {
    		return fmt.Errorf("failed to apply tag manifests to cluster: %v", err)
    	}
    	return nil
    }
    
    // generateValidatingWebhook renders a validating webhook configuration from the given tagWebhookConfig.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  10. cmd/bucket-policy-handlers_test.go

    }
    
    // Wrapper for calling Create Bucket and ensure we get one and only one success.
    func TestCreateBucket(t *testing.T) {
    	ExecObjectLayerAPITest(ExecObjectLayerAPITestArgs{t: t, objAPITest: testCreateBucket, endpoints: []string{"MakeBucket"}})
    }
    
    // testCreateBucket - Test for calling Create Bucket and ensure we get one and only one success.
    func testCreateBucket(obj ObjectLayer, instanceType, bucketName string, apiRouter http.Handler,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 32.9K bytes
    - Viewed (0)
Back to top