redistool

type ExpiringHash struct {
	// contains filtered or unexported fields
}

type ExpiringHashInterface interface {
	Set(ctx context.Context, key interface{}, hashKey int64, value *anypb.Any) error
	Unset(ctx context.Context, key interface{}, hashKey int64) error
	Scan(ctx context.Context, key interface{}, cb ScanCallback) (int, error)
	// GC iterates all relevant stored data and deletes expired entries.
	// It returns number of deleted Redis (hash) keys, including when an error occurs.
	// It only inspects/GCs hashes where it has entries. Other concurrent clients GC same and/or other corresponding hashes.
	// Hashes that don't have a corresponding client (e.g. because it crashed) will expire because of TTL on the hash key.
	GC(ctx context.Context) (int, error)
	Refresh(ctx context.Context) error
}

type ExpiringValue struct {
	ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	Value     *anypb.Any             `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type KeyToRedisKey func(key interface{}) string

type RpcApi interface {
	Log() *zap.Logger
	HandleProcessingError(msg string, err error)
	AgentToken() string
}

type ScanCallback func(value *anypb.Any, err error) (bool, error)

type TokenLimiter struct {
	// contains filtered or unexported fields
}