Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 382 for seventy (0.1 sec)

  1. cmd/object-multipart-handlers.go

    	encodedSuccessResponse := encodeResponse(response)
    
    	// Write success response.
    	writeSuccessResponseXML(w, encodedSuccessResponse)
    
    	// Notify object created event.
    	evt := eventArgs{
    		EventName:    event.ObjectCreatedCompleteMultipartUpload,
    		BucketName:   bucket,
    		Object:       objInfo,
    		ReqParams:    extractReqParams(r),
    		RespElements: extractRespElements(w),
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  2. internal/event/targetidset_test.go

    // GNU Affero General Public License for more details.
    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package event
    
    import (
    	"reflect"
    	"testing"
    )
    
    func TestTargetIDSetClone(t *testing.T) {
    	testCases := []struct {
    		set           TargetIDSet
    		targetIDToAdd TargetID
    	}{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 3.9K bytes
    - Viewed (0)
  3. internal/logger/target/testlogger/testlogger.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    // Package testlogger contains an autoregistering logger that can be used to capture logging events
    // for individual tests.
    // This package should only be included by test files.
    // To enable logging for a test, use:
    //
    //	func TestSomething(t *testing.T) {
    //		defer testlogger.T.SetLogTB(t)()
    //
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4K bytes
    - Viewed (0)
  4. code_of_conduct.md

    representing a project or community include using an official project e-mail
    address, posting via an official social media account, or acting as an appointed
    representative at an online or offline event. Representation of a project may be
    further defined and clarified by project maintainers.
    
    ## Enforcement
    
    Instances of abusive, harassing, or otherwise unacceptable behavior may be
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jan 20 18:38:58 UTC 2020
    - 3.5K bytes
    - Viewed (0)
  5. cmd/mrf.go

    		break
    	}
    
    	return
    }
    
    var healSleeper = newDynamicSleeper(5, time.Second, false)
    
    // healRoutine listens to new disks reconnection events and
    // issues healing requests for queued objects belonging to the
    // corresponding erasure set
    func (m *mrfState) healRoutine(z *erasureServerPools) {
    	for {
    		select {
    		case <-GlobalContext.Done():
    			return
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  6. internal/pubsub/pubsub.go

    	sync.RWMutex
    }
    
    // Publish message to the subscribers.
    // Note that publish is always non-blocking send so that we don't block on slow receivers.
    // Hence receivers should use buffered channel so as not to miss the published events.
    func (ps *PubSub[T, M]) Publish(item T) {
    	ps.RLock()
    	defer ps.RUnlock()
    	for _, sub := range ps.subs {
    		if sub.types.Contains(Mask(item.Mask())) && (sub.filter == nil || sub.filter(item)) {
    			select {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  7. cmd/metrics-v2.go

    			})
    			metrics = append(metrics, MetricV2{
    				Description: MetricDescription{
    					Namespace: minioNamespace,
    					Subsystem: notifySubsystem,
    					Name:      "events_skipped_total",
    					Help:      "Events that were skipped to be sent to the targets due to the in-memory queue being full",
    					Type:      counterMetric,
    				},
    				Value: float64(nstats.EventsSkipped),
    			})
    			metrics = append(metrics, MetricV2{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  8. internal/config/lambda/help.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package lambda
    
    import (
    	"github.com/minio/minio/internal/config"
    	"github.com/minio/minio/internal/event/target"
    )
    
    // Help template inputs for all lambda targets
    var (
    	HelpWebhook = config.HelpKVS{
    		config.HelpKV{
    			Key:         target.WebhookEndpoint,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 23 14:45:27 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  9. .github/workflows/codeql-analysis.yml

          with:
            # We must fetch at least the immediate parents so that if this is
            # a pull request then we can checkout the head.
            fetch-depth: 2
    
        # If this run was triggered by a pull request event, then checkout
        # the head of the pull request instead of the merge commit.
        - run: git checkout HEAD^2
          if: ${{ github.event_name == 'pull_request' }}
    
        # Initializes the CodeQL tools for scanning.
    Registered: Sun Oct 27 04:35:21 UTC 2024
    - Last Modified: Fri Oct 02 13:24:14 UTC 2020
    - 2.5K bytes
    - Viewed (0)
  10. helm/minio/templates/_helper_create_policy.txt

    #!/bin/sh
    set -e ; # Have script exit in the event of a failed command.
    
    {{- if .Values.configPathmc }}
    MC_CONFIG_DIR="{{ .Values.configPathmc }}"
    MC="/usr/bin/mc --insecure --config-dir ${MC_CONFIG_DIR}"
    {{- else }}
    MC="/usr/bin/mc --insecure"
    {{- end }}
    
    # connectToMinio
    # Use a check-sleep-check loop to wait for MinIO service to be available
    connectToMinio() {
      SCHEME=$1
      ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Mar 21 06:38:06 UTC 2023
    - 2K bytes
    - Viewed (0)
Back to top