- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for Writer (0.26 sec)
-
istioctl/pkg/writer/envoy/configdump/endpoint.go
} } return "unknown" } func (c *ConfigWriter) PrintEndpoints(filter EndpointFilter, outputFormat string) error { if c.configDump == nil { return fmt.Errorf("config writer has not been primed") } dump, err := c.retrieveSortedEndpointsSlice(filter) if err != nil { return err } marshaller := make(proto.MessageSlice, 0, len(dump)) for _, eds := range dump {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 5.6K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/policies.go
"cmp" "encoding/json" "fmt" "strings" "sigs.k8s.io/yaml" "istio.io/istio/pkg/maps" "istio.io/istio/pkg/slices" ) // PolicyFilter is used to pass filter information into service based config writer print functions type PolicyFilter struct { Namespace string } // Verify returns true if the passed workload matches the filter fields func (wf *PolicyFilter) Verify(pol *ZtunnelPolicy) bool {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.5K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
List(context.Background(), metav1.ListOptions{}) if err != nil { return err } if len(gws.Items) == 0 { fmt.Fprintln(writer, "No waypoints found.") return nil } w := new(tabwriter.Writer).Init(writer, 0, 8, 5, ' ', 0) slices.SortFunc(gws.Items, func(i, j gateway.Gateway) int { if r := cmp.Compare(i.Namespace, j.Namespace); r != 0 { return r }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 20:20:40 GMT 2024 - 15K bytes - Viewed (0) -
cmd/object-api-interface.go
// tests are adjusted to use GetObjectNInfo this function can be removed. func GetObject(ctx context.Context, api ObjectLayer, bucket, object string, startOffset int64, length int64, writer io.Writer, etag string, opts ObjectOptions) (err error) { var header http.Header if etag != "" { header.Set("ETag", etag) } Range := &HTTPRangeSpec{Start: startOffset, End: startOffset + length}
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 16.9K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/services.go
"cmp" "encoding/json" "fmt" "strings" "sigs.k8s.io/yaml" "istio.io/istio/pkg/maps" "istio.io/istio/pkg/slices" ) // ServiceFilter is used to pass filter information into service based config writer print functions type ServiceFilter struct { Namespace string } // Verify returns true if the passed workload matches the filter fields func (wf *ServiceFilter) Verify(svc *ZtunnelService) bool {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.8K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/configdump.go
"encoding/json" "fmt" "io" "text/tabwriter" "sigs.k8s.io/yaml" ) // ConfigWriter is a writer for processing responses from the Ztunnel Admin config_dump endpoint type ConfigWriter struct { Stdout io.Writer ztunnelDump *ZtunnelDump FullDump []byte } // Prime loads the config dump into the writer ready for printing func (c *ConfigWriter) Prime(b []byte) error { cd := ZtunnelDump{}
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.8K bytes - Viewed (0) -
istioctl/pkg/writer/compare/comparator.go
) // Comparator diffs between a config dump from Istiod and one from Envoy type Comparator struct { envoy, istiod *configdump.Wrapper w io.Writer context int location string } // NewComparator is a comparator constructor func NewComparator(w io.Writer, istiodResponses map[string][]byte, envoyResponse []byte) (*Comparator, error) { c := &Comparator{} for _, resp := range istiodResponses {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 3.7K bytes - Viewed (1) -
istioctl/pkg/writer/ztunnel/configdump/certificates.go
func (c *ConfigWriter) PrintSecretSummary() error { if c.ztunnelDump == nil { return fmt.Errorf("config writer has not been primed") } secretDump := c.ztunnelDump.Certificates w := new(tabwriter.Writer).Init(c.Stdout, 0, 8, 5, ' ', 0) fmt.Fprintln(w, "CERTIFICATE NAME\tTYPE\tSTATUS\tVALID CERT\tSERIAL NUMBER\tNOT AFTER\tNOT BEFORE") for _, secret := range secretDump {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 3.5K bytes - Viewed (0) -
cmd/admin-handlers.go
bugLogIf(ctx, err) writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } // Write a version for making *incompatible* changes. // The AdminClient will reject any version it does not know. if publicKey == nil { w.Write([]byte{1}) w.Write(key[:]) } stream, err := sio.AES_256_GCM.Stream(key[:]) if err != nil { bugLogIf(ctx, err) return
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
return debug, err } func setupConfigdumpZtunnelConfigWriter(debug []byte, out io.Writer) (*ztunnelDump.ConfigWriter, error) { cw := &ztunnelDump.ConfigWriter{Stdout: out, FullDump: debug} err := cw.Prime(debug) if err != nil { return nil, err } return cw, nil } func setupFileZtunnelConfigdumpWriter(filename string, out io.Writer) (*ztunnelDump.ConfigWriter, error) { data, err := readFile(filename) if err != nil {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 15:39:28 GMT 2024 - 22.2K bytes - Viewed (0)