Documentation
¶
Index ¶
- func AssertProtoEqual(t *testing.T, expected, actual proto.Message)
- func CmpProtoTimestamps(l, r *timestamp.Timestamp) bool
- func ConvertStructsToMap(i interface{}) (map[string]interface{}, error)
- func LogIfError(err error)
- func MustConvertStructsToMap(i interface{}) map[string]interface{}
- func MustTimestamp(protoTs *timestamp.Timestamp) time.Time
- func MustTimestampProto(ts time.Time) *timestamp.Timestamp
- func Truncate(val interface{}, maxLen int) string
- func UID() string
- func Wait(wg *sync.WaitGroup, timeout time.Duration) bool
- type Number
- type SyncMapLen
- func (e *SyncMapLen) Delete(id string)
- func (e *SyncMapLen) Len() int
- func (e *SyncMapLen) Load(key interface{}) (value interface{}, ok bool)
- func (e *SyncMapLen) LoadOrStore(key interface{}, value interface{}) (actual interface{}, loaded bool)
- func (e *SyncMapLen) Range(f func(key interface{}, value interface{}) bool)
- func (e *SyncMapLen) Store(key, value interface{})
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CmpProtoTimestamps ¶
func ConvertStructsToMap ¶
func LogIfError ¶
func LogIfError(err error)
func MustConvertStructsToMap ¶
func MustConvertStructsToMap(i interface{}) map[string]interface{}
Types ¶
type Number ¶
type Number struct {
// contains filtered or unexported fields
}
Numeric is a representation
type SyncMapLen ¶
type SyncMapLen struct {
// contains filtered or unexported fields
}
SyncMapLen is simply a sync.Map with options to retrieve the length of it.
func (*SyncMapLen) Delete ¶
func (e *SyncMapLen) Delete(id string)
func (*SyncMapLen) Len ¶
func (e *SyncMapLen) Len() int
func (*SyncMapLen) Load ¶
func (e *SyncMapLen) Load(key interface{}) (value interface{}, ok bool)
func (*SyncMapLen) LoadOrStore ¶
func (e *SyncMapLen) LoadOrStore(key interface{}, value interface{}) (actual interface{}, loaded bool)
func (*SyncMapLen) Range ¶
func (e *SyncMapLen) Range(f func(key interface{}, value interface{}) bool)
func (*SyncMapLen) Store ¶
func (e *SyncMapLen) Store(key, value interface{})
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
package gopool provides functionality for bounded parallelism with goroutines
|
package gopool provides functionality for bounded parallelism with goroutines |
|
Package labels provides storing, fetching and matching based on labels.
|
Package labels provides storing, fetching and matching based on labels. |
|
Package mediatype implements the IANA Media Type standard.
|
Package mediatype implements the IANA Media Type standard. |
|
Package pubsub is a simple, label-based, thread-safe PubSub implementation.
|
Package pubsub is a simple, label-based, thread-safe PubSub implementation. |
|
package workqueue is a amended copy of k8s' workqueue implementation Changes made: - workqueue.go - Added MaxSize field to default workqueue.
|
package workqueue is a amended copy of k8s' workqueue implementation Changes made: - workqueue.go - Added MaxSize field to default workqueue. |
Click to show internal directories.
Click to hide internal directories.