utils

Documentation

Index

• func MarshalObjToStruct(input interface{}) (*structpb.Struct, error)
• func MarshalPbToString(msg proto.Message) (string, error)
• func MarshalPbToStruct(in proto.Message) (out *structpb.Struct, err error)
• func UnmarshalStructToPb(structObj *structpb.Struct, msg proto.Message) error
• type AutoRefreshCache
  • func NewAutoRefreshCache(syncCb CacheSyncItem, syncRateLimiter RateLimiter, resyncPeriod time.Duration, ...) (AutoRefreshCache, error)
• type CacheItem
• type CacheSyncAction
• type CacheSyncItem
• type RateLimiter
  • func NewRateLimiter(rateLimiterName string, tps float64, burst int) RateLimiter
• type Sequencer
  • func GetSequencer() Sequencer

Examples

• NewAutoRefreshCache

Functions

func MarshalObjToStruct

func MarshalObjToStruct(input interface{}) (*structpb.Struct, error)

Marshals obj into a struct. Will use jsonPb if input is a proto message, otherwise, it'll use json marshaler.

func MarshalPbToString

func MarshalPbToString(msg proto.Message) (string, error)

Marshals a proto message using jsonPb marshaler to string.

func MarshalPbToStruct

func MarshalPbToStruct(in proto.Message) (out *structpb.Struct, err error)

Marshals a proto message into proto Struct using jsonPb marshaler.

func UnmarshalStructToPb

func UnmarshalStructToPb(structObj *structpb.Struct, msg proto.Message) error

Unmarshals a proto struct into a proto message using jsonPb marshaler.

Types

type AutoRefreshCache

type AutoRefreshCache interface {
	// starts background refresh of items
	Start(ctx context.Context)

	// Get item by id if exists else null
	Get(id string) CacheItem

	// Get object if exists else create it
	GetOrCreate(item CacheItem) (CacheItem, error)
}

AutoRefreshCache with regular GetOrCreate and Delete along with background asynchronous refresh. Caller provides callbacks for create, refresh and delete item. The cache doesn't provide apis to update items. Deprecated: This utility is deprecated, it has been refactored and moved into `cache` package.

func NewAutoRefreshCache

func NewAutoRefreshCache(syncCb CacheSyncItem, syncRateLimiter RateLimiter, resyncPeriod time.Duration,
	size int, scope promutils.Scope) (AutoRefreshCache, error)

Deprecated: This utility is deprecated, it has been refactored and moved into `cache` package.

Example

Output:

Current status for item1 is Completed

type CacheItem

type CacheItem interface {
	ID() string
}

Deprecated: This utility is deprecated, it has been refactored and moved into `cache` package.

type CacheSyncAction

type CacheSyncAction int

Possible actions for the cache to take as a result of running the sync function on any given cache item Deprecated: This utility is deprecated, it has been refactored and moved into `cache` package.

const (
	Unchanged CacheSyncAction = iota

	// The item returned has been updated and should be updated in the cache
	Update

	// The item should be removed from the cache
	Delete
)

type CacheSyncItem

type CacheSyncItem func(ctx context.Context, obj CacheItem) (
	newItem CacheItem, result CacheSyncAction, err error)

Your implementation of this function for your cache instance is responsible for returning

1. The new CacheItem, and
2. What action should be taken. The sync function has no insight into your object, and needs to be told explicitly if the new item is different from the old one.

Deprecated: This utility is deprecated, it has been refactored and moved into `cache` package.

type RateLimiter

type RateLimiter interface {
	Wait(ctx context.Context) error
}

Interface to use rate limiter

func NewRateLimiter

func NewRateLimiter(rateLimiterName string, tps float64, burst int) RateLimiter

Create a new rate-limiter with the tps and burst values

type Sequencer

type Sequencer interface {
	GetNext() uint64
	GetCur() uint64
}

Sequencer is a thread-safe incremental integer counter. Note that it is a singleton, so GetSequencer.GetNext may not always start at 0.

func GetSequencer

func GetSequencer() Sequencer