- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for encloses (0.14 sec)
-
cmd/admin-heal-ops.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
internal/grid/handlers.go
}) } // TypedStream is a stream with specific types. type TypedStream[Req, Resp RoundTripper] struct { // responses from the remote server. // Channel will be closed after error or when remote closes. // responses *must* be read to either an error is returned or the channel is closed. responses *Stream newResp func() Resp // Requests sent to the server.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
src/archive/zip/reader.go
} func (r *Reader) decompressor(method uint16) Decompressor { dcomp := r.decompressors[method] if dcomp == nil { dcomp = decompressor(method) } return dcomp } // Close closes the Zip file, rendering it unusable for I/O. func (rc *ReadCloser) Close() error { return rc.f.Close() } // DataOffset returns the offset of the file's possibly-compressed
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 27.7K bytes - Viewed (0) -
internal/event/target/postgresql.go
if IsConnErr(err) { return store.ErrNotConnected } return err } // Delete the event from store. return target.store.Del(key.Name) } // Close - closes underneath connections to PostgreSQL database. func (target *PostgreSQLTarget) Close() error { close(target.quitCh) if target.updateStmt != nil { // FIXME: log returned error. ignore time being.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 13.3K bytes - Viewed (0) -
internal/rest/client.go
} return nil, errors.New(resp.Status) } if !c.NoMetrics { resp.Body = &respBodyMonitor{ReadCloser: resp.Body, expectTimeouts: expectTimeouts} } return resp.Body, nil } // Close closes all idle connections of the underlying http client func (c *Client) Close() { atomic.StoreInt32(&c.connected, closed) } // NewClient - returns new REST client.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
src/cmd/asm/internal/asm/asm.go
} else { p.branch(targetAddr, targetProg) } case target.Type == obj.TYPE_MEM && target.Name == obj.NAME_NONE: // JMP 4(R0) *targetAddr = *target // On the ppc64, 9a encodes BR (CTR) as BR CTR. We do the same. if p.arch.Family == sys.PPC64 && target.Offset == 0 { targetAddr.Type = obj.TYPE_REG } case target.Type == obj.TYPE_CONST: // JMP $4 *targetAddr = a[0]
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Feb 21 14:34:57 GMT 2024 - 25.3K bytes - Viewed (0) -
internal/event/name.go
return "s3:Scanner:ManyVersions" case ObjectLargeVersions: return "s3:Scanner:LargeVersions" case PrefixManyFolders: return "s3:Scanner:BigPrefix" } return "" } // MarshalXML - encodes to XML data. func (name Name) MarshalXML(e *xml.Encoder, start xml.StartElement) error { return e.EncodeElement(name.String(), start) } // UnmarshalXML - decodes XML data.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 10.4K bytes - Viewed (0) -
src/cmd/asm/internal/lex/input.go
in.invokeMacro(macro) continue } fallthrough default: if tok == scanner.EOF && len(in.ifdefStack) > 0 { // We're skipping text but have run out of input with no #endif. in.Error("unclosed #ifdef or #ifndef") } in.beginningOfLine = tok == '\n' if in.enabled() { in.text = in.Stack.Text() return tok } } } in.Error("recursive macro invocation") return 0
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Aug 29 07:48:38 GMT 2023 - 12.6K bytes - Viewed (0) -
internal/event/target/kafka.go
return nil, err } return &sarama.ProducerMessage{ Topic: target.args.Topic, Key: sarama.StringEncoder(key), Value: sarama.ByteEncoder(data), }, nil } // Close - closes underneath kafka connection. func (target *KafkaTarget) Close() error { close(target.quitCh) if target.producer != nil { target.producer.Close() return target.client.Close() } return nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
internal/event/target/nats.go
if os.IsNotExist(eErr) { return nil } return eErr } if err := target.send(eventData); err != nil { return err } return target.store.Del(key.Name) } // Close - closes underneath connections to NATS server. func (target *NATSTarget) Close() (err error) { close(target.quitCh) if target.stanConn != nil { // closing the streaming connection does not close the provided NATS connection.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0)