orgresolver

type Config ¶

type Config struct {
	URL                           string
	TLSEnabled                    bool
	WorkflowRegistryAddress       string
	WorkflowRegistryChainSelector uint64
	JWTGenerator                  JWTGenerator

	Client linkingclient.LinkingServiceClient // optional
	Meter  metric.Meter                       // optional
}

func (cfg *Config) New(logger log.Logger) (*orgResolver, error)

type JWTGenerator ¶

type JWTGenerator interface {
	CreateJWTForRequest(req any) (string, error)
}

JWTGenerator interface for JWT token creation

type OrgResolver ¶

type OrgResolver interface {
	services.Service
	Get(ctx context.Context, owner string) (string, error)
}

OrgResolver interface defines methods for resolving organization IDs from workflow owners

type OrgResolverFallback ¶ added in v1.3.0

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

OrgResolverFallback wraps an OrgResolver and maintains an in-memory cache of owner->orgID mappings. On successful resolution the cache is updated. When the inner resolver returns NotFound or a retriable gRPC error, the cache is consulted as a fallback (after bounded retries for retriable errors).

This addresses a race condition where a workflow owner can be unlinked from an org just before a WorkflowDeleted event is processed, causing the resolver to return NotFound for an owner whose org was previously known.

func NewOrgResolverWithFallback(inner OrgResolver, logger log.Logger) *OrgResolverFallback

func (c *OrgResolverFallback) Close() error

func (c *OrgResolverFallback) Get(ctx context.Context, owner string) (string, error)

func (c *OrgResolverFallback) HealthReport() map[string]error

func (c *OrgResolverFallback) Name() string

func (c *OrgResolverFallback) Ready() error

func (c *OrgResolverFallback) Start(ctx context.Context) error