Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 167 for targeting (0.2 sec)

  1. pkg/volume/util/device_util_linux.go

    //
    //	For example: {
    //	   "192.168.30.7:3260": 2,
    //	   "192.168.30.8:3260": 3,
    //	}
    func (handler *deviceHandler) GetISCSIPortalHostMapForTarget(targetIqn string) (map[string]int, error) {
    	portalHostMap := make(map[string]int)
    	io := handler.getIo
    
    	// Iterate over all the iSCSI hosts in sysfs
    	sysPath := "/sys/class/iscsi_host"
    	hostDirs, err := io.ReadDir(sysPath)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 16 11:12:06 UTC 2022
    - 9.4K bytes
    - Viewed (0)
  2. internal/event/target/mqtt.go

    // MQTTTarget - MQTT target.
    type MQTTTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       MQTTArgs
    	client     mqtt.Client
    	store      store.Store[event.Event]
    	quitCh     chan struct{}
    	loggerOnce logger.LogOnce
    }
    
    // ID - returns target ID.
    func (target *MQTTTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  3. internal/event/config.go

    	if q.ARN.region == "" {
    		if !targetList.Exists(q.ARN.TargetID) {
    			return &ErrARNNotFound{q.ARN}
    		}
    		return nil
    	}
    
    	if region != "" && q.ARN.region != region {
    		return &ErrUnknownRegion{q.ARN.region}
    	}
    
    	if !targetList.Exists(q.ARN.TargetID) {
    		return &ErrARNNotFound{q.ARN}
    	}
    
    	return nil
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Nov 16 17:28:29 UTC 2021
    - 8.4K bytes
    - Viewed (0)
  4. src/cmd/go/internal/load/pkg.go

    		if !seen[path] {
    			seen[path] = true
    			all = append(all, path)
    		}
    	}
    	sort.Strings(all)
    	return all
    }
    
    // CoverVar holds the name of the generated coverage variables targeting the named file.
    type CoverVar struct {
    	File string // local file name
    	Var  string // name of count struct
    }
    
    // CoverSetup holds parameters related to coverage setup for a given package (covermode, etc).
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 28 17:00:51 UTC 2024
    - 120K bytes
    - Viewed (0)
  5. internal/event/target/nsq.go

    // NSQTarget - NSQ target.
    type NSQTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       NSQArgs
    	producer   *nsq.Producer
    	store      store.Store[event.Event]
    	config     *nsq.Config
    	loggerOnce logger.LogOnce
    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *NSQTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  6. cmd/event-notification.go

    	if evnot == nil {
    		return arns
    	}
    	region := globalSite.Region()
    	for targetID, target := range evnot.targetList.TargetMap() {
    		// httpclient target is part of ListenNotification
    		// which doesn't need to be listed as part of the ARN list
    		// This list is only meant for external targets, filter
    		// this out pro-actively.
    		if !strings.HasPrefix(targetID.ID, "httpclient+") {
    			if onlyActive {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  7. src/go/printer/testdata/linebreaks.input

           y T,
    ) {}
    
    // Example from issue #2597.
    func ManageStatus0(
    	in <-chan *Status,
    	req <-chan Request,
    	stat chan<- *TargetInfo,
    	TargetHistorySize int) {
    }
        
    func ManageStatus1(
    	in <-chan *Status,
    	req <-chan Request,
    	stat chan<- *TargetInfo,
    	TargetHistorySize int,
    ) {
    }
    
    // Example from issue #9064.
    func (y *y) xerrors() error {
    	_ = "xerror.test" //TODO-
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Apr 11 22:03:18 UTC 2018
    - 5.1K bytes
    - Viewed (0)
  8. internal/event/target/amqp.go

    type AMQPTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       AMQPArgs
    	conn       *amqp091.Connection
    	connMutex  sync.Mutex
    	store      store.Store[event.Event]
    	loggerOnce logger.LogOnce
    
    	quitCh chan struct{}
    }
    
    // ID - returns TargetID.
    func (target *AMQPTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 10K bytes
    - Viewed (0)
  9. internal/config/lambda/target/webhook.go

    	totalRequests  int64
    	failedRequests int64
    
    	lazyInit lazyInit
    
    	id         event.TargetID
    	args       WebhookArgs
    	transport  *http.Transport
    	httpClient *http.Client
    	loggerOnce logger.LogOnce
    	cancel     context.CancelFunc
    	cancelCh   <-chan struct{}
    }
    
    // ID - returns target ID.
    func (target *WebhookTarget) ID() event.TargetID {
    	return target.id
    }
    
    // IsActive - Return true if target is up and active
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/smb1/NtlmPasswordAuthentication.java

                byte[] responseKeyNT,
                byte[] serverChallenge,
                byte[] clientChallenge,
                long nanos1601,
                byte[] targetInfo)
        {
            int targetInfoLength = targetInfo != null ? targetInfo.length : 0;
            byte[] temp = new byte[28 + targetInfoLength + 4];
    
            Encdec.enc_uint32le(0x00000101, temp, 0); // Header
    Registered: Wed Jun 12 15:45:55 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 22.5K bytes
    - Viewed (0)
Back to top