@effect/cluster-node
Advanced tools
Comparing version 0.1.3 to 0.1.4
@@ -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
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
105374