Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 1,425 for Func (0.1 sec)

  1. istioctl/pkg/authz/listener.go

    }
    
    type parsedListener struct {
    	filterChains []*filterChain
    }
    
    func getFilterConfig(filter *listener.Filter, out proto.Message) error {
    	switch c := filter.ConfigType.(type) {
    	case *listener.Filter_TypedConfig:
    		if err := c.TypedConfig.UnmarshalTo(out); err != nil {
    			return err
    		}
    	}
    	return nil
    }
    
    func getHTTPConnectionManager(filter *listener.Filter) *hcm.HttpConnectionManager {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Sep 11 15:29:30 UTC 2023
    - 6K bytes
    - Viewed (0)
  2. istioctl/pkg/proxystatus/proxystatus_test.go

    			wantException: true,
    		},
    	}
    	multixds.GetXdsResponse = func(_ *discovery.DiscoveryRequest, _ string, _ string, _ clioptions.CentralControlPlaneOptions, _ []grpc.DialOption,
    	) (*discovery.DiscoveryResponse, error) {
    		return &discovery.DiscoveryResponse{}, nil
    	}
    	t.Cleanup(func() {
    		multixds.GetXdsResponse = xds.GetXdsResponse
    	})
    
    	for i, c := range cases {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Mar 15 08:28:50 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  3. internal/bucket/replication/destination.go

    }
    
    func (d Destination) isValidStorageClass() bool {
    	if d.StorageClass == "" {
    		return true
    	}
    	return d.StorageClass == "STANDARD" || d.StorageClass == "REDUCED_REDUNDANCY"
    }
    
    // IsValid - checks whether Destination is valid or not.
    func (d Destination) IsValid() bool {
    	return d.Bucket != "" || !d.isValidStorageClass()
    }
    
    func (d Destination) String() string {
    	return d.ARN
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4K bytes
    - Viewed (0)
  4. cni/pkg/iptables/iptables_linux.go

    	"istio.io/istio/pkg/ptr"
    )
    
    func AddInpodMarkIPRule(cfg *Config) error {
    	err := forEachInpodMarkIPRule(cfg, netlink.RuleAdd)
    	if errors.Is(err, unix.EEXIST) {
    		log.Debugf("Ignoring exists error adding inpod mark ip rule: %v", err)
    		return nil
    	}
    	return err
    }
    
    func DelInpodMarkIPRule(cfg *Config) error {
    	return forEachInpodMarkIPRule(cfg, netlink.RuleDel)
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Sep 06 09:44:28 UTC 2024
    - 4K bytes
    - Viewed (0)
  5. internal/dsync/drwmutex.go

    type Granted struct {
    	index   int
    	lockUID string // Locked if set with UID string, unlocked if empty
    }
    
    func (g *Granted) isLocked() bool {
    	return isLocked(g.lockUID)
    }
    
    func isLocked(uid string) bool {
    	return len(uid) > 0
    }
    
    // NewDRWMutex - initializes a new dsync RW mutex.
    func NewDRWMutex(clnt *Dsync, names ...string) *DRWMutex {
    	restClnts, _ := clnt.GetLockers()
    	sort.Strings(names)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  6. src/cmd/api/testdata/src/pkg/p2/golden.txt

    pkg p2, func F() string
    pkg p2, func F //deprecated
    pkg p2, func G() Twoer
    pkg p2, func NewError(string) error
    pkg p2, type Twoer interface { PackageTwoMeth }
    pkg p2, type Twoer interface, PackageTwoMeth()
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Dec 02 16:29:41 UTC 2022
    - 265 bytes
    - Viewed (0)
  7. internal/s3select/parquet/errors.go

    	cause      error
    }
    
    func (err *s3Error) Cause() error {
    	return err.cause
    }
    
    func (err *s3Error) ErrorCode() string {
    	return err.code
    }
    
    func (err *s3Error) ErrorMessage() string {
    	return err.message
    }
    
    func (err *s3Error) HTTPStatusCode() int {
    	return err.statusCode
    }
    
    func (err *s3Error) Error() string {
    	return err.message
    }
    
    func errParquetParsingError(err error) *s3Error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.4K bytes
    - Viewed (0)
  8. cmd/endpoint.go

    }
    
    // Type - returns type of endpoint.
    func (endpoint Endpoint) Type() EndpointType {
    	if endpoint.Host == "" {
    		return PathEndpointType
    	}
    
    	return URLEndpointType
    }
    
    // HTTPS - returns true if secure for URLEndpointType.
    func (endpoint Endpoint) HTTPS() bool {
    	return endpoint.Scheme == "https"
    }
    
    // GridHost returns the host to be used for grid connections.
    func (endpoint Endpoint) GridHost() string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 34.2K bytes
    - Viewed (0)
  9. internal/bucket/lifecycle/transition.go

    }
    
    // IsDateNull returns true if date field is null
    func (t Transition) IsDateNull() bool {
    	return t.Date.Time.IsZero()
    }
    
    // IsNull returns true if both date and days fields are null
    func (t Transition) IsNull() bool {
    	return t.StorageClass == ""
    }
    
    // NextDue returns upcoming transition date for obj and true if applicable,
    // returns false otherwise.
    func (t Transition) NextDue(obj ObjectOpts) (time.Time, bool) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jan 10 17:07:49 UTC 2022
    - 5.1K bytes
    - Viewed (0)
  10. soft_delete.go

    }
    
    type SoftDeleteQueryClause struct {
    	ZeroValue sql.NullString
    	Field     *schema.Field
    }
    
    func (sd SoftDeleteQueryClause) Name() string {
    	return ""
    }
    
    func (sd SoftDeleteQueryClause) Build(clause.Builder) {
    }
    
    func (sd SoftDeleteQueryClause) MergeClause(*clause.Clause) {
    }
    
    func (sd SoftDeleteQueryClause) ModifyStatement(stmt *Statement) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Feb 01 06:40:55 UTC 2023
    - 4.5K bytes
    - Viewed (1)
Back to top