- Sort Score
- Result 10 results
- Languages All
Results 661 - 670 of 1,425 for Func (0.06 sec)
-
schema/relationship.go
// 1. `POLYMORPHIC` tag // 2. `POLYMORPHICTYPE` and `POLYMORPHICID` tag func hasPolymorphicRelation(tagSettings map[string]string) bool { if _, ok := tagSettings["POLYMORPHIC"]; ok { return true } _, hasType := tagSettings["POLYMORPHICTYPE"] _, hasId := tagSettings["POLYMORPHICID"] return hasType && hasId } func (schema *Schema) setRelation(relation *Relationship) { // set non-embedded relation
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Jun 12 03:46:59 UTC 2024 - 22.7K bytes - Viewed (0) -
src/archive/tar/stat_actime1.go
// license that can be found in the LICENSE file. //go:build aix || linux || dragonfly || openbsd || solaris package tar import ( "syscall" "time" ) func statAtime(st *syscall.Stat_t) time.Time { return time.Unix(st.Atim.Unix()) } func statCtime(st *syscall.Stat_t) time.Time { return time.Unix(st.Ctim.Unix())
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 431 bytes - Viewed (0) -
cmd/erasure-object.go
// Read(Closer). When err != nil, the returned reader is always nil. func (er erasureObjects) GetObjectNInfo(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, opts ObjectOptions) (gr *GetObjectReader, err error) { if !opts.NoAuditLog { auditObjectErasureSet(ctx, "GetObject", object, &er) } var unlockOnDefer bool nsUnlocker := func() {} defer func() { if unlockOnDefer { nsUnlocker() } }()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 78.8K bytes - Viewed (0) -
internal/bucket/replication/and.go
} var errDuplicateTagKey = Errorf("Duplicate Tag Keys are not allowed") // isEmpty returns true if Tags field is null func (a And) isEmpty() bool { return len(a.Tags) == 0 && a.Prefix == "" } // Validate - validates the And field func (a And) Validate() error { if a.ContainsDuplicateTag() { return errDuplicateTagKey } for _, t := range a.Tags { if err := t.Validate(); err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 1.8K bytes - Viewed (0) -
istioctl/pkg/util/configdump/cluster.go
cluster "github.com/envoyproxy/go-control-plane/envoy/config/cluster/v3" v3 "istio.io/istio/pilot/pkg/xds/v3" ) // GetDynamicClusterDump retrieves a cluster dump with just dynamic active clusters in it func (w *Wrapper) GetDynamicClusterDump(stripVersions bool) (*admin.ClustersConfigDump, error) { clusterDump, err := w.GetClusterConfigDump() if err != nil { return nil, err } dac := clusterDump.GetDynamicActiveClusters()
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Nov 03 08:41:32 UTC 2022 - 2.1K bytes - Viewed (0) -
internal/event/targetlist.go
} }() } wk.Wait() } var startOnce sync.Once // Init initialize target send workers. func (list *TargetList) Init(workers int) *TargetList { startOnce.Do(func() { go list.startSendWorkers(workers) }) return list } // NewTargetList - creates TargetList. func NewTargetList(ctx context.Context) *TargetList { list := &TargetList{ targets: make(map[TargetID]Target),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.2K bytes - Viewed (0) -
callbacks/helper.go
package callbacks import ( "reflect" "sort" "gorm.io/gorm" "gorm.io/gorm/clause" ) // ConvertMapToValuesForCreate convert map to values func ConvertMapToValuesForCreate(stmt *gorm.Statement, mapValue map[string]interface{}) (values clause.Values) { values.Columns = make([]clause.Column, 0, len(mapValue)) selectColumns, restricted := stmt.SelectAndOmitColumns(true, false) keys := make([]string, 0, len(mapValue))
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Apr 14 12:32:57 UTC 2022 - 3.7K bytes - Viewed (0) -
cmd/test-utils_test.go
func resetGlobalEndpoints() { globalEndpoints = EndpointServerPools{} } func resetGlobalIsErasure() { globalIsErasure = false } // reset global heal state func resetGlobalHealState() { // Init global heal state if globalAllHealState == nil { globalAllHealState = newHealState(GlobalContext, false) } else { globalAllHealState.Lock() for _, v := range globalAllHealState.healSeqMap {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 22:13:18 UTC 2024 - 77K bytes - Viewed (0) -
istioctl/pkg/cli/mock_test.go
"net/http" "k8s.io/cli-runtime/pkg/resource" "k8s.io/client-go/rest/fake" cmdtesting "k8s.io/kubectl/pkg/cmd/testing" "k8s.io/kubectl/pkg/cmd/util" "istio.io/istio/pkg/kube" ) func init() { MakeKubeFactory = func(k kube.CLIClient) util.Factory { tf := cmdtesting.NewTestFactory() _, _, codec := cmdtesting.NewExternalScheme() tf.UnstructuredClient = &fake.RESTClient{
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 1.3K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint_test.go
gateway "sigs.k8s.io/gateway-api/apis/v1" "istio.io/api/label" "istio.io/istio/istioctl/pkg/cli" "istio.io/istio/pilot/pkg/model/kstatus" "istio.io/istio/pkg/config/constants" ) func TestWaypointList(t *testing.T) { cases := []struct { name string args []string gateways []*gateway.Gateway expectedOutFile string }{ { name: "no gateways",
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Apr 04 15:53:09 UTC 2024 - 4.4K bytes - Viewed (0)