Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 29 for jetstream (0.2 sec)

  1. internal/event/target/nats.go

    		}
    		return err
    	}
    
    	if target.natsConn != nil && args.JetStream.Enable {
    		var jstream nats.JetStream
    		jstream, err = target.natsConn.JetStream()
    		if err != nil {
    			if err.Error() != nats.ErrNoServers.Error() {
    				target.loggerOnce(context.Background(), err, target.ID().String())
    			}
    			return err
    		}
    		target.jstream = jstream
    	}
    
    	yes, err := target.isActive()
    	if err != nil {
    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)
  2. cmd/testdata/undeleteable-object.tgz

    :""},{"key":"token","value":""},{"key":"tls","value":"off"},{"key":"tls_skip_verify","value":"off"},{"key":"cert_authority","value":""},{"key":"client_cert","value":""},{"key":"client_key","value":""},{"key":"ping_interval","value":"0"},{"key":"jetstream","value":"off"},{"key":"streaming","value":"off"},{"key":"streaming_async","value":"off"},{"key":"streaming_max_pub_acks_in_flight","value":"0"},{"key":"streaming_cluster_id","value":""},{"key":"queue_dir","value":""},{"key":"queue_limit","value...
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 00:31:12 GMT 2024
    - 8.7M bytes
    - Viewed (0)
  3. internal/s3select/sql/jsonpath.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package sql
    
    import (
    	"errors"
    
    	"github.com/bcicen/jstream"
    	"github.com/minio/simdjson-go"
    )
    
    var (
    	errKeyLookup                  = errors.New("Cannot look up key in non-object value")
    	errIndexLookup                = errors.New("Cannot look up array index in non-array value")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  4. internal/s3select/parquet/reader.go

    		}
    		return nil, errParquetParsingError(err)
    	}
    
    	kvs := jstream.KVS{}
    	for _, col := range pr.r.Columns() {
    
    		var value interface{}
    		if v, ok := nextRow[col.FlatName()]; ok {
    			value, err = convertFromAnnotation(col.Element(), v)
    			if err != nil {
    				return nil, errParquetParsingError(err)
    			}
    		}
    		kvs = append(kvs, jstream.KV{Key: col.FlatName(), Value: value})
    	}
    
    	// Reuse destination if we can.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 14 13:54:47 GMT 2022
    - 4.5K bytes
    - Viewed (0)
  5. internal/s3select/simdj/record.go

    		return nil, err
    	}
    	if cap(dst.KVS) < len(elems.Elements) {
    		dst.KVS = make(jstream.KVS, 0, len(elems.Elements))
    	}
    	for _, elem := range elems.Elements {
    		v, err := sql.IterToValue(elem.Iter)
    		if err != nil {
    			v, err = elem.Iter.Interface()
    			if err != nil {
    				panic(err)
    			}
    		}
    		dst.KVS = append(dst.KVS, jstream.KV{
    			Key:   elem.Name,
    			Value: v,
    		})
    	}
    	return dst, nil
    }
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 5.4K bytes
    - Viewed (0)
  6. internal/grid/README.md

        })
    ```
    
    Sample call:
    ```go
        // Get a connection to the remote host
        conn := manager.Connection(host).Subroute("asubroute")
    	
        payload := []byte("request")
        stream, err := conn.NewStream(ctx, grid.HandlerDiskInfo, payload)
    	if err != nil {
            return err
        }
        // Read results from the stream
        err = stream.Results(func(result []byte) error {
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  7. internal/config/notify/help.go

    			Description: "client cert key for NATS mTLS auth",
    			Optional:    true,
    			Type:        "string",
    			Sensitive:   true,
    		},
    		config.HelpKV{
    			Key:         target.NATSJetStream,
    			Description: "enable JetStream support",
    			Optional:    true,
    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         target.NATSQueueDir,
    			Description: queueDirComment,
    			Optional:    true,
    			Type:        "path",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 19 04:37:54 GMT 2024
    - 18.8K bytes
    - Viewed (0)
  8. internal/grid/grid_test.go

    			t.Fatalf("Unexpected error: %v, %T", err, err)
    		}
    		// Streams should not be able to set up until registered.
    		// Thus, the error is a local error.
    		_, err = remoteConn.NewStream(context.Background(), handlerTest, []byte(testPayload))
    		if !errors.Is(err, ErrUnknownHandler) {
    			t.Fatalf("Unexpected error: %v, %T", err, err)
    		}
    	})
    }
    
    func TestSingleRoundtripGenerics(t *testing.T) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:03:35 GMT 2024
    - 30.1K bytes
    - Viewed (0)
  9. internal/grid/benchmark_test.go

    					if conn == nil {
    						b.Fatal("No connection")
    					}
    					ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    					// Send the payload.
    					t := time.Now()
    					st, err := conn.NewStream(ctx, handlerTest, payload)
    					if err != nil {
    						if debugReqs {
    							fmt.Println(err.Error())
    						}
    						b.Fatal(err.Error())
    					}
    					got := 0
    					err = st.Results(func(b []byte) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 12.2K bytes
    - Viewed (0)
  10. internal/s3select/csv/record.go

    	w.Flush()
    	return w.Error()
    }
    
    // WriteJSON - encodes to JSON data.
    func (r *Record) WriteJSON(writer io.Writer) error {
    	var kvs jstream.KVS = make([]jstream.KV, 0, len(r.columnNames))
    	for i, cn := range r.columnNames {
    		if i < len(r.csvRecord) {
    			kvs = append(kvs, jstream.KV{Key: cn, Value: r.csvRecord[i]})
    		}
    	}
    	return json.NewEncoder(writer).Encode(kvs)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Sep 13 00:00:59 GMT 2022
    - 4.1K bytes
    - Viewed (0)
Back to top