All notable changes to this project will be documented in this file.
This format is based on Keep a Changelog, and this project adheres to Semantic Versioning.
v2.2.0 2022-10-18 [tag version v1.999.220]
- Introduced
gen.Web
behavior. It implements Web API Gateway pattern is also sometimes known as the "Backend For Frontend" (BFF). See example examples/genweb - Introduced
gen.TCP
behavior - socket acceptor pool for TCP protocols. It provides everything you need to accept TCP connections and process packets with a small code base and low latency. Here is simple example examples/gentcp - Introduced
gen.UDP
- the same asgen.TCP
, but for UDP protocols. Example is here examples/genudp - Introduced Events. This is a simple pub/sub feature within a node - any
gen.Process
can become a producer by registering a new eventgen.Event
using methodgen.Process.RegisterEvent
, while the others can subscribe to these events usinggen.Process.MonitorEvent
. Subscriber process will also receivegen.MessageEventDown
if a producer process went down (terminated). This feature behaves in a monitor manner but only works within a node. You may also want to subscribe to a system event -node.EventNetwork
to receive event notification on connect/disconnect any peers. - Introduced Cloud Client - allows connecting to the cloud platform https://ergo.sevices. You may want to register your email there, and we will inform you about the platform launch day
- Introduced type registration for the ETF encoding/decoding. This feature allows you to get rid of manually decoding with
etf.TermIntoStruct
for the receiving messages. Register your type usingetf.RegisterType(...)
, and you will be receiving messages in a native type - Predefined set of errors has moved to the
lib
package - Updated
gen.ServerBehavior.HandleDirect
method (got extra argumentetf.Ref
to distinguish the requests). This change allows you to handle these requests asynchronously using methodgen.ServerProcess.Reply(...)
- Updated
node.Options
. Now it has fieldListeners
(typenode.Listener
). It allows you to start any number of listeners with custom options -Port
,TLS
settings, or customHandshake
/Proto
interfaces - Fixed build on 32-bit arch
- Fixed freezing on ARM arch #102
- Fixed problem with encoding negative int8
- Fixed #103 (there was an issue on interop with Elixir's GenStage)
- Fixed node stuck on start if it uses the name which is already taken in EPMD
- Fixed incorrect
gen.ProcessOptions.Context
handling
v2.1.0 2022-04-19 [tag version v1.999.210]
- Introduced compression feature support. Here are new methods and options to manage this feature:
gen.Process
:SetCompression(enable bool)
,Compression() bool
SetCompressionLevel(level int) bool
,CompressionLevel() int
SetCompressionThreshold(threshold int) bool
,CompressionThreshold() int
messages smaller than the threshold will be sent with no compression. The default compression threshold is 1024 bytes.
node.Options
:Compression
these settings are used as defaults for the spawning processes
- this feature will be ignored if the receiver is running on either the Erlang or Elixir node
- Introduced proxy feature support with end-to-end encryption.
node.Node
new methods:AddProxyRoute(...)
,RemoveProxyRoute(...)
ProxyRoute(...)
,ProxyRoutes()
NodesIndirect()
returns list of connected nodes via proxy connection
node.Options
:Proxy
for configuring proxy settings
- includes support (over the proxy connection): compression, fragmentation, link/monitor process, monitor node
- example examples/proxy.
- this feature is not available for the Erlang/Elixir nodes
- Introduced behavior
gen.Raft
. It's improved implementation of Raft consensus algorithm. The key improvement is using quorum under the hood to manage the leader election process and make the Raft cluster more reliable. This implementation supports quorums of 3, 5, 7, 9, or 11 quorum members. Here is an example of this feature examples/genraft. - Introduced interfaces to customize network layer
Resolver
to replace EPMD routines with your solution (e.g., ZooKeeper or any other service registrar)Handshake
allows customizing authorization/authentication processProto
provides the way to implement proprietary protocols (e.g., IoT area)
- Other new features:
gen.Process
new methods:NodeUptime()
,NodeName()
,NodeStop()
gen.ServerProcess
new method:MessageCounter()
shows how many messages have been handled by thegen.Server
callbacks
gen.ProcessOptions
new option:ProcessFallback
allows forward messages to the fallback process if the process mailbox is full. Forwarded messages are wrapped intogen.MessageFallback
struct. Related to issue #96.
gen.SupervisorChildSpec
andgen.ApplicationChildSpec
got optiongen.ProcessOptions
to customize options for the spawning child processes.
- Improved sending messages by etf.Pid or etf.Alias: methods
gen.Process.Send
,gen.ServerProcess.Cast
,gen.ServerProcess.Call
now returnnode.ErrProcessIncarnation
if a message is sending to the remote process of the previous incarnation (remote node has been restarted). Making monitor on a remote process of the previous incarnation triggers sendinggen.MessageDown
with reasonincarnation
. - Introduced type
gen.EnvKey
for the environment variables - All spawned processes now have the
node.EnvKeyNode
variable to get access to thenode.Node
value. - Improved performance of local messaging (up to 8 times for some cases)
- Important
node.Options
has changed. Make sure to adjust your code. - Fixed issue #89 (incorrect handling of Call requests)
- Fixed issues #87, #88 and #93 (closing network socket)
- Fixed issue #96 (silently drops message if process mailbox is full)
- Updated minimal requirement of Golang version to 1.17 (go.mod)
- We still keep the rule Zero Dependencies
v2.0.0 2021-10-12 [tag version v1.999.200]
- Added support of Erlang/OTP 24 (including Alias feature and Remote Spawn introduced in Erlang/OTP 23)
- Important: This release includes refined API (without backward compatibility) for a more convenient way to create OTP-designed microservices. Make sure to update your code.
- Important: Project repository has been moved to https://github.com/ergo-services/ergo. It is still available on the old URL https://github.com/halturin/ergo and GitHub will redirect all requests to the new one (thanks to GitHub for this feature).
- Introduced new behavior
gen.Saga
. It implements Saga design pattern - a sequence of transactions that updates each service state and publishes the result (or cancels the transaction or triggers the next transaction step).gen.Saga
also provides a feature of interim results (can be used as transaction progress or as a part of pipeline processing), time deadline (to limit transaction lifespan), two-phase commit (to make distributed transaction atomic). Here is example examples/gensaga. - Introduced new methods
Process.Direct
andProcess.DirectWithTimeout
to make direct request to the actor (gen.Server
or inherited object). If an actor has no implementation ofHandleDirect
callback it returnsErrUnsupportedRequest
as a error. - Introduced new callback
HandleDirect
in thegen.Server
interface as a handler for requests made byProcess.Direct
orProcess.DirectWithTimeout
. It should be easy to interact with actors from outside. - Introduced new types intended to be used to interact with Erlang/Elixir
etf.ListImproper
to support improper lists like[a|b]
(a cons cell).etf.String
(an alias for the Golang string) encodes as a binary in order to support Elixir string type (which isbinary()
type)etf.Charlist
(an alias for the Golang string) encodes as a list of chars[]rune
in order to support Erlang string type (which ischarlist()
type)
- Introduced new methods
Node.ProvideRemoteSpawn
,Node.RevokeRemoteSpawn
,Process.RemoteSpawn
. - Introduced new interfaces
Marshaler
(methodMarshalETF
) andUnmarshaler
(methodUnmarshalETF
) for the custom encoding/decoding data. - Improved performance for the local messaging (up to 3 times for some cases)
- Added example examples/http to demonsrate how HTTP server can be integrated into the Ergo node.
- Added example examples/gendemo - how to create a custom behavior (design pattern) on top of the
gen.Server
. Take inspiration from the gen/stage.go or gen/saga.go design patterns. - Added support FreeBSD, OpenBSD, NetBSD, DragonFly.
- Fixed RPC issue #45
- Fixed internal timer issue #48
- Fixed memory leaks #53
- Fixed double panic issue #52
- Fixed Atom Cache race conditioned issue #54
- Fixed ETF encoder issues #64 #66
1.2.0 - 2021-04-07
- Added TLS support. Introduced new option
TLSmode
inergo.NodeOptions
with the following values:ergo.TLSmodeDisabled
default value. encryption is disabledergo.TLSmodeAuto
enables encryption with autogenerated and self-signed certificateergo.TLSmodeStrict
enables encryption with specified server/client certificates and keys there is example of usageexamples/nodetls/tlsGenServer.go
- Introduced GenStage behavior implementation (originated from Elixir world).
GenStage
is an abstraction built on top ofGenServer
to provide a simple way to create a distributed Producer/Consumer architecture, while automatically managing the concept of backpressure. This implementation is fully compatible with Elixir's GenStage. Example hereexamples/genstage
or just run itgo run ./examples/genstage
to see it in action - Introduced new methods
AddStaticRoute
/RemoveStaticRoute
forNode
. This feature allows you to keep EPMD service behind a firewall. - Introduced
SetTrapExit
/TrapExit
methods forProcess
in order to control the trappinggen.MessageExit
message (for the linked processes) - Introduced
TermMapIntoStruct
andTermProplistIntoStruct
functions. It should be easy now to transformetf.Map
or[]eft.ProplistElement
into the given struct. See documentation for the details. - Improved DIST implementation in order to support KeepAlive messages and get rid of platform-dependent
syscall
usage - Fixed
TermIntoStruct
function. There was a problem withTuple
value transforming into the given struct - Fixed incorrect decoding atoms
true
,false
into the booleans - Fixed race condition and freeze of connection serving in corner case #21
- Fixed problem with monitoring process by the registered name (local and remote)
- Fixed issue with termination linked processes
- Fixed platform-dependent issues. Now Ergo Framework has tested and confirmed support of Linux, MacOS, Windows.
1.1.0 - 2020-04-23
- Fragmentation support (which was introduced in Erlang/OTP 22)
- Completely rewritten network subsystem (DIST/ETF).
- Improved performance in terms of network messaging (outperforms original Erlang/OTP up to x5 times. See Benchmarks)
1.0.0 - 2020-03-03
- We have changed the name - Ergo (or Ergo Framework). GitHub's repo has been
renamed as well. We also created cloned repo
ergonode
to support users of the old version of this project. So, its still available at https://github.com/halturin/ergonode. But it's strongly recommend to use the new one. - Completely reworked (almost from scratch) architecture whole project
- Implemented linking process feature (in order to support Application/Supervisor behaviors)
- Reworked Monitor-feature. Now it has full-featured support with remote process/nodes
- Added multinode support
- Added experimental observer support
- Fixed incorrect ETF string encoding
- Improved ETF TermIntoStruct decoder
- Improved code structure and readability
0.2.0 - 2019-02-23
- Now we make versioning releases
- Improve node creation. Now you can specify the listening port range. See 'Usage' for details
- Add embedded EPMD. Trying to start internal epmd service on starting ergonode.