v1

type DataPacket struct {

	// Metadata contains information about the StoryRun and the specific step this packet relates to.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// Payload is the actual data being processed.
	Payload *structpb.Struct `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// Inputs contains the evaluated step 'with:' configuration (CEL-resolved per packet).
	// This is analogous to BUBU_INPUTS in batch mode - dynamic configuration that can
	// reference outputs from previous steps. The Hub evaluates this before forwarding.
	Inputs *structpb.Struct `protobuf:"bytes,3,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// contains filtered or unexported fields
}

type HubServiceClient interface {
	// Process is a bidirectional streaming RPC that allows the hub to process and forward data between engrams.
	Process(ctx context.Context, opts ...grpc.CallOption) (HubService_ProcessClient, error)
}

type HubServiceServer interface {
	// Process is a bidirectional streaming RPC that allows the hub to process and forward data between engrams.
	Process(HubService_ProcessServer) error
	// contains filtered or unexported methods
}

type HubService_ProcessClient interface {
	Send(*ProcessRequest) error
	Recv() (*ProcessResponse, error)
	grpc.ClientStream
}

type HubService_ProcessServer interface {
	Send(*ProcessResponse) error
	Recv() (*ProcessRequest, error)
	grpc.ServerStream
}

type ProcessRequest struct {
	Packet *DataPacket `protobuf:"bytes,1,opt,name=packet,proto3" json:"packet,omitempty"`
	// contains filtered or unexported fields
}

type ProcessResponse struct {
	Packet *DataPacket `protobuf:"bytes,1,opt,name=packet,proto3" json:"packet,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedHubServiceServer struct {
}

type UnsafeHubServiceServer interface {
	// contains filtered or unexported methods
}