- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 29 for jetstream (0.16 sec)
-
internal/s3select/sql/jsonpath_test.go
package sql import ( "bytes" "fmt" "io" "os" "path/filepath" "reflect" "testing" "github.com/alecthomas/participle" "github.com/bcicen/jstream" ) func getJSONStructs(b []byte) ([]interface{}, error) { dec := jstream.NewDecoder(bytes.NewBuffer(b), 0).ObjectAsKVS() var result []interface{} for parsedVal := range dec.Stream() { result = append(result, parsedVal.Value) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 2.8K bytes - Viewed (0) -
internal/grid/handlers.go
sharedResponse bool } // NewStream creates a typed handler that can provide Marshal/Unmarshal. // Use Register to register a server handler. // Use Call to initiate a clientside call. // newPayload can be nil. In that case payloads will always be nil. // newReq can be nil. In that case no input stream is expected and the handler will be called with nil 'in' channel.
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) -
cmd/storage-rest-server.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
internal/grid/connection.go
} client.cancelFn(context.Canceled) c.outgoing.Delete(client.MuxID) }() return client.traceRoundtrip(ctx, c.trace, h, req) } // NewStream creates a new stream. // Initial payload can be reused by the caller. func (c *Connection) NewStream(ctx context.Context, h HandlerID, payload []byte) (st *Stream, err error) { if !h.valid() { return nil, ErrUnknownHandler } if c.State() != StateConnected {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/peer-rest-server.go
// STREAMS // Set an output capacity of 100 for consoleLog and listenRPC // There is another buffer that will buffer events. consoleLogRPC = grid.NewStream[*grid.MSS, grid.NoPayload, *grid.Bytes](grid.HandlerConsoleLog, grid.NewMSS, nil, grid.NewBytes).WithOutCapacity(100) listenRPC = grid.NewStream[*grid.URLValues, grid.NoPayload, *grid.Bytes](grid.HandlerListen, grid.NewURLValues, nil, grid.NewBytes).WithOutCapacity(100) )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
cmd/peer-rest-client.go
gridConn := client.gridConn() if gridConn == nil { return } payload, err := json.Marshal(traceOpts) if err != nil { bugLogIf(ctx, err) return } st, err := gridConn.NewStream(ctx, grid.HandlerTrace, payload) if err != nil { return } st.Results(func(b []byte) error { select { case traceCh <- b: default: // Do not block on slow receivers.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
internal/config/notify/parse.go
PingInterval: pingInterval, QueueDir: env.Get(queueDirEnv, kv.Get(target.NATSQueueDir)), QueueLimit: queueLimit, RootCAs: rootCAs, } natsArgs.JetStream.Enable = env.Get(jetStreamEnableEnv, kv.Get(target.NATSJetStream)) == config.EnableOn streamingEnableEnv := target.EnvNATSStreaming if k != config.Default {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 46.4K bytes - Viewed (0) -
docs/debugging/inspect/decrypt-v2.go
if false { sr.SkipEncrypted(true) return sr.DebugStream(os.Stdout) } extracted := false for { stream, err := sr.NextStream() if err != nil { if err == io.EOF { if extracted { return nil } return errors.New("no data found on stream") } if errors.Is(err, estream.ErrNoKey) { if stream.Name == "inspect.zip" { return errors.New("incorrect private key") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 21:22:47 GMT 2024 - 2.2K bytes - Viewed (0) -
internal/s3select/sql/evaluate.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package sql import ( "encoding/json" "errors" "fmt" "math" "strings" "github.com/bcicen/jstream" "github.com/minio/simdjson-go" ) var ( errInvalidASTNode = errors.New("invalid AST Node") errExpectedBool = errors.New("expected bool")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 12K bytes - Viewed (0) -
internal/s3select/json/preader.go
continue } dst, ok := r.kvDstPool.Get().([]jstream.KVS) if !ok { dst = make([]jstream.KVS, 0, 1000) } d := jstream.NewDecoder(bytes.NewBuffer(in.input), 0).ObjectAsKVS() stream := d.Stream() all := dst[:0] for mv := range stream { var kvs jstream.KVS if mv.ValueType == jstream.Object { // This is a JSON object type (that preserves key
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 6.4K bytes - Viewed (0)