extern/zrok
1
1
Fork 0
mirror of https://github.com/openziti/zrok.git synced 2024-11-07 08:44:14 +01:00
Code Issues Packages Projects Releases Wiki Activity

drop 'ListenOptions.MaxConnections' (renamed to ListenOptions.MaxTerminators in upcoming github.com/openziti/sdk-golang release) (#535)

Browse Source
This commit is contained in:
Michael Quigley 2024-01-17 11:13:07 -05:00
parent ed082cbb12
commit c3855fdb5a
No known key found for this signature in database
GPG Key ID: 9B60314A9DD20A62
6 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
cmd/zrok/testLoopPublic.go
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)

1
endpoints/drive/backend.go
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)

1
endpoints/proxy/backend.go
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)

1
endpoints/tcpTunnel/backend.go
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)

1
endpoints/udpTunnel/backend.go
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)

5
sdk/golang/sdk/listener.go
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) {