- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 175 for Messages (0.16 sec)
-
cmd/bootstrap-messages.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Aug 23 10:07:06 GMT 2023 - 1.7K bytes - Viewed (0) -
istioctl/pkg/util/formatting/formatter.go
func printYAML(ms diag.Messages) (string, error) { yamlOutput, err := yaml.Marshal(ms) return string(yamlOutput), err } // Formatting options for Message var ( colorPrefixes = map[diag.Level]string{ diag.Info: "", // no special color for info messages diag.Warning: "\033[33m", // yellow diag.Error: "\033[1;31m", // bold red } )
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jul 11 02:41:45 GMT 2023 - 3.1K bytes - Viewed (0) -
internal/s3select/genmessage.go
fmt.Println(buf.Bytes()) } // Continuation Message // ==================== // Header specification // -------------------- // Continuation messages contain two headers, as follows: // https://docs.aws.amazon.com/AmazonS3/latest/API/images/s3select-frame-diagram-cont.png // // Payload specification // --------------------- // Continuation messages have no payload. func genContinuationMessage() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 4.4K bytes - Viewed (0) -
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) -
internal/config/help.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package config // HelpKV - implements help messages for keys // with value as description of the keys. type HelpKV struct { Key string `json:"key"` Type string `json:"type"` Description string `json:"description"` Optional bool `json:"optional"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Jun 23 14:45:27 GMT 2023 - 2.8K 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) -
cni/pkg/log/uds.go
return } messages := make([]cniLog, 0, len(cniLogs)) for _, l := range cniLogs { var msg cniLog if err := json.Unmarshal([]byte(l), &msg); err != nil { log.Debugf("Failed to unmarshal CNI plugin log entry: %v", err) continue } msg.Msg = strings.TrimSpace(msg.Msg) messages = append(messages, msg) } // Lock log message printing to prevent log messages from different CNI
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K bytes - Viewed (0) -
cmd/consolelogger.go
"github.com/minio/minio/internal/logger/target/console" "github.com/minio/minio/internal/logger/target/types" "github.com/minio/minio/internal/pubsub" "github.com/minio/pkg/v2/logger/message/log" xnet "github.com/minio/pkg/v2/net" ) // number of log messages to buffer const defaultLogBufferCount = 10000 // HTTPConsoleLoggerSys holds global console logger state type HTTPConsoleLoggerSys struct { totalMessages int64
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0) -
internal/logger/help.go
Description: "configure channel queue size for webhook targets", Optional: true, Type: "number", }, config.HelpKV{ Key: QueueDir, Description: `staging dir for undelivered logger messages e.g. '/home/logger-events'`, Optional: true, Type: "string", }, config.HelpKV{ Key: Proxy, Description: "proxy url endpoint e.g. http(s)://proxy", Optional: true,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 07 20:17:46 GMT 2024 - 6.4K bytes - Viewed (0)