- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 168 for Miller (0.17 sec)
-
internal/pubsub/pubsub.go
defer ps.RUnlock() for _, sub := range ps.subs { if sub.types.Contains(Mask(item.Mask())) && (sub.filter == nil || sub.filter(item)) { select { case sub.ch <- item: default: } } } } // Subscribe - Adds a subscriber to pubsub system func (ps *PubSub[T, M]) Subscribe(mask M, subCh chan T, doneCh <-chan struct{}, filter func(entry T) bool) error { totalSubs := atomic.AddInt32(&ps.numSubscribers, 1)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Viewed (0) -
internal/http/dial_linux.go
// NewInternodeDialContext setups a custom dialer for internode communication func NewInternodeDialContext(dialTimeout time.Duration, opts TCPOptions) DialContext { return func(ctx context.Context, network, addr string) (net.Conn, error) { dialer := &net.Dialer{ Timeout: dialTimeout, Control: setTCPParametersFn(opts), } return dialer.DialContext(ctx, network, addr) } }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Jun 07 16:53:05 GMT 2023 - 4.4K bytes - Viewed (3) -
internal/http/dial_others.go
// NewInternodeDialContext setups a custom dialer for internode communication var NewInternodeDialContext = NewCustomDialContext // NewCustomDialContext configures a custom dialer for internode communications func NewCustomDialContext(dialTimeout time.Duration, _ TCPOptions) DialContext { return func(ctx context.Context, network, addr string) (net.Conn, error) { dialer := &net.Dialer{ Timeout: dialTimeout, }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.7K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/route.go
func (c *ConfigWriter) PrintRouteSummary(filter RouteFilter) error { w, routes, err := c.setupRouteConfigWriter() if err != nil { return err } if filter.Verbose { fmt.Fprintln(w, "NAME\tVHOST NAME\tDOMAINS\tMATCH\tVIRTUAL SERVICE") } else { fmt.Fprintln(w, "NAME\tVIRTUAL HOSTS") } for _, route := range routes { if filter.Verify(route) { if includeConfigType {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu May 11 05:38:17 GMT 2023 - 7.2K bytes - Viewed (0) -
internal/event/config_test.go
dataCase1 := []byte(` <QueueConfiguration> <Id>1</Id> <Filter></Filter> <Queue>arn:minio:sqs:us-east-1:1:webhook</Queue> <Event>s3:ObjectAccessed:*</Event> <Event>s3:ObjectCreated:*</Event> <Event>s3:ObjectRemoved:*</Event> </QueueConfiguration>`) dataCase2 := []byte(` <QueueConfiguration> <Id>1</Id> <Filter> <S3Key> <FilterRule>
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Dec 05 10:16:33 GMT 2023 - 29K bytes - Viewed (0) -
internal/logger/logger.go
f = strings.TrimPrefix(filepath.ToSlash(f), filepath.ToSlash(trimString)) } return filepath.FromSlash(f) } func getSource(level int) string { pc, file, lineNumber, ok := runtime.Caller(level) if ok { // Clean up the common prefixes file = trimTrace(file) _, funcName := filepath.Split(runtime.FuncForPC(pc).Name()) return fmt.Sprintf("%v:%v:%v()", file, lineNumber, funcName) }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.2K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/services.go
} // PrintServiceSummary prints a summary of the relevant services in the config dump to the ConfigWriter stdout func (c *ConfigWriter) PrintServiceSummary(filter ServiceFilter) error { w := c.tabwriter() zDump := c.ztunnelDump svcs := slices.Filter(maps.Values(zDump.Services), filter.Verify) slices.SortFunc(svcs, func(a, b *ZtunnelService) int { if r := cmp.Compare(a.Namespace, b.Namespace); r != 0 { return r }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.8K bytes - Viewed (0) -
cmd/batch-rotate_gen.go
zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "Filter": err = z.Filter.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Filter") return } case "Notify": err = z.Notify.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Notify") return }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Dec 02 10:51:33 GMT 2023 - 27.1K bytes - Viewed (0) -
internal/bucket/lifecycle/and.go
return len(a.Tags) == 0 && !a.Prefix.set && a.ObjectSizeGreaterThan == 0 && a.ObjectSizeLessThan == 0 } // Validate - validates the And field func (a And) Validate() error { // > This is used in a Lifecycle Rule Filter to apply a logical AND to two or more predicates. // ref: https://docs.aws.amazon.com/AmazonS3/latest/API/API_LifecycleRuleAndOperator.html // i.e, predCount >= 2 var predCount int if a.Prefix.set { predCount++ }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 2.9K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener_test.go
Filters: []*listener.Filter{{ Name: wellknown.TCPProxy, }}, }}, }, expect: true, }, { desc: "unknown-type", inFilter: &ListenerFilter{ Type: "UNKNOWN", }, inListener: &listener.Listener{ FilterChains: []*listener.FilterChain{{ Filters: []*listener.Filter{}, }}, }, expect: true, }, {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Sep 11 15:29:30 GMT 2023 - 4.1K bytes - Viewed (0)