Search Options

Results per page
Sort
Preferred Languages
Advance

Results 341 - 350 of 1,387 for funcs (0.05 sec)

  1. internal/jwt/parser.go

    // If nil an empty string will be returned.
    func (c *MapClaims) GetAccessKey() string {
    	if c == nil {
    		return ""
    	}
    	return c.AccessKey
    }
    
    // NewStandardClaims - initializes standard claims
    func NewStandardClaims() *StandardClaims {
    	return &StandardClaims{}
    }
    
    // SetIssuer sets issuer for these claims
    func (c *StandardClaims) SetIssuer(issuer string) {
    	c.Issuer = issuer
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  2. cmd/update_test.go

    			t.Fatalf("result: expected: %v, got: %v", testCase.expectedResult, result)
    		}
    	}
    }
    
    func TestDownloadReleaseData(t *testing.T) {
    	httpServer1 := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {}))
    	defer httpServer1.Close()
    	httpServer2 := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  3. internal/s3select/sql/parser_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package sql
    
    import (
    	"bytes"
    	"testing"
    
    	"github.com/alecthomas/participle"
    	"github.com/alecthomas/participle/lexer"
    )
    
    func TestJSONPathElement(t *testing.T) {
    	p := participle.MustBuild(
    		&JSONPathElement{},
    		participle.Lexer(sqlLexer),
    		participle.CaseInsensitive("Keyword"),
    		participle.CaseInsensitive("Timeword"),
    	)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  4. cmd/metrics-v3-cache.go

    		clusterDriveMetrics: newClusterStorageInfoCache(),
    		nodesUpDown:         newNodesUpDownCache(),
    	}
    }
    
    type nodesOnline struct {
    	Online, Offline int
    }
    
    func newNodesUpDownCache() *cachevalue.Cache[nodesOnline] {
    	loadNodesUpDown := func(ctx context.Context) (v nodesOnline, err error) {
    		v.Online, v.Offline = globalNotificationSys.GetPeerOnlineCount()
    		return
    	}
    	return cachevalue.NewFromFunc(1*time.Minute,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  5. cmd/consolelogger.go

    // for this node or peers
    func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool {
    	return sys != nil && sys.pubsub.Subscribers() > 0
    }
    
    // Subscribe starts console logging for this node.
    func (sys *HTTPConsoleLoggerSys) Subscribe(subCh chan log.Info, doneCh <-chan struct{}, node string, last int, logKind madmin.LogMask, filter func(entry log.Info) bool) error {
    	// Enable console logging for remote client.
    	if !sys.HasLogListeners() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  6. src/cmd/api/testdata/src/pkg/p4/p4.go

    package p4
    
    type Pair[T1 interface{ M() }, T2 ~int] struct {
    	f1 T1
    	f2 T2
    }
    
    func NewPair[T1 interface{ M() }, T2 ~int](v1 T1, v2 T2) Pair[T1, T2] {
    	return Pair[T1, T2]{f1: v1, f2: v2}
    }
    
    func (p Pair[X1, _]) First() X1 {
    	return p.f1
    }
    
    func (p Pair[_, X2]) Second() X2 {
    	return p.f2
    }
    
    // Deprecated: Use something else.
    func Clone[S ~[]T, T any](s S) S {
    	return append(S(nil), s...)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Dec 02 16:29:41 UTC 2022
    - 552 bytes
    - Viewed (0)
  7. cni/pkg/util/podutil_test.go

    	assert.Equal(t, len(podIPs), 2)
    }
    
    func TestGetPodIPsIfNoPodIPPresent(t *testing.T) {
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    			Namespace: "test",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: "derp",
    		},
    		Status: corev1.PodStatus{},
    	}
    
    	podIPs := GetPodIPsIfPresent(pod)
    	assert.Equal(t, len(podIPs), 0)
    }
    
    func TestPodRedirectionEnabled(t *testing.T) {
    	var (
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  8. istioctl/pkg/util/formatting/formatter_test.go

    // limitations under the License.
    
    package formatting
    
    import (
    	"testing"
    
    	. "github.com/onsi/gomega"
    
    	"istio.io/istio/pkg/config/analysis/diag"
    	"istio.io/istio/pkg/url"
    )
    
    func TestFormatter_PrintLog(t *testing.T) {
    	g := NewWithT(t)
    
    	firstMsg := diag.NewMessage(
    		diag.NewMessageType(diag.Error, "B1", "Explosion accident: %v"),
    		diag.MockResource("SoapBubble"),
    		"the bubble is too big",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 31 14:48:28 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  9. cmd/tier-sweeper.go

    func newObjSweeper(bucket, object string) *objSweeper {
    	return &objSweeper{
    		Object: object,
    		Bucket: bucket,
    	}
    }
    
    // WithVersion sets the version ID from v
    func (os *objSweeper) WithVersion(vid string) *objSweeper {
    	os.VersionID = vid
    	return os
    }
    
    // WithVersioning sets bucket versioning for sweeper.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 17 05:09:58 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  10. callbacks/delete.go

    					return
    				}
    			}
    		}
    
    	}
    }
    
    func Delete(config *Config) func(db *gorm.DB) {
    	supportReturning := utils.Contains(config.DeleteClauses, "RETURNING")
    
    	return func(db *gorm.DB) {
    		if db.Error != nil {
    			return
    		}
    
    		if db.Statement.Schema != nil {
    			for _, c := range db.Statement.Schema.DeleteClauses {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Feb 25 02:48:23 UTC 2022
    - 5.6K bytes
    - Viewed (0)
Back to top