Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 2,748 for authFn (0.07 sec)

  1. internal/grid/manager.go

    		return
    	}
    	if err := m.authToken(cReq.Token); err != nil {
    		writeErr(fmt.Errorf("auth token: %w", err))
    		return
    	}
    
    	if debugPrint {
    		fmt.Printf("handler: Got Connect Req %+v\n", cReq)
    	}
    	writeErr(remote.handleIncoming(ctx, conn, cReq))
    }
    
    // AuthFn should provide an authentication string for the given aud.
    type AuthFn func() string
    
    // ValidateAuthFn should check authentication for the given aud.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. cmd/grid.go

    				CipherSuites:     fips.TLSCiphers(),
    				CurvePreferences: fips.TLSCurveIDs(),
    			}),
    		Local:        local,
    		Hosts:        hosts,
    		AuthToken:    validateStorageRequestToken,
    		AuthFn:       newCachedAuthToken(),
    		BlockConnect: globalGridStart,
    		// Record incoming and outgoing bytes.
    		Incoming:  globalConnStats.incInternodeInputBytes,
    		Outgoing:  globalConnStats.incInternodeOutputBytes,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  3. internal/grid/connection_test.go

    	remoteHost := hosts[1]
    	local, err := NewManager(context.Background(), ManagerOptions{
    		Dialer: ConnectWS(dialer.DialContext,
    			dummyNewToken,
    			nil),
    		Local:        localHost,
    		Hosts:        hosts,
    		AuthFn:       dummyNewToken,
    		AuthToken:    dummyTokenValidate,
    		BlockConnect: connReady,
    	})
    	errFatal(err)
    
    	// 1: Echo
    	errFatal(local.RegisterSingleHandler(handlerTest, func(payload []byte) ([]byte, *RemoteErr) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 08 21:44:00 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  4. internal/grid/grid.go

    	}
    }
    
    // ConnectWS returns a function that dials a websocket connection to the given address.
    // Route and auth are added to the connection.
    func ConnectWS(dial ContextDialer, auth AuthFn, tls *tls.Config) func(ctx context.Context, remote string) (net.Conn, error) {
    	return ConnectWSWithRoutePath(dial, auth, tls, RoutePath)
    }
    
    // ValidateTokenFn must validate the token and return an error if it is invalid.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  5. internal/grid/connection.go

    	// outQueue is the output queue
    	outQueue chan []byte
    
    	// Client or serverside.
    	side ws.State
    
    	// Dialer for outgoing connections.
    	dial   ConnDialer
    	authFn AuthFn
    
    	handleMsgWg sync.WaitGroup
    
    	// connChange will be signaled whenever State has been updated, or at regular intervals.
    	// Holding the lock allows safe reads of State, and guarantees that changes will be detected.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  6. internal/grid/debug.go

    	for i, host := range hosts {
    		manager, err := NewManager(ctx, ManagerOptions{
    			Dialer: ConnectWS(dialer.DialContext,
    				dummyNewToken,
    				nil),
    			Local:        host,
    			Hosts:        hosts,
    			AuthFn:       dummyNewToken,
    			AuthToken:    dummyTokenValidate,
    			BlockConnect: ready,
    			RoutePath:    RoutePath,
    		})
    		if err != nil {
    			return nil, err
    		}
    		m := mux.NewRouter()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  7. internal/grid/msg.go

    	Op() Op
    }
    
    type connectReq struct {
    	ID    [16]byte
    	Host  string
    	Time  time.Time
    	Token string
    }
    
    // addToken will add the token to the connect request.
    func (c *connectReq) addToken(fn AuthFn) {
    	c.Token = fn()
    }
    
    func (connectReq) Op() Op {
    	return OpConnect
    }
    
    type connectResp struct {
    	ID             [16]byte
    	Accepted       bool
    	RejectedReason string
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  8. istioctl/pkg/authz/authz.go

    		Example: `  # Check AuthorizationPolicy applied to pod httpbin-88ddbcfdd-nt5jb:
      istioctl x authz check httpbin-88ddbcfdd-nt5jb
    
      # Check AuthorizationPolicy applied to one pod under a deployment
      istioctl x authz check deployment/productpage-v1
    
      # Check AuthorizationPolicy from Envoy config dump file:
      istioctl x authz check -f httpbin_config_dump.json`,
    		Args: func(cmd *cobra.Command, args []string) error {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 5K bytes
    - Viewed (0)
  9. cmd/auth-handler_test.go

    				Body:   nopCloser,
    			},
    			authT: authTypePostPolicy,
    		},
    	}
    
    	// .. Tests all request auth type.
    	for i, testc := range testCases {
    		authT := getRequestAuthType(testc.req)
    		if authT != testc.authT {
    			t.Errorf("Test %d: Expected %d, got %d", i+1, testc.authT, authT)
    		}
    	}
    }
    
    // Test all s3 supported auth types.
    func TestS3SupportedAuthType(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  10. cmd/auth-handler.go

    		return authTypeAnonymous
    	}
    	return authTypeUnknown
    }
    
    func validateAdminSignature(ctx context.Context, r *http.Request, region string) (auth.Credentials, bool, APIErrorCode) {
    	var cred auth.Credentials
    	var owner bool
    	s3Err := ErrAccessDenied
    	if _, ok := r.Header[xhttp.AmzContentSha256]; ok &&
    		getRequestAuthType(r) == authTypeSigned {
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 26.1K bytes
    - Viewed (0)
Back to top