- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for StoreInt32 (0.19 sec)
-
internal/logger/target/http/http.go
return nil } func (h *Target) send(ctx context.Context, payload []byte, payloadType string, timeout time.Duration) (err error) { defer func() { if err != nil { atomic.StoreInt32(&h.status, statusOffline) } else { atomic.StoreInt32(&h.status, statusOnline) } }() ctx, cancel := context.WithTimeout(ctx, timeout) defer cancel() req, err := http.NewRequestWithContext(ctx, http.MethodPost,
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
} msg := sarama.ProducerMessage{ Topic: h.kconfig.Topic, Value: sarama.ByteEncoder(logJSON), } _, _, err = h.producer.SendMessage(&msg) if err != nil { atomic.StoreInt32(&h.status, statusOffline) } else { atomic.StoreInt32(&h.status, statusOnline) } return err } // Init initialize kafka target func (h *Target) init() error { sconfig := sarama.NewConfig() if h.kconfig.Version != "" {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
cmd/erasure-decode.go
n, err := rr.ReadAt(p.buf[bufIdx], p.offset) if err != nil { switch { case errors.Is(err, errFileNotFound): atomic.StoreInt32(&missingPartsHeal, 1) case errors.Is(err, errFileCorrupt): atomic.StoreInt32(&bitrotHeal, 1) case errors.Is(err, errDiskNotFound): atomic.AddInt32(&disksNotFound, 1) } // This will be communicated upstream.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
internal/rest/client.go
} return resp.Body, nil } // Close closes all idle connections of the underlying http client func (c *Client) Close() { atomic.StoreInt32(&c.connected, closed) } // NewClient - returns new REST client. func NewClient(uu *url.URL, tr http.RoundTripper, newAuthToken func(aud string) string) *Client { connected := int32(online) urlStr := uu.String()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14K bytes - Viewed (0) -
api/go1.txt
pkg sync/atomic, func LoadUint32(*uint32) uint32 pkg sync/atomic, func LoadUint64(*uint64) uint64 pkg sync/atomic, func LoadUintptr(*uintptr) uintptr pkg sync/atomic, func StoreInt32(*int32, int32) pkg sync/atomic, func StoreInt64(*int64, int64) pkg sync/atomic, func StorePointer(*unsafe.Pointer, unsafe.Pointer) pkg sync/atomic, func StoreUint32(*uint32, uint32)
Plain Text - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Wed Aug 14 18:58:28 GMT 2013 - 1.7M bytes - Viewed (1)