- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 338 for init (0.33 sec)
-
internal/event/target/mqtt.go
} if m.QoS == 0 { return errors.New("qos should be set to 1 or 2 if queueDir is set") } } return nil } // MQTTTarget - MQTT target. type MQTTTarget struct { initOnce once.Init id event.TargetID args MQTTArgs client mqtt.Client store store.Store[event.Event] quitCh chan struct{} loggerOnce logger.LogOnce } // ID - returns target ID.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 8.2K bytes - Viewed (0) -
cmd/consolelogger.go
case subCh <- entry: case <-doneCh: return nil } } } return sys.pubsub.Subscribe(madmin.LogMaskAll, subCh, doneCh, filter) } // Init if HTTPConsoleLoggerSys is valid, always returns nil right now func (sys *HTTPConsoleLoggerSys) Init(_ context.Context) error { return nil } // Endpoint - dummy function for interface compatibility func (sys *HTTPConsoleLoggerSys) Endpoint() string {
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/event/target/webhook.go
func (target *WebhookTarget) Close() error { target.cancel() return nil } func (target *WebhookTarget) init() error { return target.initOnce.Do(target.initWebhook) } // Only called from init() func (target *WebhookTarget) initWebhook() error { args := target.args transport := target.transport if args.ClientCert != "" && args.ClientKey != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 20 22:40:07 GMT 2023 - 8.5K bytes - Viewed (0) -
internal/logger/targets.go
// a single log entry and Send it to the log target // // e.g. Send the log to a http server type Target interface { String() string Endpoint() string Stats() types.TargetStats Init(ctx context.Context) error IsOnline(ctx context.Context) bool Cancel() Send(ctx context.Context, entry interface{}) error Type() types.TargetType } var ( // systemTargets is the set of enabled loggers.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 22:56:14 GMT 2024 - 6.1K bytes - Viewed (0) -
internal/logger/target/testlogger/testlogger.go
"github.com/minio/pkg/v2/logger/message/log" ) const ( logMessage = iota errorMessage fatalMessage ) // T is the test logger. var T = &testLogger{} func init() { logger.AddSystemTarget(context.Background(), T) } type testLogger struct { current atomic.Pointer[testing.TB] action atomic.Int32 } // SetLogTB will set the logger to output to tb.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 4K bytes - Viewed (0) -
internal/bucket/bandwidth/reader.go
} // MonitorReaderOptions provides configurable options for monitor reader implementation. type MonitorReaderOptions struct { BucketOptions HeaderSize int } // Read implements a throttled read func (r *MonitoredReader) Read(buf []byte) (n int, err error) { if r.throttle == nil { return r.r.Read(buf) } if r.lastErr != nil { err = r.lastErr return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 3.1K bytes - Viewed (0) -
src/cmd/cgo/internal/test/cgo_thread_lock.go
} */ import "C" import ( "runtime" "testing" "time" ) //export Gosched func Gosched() { runtime.Gosched() } func init() { testThreadLockFunc = testThreadLock } func testThreadLock(t *testing.T) { stop := make(chan int) go func() { // We need the G continue running, // so the M has a chance to run this G. for { select { case <-stop: return
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Thu May 18 16:55:07 GMT 2023 - 939 bytes - Viewed (0) -
src/cmd/asm/main.go
// the same list with -gcflags=-spectre=LIST and -asmflags=-spectrre=LIST case "all", "ret": ctxt.Retpoline = true } ctxt.Bso = bufio.NewWriter(os.Stdout) defer ctxt.Bso.Flush() architecture.Init(ctxt) // Create object file, write header. buf, err := bio.Create(*flags.OutputFile) if err != nil { log.Fatal(err) } defer buf.Close() if !*flags.SymABIs {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Aug 29 07:48:38 GMT 2023 - 2.7K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/configdump.go
func (c *ConfigWriter) PrintPodRootCAFromDynamicSecretDump() (string, error) { // TODO return "", nil } func (c *ConfigWriter) tabwriter() *tabwriter.Writer { w := new(tabwriter.Writer).Init(c.Stdout, 0, 8, 1, ' ', 0) return w
Go - Registered: Wed May 08 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/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 { if strings.Contains(secret.State, "Unavailable") {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 25 16:38:16 GMT 2024 - 3.2K bytes - Viewed (0)