- Sort Score
- Result 10 results
- Languages All
Results 431 - 440 of 1,179 for funcs (0.02 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)