diff --git a/agents/rap-node-agent/internal/mesh/contracts.go b/agents/rap-node-agent/internal/mesh/contracts.go index dd610ec..8e9e44b 100644 --- a/agents/rap-node-agent/internal/mesh/contracts.go +++ b/agents/rap-node-agent/internal/mesh/contracts.go @@ -16,6 +16,7 @@ var ( ErrForwardPeerUnavailable = errors.New("production mesh next peer is unavailable") ErrForwardEnvelopeInvalid = errors.New("production mesh envelope is invalid") ErrForwardObservationFailed = errors.New("production mesh envelope observation failed") + ErrForwardDeliveryFailed = errors.New("production mesh envelope delivery failed") ErrMeshRuntimeDisabled = errors.New("mesh synthetic runtime is disabled") ErrUnsupportedSyntheticMessage = errors.New("unsupported synthetic mesh message") ErrRouteIDRequired = errors.New("mesh synthetic route id is required") @@ -57,10 +58,18 @@ const ( SyntheticRouteStateDegraded = "degraded" SyntheticRouteStateFailed = "failed" - ProductionChannelFabricControl = "fabric_control" - ProductionMessageFabricControl = "fabric.control" - MaxProductionEnvelopePayloadBytes = 4096 - MaxProductionEnvelopeFutureSkew = time.Minute + ProductionChannelFabricControl = "fabric_control" + ProductionMessageFabricControl = "fabric.control" + ProductionChannelVPNPacket = "vpn_packet" + ProductionMessageVPNPacketBatch = "vpn.packet_batch" + FabricServiceClassVPNPackets = "vpn_packets" + FabricServiceChannelBulk = "bulk" + FabricServiceChannelControl = "control" + FabricServiceChannelInteractive = "interactive" + FabricServiceChannelReliable = "reliable" + MaxProductionEnvelopePayloadBytes = 4096 + MaxProductionVPNPacketPayloadBytes = 256 * 1024 + MaxProductionEnvelopeFutureSkew = time.Minute ) type PeerIdentity struct {