Versions in this module Expand all Collapse all v1 v1.0.2 May 18, 2023 Changes in this version + func AgentAuthorizer(log logrus.FieldLogger, ds datastore.DataStore, clk clock.Clock) middleware.AgentAuthorizer + func EntryFetcher(ds datastore.DataStore) middleware.EntryFetcher + func Middleware(log logrus.FieldLogger, metrics telemetry.Metrics, ds datastore.DataStore, ...) middleware.Middleware + func RateLimits(config RateLimitConfig) map[string]api.RateLimiter + func UpstreamPublisher(manager *ca.Manager) bundle.UpstreamPublisher + type APIServers struct + AgentServer agentv1.AgentServer + BundleServer bundlev1.BundleServer + DebugServer debugv1_pb.DebugServer + EntryServer entryv1.EntryServer + HealthServer grpc_health_v1.HealthServer + SVIDServer svidv1.SVIDServer + TrustDomainServer trustdomainv1.TrustDomainServer + type AuthorizedEntryFetcherWithFullCache struct + func NewAuthorizedEntryFetcherWithFullCache(ctx context.Context, buildCache entryCacheBuilderFn, log logrus.FieldLogger, ...) (*AuthorizedEntryFetcherWithFullCache, error) + func (a *AuthorizedEntryFetcherWithFullCache) FetchAuthorizedEntries(ctx context.Context, agentID spiffeid.ID) ([]*types.Entry, error) + func (a *AuthorizedEntryFetcherWithFullCache) RunRebuildCacheTask(ctx context.Context) error + type Config struct + AdminIDs []spiffeid.ID + AgentTTL time.Duration + AuditLogEnabled bool + AuthPolicyEngine *authpolicy.Engine + BundleEndpoint bundle.EndpointConfig + BundleManager *bundle_client.Manager + CacheReloadInterval time.Duration + Catalog catalog.Catalog + Clock clock.Clock + LocalAddr net.Addr + Log logrus.FieldLogger + Manager *ca.Manager + Metrics telemetry.Metrics + RateLimit RateLimitConfig + SVIDObserver svid.Observer + ServerCA ca.ServerCA + TCPAddr *net.TCPAddr + TrustDomain spiffeid.TrustDomain + Uptime func() time.Duration + type Endpoints struct + APIServers APIServers + AdminIDs []spiffeid.ID + AuditLogEnabled bool + AuthPolicyEngine *authpolicy.Engine + BundleCache *bundle.Cache + BundleEndpointServer Server + DataStore datastore.DataStore + EntryFetcherCacheRebuildTask func(context.Context) error + LocalAddr net.Addr + Log logrus.FieldLogger + Metrics telemetry.Metrics + RateLimit RateLimitConfig + SVIDObserver svid.Observer + TCPAddr *net.TCPAddr + TrustDomain spiffeid.TrustDomain + func New(ctx context.Context, c Config) (*Endpoints, error) + func (e *Endpoints) ListenAndServe(ctx context.Context) error + type RateLimitConfig struct + Attestation bool + Signing bool + type Server interface + ListenAndServe func(ctx context.Context) error