We're excited to share Encore's world-class developer experience now extends to asynchronous event processing with the addition of Encore PubSub!
Pub/Sub is one of the core building blocks of modern distributed systems. This means you can now easily:
Building such applications typically involves endless repetition and tedious boilerplate. No more.
Run encore version update to grab the latest version and experience it for yourself!
— If you're new to Encore, check out the Quick Start Guide to get started building.
Encore PubSub takes the same approach to building distributed systems as the rest of Encore, and makes building event-driven, asynchronous a breeze. With Encore you define your topics and subscriptions directly in your backend code, like any other object.
With just a few lines of code we have a serverless backend that scales from zero to hundreds of millions of users, with zero boilerplate and with static type safety. Encore takes care of all the complex, boring parts, so you can focus on building your product:
The best part of all? It works the same way for local development as well as the major cloud providers. Encore provisions the cloud native infrastructure component for your specific cloud provider of choice, but the code works the same way.
To define a topic and begin publishing messages is just a handful lines of code:
import "encore.dev/pubsub"
type SignupEvent struct {
Username string
Email string
}
var Signups = pubsub.NewTopic[*SignupEvent]("user-signups", pubsub.TopicConfig{
DeliveryGuarantee: pubsub.AtLeastOnce,
})
// To publish a message:
_, err := Signups.Publish(ctx, &SignupEvent{Username: "jane.doe", Email: "[email protected]"})
To begin receiving messages is equally simple:
import "encore.dev/pubsub"
var _ = pubsub.NewSubscription(
user.Signups, "send-welcome-email",
pubsub.SubscriptionConfig[*user.SignupEvent] {
Handler: SendWelcomeEmail,
},
)
func SendWelcomeEmail(ctx context.Context, event *user.SignupEvent) error {
// .. send email ...
}
We're excited to share Encore's world-class developer experience now extends to asynchronous event processing with the addition of Encore PubSub!
Pub/Sub is one of the core building blocks of modern distributed systems. This means you can now easily:
Building such applications typically involves endless repetition and tedious boilerplate. No more.
Run encore version update to grab the latest version and experience it for yourself!
— If you're new to Encore, check out the Quick Start Guide to get started building.
Encore PubSub takes the same approach to building distributed systems as the rest of Encore, and makes building event-driven, asynchronous a breeze. With Encore you define your topics and subscriptions directly in your backend code, like any other object.
With just a few lines of code we have a serverless backend that scales from zero to hundreds of millions of users, with zero boilerplate and with static type safety. Encore takes care of all the complex, boring parts, so you can focus on building your product:
The best part of all? It works the same way for local development as well as the major cloud providers. Encore provisions the cloud native infrastructure component for your specific cloud provider of choice, but the code works the same way.
To define a topic and begin publishing messages is just a handful lines of code:
import "encore.dev/pubsub"
type SignupEvent struct {
Username string
Email string
}
var Signups = pubsub.NewTopic[*SignupEvent]("user-signups", pubsub.TopicConfig{
DeliveryGuarantee: pubsub.AtLeastOnce,
})
// To publish a message:
_, err := Signups.Publish(ctx, &SignupEvent{Username: "jane.doe", Email: "[email protected]"})
To begin receiving messages is equally simple:
import "encore.dev/pubsub"
var _ = pubsub.NewSubscription(
user.Signups, "send-welcome-email",
pubsub.SubscriptionConfig[*user.SignupEvent] {
Handler: SendWelcomeEmail,
},
)
func SendWelcomeEmail(ctx context.Context, event *user.SignupEvent) error {
// .. send email ...
}
To complement the new PubSub support Encore now comes with a new et (encore testing) package to simplify testing distributed systems.
We're starting with support for testing PubSub behavior, but over time we plan to expand on it to support easy testing of various distributed system behaviors. Read the package docs for more information.
encore db shell database sessions (#263)GOARCH and the docker base image for encore eject docker (#269)encore run before encore auth login on new systems (#299)encore.dev/rlog log output when using structured logging of booleans (#308)We rely on the community to improve Encore, and we're overwhelmed by your support and encouragement. Big thanks to @davidmytton, @bscott, @bjaanes and others for your bug reports and feedback!
Developers building with Encore are forward-thinkers working on exciting and innovative products. Join the conversation on Discord to see what's going on, learn from others, and share what you're working on.
Over the coming weeks we'll be adding much requested flexibility to the Encore framework, with improved support for things like: middleware, configuration and dependency injection. Vote on your favorite feature on the roadmap – If you like what's going on, why not give the project a star?
As always, if you have questions or ideas, come tell us on Discord. We’re excited to hear your feedback! ❤️
Catch you in the cloud, The Encore Team