Skip to content

(maint) centralise nats configuration #684

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 1 commit into from
Nov 25, 2024
Merged

(maint) centralise nats configuration #684

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions cmd/explore.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -68,12 +68,12 @@ func StartLocalSources(ctx context.Context, oi sdp.OvermindInstance, token *oaut
SourceUUID: uuid.New(),
App: oi.ApiUrl.Host,
ApiKey: token.AccessToken,
NATSOptions: &natsOptions,
MaxParallelExecutions: 2_000,
HeartbeatOptions: heartbeatOptions,
}
stdlibEngine, err := stdlibSource.InitializeEngine(
&ec,
natsOptions,
heartbeatOptions,
true,
)
if err != nil {
Expand Down Expand Up @@ -137,12 +137,12 @@ func StartLocalSources(ctx context.Context, oi sdp.OvermindInstance, token *oaut
App: oi.ApiUrl.Host,
ApiKey: token.AccessToken,
MaxParallelExecutions: 2_000,
NATSOptions: &natsOptions,
HeartbeatOptions: heartbeatOptions,
}
awsEngine, err := proc.InitializeAwsSourceEngine(
ctx,
&ec,
natsOptions,
heartbeatOptions,
1, // Don't retry as we want the user to get notified immediately
configs...,
)
Expand Down
6 changes: 3 additions & 3 deletions go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,12 +21,12 @@ require (
github.com/mitchellh/go-homedir v1.1.0
github.com/muesli/reflow v0.3.0
github.com/muesli/termenv v0.15.3-0.20240912151726-82936c5ea257
github.com/overmindtech/aws-source v0.0.0-20241122003116-f07c0fe4a5ff
github.com/overmindtech/discovery v0.31.2
github.com/overmindtech/aws-source v0.0.0-20241125154730-989990c8c512
github.com/overmindtech/discovery v0.31.3
github.com/overmindtech/k8s-source v0.8.1-0.20241122011626-7172ee50d2d8
github.com/overmindtech/pterm v0.0.0-20240919144758-04d94ccb2297
github.com/overmindtech/sdp-go v0.101.0
github.com/overmindtech/stdlib-source v0.0.0-20241120144015-27855ec11354
github.com/overmindtech/stdlib-source v0.0.0-20241125154206-1dd2f26c684d
github.com/pkg/browser v0.0.0-20240102092130-5ac0b6a4141c
github.com/sirupsen/logrus v1.9.3
github.com/sourcegraph/conc v0.3.0
Expand Down
12 changes: 6 additions & 6 deletions go.sum
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -314,10 +314,10 @@ github.com/onsi/gomega v1.19.0 h1:4ieX6qQjPP/BfC3mpsAtIGGlxTWPeA3Inl/7DtXw1tw=
github.com/onsi/gomega v1.19.0/go.mod h1:LY+I3pBVzYsTBU1AnDwOSxaYi9WoWiqgwooUqq9yPro=
github.com/openrdap/rdap v0.9.2-0.20240517203139-eb57b3a8dedd h1:UuQycBx6K0lB0/IfHePshOYjlrptkF4FoApFP2Y4s3k=
github.com/openrdap/rdap v0.9.2-0.20240517203139-eb57b3a8dedd/go.mod h1:391Ww1JbjG4FHOlvQqCd6n25CCCPE64JzC5cCYPxhyM=
github.com/overmindtech/aws-source v0.0.0-20241122003116-f07c0fe4a5ff h1:ox7DZoM5CM/LgUF5BcKxe2stFj2r/XDalbIONw0rlcM=
github.com/overmindtech/aws-source v0.0.0-20241122003116-f07c0fe4a5ff/go.mod h1:KkOPfqr/f5ArVy7cJhtAULcEbm8uE1JWy1pNabABgmM=
github.com/overmindtech/discovery v0.31.2 h1:tLR1LxHwbpHSiboZiYA+5loxav9YJj1ZCMWyNrBF4e0=
github.com/overmindtech/discovery v0.31.2/go.mod h1:9Y97Ynm15PTRSt/lsZQ68JTpgIngupxDDGdHdAFFCxE=
github.com/overmindtech/aws-source v0.0.0-20241125154730-989990c8c512 h1:4ZJUMUS3cbSNp7aU+EPu0cl9wKGZWGoZnkonSIE+hws=
github.com/overmindtech/aws-source v0.0.0-20241125154730-989990c8c512/go.mod h1:gKD+8u/eGg3Kl3uYlvYWfOqnVoBGISeE9zP76PP70xM=
github.com/overmindtech/discovery v0.31.3 h1:cLtinmLP/FhDjpuOXbQRqofa163mxjvRCUdS+1Ks2wM=
github.com/overmindtech/discovery v0.31.3/go.mod h1:l8BhUxwPZcHmoaA6gCaT7rVjlN1NXy8oiAAXfrNIKnU=
github.com/overmindtech/k8s-source v0.8.1-0.20241122011626-7172ee50d2d8 h1:BmUgFLeFHr93JyFMq/IPKJZQ/IdLLjkU2dudYYs9sYs=
github.com/overmindtech/k8s-source v0.8.1-0.20241122011626-7172ee50d2d8/go.mod h1:GT28TJiKq72pzpPEvFf7GiLIugMeklXj8KYhAUBJCQo=
github.com/overmindtech/pterm v0.0.0-20240919144758-04d94ccb2297 h1:ih4bqBMHTCtg3lMwJszNkMGO9n7Uoe0WX5be1/x+s+g=
Expand All @@ -326,8 +326,8 @@ github.com/overmindtech/sdp-go v0.101.0 h1:2s5pr/M2sYD6kQci+Gtp58dPvW4nFlwDtLc6t
github.com/overmindtech/sdp-go v0.101.0/go.mod h1:k+F4AXyqbME/xLpR4FBet+Vq6uwbpvGp7638qLuX6cs=
github.com/overmindtech/sdpcache v1.6.4 h1:MJoYBDqDE3s8FrRzZ0RPgFiH39HWI/Mv2ImH1NdLT8k=
github.com/overmindtech/sdpcache v1.6.4/go.mod h1:/F9XStVdntRJEQjlZ86BPuB1Y7VPo1PFcsCNiU1IoGE=
github.com/overmindtech/stdlib-source v0.0.0-20241120144015-27855ec11354 h1:RgIfEbxGNFE/3GR4owNXnfSOVJ6V+Obp1AeH8SK0oiM=
github.com/overmindtech/stdlib-source v0.0.0-20241120144015-27855ec11354/go.mod h1:QruYlJw02HsCnz05d4UGBJtvstVW2z4rBOA1zdEePOA=
github.com/overmindtech/stdlib-source v0.0.0-20241125154206-1dd2f26c684d h1:SRtzAKnHpELU1/6N0t92SgStJBDHyAgwGlpJ7BTo5E0=
github.com/overmindtech/stdlib-source v0.0.0-20241125154206-1dd2f26c684d/go.mod h1:qcEnDassw0rcfxeIP8iOqpwakv+JQ89/RIzEL/vTULc=
github.com/pelletier/go-toml v1.9.5 h1:4yBQzkHv+7BHq2PQUZF3Mx0IYxG7LsP222s7Agd3ve8=
github.com/pelletier/go-toml v1.9.5/go.mod h1:u1nR/EPcESfeI/szUZKdtJ0xRNbUoANCkoOuaOx1Y+c=
github.com/pelletier/go-toml/v2 v2.2.2 h1:aYUidT7k73Pcl9nb2gScu7NSrKCSHIDE89b3+6Wq+LM=
Expand Down
Loading