- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 72 for messages (0.16 sec)
-
internal/s3select/message.go
207, 151, 211, 146, // message crc. } // newErrorMessage - creates new Request Level Error Message. S3 sends this message if the request failed for any reason. // It contains the error code and error message for the failure. If S3 sends a RequestLevelError message, // it doesn't send an End message. // // Header specification: // Request-level error messages contain three headers, as follows:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
} var messages diag.Messages = make([]diag.Message, 0) if minor <= 21 { // ENHANCED_RESOURCE_SCOPING if err := checkPilot(cli, ctx.IstioNamespace(), &messages); err != nil { return nil, err } } if minor <= 20 { // VERIFY_CERTIFICATE_AT_CLIENT and ENABLE_AUTO_SNI if err := checkDestinationRuleTLS(cli, &messages); err != nil { return nil, err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 02:57:30 GMT 2024 - 19.3K bytes - Viewed (0) -
internal/grid/connection.go
v, ok := c.inStream.Load(m.MuxID) if !ok { if debugPrint { fmt.Println(c.Local, "OpMuxClientMsg: Unknown Mux:", m.MuxID) } gridLogIf(ctx, c.queueMsg(message{Op: OpDisconnectClientMux, MuxID: m.MuxID}, nil)) PutByteBuffer(m.Payload) return } v.message(m) } func (c *Connection) handleResponse(m message) { if debugPrint {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
return fmt.Sprintf("no running Istio pods in %q", c.Namespace) } var _ error = ControlPlaneNotFoundError{} type Options struct { // MessageWriter is a writer for displaying messages to users. MessageWriter io.Writer // XdsViaAgents accesses Istiod via the tap service of each agent. // This is only used in `proxy-status` command. XdsViaAgents bool
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
istioctl/pkg/analyze/analyze.go
fmt.Fprintln(cmd.ErrOrStderr(), "\t", a) } } fmt.Fprintln(cmd.ErrOrStderr()) } // Get messages for output outputMessages := result.Messages.SetDocRef("istioctl-analyze").FilterOutLowerThan(outputThreshold.Level) // Print all the messages to stdout in the specified format output, err := formatting.Print(outputMessages, msgOutputFormat, colorize) if err != nil { return err
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 17K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
h.logChMu.Lock() xioutil.SafeClose(h.logCh) h.logCh = nil h.logChMu.Unlock() if h.producer != nil { h.producer.Close() h.client.Close() } // Wait for messages to be sent... h.wg.Wait() } // New initializes a new logger target which // sends log over http to the specified endpoint func New(config Config) *Target { target := &Target{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
cni/pkg/nodeagent/ztunnelserver.go
} }() } } // ZDS protocol is very simple, for every message sent, and ack is sent. // the ack only has temporal correlation (i.e. it is the first and only ack msg after the message was sent) // All this to say, that we want to make sure that message to ztunnel are sent from a single goroutine // so we don't mix messages and acks. // nolint: unparam
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
internal/grid/muxclient.go
} return nil, context.Cause(ctx) } } // send the message. msg.Seq and msg.MuxID will be set func (m *muxClient) send(msg message) error { m.respMu.Lock() defer m.respMu.Unlock() if m.closed { return errors.New("mux client closed") } return m.sendLocked(msg) } // sendLocked the message. msg.Seq and msg.MuxID will be set. // m.respMu must be held.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cni/pkg/cmd/root.go
if cfg.InstallConfig.AmbientEnabled { // Start ambient controller // node agent will spawn a goroutine and watch the K8S API for events, // as well as listen for messages from the CNI binary. log.Info("Starting ambient node agent with inpod redirect mode") ambientAgent, err := nodeagent.NewServer(ctx, watchServerReady, cfg.InstallConfig.CNIEventAddress, nodeagent.AmbientArgs{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.5K bytes - Viewed (0) -
internal/grid/handlers.go
// StatelessHandler is handlers for one to many requests, // where responses may be dropped. // Stateless requests provide no incoming stream and there is no flow control // on outgoing messages. StatelessHandler struct { Handle StatelessHandlerFn // OutCapacity is the output capacity on the caller. // If <= 0 capacity will be 1. OutCapacity int }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0)