- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 106 for unmarshaler (0.17 sec)
-
internal/s3select/select.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 21K bytes - Viewed (0) -
pilot/pkg/networking/core/accesslog_test.go
for _, fc := range l.FilterChains { for _, filter := range fc.Filters { switch filter.Name { case wellknown.TCPProxy: tcpConfig := &tcp.TcpProxy{} if err := filter.GetTypedConfig().UnmarshalTo(tcpConfig); err != nil { t.Fatal(err) } if tcpConfig.GetCluster() == util.BlackHoleCluster { // Ignore the tcp_proxy filter with black hole cluster that just doesn't have access log.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 19.9K bytes - Viewed (0) -
src/net/lookup.go
break } if err != nil { return "", nil, &DNSError{ Err: "cannot unmarshal DNS message", Name: name, Server: server, } } if h.Type != dnsmessage.TypeSRV { if err := p.SkipAnswer(); err != nil { return "", nil, &DNSError{ Err: "cannot unmarshal DNS message", Name: name, Server: server, } } continue }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 28.6K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
err = l.ActiveState.Listener.UnmarshalTo(listenerTyped) if err != nil { return nil, err } if listenerTyped.Name == model.VirtualInboundListenerName { for _, filterChain := range listenerTyped.FilterChains { for _, filter := range filterChain.Filters { hcm := &hcm.HttpConnectionManager{} if err := filter.GetTypedConfig().UnmarshalTo(hcm); err == nil { return hcm, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 50.4K bytes - Viewed (0) -
src/internal/chacha8rand/chacha8.go
} return data } type errUnmarshalChaCha8 struct{} func (*errUnmarshalChaCha8) Error() string { return "invalid ChaCha8 encoding" } // Unmarshal unmarshals the state from a byte slice. func Unmarshal(s *State, data []byte) error { if len(data) != 6*8 || string(data[:8]) != "chacha8:" { return new(errUnmarshalChaCha8) } used := byteorder.BeUint64(data[1*8:])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 21:47:29 UTC 2024 - 4.4K bytes - Viewed (0) -
pkg/proxy/util/linebuffer.go
// returns the number of times Write() or WriteBytes() was called; it assumes that // you never wrote any newlines to the buffer yourself. Lines() int } var _ logr.Marshaler = &realLineBuffer{} type realLineBuffer struct { b bytes.Buffer lines int } // NewLineBuffer returns a new "real" LineBuffer func NewLineBuffer() LineBuffer { return &realLineBuffer{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 3.7K bytes - Viewed (0) -
src/cmd/go/internal/test/flagdefs.go
"stdmethods": true, "stdversion": true, "stringintconv": true, "structtag": true, "testinggoroutine": true, "tests": true, "timeformat": true, "unmarshal": true, "unreachable": true, "unsafeptr": true, "unusedresult": true,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 01:02:40 UTC 2024 - 2.2K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_builder_test.go
expectIstioMTLS := func(t test.Failer, filterChain *listener.FilterChain) { tlsContext := &tls.DownstreamTlsContext{} if err := filterChain.GetTransportSocket().GetTypedConfig().UnmarshalTo(tlsContext); err != nil { t.Fatal(err) } commonTLSContext := tlsContext.CommonTlsContext if len(commonTLSContext.TlsCertificateSdsSecretConfigs) == 0 { t.Fatal("expected tls certificates") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 24.7K bytes - Viewed (0) -
cmd/kubeadm/app/componentconfigs/kubelet.go
return result } func (kc *kubeletConfig) Marshal() ([]byte, error) { return kc.configBase.Marshal(&kc.config) } func (kc *kubeletConfig) Unmarshal(docmap kubeadmapi.DocumentMap) error { return kc.configBase.Unmarshal(docmap, &kc.config) } func (kc *kubeletConfig) Get() interface{} { return &kc.config } func (kc *kubeletConfig) Set(cfg interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 8K bytes - Viewed (0) -
tests/embedded_struct_test.go
str, ok := src.(string) if !ok { byt, ok := src.([]byte) if !ok { return errors.New("Embedded.Scan byte assertion failed") } if err := json.Unmarshal(byt, &value); err != nil { return err } } else { if err := json.Unmarshal([]byte(str), &value); err != nil { return err } } *c = value return nil } func TestEmbeddedScanValuer(t *testing.T) {
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed May 08 04:07:58 UTC 2024 - 7.3K bytes - Viewed (0)