Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

parsec

package module

Go to main page

Versions in this module

v0

v0.3.1

Jun 16, 2026

v0.3.0

Jun 8, 2026

Changes in this version

type Options

+ Cache cache.Cache

+ JWKSHandler http.Handler

+ MemoryRefreshPruneInterval time.Duration

+ PerChannelPublishLimits map[string]ratelimit.Limit

+ PerChannelSubscribeLimits map[string]ratelimit.Limit

+ RefreshStore auth.RefreshStore

+ RevocationStore tokenbroker.RevocationStore

type Parsec

+ func (p *Parsec) Cache() cache.Cache

+ func (p *Parsec) CacheBackend() string

+ func (p *Parsec) CheckPublishLimit(ctx context.Context, subject string, channel channels.Name, ...) (ratelimit.Decision, error)

+ func (p *Parsec) CheckSubscribeLimit(ctx context.Context, subject string, channel channels.Name, ...) (ratelimit.Decision, error)

+ func (p *Parsec) GenerateKeyAlg(alg auth.Alg) (auth.Key, error)

+ func (p *Parsec) JWKSHandler() http.Handler

+ func (p *Parsec) RefreshAccessCtx(ctx context.Context, refreshToken string) (RefreshResult, error)

+ func (p *Parsec) RevocationStore() tokenbroker.RevocationStore

type RefreshResult

+ RefreshExpires time.Time

+ RefreshToken string

+ Rotated bool

v0.2.0

Jun 5, 2026

v0.1.0

May 27, 2026

Changes in this version

+ const MetricsPath

+ func ClaimsFromContext(ctx context.Context) *auth.Claims

+ func RemoteIPFromContext(ctx context.Context) string

+ func SubjectFromContext(ctx context.Context) string

+ func WithClaims(ctx context.Context, c *auth.Claims) context.Context

+ func WithRemoteIP(ctx context.Context, ip string) context.Context

+ func WithSubject(ctx context.Context, sub string) context.Context

+ type AdminUIOptions struct

+ Enabled bool

+ type Channel = channels.Channel

+ type ChannelName = channels.Name

+ type Credentials struct

+ AccessExpires time.Time

+ AccessToken string

+ Name channels.Name

+ RefreshExpires time.Time

+ RefreshToken string

+ type Message = sinks.Message

+ type Options struct

+ AccessLogger *slog.Logger

+ AccessTokenTTL time.Duration

+ AdminUI AdminUIOptions

+ BrokerOptions broker.Options

+ ConfigSource string

+ DLQ sinks.DLQ

+ FS afero.Fs

+ KeyRing *auth.KeyRing

+ KeyringPollInterval time.Duration

+ Limiter ratelimit.Limiter

+ Logger *slog.Logger

+ MaxRefreshTokenTTL time.Duration

+ MetricsBearerToken string

+ MetricsRegistry *prometheus.Registry

+ NodeID string

+ OIDCConfig *auth.OIDCConfig

+ OTLPEndpoint string

+ Peers []string

+ PerSinkRetry map[string]sinks.RetryConfig

+ RateLimits ratelimit.RateLimits

+ RedisAddr string

+ RedisClient redis.UniversalClient

+ RedisKeyPrefix string

+ RedisShards []*centrifuge.RedisShard

+ Region string

+ SchemaHandler http.Handler

+ SinkRetry sinks.RetryConfig

+ Sinks *sinks.Registry

+ StateDir string

+ SweepInterval time.Duration

+ TelemetryHandler http.Handler

+ TokenBrokerHandler http.Handler

+ TrustedProxies []net.IPNet

+ WebTransport WebTransportOptions

+ func (o Options) OIDCEnabled() bool

+ type Parsec struct

+ func New(opts Options) (*Parsec, error)

+ func (p *Parsec) AccessLogger() *slog.Logger

+ func (p *Parsec) AdminUIOptions() AdminUIOptions

+ func (p *Parsec) Broker() *broker.Broker

+ func (p *Parsec) CheckRateLimit(ctx context.Context, bucket, subject string, override *ratelimit.Limit) (ratelimit.Decision, error)

+ func (p *Parsec) CompositeVerifier() *auth.CompositeVerifier

+ func (p *Parsec) ConfigSource() string

+ func (p *Parsec) CreatePrivate(subjectID, name string, ttl time.Duration, scopes []auth.Scope) (Credentials, error)

+ func (p *Parsec) DLQ() sinks.DLQ

+ func (p *Parsec) DLQBackend() string

+ func (p *Parsec) GenerateKey() (auth.Key, error)

+ func (p *Parsec) Issuer() *auth.Issuer

+ func (p *Parsec) KeyRing() *auth.KeyRing

+ func (p *Parsec) KeyringPath() string

+ func (p *Parsec) KeyringStore() auth.KeyRingStore

+ func (p *Parsec) Limiter() ratelimit.Limiter

+ func (p *Parsec) Manager() *channels.Manager

+ func (p *Parsec) Metrics() *metrics.Metrics

+ func (p *Parsec) MetricsBearerToken() string

+ func (p *Parsec) OIDCEnabled() bool

+ func (p *Parsec) OIDCIssuer() string

+ func (p *Parsec) OIDCVerifier() *auth.OIDCVerifier

+ func (p *Parsec) OTLPEndpoint() string

+ func (p *Parsec) OpenPublic(name string, ttl time.Duration) (*channels.Channel, error)

+ func (p *Parsec) Peers() []string

+ func (p *Parsec) Persistence() string

+ func (p *Parsec) PromoteKey(id string) error

+ func (p *Parsec) Publish(ctx context.Context, name string, data []byte) (broker.PublishResult, error)

+ func (p *Parsec) PublishOrSink(ctx context.Context, name string, data []byte, sinkName string, ...) (bool, error)

+ func (p *Parsec) RateLimits() ratelimit.RateLimits

+ func (p *Parsec) RefreshAccess(refreshToken string) (RefreshResult, error)

+ func (p *Parsec) Region() string

+ func (p *Parsec) ReloadKeys() error

+ func (p *Parsec) RetireKey(id string) error

+ func (p *Parsec) Run(ctx context.Context) error

+ func (p *Parsec) SchemaHandler() http.Handler

+ func (p *Parsec) SinkRetryConfig() sinks.RetryConfig

+ func (p *Parsec) Sinks() *sinks.Registry

+ func (p *Parsec) TelemetryHandler() http.Handler

+ func (p *Parsec) TokenBrokerHandler() http.Handler

+ func (p *Parsec) Tracer() trace.Tracer

+ func (p *Parsec) TracerShutdown(ctx context.Context) error

+ func (p *Parsec) TrustedProxies() []net.IPNet

+ func (p *Parsec) Verifier() *auth.Verifier

+ func (p *Parsec) WebTransportOptions() WebTransportOptions

+ type RefreshResult struct

+ AccessExpires time.Time

+ AccessToken string

+ type Sink = sinks.Sink

+ type WebTransportOptions struct

+ Addr string

+ AllowedOrigins []string

+ TLSCertFile string

+ TLSKeyFile string

+ func (o WebTransportOptions) Enabled() bool