Search Options

Results per page
Sort
Preferred Languages
Advance

Results 431 - 440 of 1,179 for funcs (0.03 sec)

  1. internal/event/target/mqtt.go

    	loggerOnce logger.LogOnce
    }
    
    // ID - returns target ID.
    func (target *MQTTTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *MQTTTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *MQTTTarget) Store() event.TargetStore {
    	return target.store
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  2. internal/event/rules.go

    }
    
    // Rules - event rules
    type Rules map[string]TargetIDSet
    
    // Add - adds pattern and target ID.
    func (rules Rules) Add(pattern string, targetID TargetID) {
    	rules[pattern] = NewTargetIDSet(targetID).Union(rules[pattern])
    }
    
    // MatchSimple - returns true one of the matching object name in rules.
    func (rules Rules) MatchSimple(objectName string) bool {
    	for pattern := range rules {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  3. internal/config/storageclass/storage-class.go

    }
    
    // UnmarshalJSON - Validate SS and RRS parity when unmarshalling JSON.
    func (sCfg *Config) UnmarshalJSON(data []byte) error {
    	type Alias Config
    	aux := &struct {
    		*Alias
    	}{
    		Alias: (*Alias)(sCfg),
    	}
    	return json.Unmarshal(data, &aux)
    }
    
    // IsValid - returns true if input string is a valid
    // storage class kind supported.
    func IsValid(sc string) bool {
    	return sc == RRS || sc == STANDARD
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  4. cmd/erasure-common.go

    package cmd
    
    import (
    	"context"
    	"math/rand"
    	"sync"
    	"time"
    )
    
    func (er erasureObjects) getOnlineDisks() (newDisks []StorageAPI) {
    	disks := er.getDisks()
    	var wg sync.WaitGroup
    	var mu sync.Mutex
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	for _, i := range r.Perm(len(disks)) {
    		i := i
    		wg.Add(1)
    		go func() {
    			defer wg.Done()
    			if disks[i] == nil {
    				return
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  5. internal/s3select/json/args.go

    type ReaderArgs struct {
    	ContentType string `xml:"Type"`
    	unmarshaled bool
    }
    
    // IsEmpty - returns whether reader args is empty or not.
    func (args *ReaderArgs) IsEmpty() bool {
    	return !args.unmarshaled
    }
    
    // UnmarshalXML - decodes XML data.
    func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type subReaderArgs ReaderArgs
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.7K bytes
    - Viewed (0)
  6. cmd/metacache_test.go

    			prefix: "prefix/prefix2/",
    			want:   "prefix/prefix2/",
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			if got := baseDirFromPrefix(tt.prefix); got != tt.want {
    				t.Errorf("baseDirFromPrefix() = %v, want %v", got, tt.want)
    			}
    		})
    	}
    }
    
    func Test_metacache_finished(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 08 18:06:45 UTC 2021
    - 6.8K bytes
    - Viewed (0)
  7. cmd/os-readdir_test.go

    	dir     string
    	entries []string
    }
    
    // Test to read empty directory.
    func setupTestReadDirEmpty(t *testing.T) (testResults []result) {
    	// Add empty entry slice for this test directory.
    	testResults = append(testResults, result{t.TempDir(), []string{}})
    	return testResults
    }
    
    // Test to read non-empty directory with only files.
    func setupTestReadDirFiles(t *testing.T) (testResults []result) {
    	dir := t.TempDir()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 7.5K bytes
    - Viewed (0)
  8. cmd/streaming-v4-unsigned.go

    	reader   *bufio.Reader
    	trailers http.Header
    
    	buffer []byte
    	offset int
    	err    error
    	debug  bool
    }
    
    func (cr *s3UnsignedChunkedReader) Close() (err error) {
    	return cr.err
    }
    
    // Read - implements `io.Reader`, which transparently decodes
    // the incoming AWS Signature V4 streaming signature.
    func (cr *s3UnsignedChunkedReader) Read(buf []byte) (n int, err error) {
    	// First, if there is any unread data, copy it to the client
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat May 06 02:53:12 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  9. internal/bucket/versioning/versioning_test.go

    		t.Fatalf("XML shouldn't contain ExcludedPrefixes tag - %s", str)
    	}
    }
    
    func TestVersioningZero(t *testing.T) {
    	var v Versioning
    	if v.Enabled() {
    		t.Fatalf("Expected to be disabled but got enabled")
    	}
    	if v.Suspended() {
    		t.Fatalf("Expected to be disabled but got suspended")
    	}
    }
    
    func TestExcludeFolders(t *testing.T) {
    	v := Versioning{
    		Status:         Enabled,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun May 08 05:06:44 UTC 2022
    - 8.8K bytes
    - Viewed (0)
  10. internal/s3select/jstream/decoder_test.go

    package jstream
    
    import (
    	"bytes"
    	"testing"
    )
    
    func mkReader(s string) *bytes.Reader { return bytes.NewReader([]byte(s)) }
    
    func TestDecoderSimple(t *testing.T) {
    	var (
    		counter int
    		mv      *MetaValue
    		body    = `[{"bio":"bada bing bada boom","id":1,"name":"Charles","falseVal":false}]`
    	)
    
    	decoder := NewDecoder(mkReader(body), 1)
    
    	for mv = range decoder.Stream() {
    		counter++
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.6K bytes
    - Viewed (0)
Back to top