- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 371 for street (0.16 sec)
-
internal/grid/stream.go
package grid import ( "context" "errors" ) // A Stream is a two-way stream. // All responses *must* be read by the caller. // If the call is canceled through the context, // the appropriate error will be returned. type Stream struct { // responses from the remote server. // Channel will be closed after error or when remote closes.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 2.8K bytes - Viewed (0) -
cmd/metacache-stream.go
"github.com/tinylib/msgp/msgp" "github.com/valyala/bytebufferpool" ) // metadata stream format: // // The stream is s2 compressed. // https://github.com/klauspost/compress/tree/master/s2#s2-compression // This ensures integrity and reduces the size typically by at least 50%. // // All stream elements are msgpack encoded. // // 1 Integer, metacacheStreamVersion of the writer.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
tests/embedded_struct_test.go
) func TestEmbeddedStruct(t *testing.T) { type ReadOnly struct { ReadOnly *bool } type BasePost struct { Id int64 Title string URL string ReadOnly } type Author struct { ID string Name string Email string } type HNPost struct { BasePost Author `gorm:"EmbeddedPrefix:user_"` // Embedded struct Upvotes int32 } type EngadgetPost struct {
Go - Registered: Sun Apr 21 09:35:09 GMT 2024 - Last Modified: Thu Oct 26 03:58:13 GMT 2023 - 7.3K bytes - Viewed (0) -
cmd/metacache-stream_test.go
Klaus Post <******@****.***> 1663610716 +0200
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 15K bytes - Viewed (0) -
internal/config/crypto.go
if err != nil { return nil, err } stream, err := metadata.Algorithm.Stream(key) if err != nil { return nil, err } if stream.NonceSize() != len(metadata.Nonce) { return nil, sio.NotAuthentic } return stream.DecryptReader(ciphertext, metadata.Nonce, nil), nil } type encryptedObject struct { KeyID string `json:"keyid"` KMSKey []byte `json:"kmskey"`
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 4.8K bytes - Viewed (0) -
internal/grid/grid_test.go
start := time.Now() stream, err := handler.Call(context.Background(), remoteConn, &testRequest{Num: 1, String: testPayload}) errFatal(err) go func() { defer close(stream.Requests) for i := 0; i < payloads; i++ { // t.Log("sending new client request") stream.Requests <- &testRequest{Num: i, String: testPayload} } }() var n int err = stream.Results(func(resp *testResponse) error {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 08 18:15:27 GMT 2024 - 30.1K bytes - Viewed (0) -
internal/grid/muxclient.go
stateless bool acked bool init bool deadline time.Duration outBlock chan struct{} subroute *subHandlerID respErr atomic.Pointer[error] } // Response is a response from the server. type Response struct { Msg []byte Err error } func newMuxClient(ctx context.Context, muxID uint64, parent *Connection) *muxClient {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/config/crypto_test.go
if err != nil { t.Fatalf("Test %d: failed to encrypt stream: %v", i, err) } data, err := io.ReadAll(ciphertext) if err != nil { t.Fatalf("Test %d: failed to encrypt stream: %v", i, err) } plaintext, err := Decrypt(KMS, bytes.NewReader(data), test.Context) if err != nil { t.Fatalf("Test %d: failed to decrypt stream: %v", i, err) } data, err = io.ReadAll(plaintext) if err != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 3.2K bytes - Viewed (0) -
cmd/metacache-server-pool.go
o.SetFilter() if o.Transient { o.Create = false } // We have 2 cases: // 1) Cold listing, just list. // 2) Returning, but with no id. Start async listing. // 3) Returning, with ID, stream from list. // // If we don't have a list id we must ask the server if it has a cache or create a new. if o.ID != "" && !o.Transient { // Create or ping with handout...
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
cmd/bitrot-streaming.go
"context" "hash" "io" "sync" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/ioutil" ) // Calculates bitrot in chunks and writes the hash into the stream. type streamingBitrotWriter struct { iow io.WriteCloser closeWithErr func(err error) error h hash.Hash shardSize int64 canClose *sync.WaitGroup }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 5.8K bytes - Viewed (0)