Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 370 for xnet (0.12 sec)

  1. internal/event/target/nsq.go

    import (
    	"context"
    	"crypto/tls"
    	"encoding/json"
    	"errors"
    	"fmt"
    	"net/url"
    	"os"
    	"path/filepath"
    
    	"github.com/nsqio/go-nsq"
    
    	"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"
    )
    
    // NSQ constants
    const (
    	NSQAddress       = "nsqd_address"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 7.1K bytes
    - Viewed (0)
  2. cmd/net.go

    package cmd
    
    import (
    	"errors"
    	"fmt"
    	"net"
    	"net/url"
    	"runtime"
    	"sort"
    	"strings"
    
    	"github.com/minio/minio-go/v7/pkg/set"
    	"github.com/minio/minio/internal/config"
    	"github.com/minio/minio/internal/logger"
    	xnet "github.com/minio/pkg/v2/net"
    )
    
    // IPv4 addresses of local host.
    var localIP4 = mustGetLocalIP4()
    
    // mustSplitHostPort is a wrapper to net.SplitHostPort() where error is assumed to be a fatal.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 26 15:00:38 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  3. internal/config/subnet/config.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package subnet
    
    import (
    	"net/http"
    	"net/url"
    	"os"
    	"strings"
    	"sync"
    
    	"github.com/minio/minio/internal/config"
    	"github.com/minio/pkg/v2/env"
    	xnet "github.com/minio/pkg/v2/net"
    )
    
    const (
    	baseURL    = "https://subnet.min.io"
    	baseURLDev = "http://localhost:9000"
    )
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Nov 24 17:59:35 GMT 2023
    - 3.8K bytes
    - Viewed (0)
  4. internal/config/identity/openid/providercfg.go

    package openid
    
    import (
    	"context"
    	"encoding/json"
    	"errors"
    	"fmt"
    	"net/http"
    
    	"github.com/minio/minio/internal/arn"
    	"github.com/minio/minio/internal/config"
    	"github.com/minio/minio/internal/config/identity/openid/provider"
    	xhttp "github.com/minio/minio/internal/http"
    	xnet "github.com/minio/pkg/v2/net"
    )
    
    type providerCfg struct {
    	// Used for user interface like console
    	DisplayName string
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  5. internal/event/target/amqp.go

    package target
    
    import (
    	"context"
    	"encoding/json"
    	"errors"
    	"fmt"
    	"net"
    	"net/url"
    	"os"
    	"path/filepath"
    	"sync"
    
    	"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"
    	"github.com/rabbitmq/amqp091-go"
    )
    
    // AMQPArgs - AMQP target arguments.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 10K bytes
    - Viewed (0)
  6. internal/config/identity/openid/jwt_test.go

    	"context"
    	"encoding/base64"
    	"encoding/json"
    	"fmt"
    	"io"
    	"net/http"
    	"net/http/httptest"
    	"net/url"
    	"sync"
    	"testing"
    	"time"
    
    	jwtgo "github.com/golang-jwt/jwt/v4"
    	"github.com/minio/minio/internal/arn"
    	"github.com/minio/minio/internal/config"
    	jwtm "github.com/minio/minio/internal/jwt"
    	xnet "github.com/minio/pkg/v2/net"
    )
    
    func TestUpdateClaimsExpiry(t *testing.T) {
    	testCases := []struct {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 8.3K bytes
    - Viewed (0)
  7. internal/config/policy/opa/config.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package opa
    
    import (
    	"bytes"
    	"encoding/json"
    	"io"
    	"net/http"
    
    	"github.com/minio/minio/internal/config"
    	"github.com/minio/pkg/v2/env"
    	xnet "github.com/minio/pkg/v2/net"
    	"github.com/minio/pkg/v2/policy"
    )
    
    // Env IAM OPA URL
    const (
    	URL       = "url"
    	AuthToken = "auth_token"
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 14 21:50:16 GMT 2023
    - 5.2K bytes
    - Viewed (1)
  8. internal/event/target/postgresql.go

    	"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"
    )
    
    const (
    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)
  9. internal/event/target/elasticsearch.go

    	"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"
    	"github.com/pkg/errors"
    )
    
    // Elastic constants
    const (
    	ElasticFormat     = "format"
    	ElasticURL        = "url"
    	ElasticIndex      = "index"
    	ElasticQueueDir   = "queue_dir"
    	ElasticQueueLimit = "queue_limit"
    	ElasticUsername   = "username"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 15K bytes
    - Viewed (0)
  10. cmd/consolelogger.go

    	"github.com/minio/minio/internal/logger/target/console"
    	"github.com/minio/minio/internal/logger/target/types"
    	"github.com/minio/minio/internal/pubsub"
    	"github.com/minio/pkg/v2/logger/message/log"
    	xnet "github.com/minio/pkg/v2/net"
    )
    
    // number of log messages to buffer
    const defaultLogBufferCount = 10000
    
    // HTTPConsoleLoggerSys holds global console logger state
    type HTTPConsoleLoggerSys struct {
    	totalMessages  int64
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 5.5K bytes
    - Viewed (0)
Back to top