monolith

type Connection = IConnection[sqlx.DB]

type IAuthorizer interface {
	Authorize(actor interface{}, action interface{}, resource interface{}) error
}

type ICache interface {
	Get(ctx context.Context, key string, out protoreflect.ProtoMessage) error
	Set(ctx context.Context, key string, val protoreflect.ProtoMessage, expiration ...time.Duration) error
}

type IConnection[T any] interface {
	GetConnection(ctx context.Context) (T, bool)
}

type IObserver[T comparable] interface {
	Subscribe(t T, p observer.Processor[T]) observer.SourceID
	Unsubscribe(s observer.SourceID)
	Emit(e *observer.Event[T]) error
}

type ISession interface {
	Claims(accessToken string) (*jwt.RegisteredClaims, error)
}

type Observer = IObserver[string]