Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 82 for registerScope (0.55 sec)

  1. istioctl/pkg/root/root.go

    		"Default values for istioctl flags").Get()
    
    	LoggingOptions = defaultLogOptions()
    
    	// scope is for dev logging.  Warning: log levels are not set by --log_output_level until command is Run().
    	Scope = log.RegisterScope("cli", "istioctl")
    )
    
    func defaultLogOptions() *log.Options {
    	o := log.DefaultOptions()
    	// Default to warning for everything; we usually don't want logs in istioctl
    	o.SetDefaultOutputLevel("all", log.WarnLevel)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Mar 26 20:38:10 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  2. operator/cmd/mesh/shared.go

    var installerScope = log.RegisterScope("installer", "installer")
    
    func init() {
    	// adding to remove message about the controller-runtime logs not getting displayed
    	// We cannot do this in the `log` package since it would place a runtime dependency on controller-runtime for all binaries.
    	scope := log.RegisterScope("controlleruntime", "scope for controller runtime")
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Mar 29 02:29:02 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  3. pkg/xds/monitoring.go

    // limitations under the License.
    
    package xds
    
    import (
    	"time"
    
    	istiolog "istio.io/istio/pkg/log"
    	"istio.io/istio/pkg/model"
    	"istio.io/istio/pkg/monitoring"
    )
    
    var (
    	Log = istiolog.RegisterScope("ads", "ads debugging")
    	log = Log
    
    	errTag  = monitoring.CreateLabel("err")
    	nodeTag = monitoring.CreateLabel("node")
    	typeTag = monitoring.CreateLabel("type")
    
    	TotalXDSInternalErrors = monitoring.NewSum(
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. pkg/security/retry.go

    	retry "github.com/grpc-ecosystem/go-grpc-middleware/retry"
    	"google.golang.org/grpc"
    	"google.golang.org/grpc/codes"
    
    	"istio.io/istio/pkg/log"
    	"istio.io/istio/security/pkg/monitoring"
    )
    
    var caLog = log.RegisterScope("ca", "ca client")
    
    // CARetryOptions returns the default retry options recommended for CA calls
    // This includes 5 retries, with backoff from 100ms -> 1.6s with jitter.
    var CARetryOptions = []retry.CallOption{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  5. pkg/test/shell/shell.go

    //  limitations under the License.
    
    package shell
    
    import (
    	"fmt"
    	"os/exec"
    	"strings"
    
    	"github.com/google/shlex"
    
    	"istio.io/istio/pkg/log"
    )
    
    var scope = log.RegisterScope("shell", "Shell execution scope")
    
    // Execute the given command.
    func Execute(combinedOutput bool, format string, args ...any) (string, error) {
    	s := fmt.Sprintf(format, args...)
    
    	parts, err := shlex.Split(s)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  6. pkg/log/options_test.go

    				}
    
    				if !reflect.DeepEqual(c.result, *o) {
    					t.Errorf("Got %v, expected %v", *o, c.result)
    				}
    			})
    		}
    
    		_ = RegisterScope("foo", "bar")
    	}
    }
    
    func TestSetDefaultLevel(t *testing.T) {
    	resetGlobals()
    
    	_ = RegisterScope("TestSetLevel", "")
    
    	cases := []struct {
    		flagLevels    string
    		scope         string
    		defaultLevel  Level
    		expectedLevel Level
    	}{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Mar 26 20:38:10 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  7. pkg/test/echo/server/endpoint/util.go

    // limitations under the License.
    
    package endpoint
    
    import (
    	"crypto/tls"
    	"net"
    	"os"
    	"strconv"
    	"time"
    
    	"istio.io/istio/pkg/log"
    )
    
    var epLog = log.RegisterScope("endpoint", "echo serverside")
    
    const (
    	requestTimeout = 15 * time.Second
    	idleTimeout    = 5 * time.Second
    )
    
    func listenOnAddress(ip string, port int) (net.Listener, int, error) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  8. security/pkg/k8s/controller/casecret.go

    	"context"
    	"time"
    
    	v1 "k8s.io/api/core/v1"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	corev1 "k8s.io/client-go/kubernetes/typed/core/v1"
    
    	"istio.io/istio/pkg/log"
    )
    
    var k8sControllerLog = log.RegisterScope("secretcontroller", "Citadel kubernetes controller log")
    
    // CaSecretController manages the self-signed signing CA secret.
    type CaSecretController struct {
    	client corev1.CoreV1Interface
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  9. pilot/pkg/autoregistration/internal/health/controller.go

    	"istio.io/istio/pilot/pkg/model"
    	"istio.io/istio/pilot/pkg/model/status"
    	"istio.io/istio/pkg/kube/controllers"
    	istiolog "istio.io/istio/pkg/log"
    )
    
    var log = istiolog.RegisterScope("wle", "wle controller debugging")
    
    type HealthEvent struct {
    	// whether or not the agent thought the target is healthy
    	Healthy bool `json:"healthy,omitempty"`
    	// error message propagated
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Sep 19 20:41:55 UTC 2023
    - 3.4K bytes
    - Viewed (0)
  10. pilot/pkg/status/resource.go

    	"istio.io/istio/pkg/config"
    	"istio.io/istio/pkg/config/resource"
    	"istio.io/istio/pkg/config/schema/collections"
    	"istio.io/istio/pkg/config/schema/gvk"
    	"istio.io/istio/pkg/log"
    )
    
    var scope = log.RegisterScope("status",
    	"status controller for istio")
    
    func ResourceFromString(s string) *Resource {
    	pieces := strings.Split(s, "/")
    	if len(pieces) != 6 {
    		scope.Errorf("cannot unmarshal %s into resource identifier", s)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 30 16:13:59 UTC 2023
    - 3.2K bytes
    - Viewed (0)
Back to top