MCPX MCP Gateway

package streamflow import ( internaltypes "lunar/engine/streams/internal-types" ) // Ensure interfaces are implemented var _ internaltypes.EntryPointI = &EntryPoint{} // EntryPoint represents an entry point of the flow graph, // where flow graph can be connected to the outside world (stream or another flow). type EntryPoint struct { node *FlowGraphNode ExternalEdge // stream or flow connection } func NewEntryPoint(node *FlowGraphNode) *EntryPoint { return &EntryPoint{ node: node, } } // GetNode returns the node reference. func (ep *EntryPoint) GetNode() internaltypes.FlowGraphNodeI { return ep.node } // GetStream returns the stream reference. func (ep *EntryPoint) GetStream() internaltypes.StreamRefI { return ep.stream } // GetFlow returns the flow reference. func (ep *EntryPoint) GetFlow() internaltypes.FlowRefI { return ep.flow } // IsValid checks if the border point is valid. func (ep *EntryPoint) IsValid() bool { if ep.stream != nil && ep.flow != nil { return false // both can't be defined } return ep.node != nil && (ep.stream != nil || ep.flow != nil) }