Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for Dieset (0.21 sec)

  1. cni/pkg/ipset/ipset.go

    // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    // See the License for the specific language governing permissions and
    // limitations under the License.
    
    package ipset
    
    import (
    	"errors"
    	"fmt"
    	"net/netip"
    )
    
    type IPSet struct {
    	V4Name string
    	V6Name string
    	Prefix string
    	Deps   NetlinkIpsetDeps
    }
    
    const (
    	V4Name = "%s-v4"
    	V6Name = "%s-v6"
    )
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  2. internal/pubsub/mask.go

    package pubsub
    
    import (
    	"math"
    	"math/bits"
    )
    
    // Mask allows filtering by a bitset mask.
    type Mask uint64
    
    const (
    	// MaskAll is the mask for all entries.
    	MaskAll Mask = math.MaxUint64
    )
    
    // MaskFromMaskable extracts mask from an interface.
    func MaskFromMaskable(m Maskable) Mask {
    	return Mask(m.Mask())
    }
    
    // Contains returns whether *all* flags in other is present in t.
    func (t Mask) Contains(other Mask) bool {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jul 05 21:45:49 GMT 2022
    - 1.3K bytes
    - Viewed (0)
  3. cmd/common-main.go

    	//nolint:gocritic
    	if !env.IsSet(config.EnvRootUser) && env.IsSet(config.EnvRootPassword) {
    		logger.Fatal(config.ErrMissingEnvCredentialRootUser(nil), "Unable to start MinIO")
    	} else if env.IsSet(config.EnvRootUser) && !env.IsSet(config.EnvRootPassword) {
    		logger.Fatal(config.ErrMissingEnvCredentialRootPassword(nil), "Unable to start MinIO")
    	} else if !env.IsSet(config.EnvRootUser) && !env.IsSet(config.EnvRootPassword) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 35.5K bytes
    - Viewed (2)
  4. cni/pkg/nodeagent/net.go

    	// allow overriding for tests
    	netnsRunner        func(fdable NetnsFd, toRun func() error) error
    	hostsideProbeIPSet ipset.IPSet
    }
    
    var _ MeshDataplane = &NetServer{}
    
    func newNetServer(ztunnelServer ZtunnelServer, podNsMap *podNetnsCache,
    	iptablesConfigurator *iptables.IptablesConfigurator, podNs PodNetnsFinder,
    	probeSet ipset.IPSet,
    ) *NetServer {
    	return &NetServer{
    		ztunnelServer:        ztunnelServer,
    		currentPodSnapshot:   podNsMap,
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.2K bytes
    - Viewed (1)
  5. cni/pkg/nodeagent/server.go

    }
    
    // createHostsideProbeIpset creates an ipset. This is designed to be called from the host netns.
    // Note that if the ipset already exist by name, Create will not return an error.
    //
    // We will unconditionally flush our set before use here, so it shouldn't matter.
    func createHostsideProbeIpset(isV6 bool) (ipset.IPSet, error) {
    	linDeps := ipset.RealNlDeps()
    	probeSet, err := ipset.NewIPSet(iptables.ProbeIPSet, isV6, linDeps)
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  6. internal/config/cache/remote.go

    	IfRange           string     `json:"ifRange,omitempty" msg:",omitempty"`
    	IfPartNumber      int        `json:"ifPartNumber,omitempty" msg:",omitempty"`
    }
    
    // IsSet tells the cache lookup to avoid sending a request
    func (r *CondCheck) IsSet() bool {
    	if r == nil {
    		return false
    	}
    	return r.IfMatch != "" || r.IfNoneMatch != "" || r.IfModifiedSince != nil || r.IfUnModifiedSince != nil || r.IfRange != ""
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Nov 22 21:46:17 GMT 2023
    - 3.7K bytes
    - Viewed (0)
  7. cmd/server-rlimit.go

    	_ = setDebugMemoryLimit(ctx)
    
    	err = sys.SetMaxMemoryLimit(maxLimit, maxLimit)
    	return err
    }
    
    func setDebugMemoryLimit(ctx *cli.Context) error {
    	if ctx == nil {
    		return nil
    	}
    	if ctx.IsSet("memlimit") {
    		memlimit := ctx.String("memlimit")
    		if memlimit == "" {
    			memlimit = ctx.GlobalString("memlimit")
    		}
    		mlimit, err := humanize.ParseBytes(memlimit)
    		if err != nil {
    			return err
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:06:57 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  8. cmd/site-replication.go

    		if peer.DeploymentID == v.DeploymentID {
    			found = true
    			if (!peer.SyncState.Empty() || peer.DefaultBandwidth.IsSet) && peer.Endpoint == "" { // peer.Endpoint may be "" if only sync state/bandwidth is being updated
    				break
    			}
    			if peer.Endpoint == v.Endpoint && peer.SyncState.Empty() && !peer.DefaultBandwidth.IsSet {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 184.1K bytes
    - Viewed (1)
Back to top