Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 17 for NATS (0.03 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/event/target/nats.go

    	}
    
    	return nil
    }
    
    // To obtain a nats connection from args.
    func (n NATSArgs) connectNats() (*nats.Conn, error) {
    	connOpts := []nats.Option{nats.Name("Minio Notification"), nats.MaxReconnects(-1)}
    	if n.Username != "" && n.Password != "" {
    		connOpts = append(connOpts, nats.UserInfo(n.Username, n.Password))
    	}
    	if n.UserCredentials != "" {
    		connOpts = append(connOpts, nats.UserCredentials(n.UserCredentials))
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Apr 27 04:30:57 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  2. internal/event/target/nats_tls_contrib_test.go

     * limitations under the License.
     */
    
    package target
    
    import (
    	"path"
    	"path/filepath"
    	"testing"
    
    	xnet "github.com/minio/pkg/v3/net"
    	natsserver "github.com/nats-io/nats-server/v2/test"
    )
    
    func TestNatsConnTLSCustomCA(t *testing.T) {
    	s, opts := natsserver.RunServerWithConfig(filepath.Join("testdata", "contrib", "nats_tls.conf"))
    	defer s.Shutdown()
    
    	clientConfig := &NATSArgs{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Apr 22 22:12:26 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  3. docs/bucket/notifications/README.md

    notify_nats[:name]  publish bucket notifications to NATS endpoints
    
    ARGS:
    address*                          (address)   NATS server address e.g. '0.0.0.0:4222'
    subject*                          (string)    NATS subscription subject
    username                          (string)    NATS username
    password                          (string)    NATS password
    token                             (string)    NATS token
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 84.2K bytes
    - Click Count (0)
  4. internal/config/notify/help.go

    			Key:         target.NATSAddress,
    			Description: "NATS server address e.g. '0.0.0.0:4222'",
    			Type:        "address",
    			Sensitive:   true,
    		},
    		config.HelpKV{
    			Key:         target.NATSSubject,
    			Description: "NATS subscription subject",
    			Type:        "string",
    		},
    		config.HelpKV{
    			Key:         target.NATSUsername,
    			Description: "NATS username",
    			Optional:    true,
    			Type:        "string",
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 19.2K bytes
    - Click Count (0)
  5. go.sum

    github.com/nats-io/nats.go v1.14.0/go.mod h1:BPko4oXsySz4aSWeFgOHLZs3G4Jq4ZAyE6/zMCxRT6w=
    github.com/nats-io/nats.go v1.15.0/go.mod h1:BPko4oXsySz4aSWeFgOHLZs3G4Jq4ZAyE6/zMCxRT6w=
    github.com/nats-io/nats.go v1.22.1/go.mod h1:tLqubohF7t4z3du1QDPYJIQQyhb4wl6DhjxEajSI7UA=
    github.com/nats-io/nats.go v1.41.2 h1:5UkfLAtu/036s99AhFRlyNDI1Ieylb36qbGjJzHixos=
    github.com/nats-io/nats.go v1.41.2/go.mod h1:iRWIPokVIFbVijxuMQq4y9ttaBTMe0SFdlZfMDd+33g=
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 79.8K bytes
    - Click Count (0)
  6. cmd/config-versions.go

    }
    
    // ConsoleLogger is introduced to workaround the dependency about logrus
    type ConsoleLogger struct {
    	Enable bool `json:"enable"`
    }
    
    // serverConfigV33 is just like version '32', removes clientID from NATS and MQTT, and adds queueDir, queueLimit in all notification targets.
    type serverConfigV33 struct {
    	quick.Config `json:"-"` // ignore interfaces
    
    	Version string `json:"version"`
    
    	// S3 API configuration.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 2.5K bytes
    - Click Count (0)
  7. cmd/config-migrate.go

    	}
    	for k, args := range cfg.Notify.MQTT {
    		notify.SetNotifyMQTT(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.MySQL {
    		notify.SetNotifyMySQL(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.NATS {
    		notify.SetNotifyNATS(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.NSQ {
    		notify.SetNotifyNSQ(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.PostgreSQL {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.4K bytes
    - Click Count (0)
  8. docs/tls/README.md

    ```
    
    ## 4. Install Certificates from Third-party CAs
    
    MinIO can connect to other servers, including MinIO nodes or other server types such as NATs and Redis. If these servers use certificates that were not registered with a known CA, add trust for these certificates to MinIO Server by placing these certificates under one of the following MinIO configuration paths:
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 8.6K bytes
    - Click Count (0)
  9. internal/config/notify/parse.go

    		}
    		if err = mysqlArgs.Validate(); err != nil {
    			return nil, err
    		}
    		mysqlTargets[k] = mysqlArgs
    	}
    	return mysqlTargets, nil
    }
    
    // DefaultNATSKVS - NATS KV for nats config.
    var (
    	DefaultNATSKVS = config.KVS{
    		config.KV{
    			Key:   config.Enable,
    			Value: config.EnableOff,
    		},
    		config.KV{
    			Key:   target.NATSAddress,
    			Value: "",
    		},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 47.5K bytes
    - Click Count (0)
  10. helm-releases/minio-5.4.0.tgz

    to use the TLS secret: ```bash helm install --set tls.enabled=true,tls.certSecret=tls-ssl-minio minio/minio ``` ### Installing certificates from third party CAs MinIO can connect to other servers, including MinIO nodes or other server types such as NATs and Redis. If these servers use certificates that were not registered with a known CA, add trust for these certificates to MinIO Server by bundling these certificates into a Kubernetes secret and providing it to Helm via the `trustedCertsSecret` value....
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jan 03 05:34:47 GMT 2025
    - 21.7K bytes
    - Click Count (0)
Back to Top