- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for bliver (0.19 sec)
-
internal/event/target/mqtt.go
MqttTopic = "topic" MqttQoS = "qos" MqttUsername = "username" MqttPassword = "password" MqttReconnectInterval = "reconnect_interval" MqttKeepAliveInterval = "keep_alive_interval" MqttQueueDir = "queue_dir" MqttQueueLimit = "queue_limit" EnvMQTTEnable = "MINIO_NOTIFY_MQTT_ENABLE" EnvMQTTBroker = "MINIO_NOTIFY_MQTT_BROKER"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 8.2K bytes - Viewed (0) -
internal/event/target/postgresql.go
"context" "database/sql" "encoding/json" "errors" "fmt" "net/url" "os" "path/filepath" "regexp" "strconv" "strings" "time" "unicode" _ "github.com/lib/pq" // Register postgres driver "github.com/minio/minio/internal/event" "github.com/minio/minio/internal/logger" "github.com/minio/minio/internal/once" "github.com/minio/minio/internal/store" xnet "github.com/minio/pkg/v2/net" )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 13.3K bytes - Viewed (0) -
cmd/tier.go
config.Lock() defer config.Unlock() var ok bool // Lookup in-memory drivercache d, ok = config.drivercache[tierName] if ok { return d, nil } // Initialize driver from tier config matching tierName t, ok := config.Tiers[tierName] if !ok { return nil, errTierNotFound } d, err = newWarmBackend(ctx, t, false) if err != nil { return nil, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0) -
internal/grid/muxclient.go
// Spawn simple disconnect if requests == nil { go m.handleOneWayStream(responseCh, responses) return &Stream{responses: responseCh, Requests: nil, ctx: m.ctx, cancel: m.cancelFn, muxID: m.MuxID}, nil } // Deliver responses and send unblocks back to the server. go m.handleTwowayResponses(responseCh, responses) go m.handleTwowayRequests(responses, requests)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/storage-rest-client.go
// return 503 server closed error, consider it as an offline node case strings.Contains(err.Error(), http.ErrServerClosed.Error()): return true // Corner case, the server closed the connection with a keep-alive timeout // some requests are not retried internally, such as POST request with written body case strings.Contains(err.Error(), "server closed idle connection"): return true } return false }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/sftp-server-driver.go
Harshavardhana <******@****.***> 1713529422 -0700
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 12.9K bytes - Viewed (0) -
cmd/ftp-server.go
} ftpServer, err := ftp.NewServer(&ftp.Options{ Name: name, WelcomeMessage: fmt.Sprintf("Welcome to '%s' FTP Server Version='%s' License='%s'", MinioStoreName, MinioLicense, Version), Driver: NewFTPDriver(), Port: port, Perm: ftp.NewSimplePerm("nobody", "nobody"), TLS: tls, KeyFile: tlsPrivateKey, CertFile: tlsPublicCert,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 09 03:07:08 GMT 2024 - 4.8K bytes - Viewed (2) -
internal/event/target/mysql_test.go
import ( "database/sql" "testing" ) // TestPostgreSQLRegistration checks if sql driver // is registered and fails otherwise. func TestMySQLRegistration(t *testing.T) { var found bool for _, drv := range sql.Drivers() { if drv == "mysql" { found = true break } } if !found { t.Fatal("mysql driver not registered") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 02 14:53:13 GMT 2023 - 1.1K bytes - Viewed (0) -
internal/event/target/postgresql_test.go
import ( "database/sql" "testing" ) // TestPostgreSQLRegistration checks if postgres driver // is registered and fails otherwise. func TestPostgreSQLRegistration(t *testing.T) { var found bool for _, drv := range sql.Drivers() { if drv == "postgres" { found = true break } } if !found { t.Fatal("postgres driver not registered") } } func TestPsqlTableNameValidation(t *testing.T) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 1.7K bytes - Viewed (0) -
cmd/ftp-server-driver.go
"github.com/minio/pkg/v2/mimedb" ftp "goftp.io/server/v2" ) var _ ftp.Driver = &ftpDriver{} // ftpDriver implements ftpDriver to store files in minio type ftpDriver struct { endpoint string } // NewFTPDriver implements ftp.Driver interface func NewFTPDriver() ftp.Driver { return &ftpDriver{endpoint: fmt.Sprintf("127.0.0.1:%s", globalMinioPort)} }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 13.6K bytes - Viewed (0)