Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

@effect/cluster-node

Package Overview
Dependencies
Maintainers
0
Versions
148
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@effect/cluster-node - npm Package Compare versions

Comparing version 0.1.3 to 0.1.4

12

dist/cjs/ShardingProtocol.js

@@ -23,4 +23,4 @@ "use strict";

*/
class AssignShards extends Schema.TaggedRequest()("@effect/cluster-node/ShardingProtocol/AssignShards", Schema.Never, Schema.Void, {
shards: Schema.HashSet(ShardId.schema)
class AssignShards extends /*#__PURE__*/Schema.TaggedRequest()("@effect/cluster-node/ShardingProtocol/AssignShards", Schema.Never, Schema.Void, {
shards: /*#__PURE__*/Schema.HashSet(ShardId.schema)
}) {}

@@ -32,4 +32,4 @@ /**

exports.AssignShards = AssignShards;
class UnassignShards extends Schema.TaggedRequest()("@effect/cluster-node/ShardingProtocol/UnassignShards", Schema.Never, Schema.Void, {
shards: Schema.HashSet(ShardId.schema)
class UnassignShards extends /*#__PURE__*/Schema.TaggedRequest()("@effect/cluster-node/ShardingProtocol/UnassignShards", Schema.Never, Schema.Void, {
shards: /*#__PURE__*/Schema.HashSet(ShardId.schema)
}) {}

@@ -41,3 +41,3 @@ /**

exports.UnassignShards = UnassignShards;
class Send extends Schema.TaggedRequest()("@effect/cluster-node/ShardingProtocol/Send", ShardingException.schema, MessageState.schema(SerializedMessage.schema), {
class Send extends /*#__PURE__*/Schema.TaggedRequest()("@effect/cluster-node/ShardingProtocol/Send", ShardingException.schema, /*#__PURE__*/MessageState.schema(SerializedMessage.schema), {
envelope: SerializedEnvelope.schema

@@ -50,4 +50,4 @@ }) {}

exports.Send = Send;
class PingShard extends Schema.TaggedRequest()("@effect/cluster-node/ShardingProtocol/PingShard", Schema.Never, Schema.Boolean, {}) {}
class PingShard extends /*#__PURE__*/Schema.TaggedRequest()("@effect/cluster-node/ShardingProtocol/PingShard", Schema.Never, Schema.Boolean, {}) {}
exports.PingShard = PingShard;
//# sourceMappingURL=ShardingProtocol.js.map

@@ -21,3 +21,3 @@ "use strict";

*/
class Register extends Schema.TaggedRequest()("@effect/cluster-node/ShardManagerProtocolRpc/Register", Schema.Never, Schema.Void, {
class Register extends /*#__PURE__*/Schema.TaggedRequest()("@effect/cluster-node/ShardManagerProtocolRpc/Register", Schema.Never, Schema.Void, {
pod: Pod.schema

@@ -30,3 +30,3 @@ }) {}

exports.Register = Register;
class Unregister extends Schema.TaggedRequest()("@effect/cluster-node/ShardManagerProtocolRpc/Unregister", Schema.Never, Schema.Void, {
class Unregister extends /*#__PURE__*/Schema.TaggedRequest()("@effect/cluster-node/ShardManagerProtocolRpc/Unregister", Schema.Never, Schema.Void, {
podAddress: PodAddress.schema

@@ -39,3 +39,3 @@ }) {}

exports.Unregister = Unregister;
class NotifyUnhealthyPod extends Schema.TaggedRequest()("@effect/cluster-node/ShardManagerProtocolRpc/NotifyUnhealthyPod", Schema.Never, Schema.Void, {
class NotifyUnhealthyPod extends /*#__PURE__*/Schema.TaggedRequest()("@effect/cluster-node/ShardManagerProtocolRpc/NotifyUnhealthyPod", Schema.Never, Schema.Void, {
podAddress: PodAddress.schema

@@ -48,7 +48,7 @@ }) {}

exports.NotifyUnhealthyPod = NotifyUnhealthyPod;
class GetAssignements extends Schema.TaggedRequest()("@effect/cluster-node/ShardManagerProtocolRpc/GetAssignements", Schema.Never, Schema.HashMap({
class GetAssignements extends /*#__PURE__*/Schema.TaggedRequest()("@effect/cluster-node/ShardManagerProtocolRpc/GetAssignements", Schema.Never, /*#__PURE__*/Schema.HashMap({
key: ShardId.schema,
value: Schema.Option(PodAddress.schema)
value: /*#__PURE__*/Schema.Option(PodAddress.schema)
}), {}) {}
exports.GetAssignements = GetAssignements;
//# sourceMappingURL=ShardManagerProtocol.js.map

@@ -14,4 +14,4 @@ /**

*/
export class AssignShards extends Schema.TaggedRequest()("@effect/cluster-node/ShardingProtocol/AssignShards", Schema.Never, Schema.Void, {
shards: Schema.HashSet(ShardId.schema)
export class AssignShards extends /*#__PURE__*/Schema.TaggedRequest()("@effect/cluster-node/ShardingProtocol/AssignShards", Schema.Never, Schema.Void, {
shards: /*#__PURE__*/Schema.HashSet(ShardId.schema)
}) {}

@@ -22,4 +22,4 @@ /**

*/
export class UnassignShards extends Schema.TaggedRequest()("@effect/cluster-node/ShardingProtocol/UnassignShards", Schema.Never, Schema.Void, {
shards: Schema.HashSet(ShardId.schema)
export class UnassignShards extends /*#__PURE__*/Schema.TaggedRequest()("@effect/cluster-node/ShardingProtocol/UnassignShards", Schema.Never, Schema.Void, {
shards: /*#__PURE__*/Schema.HashSet(ShardId.schema)
}) {}

@@ -30,3 +30,3 @@ /**

*/
export class Send extends Schema.TaggedRequest()("@effect/cluster-node/ShardingProtocol/Send", ShardingException.schema, MessageState.schema(SerializedMessage.schema), {
export class Send extends /*#__PURE__*/Schema.TaggedRequest()("@effect/cluster-node/ShardingProtocol/Send", ShardingException.schema, /*#__PURE__*/MessageState.schema(SerializedMessage.schema), {
envelope: SerializedEnvelope.schema

@@ -38,3 +38,3 @@ }) {}

*/
export class PingShard extends Schema.TaggedRequest()("@effect/cluster-node/ShardingProtocol/PingShard", Schema.Never, Schema.Boolean, {}) {}
export class PingShard extends /*#__PURE__*/Schema.TaggedRequest()("@effect/cluster-node/ShardingProtocol/PingShard", Schema.Never, Schema.Boolean, {}) {}
//# sourceMappingURL=ShardingProtocol.js.map

@@ -12,3 +12,3 @@ /**

*/
export class Register extends Schema.TaggedRequest()("@effect/cluster-node/ShardManagerProtocolRpc/Register", Schema.Never, Schema.Void, {
export class Register extends /*#__PURE__*/Schema.TaggedRequest()("@effect/cluster-node/ShardManagerProtocolRpc/Register", Schema.Never, Schema.Void, {
pod: Pod.schema

@@ -20,3 +20,3 @@ }) {}

*/
export class Unregister extends Schema.TaggedRequest()("@effect/cluster-node/ShardManagerProtocolRpc/Unregister", Schema.Never, Schema.Void, {
export class Unregister extends /*#__PURE__*/Schema.TaggedRequest()("@effect/cluster-node/ShardManagerProtocolRpc/Unregister", Schema.Never, Schema.Void, {
podAddress: PodAddress.schema

@@ -28,3 +28,3 @@ }) {}

*/
export class NotifyUnhealthyPod extends Schema.TaggedRequest()("@effect/cluster-node/ShardManagerProtocolRpc/NotifyUnhealthyPod", Schema.Never, Schema.Void, {
export class NotifyUnhealthyPod extends /*#__PURE__*/Schema.TaggedRequest()("@effect/cluster-node/ShardManagerProtocolRpc/NotifyUnhealthyPod", Schema.Never, Schema.Void, {
podAddress: PodAddress.schema

@@ -36,6 +36,6 @@ }) {}

*/
export class GetAssignements extends Schema.TaggedRequest()("@effect/cluster-node/ShardManagerProtocolRpc/GetAssignements", Schema.Never, Schema.HashMap({
export class GetAssignements extends /*#__PURE__*/Schema.TaggedRequest()("@effect/cluster-node/ShardManagerProtocolRpc/GetAssignements", Schema.Never, /*#__PURE__*/Schema.HashMap({
key: ShardId.schema,
value: Schema.Option(PodAddress.schema)
value: /*#__PURE__*/Schema.Option(PodAddress.schema)
}), {}) {}
//# sourceMappingURL=ShardManagerProtocol.js.map
{
"name": "@effect/cluster-node",
"version": "0.1.3",
"version": "0.1.4",
"description": "Unified interfaces for common cluster-node-specific services",

@@ -13,7 +13,7 @@ "license": "MIT",

"peerDependencies": {
"@effect/platform": "^0.59.2",
"@effect/platform-node": "^0.54.3",
"@effect/rpc": "^0.32.2",
"@effect/schema": "^0.68.26",
"effect": "^3.5.6"
"@effect/platform": "^0.59.3",
"@effect/platform-node": "^0.54.4",
"@effect/rpc": "^0.32.3",
"@effect/schema": "^0.68.27",
"effect": "^3.5.7"
},

@@ -20,0 +20,0 @@ "publishConfig": {

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc