Merge pull request #536 from openziti/max_terminators

Set Maximum Terminators to Default (#535)
This commit is contained in:
Michael Quigley 2024-01-17 11:26:03 -05:00 committed by GitHub
commit 16e2cff4c9
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
7 changed files with 6 additions and 6 deletions

View File

@ -4,6 +4,8 @@
CHANGE: Improved OpenZiti resource cleanup resilience. Previous resource cleanup would stop when an error was encountered at any stage of the cleanup process (serps, sps, config, service). New cleanup implementation logs errors but continues to clean up anything that it can (https://github.com/openziti/zrok/issues/533) CHANGE: Improved OpenZiti resource cleanup resilience. Previous resource cleanup would stop when an error was encountered at any stage of the cleanup process (serps, sps, config, service). New cleanup implementation logs errors but continues to clean up anything that it can (https://github.com/openziti/zrok/issues/533)
CHANGE: Instead of setting the `ListenOptions.MaxConnections` property to `64`, use the default value of `3`. This property actually controls the number of terminators created on the underlying OpenZiti network. This property is actually getting renamed to `ListenOptions.MaxTerminators` in an upcoming release of `github.com/openziti/sdk-golang` (https://github.com/openziti/zrok/issues/535)
## v0.4.22 ## v0.4.22
FIX: The goreleaser action is not updated to work with the latest golang build. Modifed `go.mod` to comply with what goreleaser expects FIX: The goreleaser action is not updated to work with the latest golang build. Modifed `go.mod` to comply with what goreleaser expects

View File

@ -151,7 +151,6 @@ func (l *looper) serviceListener() {
} }
options := ziti.ListenOptions{ options := ziti.ListenOptions{
ConnectTimeout: 5 * time.Minute, ConnectTimeout: 5 * time.Minute,
MaxConnections: 64,
WaitForNEstablishedListeners: 1, WaitForNEstablishedListeners: 1,
} }
zctx, err := ziti.NewContext(zcfg) zctx, err := ziti.NewContext(zcfg)

View File

@ -27,7 +27,6 @@ type Backend struct {
func NewBackend(cfg *BackendConfig) (*Backend, error) { func NewBackend(cfg *BackendConfig) (*Backend, error) {
options := ziti.ListenOptions{ options := ziti.ListenOptions{
ConnectTimeout: 5 * time.Minute, ConnectTimeout: 5 * time.Minute,
MaxConnections: 64,
WaitForNEstablishedListeners: 1, WaitForNEstablishedListeners: 1,
} }
zcfg, err := ziti.NewConfigFromFile(cfg.IdentityPath) zcfg, err := ziti.NewConfigFromFile(cfg.IdentityPath)

View File

@ -32,7 +32,6 @@ type Backend struct {
func NewBackend(cfg *BackendConfig) (*Backend, error) { func NewBackend(cfg *BackendConfig) (*Backend, error) {
options := ziti.ListenOptions{ options := ziti.ListenOptions{
ConnectTimeout: 5 * time.Minute, ConnectTimeout: 5 * time.Minute,
MaxConnections: 64,
WaitForNEstablishedListeners: 1, WaitForNEstablishedListeners: 1,
} }
zcfg, err := ziti.NewConfigFromFile(cfg.IdentityPath) zcfg, err := ziti.NewConfigFromFile(cfg.IdentityPath)

View File

@ -25,7 +25,6 @@ type Backend struct {
func NewBackend(cfg *BackendConfig) (*Backend, error) { func NewBackend(cfg *BackendConfig) (*Backend, error) {
options := ziti.ListenOptions{ options := ziti.ListenOptions{
ConnectTimeout: 5 * time.Minute, ConnectTimeout: 5 * time.Minute,
MaxConnections: 64,
WaitForNEstablishedListeners: 1, WaitForNEstablishedListeners: 1,
} }
zcfg, err := ziti.NewConfigFromFile(cfg.IdentityPath) zcfg, err := ziti.NewConfigFromFile(cfg.IdentityPath)

View File

@ -25,7 +25,6 @@ type Backend struct {
func NewBackend(cfg *BackendConfig) (*Backend, error) { func NewBackend(cfg *BackendConfig) (*Backend, error) {
options := ziti.ListenOptions{ options := ziti.ListenOptions{
ConnectTimeout: 5 * time.Minute, ConnectTimeout: 5 * time.Minute,
MaxConnections: 64,
WaitForNEstablishedListeners: 1, WaitForNEstablishedListeners: 1,
} }
zcfg, err := ziti.NewConfigFromFile(cfg.IdentityPath) zcfg, err := ziti.NewConfigFromFile(cfg.IdentityPath)

View File

@ -9,7 +9,10 @@ import (
) )
func NewListener(shrToken string, root env_core.Root) (edge.Listener, error) { func NewListener(shrToken string, root env_core.Root) (edge.Listener, error) {
return NewListenerWithOptions(shrToken, root, &ziti.ListenOptions{ConnectTimeout: 30 * time.Second, MaxConnections: 64, WaitForNEstablishedListeners: 1}) return NewListenerWithOptions(shrToken, root, &ziti.ListenOptions{
ConnectTimeout: 30 * time.Second,
WaitForNEstablishedListeners: 1,
})
} }
func NewListenerWithOptions(shrToken string, root env_core.Root, opts *ziti.ListenOptions) (edge.Listener, error) { func NewListenerWithOptions(shrToken string, root env_core.Root, opts *ziti.ListenOptions) (edge.Listener, error) {