Function New

pkg/cache/policyevalbundle/policyevalbundle.go:41–63

New creates a policy evaluation bundle cache with built-in TTL, bucket, and description.

(ctx context.Context, rc *natsconn.ReloadableConnection, logger log.Logger)

// New creates a policy evaluation bundle cache with built-in TTL, bucket, and description.
func New(ctx context.Context, rc *natsconn.ReloadableConnection, logger log.Logger) (*Cache, error) {
	opts := []cache.Option{
		cache.WithTTL(ttl),
		cache.WithMaxBytes(maxBytes),
		cache.WithDescription(description),
	}

	if logger != nil {
		opts = append(opts, cache.WithLogger(log.NewHelper(logger)))
	}

	if rc != nil {
		opts = append(opts, cache.WithNATS(rc.Conn, bucket))
		opts = append(opts, cache.WithReconnect(rc.Subscribe(ctx)))
		opts = append(opts, cache.WithReplicas(rc.Replicas))
	}

	c, err := cache.New[[]byte](opts...)
	if err != nil {
		return nil, err
	}
	return &Cache{Cache: c}, nil
}