Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for NSQ (0.17 sec)

  1. internal/event/target/nsq.go

    	EnvNSQEnable        = "MINIO_NOTIFY_NSQ_ENABLE"
    	EnvNSQAddress       = "MINIO_NOTIFY_NSQ_NSQD_ADDRESS"
    	EnvNSQTopic         = "MINIO_NOTIFY_NSQ_TOPIC"
    	EnvNSQTLS           = "MINIO_NOTIFY_NSQ_TLS"
    	EnvNSQTLSSkipVerify = "MINIO_NOTIFY_NSQ_TLS_SKIP_VERIFY"
    	EnvNSQQueueDir      = "MINIO_NOTIFY_NSQ_QUEUE_DIR"
    	EnvNSQQueueLimit    = "MINIO_NOTIFY_NSQ_QUEUE_LIMIT"
    )
    
    // NSQArgs - NSQ target arguments.
    type NSQArgs struct {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 7.1K bytes
    - Viewed (0)
  2. internal/event/target/nsq_test.go

    Aditya Manthramurthy <******@****.***> 1693857457 -0700
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 2.2K bytes
    - Viewed (0)
  3. internal/config/notify/config.go

    	MQTT          map[string]target.MQTTArgs          `json:"mqtt"`
    	MySQL         map[string]target.MySQLArgs         `json:"mysql"`
    	NATS          map[string]target.NATSArgs          `json:"nats"`
    	NSQ           map[string]target.NSQArgs           `json:"nsq"`
    	PostgreSQL    map[string]target.PostgreSQLArgs    `json:"postgresql"`
    	Redis         map[string]target.RedisArgs         `json:"redis"`
    	Webhook       map[string]target.WebhookArgs       `json:"webhook"`
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 2.8K bytes
    - Viewed (0)
  4. docs/bucket/notifications/README.md

    or environment variables
    
    ```
    KEY:
    notify_nsq[:name]  publish bucket notifications to NSQ endpoints
    
    ARGS:
    MINIO_NOTIFY_NSQ_ENABLE*          (on|off)    enable notify_nsq target, default is 'off'
    MINIO_NOTIFY_NSQ_NSQD_ADDRESS*    (address)   NSQ server address e.g. '127.0.0.1:4150'
    MINIO_NOTIFY_NSQ_TOPIC*           (string)    NSQ topic
    MINIO_NOTIFY_NSQ_TLS              (on|off)    set to 'on' to enable TLS
    Plain Text
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 84K bytes
    - Viewed (2)
  5. cmd/config-migrate.go

    		// V30 -> V31
    		cfg.OpenID = openid.Config{}
    		cfg.Policy.OPA = opa.Args{
    			URL:       &xnet.URL{},
    			AuthToken: "",
    		}
    	case "31":
    		// V31 -> V32
    		cfg.Notify.NSQ = make(map[string]target.NSQArgs)
    		cfg.Notify.NSQ["1"] = target.NSQArgs{}
    	}
    
    	// Move to latest.
    	cfg.Version = "33"
    
    	newCfg := newServerConfig()
    
    	config.SetRegion(newCfg, cfg.Region)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Oct 18 18:05:24 GMT 2023
    - 5.4K bytes
    - Viewed (0)
  6. docs/config/README.md

    notify_kafka          publish bucket notifications to Kafka endpoints
    notify_mqtt           publish bucket notifications to MQTT endpoints
    notify_nats           publish bucket notifications to NATS endpoints
    notify_nsq            publish bucket notifications to NSQ endpoints
    notify_mysql          publish bucket notifications to MySQL databases
    notify_postgres       publish bucket notifications to Postgres databases
    Plain Text
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Sep 11 21:48:54 GMT 2023
    - 17.7K bytes
    - Viewed (0)
  7. internal/config/notify/help.go

    		},
    	}
    
    	HelpNSQ = config.HelpKVS{
    		config.HelpKV{
    			Key:         target.NSQAddress,
    			Description: "NSQ server address e.g. '127.0.0.1:4150'",
    			Type:        "address",
    			Sensitive:   true,
    		},
    		config.HelpKV{
    			Key:         target.NSQTopic,
    			Description: "NSQ topic",
    			Type:        "string",
    		},
    		config.HelpKV{
    			Key:         target.NSQTLS,
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Mar 19 04:37:54 GMT 2024
    - 18.8K bytes
    - Viewed (0)
  8. cmd/config-current.go

    			Description:     "publish bucket notifications to NATS endpoints",
    			MultipleTargets: true,
    		},
    		config.HelpKV{
    			Key:             config.NotifyNSQSubSys,
    			Description:     "publish bucket notifications to NSQ endpoints",
    			MultipleTargets: true,
    		},
    		config.HelpKV{
    			Key:             config.NotifyMySQLSubSys,
    			Description:     "publish bucket notifications to MySQL databases",
    			MultipleTargets: true,
    		},
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 30.9K bytes
    - Viewed (0)
  9. internal/config/notify/parse.go

    		}
    
    		if err = natsArgs.Validate(); err != nil {
    			return nil, err
    		}
    
    		natsTargets[k] = natsArgs
    	}
    	return natsTargets, nil
    }
    
    // DefaultNSQKVS - NSQ KV for config
    var (
    	DefaultNSQKVS = config.KVS{
    		config.KV{
    			Key:   config.Enable,
    			Value: config.EnableOff,
    		},
    		config.KV{
    			Key:   target.NSQAddress,
    			Value: "",
    		},
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 46.4K bytes
    - Viewed (0)
  10. go.sum

    github.com/ncw/directio v1.0.5 h1:JSUBhdjEvVaJvOoyPAbcW0fnd0tvRXD76wEfZ1KcQz4=
    github.com/ncw/directio v1.0.5/go.mod h1:rX/pKEYkOXBGOggmcyJeJGloCkleSvphPx2eV3t6ROk=
    github.com/nsqio/go-nsq v1.1.0 h1:PQg+xxiUjA7V+TLdXw7nVrJ5Jbl3sN86EhGCQj4+FYE=
    github.com/nsqio/go-nsq v1.1.0/go.mod h1:vKq36oyeVXgsS5Q8YEO7WghqidAVXQlcFxzQbQTuDEY=
    github.com/oklog/ulid v1.3.1 h1:EGfNDEx6MqHz8B3uNV6QAib1UR2Lm97sHi3ocA6ESJ4=
    Plain Text
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Apr 16 18:48:56 GMT 2024
    - 84.4K bytes
    - Viewed (0)
Back to top